Skip to content

Commit cc2481c

Browse files
committed
oss etn change
1 parent b0342db commit cc2481c

File tree

2 files changed

+45
-35
lines changed

2 files changed

+45
-35
lines changed

pkg/chart/ChartService.go

Lines changed: 37 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,7 @@ type ChartService interface {
6565
CheckIfChartRefUserUploadedByAppId(id int) (bool, error)
6666
PatchEnvOverrides(values json.RawMessage, oldChartType string, newChartType string) (json.RawMessage, error)
6767

68+
ChartRefAutocompleteGlobalData() (*chartRefBean.ChartRefAutocompleteResponse, error)
6869
ChartRefAutocompleteForAppOrEnv(appId int, envId int) (*chartRefBean.ChartRefAutocompleteResponse, error)
6970

7071
ConfigureGitOpsRepoUrlForApp(appId int, repoUrl, chartLocation string, isCustomRepo bool, userId int32) (*bean2.DeploymentConfig, error)
@@ -814,22 +815,45 @@ func (impl *ChartServiceImpl) IsReadyToTrigger(appId int, envId int, pipelineId
814815
}
815816

816817
func (impl *ChartServiceImpl) ChartRefAutocompleteForAppOrEnv(appId int, envId int) (*chartRefBean.ChartRefAutocompleteResponse, error) {
817-
chartRefResponse := &chartRefBean.ChartRefAutocompleteResponse{}
818-
var chartRefs []chartRefBean.ChartRefAutocompleteDto
818+
chartRefResponse, err := impl.ChartRefAutocompleteGlobalData()
819+
if err != nil {
820+
impl.logger.Errorw("error, ChartRefAutocompleteGlobalData", "err", err)
821+
return nil, err
822+
}
823+
chart, err := impl.chartRepository.FindLatestChartForAppByAppId(appId)
824+
if err != nil && err != pg.ErrNoRows {
825+
impl.logger.Errorw("error in fetching latest chart", "err", err)
826+
return chartRefResponse, err
827+
}
828+
chartRefResponse.LatestAppChartRef = chart.ChartRefId
829+
if envId > 0 {
830+
envOverride, err := impl.envConfigOverrideReadService.FindLatestChartForAppByAppIdAndEnvId(appId, envId)
831+
if err != nil && !errors.IsNotFound(err) {
832+
impl.logger.Errorw("error in fetching latest chart", "err", err)
833+
return chartRefResponse, err
834+
}
835+
if envOverride != nil && envOverride.Chart != nil {
836+
chartRefResponse.LatestEnvChartRef = envOverride.Chart.ChartRefId
837+
} else {
838+
chartRefResponse.LatestEnvChartRef = chart.ChartRefId
839+
}
840+
}
841+
return chartRefResponse, nil
842+
}
819843

844+
func (impl *ChartServiceImpl) ChartRefAutocompleteGlobalData() (*chartRefBean.ChartRefAutocompleteResponse, error) {
820845
results, err := impl.chartRefService.GetAll()
821846
if err != nil {
822847
impl.logger.Errorw("error in fetching chart ref", "err", err)
823-
return chartRefResponse, err
848+
return nil, err
824849
}
825-
826850
resultsMetadataMap, err := impl.chartRefService.GetAllChartMetadata()
827851
if err != nil {
828852
impl.logger.Errorw("error in fetching chart metadata", "err", err)
829-
return chartRefResponse, err
853+
return nil, err
830854
}
831-
chartRefResponse.ChartsMetadata = resultsMetadataMap
832-
var LatestAppChartRef int
855+
var latestChartRef int
856+
chartRefs := make([]chartRefBean.ChartRefAutocompleteDto, 0, len(results))
833857
for _, result := range results {
834858
chartRefs = append(chartRefs, chartRefBean.ChartRefAutocompleteDto{
835859
Id: result.Id,
@@ -840,32 +864,14 @@ func (impl *ChartServiceImpl) ChartRefAutocompleteForAppOrEnv(appId int, envId i
840864
IsAppMetricsSupported: result.IsAppMetricsSupported,
841865
})
842866
if result.Default == true {
843-
LatestAppChartRef = result.Id
844-
}
845-
}
846-
847-
chart, err := impl.chartRepository.FindLatestChartForAppByAppId(appId)
848-
if err != nil && err != pg.ErrNoRows {
849-
impl.logger.Errorw("error in fetching latest chart", "err", err)
850-
return chartRefResponse, err
851-
}
852-
853-
if envId > 0 {
854-
envOverride, err := impl.envConfigOverrideReadService.FindLatestChartForAppByAppIdAndEnvId(appId, envId)
855-
if err != nil && !errors.IsNotFound(err) {
856-
impl.logger.Errorw("error in fetching latest chart", "err", err)
857-
return chartRefResponse, err
858-
}
859-
if envOverride != nil && envOverride.Chart != nil {
860-
chartRefResponse.LatestEnvChartRef = envOverride.Chart.ChartRefId
861-
} else {
862-
chartRefResponse.LatestEnvChartRef = chart.ChartRefId
867+
latestChartRef = result.Id
863868
}
864869
}
865-
chartRefResponse.LatestAppChartRef = chart.ChartRefId
866-
chartRefResponse.ChartRefs = chartRefs
867-
chartRefResponse.LatestChartRef = LatestAppChartRef
868-
return chartRefResponse, nil
870+
return &chartRefBean.ChartRefAutocompleteResponse{
871+
ChartsMetadata: resultsMetadataMap,
872+
ChartRefs: chartRefs,
873+
LatestChartRef: latestChartRef,
874+
}, nil
869875
}
870876

871877
func (impl *ChartServiceImpl) FindPreviousChartByAppId(appId int) (chartTemplate *TemplateRequest, err error) {

pkg/config/configDiff/DeploymentConfigurationService.go

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -144,6 +144,12 @@ func (impl *DeploymentConfigurationServiceImpl) ConfigAutoComplete(appId int, en
144144
impl.logger.Errorw("error in fetching CM and CS names at app or env level", "appId", appId, "envId", envId, "err", err)
145145
return nil, err
146146
}
147+
combinedProperties := GetConfigAutoCompleteCombinedPropertiesDataWithoutDraft(cMCSNamesAppLevel, cMCSNamesEnvLevel, envId)
148+
configDataResp := bean2.NewConfigDataResponse().WithResourceConfig(combinedProperties)
149+
return configDataResp, nil
150+
}
151+
152+
func GetConfigAutoCompleteCombinedPropertiesDataWithoutDraft(cMCSNamesAppLevel, cMCSNamesEnvLevel []bean.ConfigNameAndType, envId int) (combinedProperties []*bean2.ConfigProperty) {
147153
cmcsKeyPropertyAppLevelMap, cmcsKeyPropertyEnvLevelMap := adaptor.GetCmCsAppAndEnvLevelMap(cMCSNamesAppLevel, cMCSNamesEnvLevel)
148154
for key, configProperty := range cmcsKeyPropertyAppLevelMap {
149155
if _, ok := cmcsKeyPropertyEnvLevelMap[key]; !ok {
@@ -161,11 +167,9 @@ func (impl *DeploymentConfigurationServiceImpl) ConfigAutoComplete(appId int, en
161167
configProperty.ConfigStage = bean2.Env
162168
}
163169
}
164-
combinedProperties := helper.GetCombinedPropertiesMap(cmcsKeyPropertyAppLevelMap, cmcsKeyPropertyEnvLevelMap)
170+
combinedProperties = helper.GetCombinedPropertiesMap(cmcsKeyPropertyAppLevelMap, cmcsKeyPropertyEnvLevelMap)
165171
combinedProperties = append(combinedProperties, adaptor.GetConfigProperty(0, "", bean.DeploymentTemplate, bean2.PublishedConfigState))
166-
167-
configDataResp := bean2.NewConfigDataResponse().WithResourceConfig(combinedProperties)
168-
return configDataResp, nil
172+
return combinedProperties
169173
}
170174

171175
func (impl *DeploymentConfigurationServiceImpl) GetAllConfigData(ctx context.Context, configDataQueryParams *bean2.ConfigDataQueryParams, userHasAdminAccess bool) (*bean2.DeploymentAndCmCsConfigDto, error) {

0 commit comments

Comments
 (0)