support given for cloning linked ci pipelines via workflow cloning API (#2944)

Author: prakash100198

api/appbean/AppDetail.go

@@ -86,12 +86,16 @@ type CiPipelineDetails struct {
 	PreBuildStage             *bean.PipelineStageDto      `json:"preBuildStage,omitempty"`
 	PostBuildStage            *bean.PipelineStageDto      `json:"postBuildStage,omitempty"`
 	IsExternal                bool                        `json:"isExternal"` // true for linked and external
+	ParentCiPipeline          int                         `json:"parentCiPipeline,omitempty"`
+	ParentAppId               int                         `json:"parentAppId,omitempty"`
+	LinkedCount               int                         `json:"linkedCount,omitempty"`
 }
 
 type CiPipelineMaterialConfig struct {
-	Type         pipelineConfig.SourceType `json:"type,omitempty" validate:"oneof=SOURCE_TYPE_BRANCH_FIXED WEBHOOK"`
-	Value        string                    `json:"value,omitempty" `
-	CheckoutPath string                    `json:"checkoutPath"`
+	Type          pipelineConfig.SourceType `json:"type,omitempty" validate:"oneof=SOURCE_TYPE_BRANCH_FIXED WEBHOOK"`
+	Value         string                    `json:"value,omitempty" `
+	CheckoutPath  string                    `json:"checkoutPath"`
+	GitMaterialId int                       `json:"gitMaterialId"`
 }
 
 type BuildScript struct {

api/restHandler/CoreAppRestHandler.go

@@ -680,6 +680,9 @@ func (handler CoreAppRestHandlerImpl) buildCiPipelineResp(appId int, ciPipeline
 		DockerBuildArgs:          ciPipeline.DockerArgs,
 		VulnerabilityScanEnabled: ciPipeline.ScanEnabled,
 		IsExternal:               ciPipeline.IsExternal,
+		ParentCiPipeline:         ciPipeline.ParentCiPipeline,
+		ParentAppId:              ciPipeline.ParentAppId,
+		LinkedCount:              ciPipeline.LinkedCount,
 	}
 
 	//build ciPipelineMaterial resp
@@ -691,9 +694,10 @@ func (handler CoreAppRestHandlerImpl) buildCiPipelineResp(appId int, ciPipeline
 			return nil, err
 		}
 		ciPipelineMaterialConfig := &appBean.CiPipelineMaterialConfig{
-			Type:         ciMaterial.Source.Type,
-			Value:        ciMaterial.Source.Value,
-			CheckoutPath: gitMaterial.CheckoutPath,
+			Type:          ciMaterial.Source.Type,
+			Value:         ciMaterial.Source.Value,
+			CheckoutPath:  gitMaterial.CheckoutPath,
+			GitMaterialId: gitMaterial.Id,
 		}
 		ciPipelineMaterialsConfig = append(ciPipelineMaterialsConfig, ciPipelineMaterialConfig)
 	}
@@ -1534,7 +1538,7 @@ func (handler CoreAppRestHandlerImpl) createWorkflowInDb(workflowName string, ap
 func (handler CoreAppRestHandlerImpl) createCiPipeline(appId int, userId int32, workflowId int, ciPipelineData *appBean.CiPipelineDetails) (int, error) {
 
 	// if ci pipeline is of external type, then throw error as we are not supporting it as of now
-	if ciPipelineData.IsExternal {
+	if ciPipelineData.ParentCiPipeline == 0 && ciPipelineData.ParentAppId == 0 && ciPipelineData.IsExternal {
 		err := errors.New("external ci pipeline creation is not supported yet")
 		handler.logger.Error("external ci pipeline creation is not supported yet")
 		return 0, err
@@ -1543,8 +1547,15 @@ func (handler CoreAppRestHandlerImpl) createCiPipeline(appId int, userId int32,
 	// build ci pipeline materials starts
 	var ciMaterialsRequest []*bean.CiMaterial
 	for _, ciMaterial := range ciPipelineData.CiPipelineMaterialsConfig {
-		//finding gitMaterial by appId and checkoutPath
-		gitMaterial, err := handler.materialRepository.FindByAppIdAndCheckoutPath(appId, ciMaterial.CheckoutPath)
+		var gitMaterial *pipelineConfig.GitMaterial
+		var err error
+		if ciPipelineData.ParentCiPipeline == 0 && ciPipelineData.ParentAppId == 0 {
+			//finding gitMaterial by appId and checkoutPath
+			gitMaterial, err = handler.materialRepository.FindByAppIdAndCheckoutPath(appId, ciMaterial.CheckoutPath)
+		} else {
+			//if linkedci find git material by it's id
+			gitMaterial, err = handler.materialRepository.FindById(ciMaterial.GitMaterialId)
+		}
 		if err != nil {
 			handler.logger.Errorw("service err, FindByAppIdAndCheckoutPath in CreateWorkflows", "err", err, "appId", appId)
 			return 0, err
@@ -1587,6 +1598,9 @@ func (handler CoreAppRestHandlerImpl) createCiPipeline(appId int, userId int32,
 			CiMaterial:               ciMaterialsRequest,
 			PreBuildStage:            ciPipelineData.PreBuildStage,
 			PostBuildStage:           ciPipelineData.PostBuildStage,
+			ParentCiPipeline:         ciPipelineData.ParentCiPipeline,
+			ParentAppId:              ciPipelineData.ParentAppId,
+			LinkedCount:              ciPipelineData.LinkedCount,
 		},
 	}