@@ -28,7 +28,6 @@ import (
28
28
"github.com/devtron-labs/common-lib/utils/k8s/commonBean"
29
29
"github.com/devtron-labs/devtron/api/bean"
30
30
"github.com/devtron-labs/devtron/internal/sql/repository/pipelineConfig/bean/workflow/cdWorkflow"
31
- "github.com/devtron-labs/devtron/pkg/app"
32
31
bean2 "github.com/devtron-labs/devtron/pkg/build/pipeline/bean"
33
32
repository2 "github.com/devtron-labs/devtron/pkg/cluster/environment/repository"
34
33
"github.com/devtron-labs/devtron/pkg/config/read"
@@ -66,7 +65,6 @@ type WorkflowServiceImpl struct {
66
65
config * rest.Config
67
66
ciCdConfig * types.CiCdConfig
68
67
configMapService read.ConfigReadService
69
- appService app.AppService
70
68
envRepository repository2.EnvironmentRepository
71
69
globalCMCSService GlobalCMCSService
72
70
argoWorkflowExecutor executors.ArgoWorkflowExecutor
@@ -78,15 +76,20 @@ type WorkflowServiceImpl struct {
78
76
79
77
// TODO: Move to bean
80
78
81
- func NewWorkflowServiceImpl (Logger * zap.SugaredLogger , envRepository repository2.EnvironmentRepository , ciCdConfig * types.CiCdConfig ,
82
- appService app.AppService , globalCMCSService GlobalCMCSService , argoWorkflowExecutor executors.ArgoWorkflowExecutor ,
79
+ func NewWorkflowServiceImpl (Logger * zap.SugaredLogger ,
80
+ envRepository repository2.EnvironmentRepository ,
81
+ ciCdConfig * types.CiCdConfig ,
82
+ configMapService read.ConfigReadService ,
83
+ globalCMCSService GlobalCMCSService ,
84
+ argoWorkflowExecutor executors.ArgoWorkflowExecutor ,
83
85
k8sUtil * k8s.K8sServiceImpl ,
84
- systemWorkflowExecutor executors.SystemWorkflowExecutor , k8sCommonService k8s2.K8sCommonService ,
86
+ systemWorkflowExecutor executors.SystemWorkflowExecutor ,
87
+ k8sCommonService k8s2.K8sCommonService ,
85
88
infraProvider infraProviders.InfraProvider ) (* WorkflowServiceImpl , error ) {
86
89
commonWorkflowService := & WorkflowServiceImpl {
87
90
Logger : Logger ,
88
91
ciCdConfig : ciCdConfig ,
89
- appService : appService ,
92
+ configMapService : configMapService ,
90
93
envRepository : envRepository ,
91
94
globalCMCSService : globalCMCSService ,
92
95
argoWorkflowExecutor : argoWorkflowExecutor ,
@@ -277,6 +280,19 @@ func (impl *WorkflowServiceImpl) addExistingCmCsInWorkflowForCDStage(workflowReq
277
280
return nil , nil , err
278
281
}
279
282
impl .Logger .Debugw ("existing cm" , "cm" , existingConfigMap , "secrets" , existingSecrets )
283
+ if existingConfigMap != nil {
284
+ for i := range existingConfigMap .Maps {
285
+ workflowConfigMaps = append (workflowConfigMaps , existingConfigMap .Maps [i ])
286
+ }
287
+ }
288
+ if existingSecrets != nil {
289
+ for i := range existingSecrets .Secrets {
290
+ if existingSecrets .Secrets [i ] == nil {
291
+ continue
292
+ }
293
+ workflowSecrets = append (workflowSecrets , * existingSecrets .Secrets [i ])
294
+ }
295
+ }
280
296
return workflowConfigMaps , workflowSecrets , nil
281
297
}
282
298
0 commit comments