feat:validation for pipeline Type

api/restHandler/app/pipeline/configure/BuildPipelineRestHandler.go

@@ -439,7 +439,7 @@ func (handler *PipelineConfigRestHandlerImpl) PatchCiPipelines(w http.ResponseWr
 	}
 	createResp, err := handler.pipelineBuilder.PatchCiPipeline(&patchRequest)
 	if err != nil {
-		if err.Error() == CiPipeline.PIPELINE_NAME_ALREADY_EXISTS_ERROR {
+		if err.Error() == CiPipeline.PIPELINE_NAME_ALREADY_EXISTS_ERROR || err.Error() == CiPipeline.PIPELINE_TYPE_IS_NOT_VALID {
 			handler.Logger.Errorw("service err, pipeline name already exist ", "err", err)
 			common.WriteJsonResp(w, err, nil, http.StatusBadRequest)
 			return

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,10 @@ 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)
+		return nil, errors.New(CiPipeline.PIPELINE_TYPE_IS_NOT_VALID)
+	}
 	cannotUpdate := false
 	for _, material := range pipeline.CiPipelineMaterials {
 		if material.ScmId != "" {
@@ -1455,7 +1458,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

@@ -816,7 +816,10 @@ func (impl CiCdPipelineOrchestratorImpl) CreateCiConf(createRequest *bean.CiConf
 		}
 		// Rollback tx on error.
 		defer tx.Rollback()
-
+		if !ciPipeline.PipelineType.IsValidPipelineType() {
+			impl.logger.Debugw(" Invalid PipelineType", "ciPipeline.PipelineType", ciPipeline.PipelineType)
+			return nil, errors.New(CiPipeline.PIPELINE_TYPE_IS_NOT_VALID)
+		}
 		ciPipelineObject := &pipelineConfig.CiPipeline{
 			AppId:                    createRequest.AppId,
 			IsManual:                 ciPipeline.IsManual,

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"
 
 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/244_pipeline_type.down.sql

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

scripts/sql/244_pipeline_type.up.sql

@@ -0,0 +1,11 @@
+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 = 0;
+
+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 = 2;