added common code

Author: kartik-579

internal/sql/repository/deploymentConfig/repository.go

@@ -46,6 +46,7 @@ type Repository interface {
 	GetAppAndEnvLevelConfigsInBulk(appIdToEnvIdsMap map[int][]int) ([]*DeploymentConfig, error)
 	GetByAppIdAndEnvIdEvenIfInactive(appId, envId int) (*DeploymentConfig, error)
 	UpdateRepoUrlByAppIdAndEnvId(repoUrl string, appId, envId int) error
+	GetConfigByAppIds(appIds []int) ([]*DeploymentConfig, error)
 }
 
 type RepositoryImpl struct {
@@ -172,3 +173,12 @@ func (impl *RepositoryImpl) UpdateRepoUrlByAppIdAndEnvId(repoUrl string, appId,
 		Update()
 	return err
 }
+
+func (impl *RepositoryImpl) GetConfigByAppIds(appIds []int) ([]*DeploymentConfig, error) {
+	var results []*DeploymentConfig
+	err := impl.dbConnection.Model(&results).
+		Where("app_id in (?) ", pg.In(appIds)).
+		Where("active = ?", true).
+		Select()
+	return results, err
+}

pkg/deployment/common/deploymentConfigService.go

@@ -18,6 +18,7 @@ import (
 
 type DeploymentConfigService interface {
 	CreateOrUpdateConfig(tx *pg.Tx, config *bean.DeploymentConfig, userId int32) (*bean.DeploymentConfig, error)
+	CreateOrUpdateConfigInBulk(tx *pg.Tx, configToBeCreated, configToBeUpdated []*bean.DeploymentConfig, userId int32) error
 	IsDeploymentConfigUsed() bool
 	GetConfigForDevtronApps(appId, envId int) (*bean.DeploymentConfig, error)
 	GetAndMigrateConfigIfAbsentForDevtronApps(appId, envId int) (*bean.DeploymentConfig, error)
@@ -27,6 +28,7 @@ type DeploymentConfigService interface {
 	GetAppLevelConfigForDevtronApp(appId int) (*bean.DeploymentConfig, error)
 	UpdateRepoUrlForAppAndEnvId(repoURL string, appId, envId int) error
 	GetDeploymentAppTypeForCDInBulk(pipelines []*pipelineConfig.Pipeline) (map[int]string, error)
+	GetConfigsByAppIds(appIds []int) ([]*bean.DeploymentConfig, error)
 }
 
 type DeploymentConfigServiceImpl struct {
@@ -90,6 +92,41 @@ func (impl *DeploymentConfigServiceImpl) CreateOrUpdateConfig(tx *pg.Tx, config
 	return ConvertDeploymentConfigDbObjToDTO(newDBObj), nil
 }
 
+func (impl *DeploymentConfigServiceImpl) CreateOrUpdateConfigInBulk(tx *pg.Tx, configToBeCreated, configToBeUpdated []*bean.DeploymentConfig, userId int32) error {
+
+	dbObjCreate := make([]*deploymentConfig.DeploymentConfig, len(configToBeCreated))
+	for i := range configToBeCreated {
+		dbObj := ConvertDeploymentConfigDTOToDbObj(configToBeCreated[i])
+		dbObj.AuditLog.CreateAuditLog(userId)
+		dbObjCreate = append(dbObjCreate, dbObj)
+	}
+
+	dbObjUpdate := make([]*deploymentConfig.DeploymentConfig, len(configToBeUpdated))
+	for i := range configToBeUpdated {
+		dbObj := ConvertDeploymentConfigDTOToDbObj(configToBeUpdated[i])
+		dbObj.AuditLog.CreateAuditLog(userId)
+		dbObjUpdate = append(dbObjUpdate, dbObj)
+	}
+
+	if len(dbObjCreate) > 0 {
+		_, err := impl.deploymentConfigRepository.SaveAll(tx, dbObjCreate)
+		if err != nil {
+			impl.logger.Errorw("error in saving deploymentConfig", "dbObjCreate", dbObjCreate, "err", err)
+			return err
+		}
+	}
+
+	if len(dbObjUpdate) > 0 {
+		_, err := impl.deploymentConfigRepository.UpdateAll(tx, dbObjUpdate)
+		if err != nil {
+			impl.logger.Errorw("error in updating deploymentConfig", "dbObjUpdate", dbObjUpdate, "err", err)
+			return err
+		}
+	}
+
+	return nil
+}
+
 func (impl *DeploymentConfigServiceImpl) IsDeploymentConfigUsed() bool {
 	return impl.deploymentServiceTypeConfig.UseDeploymentConfigData
 }
@@ -478,3 +515,19 @@ func (impl *DeploymentConfigServiceImpl) GetDeploymentAppTypeForCDInBulk(pipelin
 	}
 	return resp, nil
 }
+
+func (impl *DeploymentConfigServiceImpl) GetConfigsByAppIds(appIds []int) ([]*bean.DeploymentConfig, error) {
+	if len(appIds) == 0 {
+		return nil, nil
+	}
+	configs, err := impl.deploymentConfigRepository.GetConfigByAppIds(appIds)
+	if err != nil {
+		impl.logger.Errorw("error in getting deployment config db object by appIds", "appIds", appIds, "err", err)
+		return nil, err
+	}
+	resp := make([]*bean.DeploymentConfig, 0, len(configs))
+	for _, config := range configs {
+		resp = append(resp, ConvertDeploymentConfigDbObjToDTO(config))
+	}
+	return resp, nil
+}