give an uniform check for release process

pkg/tiller/release_content.go

@@ -23,8 +23,9 @@ import (
 
 // GetReleaseContent gets all of the stored information for the given release.
 func (s *ReleaseServer) GetReleaseContent(c ctx.Context, req *services.GetReleaseContentRequest) (*services.GetReleaseContentResponse, error) {
-	if !ValidName.MatchString(req.Name) {
-		return nil, errMissingRelease
+	if err := validateReleaseName(req.Name); err != nil {
+		s.Log("releaseContent: Release name is invalid: %s", req.Name)
+		return nil, err
 	}
 
 	if req.Version <= 0 {

pkg/tiller/release_history.go

@@ -25,6 +25,11 @@ import (
 
 // GetHistory gets the history for a given release.
 func (s *ReleaseServer) GetHistory(ctx context.Context, req *tpb.GetHistoryRequest) (*tpb.GetHistoryResponse, error) {
+	if err := validateReleaseName(req.Name); err != nil {
+		s.Log("getHistory: Release name is invalid: %s", req.Name)
+		return nil, err
+	}
+
 	s.Log("getting history for release %s", req.Name)
 	h, err := s.env.Releases.History(req.Name)
 	if err != nil {

pkg/tiller/release_rollback.go

@@ -59,10 +59,12 @@ func (s *ReleaseServer) RollbackRelease(c ctx.Context, req *services.RollbackRel
 // prepareRollback finds the previous release and prepares a new release object with
 // the previous release's configuration
 func (s *ReleaseServer) prepareRollback(req *services.RollbackReleaseRequest) (*release.Release, *release.Release, error) {
-	switch {
-	case !ValidName.MatchString(req.Name):
-		return nil, nil, errMissingRelease
-	case req.Version < 0:
+	if err := validateReleaseName(req.Name); err != nil {
+		s.Log("prepareRollback: Release name is invalid: %s", req.Name)
+		return nil, err
+	}
+
+	if req.Version < 0 {
 		return nil, nil, errInvalidRevision
 	}
 

pkg/tiller/release_server.go

@@ -59,6 +59,8 @@ var (
 	errMissingRelease = errors.New("no release provided")
 	// errInvalidRevision indicates that an invalid release revision number was provided.
 	errInvalidRevision = errors.New("invalid release revision")
+	//errInvalidName indicates that an invalid release name was provided
+	errInvalidName = errors.New("invalid release name")
 )
 
 // ListDefaultLimit is the default limit for number of items returned in a list.
@@ -359,3 +361,11 @@ func validateManifest(c environment.KubeClient, ns string, manifest []byte) erro
 	_, err := c.BuildUnstructured(ns, r)
 	return err
 }
+
+func validateReleaseName(releaseName string) error {
+	if !ValidName.MatchString(releaseName) || (len(releaseName) > releaseNameMaxLen) {
+		return errInvalidName
+	}
+
+	return nil
+}

pkg/tiller/release_server_test.go

@@ -197,8 +197,9 @@ func TestValidName(t *testing.T) {
 		" ":                      false,
 		".nina.":                 false,
 		"nina.pinta":             true,
+		"abcdefghi-abcdefghi-abcdefghi-abcdefghi-abcdefghi-abc": false,
 	} {
-		if valid != ValidName.MatchString(name) {
+		if valid != validateReleaseName(name) {
 			t.Errorf("Expected %q to be %t", name, valid)
 		}
 	}

pkg/tiller/release_status.go

@@ -26,8 +26,9 @@ import (
 
 // GetReleaseStatus gets the status information for a named release.
 func (s *ReleaseServer) GetReleaseStatus(c ctx.Context, req *services.GetReleaseStatusRequest) (*services.GetReleaseStatusResponse, error) {
-	if !ValidName.MatchString(req.Name) {
-		return nil, errMissingRelease
+	if err := validateReleaseName(req.Name); err != nil {
+		s.Log("getStatus: Release name is invalid: %s", req.Name)
+		return nil, err
 	}
 
 	var rel *release.Release

pkg/tiller/release_testing.go

@@ -25,8 +25,9 @@ import (
 // RunReleaseTest runs pre-defined tests stored as hooks on a given release
 func (s *ReleaseServer) RunReleaseTest(req *services.TestReleaseRequest, stream services.ReleaseService_RunReleaseTestServer) error {
 
-	if !ValidName.MatchString(req.Name) {
-		return errMissingRelease
+	if err := validateReleaseName(req.Name); err != nil {
+		s.Log("releaseTest: Release name is invalid: %s", req.Name)
+		return nil, err
 	}
 
 	// finds the non-deleted release with the given name

pkg/tiller/release_uninstall.go

@@ -30,13 +30,9 @@ import (
 
 // UninstallRelease deletes all of the resources associated with this release, and marks the release DELETED.
 func (s *ReleaseServer) UninstallRelease(c ctx.Context, req *services.UninstallReleaseRequest) (*services.UninstallReleaseResponse, error) {
-	if !ValidName.MatchString(req.Name) {
-		s.Log("uninstall: Release not found: %s", req.Name)
-		return nil, errMissingRelease
-	}
-
-	if len(req.Name) > releaseNameMaxLen {
-		return nil, fmt.Errorf("release name %q exceeds max length of %d", req.Name, releaseNameMaxLen)
+	if err := validateReleaseName(req.Name); err != nil {
+		s.Log("uninstallRelease: Release name is invalid: %s", req.Name)
+		return nil, err
 	}
 
 	err := s.env.Releases.LockRelease(req.Name)

pkg/tiller/release_update.go

@@ -29,6 +29,11 @@ import (
 
 // UpdateRelease takes an existing release and new information, and upgrades the release.
 func (s *ReleaseServer) UpdateRelease(c ctx.Context, req *services.UpdateReleaseRequest) (*services.UpdateReleaseResponse, error) {
+	if err := validateReleaseName(req.Name); err != nil {
+		s.Log("updateRelease: Release name is invalid: %s", req.Name)
+		return nil, err
+	}
+
 	err := s.env.Releases.LockRelease(req.Name)
 	if err != nil {
 		return nil, err
@@ -59,10 +64,6 @@ func (s *ReleaseServer) UpdateRelease(c ctx.Context, req *services.UpdateRelease
 
 // prepareUpdate builds an updated release for an update operation.
 func (s *ReleaseServer) prepareUpdate(req *services.UpdateReleaseRequest) (*release.Release, *release.Release, error) {
-	if !ValidName.MatchString(req.Name) {
-		return nil, nil, errMissingRelease
-	}
-
 	if req.Chart == nil {
 		return nil, nil, errMissingChart
 	}