feat:validation for pipeline Type

internal/util/ErrorUtil.go

@@ -37,6 +37,33 @@ type ApiError struct {
 	UserDetailMessage string      `json:"userDetailMessage,omitempty"`
 }
 
+func NewApiError() *ApiError {
+	return &ApiError{}
+}
+
+func (e *ApiError) WithHttpStatusCode(httpStatusCode int) *ApiError {
+	e.HttpStatusCode = httpStatusCode
+	return e
+}
+
+func (e *ApiError) WithCode(code string) *ApiError {
+	e.Code = code
+	return e
+}
+func (e *ApiError) WithInternalMessage(InternalMessage string) *ApiError {
+	e.InternalMessage = InternalMessage
+	return e
+}
+func (e *ApiError) WithUserMessage(userMessage interface{}) *ApiError {
+	e.UserMessage = userMessage
+	return e
+}
+
+func (e *ApiError) WithUserDetailMessage(UserDetailMessage string) *ApiError {
+	e.UserDetailMessage = UserDetailMessage
+	return e
+}
+
 func (e *ApiError) Error() string {
 	return e.InternalMessage
 }

pkg/bean/app.go

@@ -191,7 +191,6 @@ type ExternalCiConfigRole struct {
 
 // -------------------
 type PatchAction int
-type PipelineType string
 
 const (
 	CREATE        PatchAction = iota

pkg/pipeline/BuildPipelineConfigService.go

@@ -280,7 +280,11 @@ func (impl *CiPipelineConfigServiceImpl) patchCiPipelineUpdateSource(baseCiConfi
 		impl.logger.Errorw("error in fetching pipeline", "id", modifiedCiPipeline.Id, "err", err)
 		return nil, err
 	}
-
+	if !modifiedCiPipeline.PipelineType.IsValidPipelineType() {
+		impl.logger.Debugw(" Invalid PipelineType", "PipelineType", modifiedCiPipeline.PipelineType)
+		errorMessage := fmt.Sprintf(CiPipeline.PIPELINE_TYPE_IS_NOT_VALID, modifiedCiPipeline.Name)
+		return nil, util.NewApiError().WithHttpStatusCode(http.StatusBadRequest).WithInternalMessage(errorMessage).WithUserMessage(errorMessage)
+	}
 	cannotUpdate := false
 	for _, material := range pipeline.CiPipelineMaterials {
 		if material.ScmId != "" {
@@ -1455,7 +1459,7 @@ func (impl *CiPipelineConfigServiceImpl) GetCiPipelineMin(appId int, envIds []in
 	var ciPipelineResp []*bean.CiPipelineMin
 	for _, pipeline := range pipelines {
 		parentCiPipeline := pipelineConfig.CiPipeline{}
-		pipelineType := CiPipeline.NORMAL
+		pipelineType := CiPipeline.CI_BUILD
 
 		if pipelineParentCiMap[pipeline.Id] != nil {
 			parentCiPipeline = *pipelineParentCiMap[pipeline.Id]

pkg/pipeline/CiCdPipelineOrchestrator.go

@@ -28,6 +28,7 @@ import (
 	"fmt"
 	attributesBean "github.com/devtron-labs/devtron/pkg/attributes/bean"
 	"golang.org/x/exp/slices"
+	"net/http"
 	"path"
 	"regexp"
 	"strconv"
@@ -816,7 +817,6 @@ func (impl CiCdPipelineOrchestratorImpl) CreateCiConf(createRequest *bean.CiConf
 		}
 		// Rollback tx on error.
 		defer tx.Rollback()
-
 		ciPipelineObject := &pipelineConfig.CiPipeline{
 			AppId:                    createRequest.AppId,
 			IsManual:                 ciPipeline.IsManual,
@@ -2087,7 +2087,13 @@ func (impl CiCdPipelineOrchestratorImpl) CreateEcrRepo(dockerRepository, AWSRegi
 }
 
 func (impl CiCdPipelineOrchestratorImpl) AddPipelineToTemplate(createRequest *bean.CiConfigRequest, isSwitchCiPipelineRequest bool) (resp *bean.CiConfigRequest, err error) {
-
+	for _, ciPipeline := range createRequest.CiPipelines {
+		if !ciPipeline.PipelineType.IsValidPipelineType() {
+			impl.logger.Debugw(" Invalid PipelineType", "ciPipeline.PipelineType", ciPipeline.PipelineType)
+			errorMessage := fmt.Sprintf(CiPipeline.PIPELINE_TYPE_IS_NOT_VALID, ciPipeline.PipelineType)
+			return nil, util.NewApiError().WithHttpStatusCode(http.StatusBadRequest).WithInternalMessage(errorMessage).WithUserMessage(errorMessage)
+		}
+	}
 	if createRequest.AppWorkflowId == 0 {
 		// create workflow
 		wf := &appWorkflow.AppWorkflow{

pkg/pipeline/adapter/adapter.go

@@ -174,11 +174,9 @@ func IsLinkedCD(ci pipelineConfig.CiPipeline) bool {
 }
 
 // IsLinkedCI will return if the pipelineConfig.CiPipeline is a Linked CI
-// Currently there are inconsistent values present in PipelineType ("CI_EXTERNAL", "LINKED") 207_ci_external.up
-// TODO migrate the deprecated values and maintain a consistent PipelineType
 func IsLinkedCI(ci pipelineConfig.CiPipeline) bool {
 	return ci.ParentCiPipeline != 0 &&
-		(ci.PipelineType == string(CiPipeline.CI_EXTERNAL) || ci.PipelineType == string(CiPipeline.LINKED))
+		ci.PipelineType == string(CiPipeline.LINKED)
 }
 
 // IsCIJob will return if the pipelineConfig.CiPipeline is a CI JOB

pkg/pipeline/bean/CiPipeline/CiBuildConfig.go

@@ -12,17 +12,16 @@ const Main = "main"
 const UniquePlaceHolderForAppName = "$etron"
 
 const PIPELINE_NAME_ALREADY_EXISTS_ERROR = "pipeline name already exist"
+const PIPELINE_TYPE_IS_NOT_VALID = "PipelineType is not valid  for pipeline %s"
 
 type PipelineType string
 
 const (
-	NORMAL PipelineType = "NORMAL"
-	LINKED PipelineType = "LINKED"
-	// CI_EXTERNAL field is been sent from the dashboard in CreateLinkedCI request and directly gets saved to Database without any validations
-	CI_EXTERNAL PipelineType = "CI_EXTERNAL" // Deprecated Enum: TODO fix the PipelineTypes in code and database
-	EXTERNAL    PipelineType = "EXTERNAL"
-	CI_JOB      PipelineType = "CI_JOB"
-	LINKED_CD   PipelineType = "LINKED_CD"
+	CI_BUILD  PipelineType = "CI_BUILD"
+	LINKED    PipelineType = "LINKED"
+	EXTERNAL  PipelineType = "EXTERNAL"
+	CI_JOB    PipelineType = "CI_JOB"
+	LINKED_CD PipelineType = "LINKED_CD"
 )
 
 type CiBuildConfigBean struct {
@@ -58,3 +57,12 @@ type BuildPackConfig struct {
 	Args            map[string]string `json:"args"`
 	ProjectPath     string            `json:"projectPath,omitempty"`
 }
+
+func (pType PipelineType) IsValidPipelineType() bool {
+	switch pType {
+	case CI_BUILD, LINKED, EXTERNAL, CI_JOB, LINKED_CD:
+		return true
+	default:
+		return false
+	}
+}

scripts/sql/246_pipeline_type.down.sql

@@ -0,0 +1 @@
+---- Not Required

scripts/sql/246_pipeline_type.up.sql

@@ -0,0 +1,6 @@
+UPDATE   "public"."ci_pipeline"  SET ci_pipeline_type='LINKED' WHERE ci_pipeline_type='CI_EXTERNAL';
+
+UPDATE "public"."ci_pipeline"
+SET ci_pipeline_type = 'CI_BUILD'
+    FROM app
+WHERE ci_pipeline.app_id = app.id AND ci_pipeline.ci_pipeline_type IS NULL AND app.app_type in( 0,2);