Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
46 changes: 45 additions & 1 deletion pkg/configDiff/DeploymentConfigurationService.go
Original file line number Diff line number Diff line change
Expand Up @@ -327,7 +327,12 @@ func (impl *DeploymentConfigurationServiceImpl) getCmCsConfigHistory(ctx context
return nil, err
}
resolvedConfigDataReq := &bean.ConfigDataRequest{ConfigData: resolvedConfigDataList}
resolvedConfigDataStringJson, err := utils.ConvertToJsonRawMessage(resolvedConfigDataReq)
resolvedConfigDataString, err := utils.ConvertToString(resolvedConfigDataReq)
if err != nil {
impl.logger.Errorw("getCmCsPublishedConfigResponse, error in converting config data to json raw message", "pipelineId", configDataQueryParams.PipelineId, "wfrId", configDataQueryParams.WfrId, "err", err)
return nil, err
}
resolvedConfigDataStringJson, err := utils.ConvertToJsonRawMessage(resolvedConfigDataString)
if err != nil {
impl.logger.Errorw("getCmCsPublishedConfigResponse, error in ConvertToJsonRawMessage for resolvedConfigDataString", "pipelineId", configDataQueryParams.PipelineId, "wfrId", configDataQueryParams.WfrId, "err", err)
return nil, err
Expand Down Expand Up @@ -477,6 +482,13 @@ func (impl *DeploymentConfigurationServiceImpl) getConfigDataForAppConfiguration
configDataDto := &bean2.DeploymentAndCmCsConfigDto{}
var err error
switch configDataQueryParams.ConfigType {
case bean2.DefaultVersion.ToString():
configDataDto, err = impl.getDeploymentAndCmCsConfigDataForDefaultVersion(ctx, configDataQueryParams)
if err != nil {
impl.logger.Errorw("GetAllConfigData, error in config data for Default version", "configDataQueryParams", configDataQueryParams, "err", err)
return nil, err
}
//no cm or cs to send for default versions
case bean2.PreviousDeployments.ToString():
configDataDto, err = impl.getDeploymentAndCmCsConfigDataForPreviousDeployments(ctx, configDataQueryParams, appId, envId, userHasAdminAccess)
if err != nil {
Expand All @@ -493,6 +505,38 @@ func (impl *DeploymentConfigurationServiceImpl) getConfigDataForAppConfiguration
return configDataDto, nil
}

func (impl *DeploymentConfigurationServiceImpl) getDeploymentsConfigForDefaultVersion(ctx context.Context, chartRefId int) (json.RawMessage, error) {
deploymentTemplateRequest := generateManifest.DeploymentTemplateRequest{
ChartRefId: chartRefId,
RequestDataMode: generateManifest.Values,
Type: repository2.DefaultVersions,
}
deploymentTemplateResponse, err := impl.deploymentTemplateService.GetDeploymentTemplate(ctx, deploymentTemplateRequest)
if err != nil {
impl.logger.Errorw("getDeploymentTemplateForEnvLevel, error in getting deployment template for ", "deploymentTemplateRequest", deploymentTemplateRequest, "err", err)
return nil, err
}
deploymentJson := json.RawMessage{}
err = deploymentJson.UnmarshalJSON([]byte(deploymentTemplateResponse.Data))
if err != nil {
impl.logger.Errorw("getDeploymentTemplateForEnvLevel, error in unmarshalling string deploymentTemplateResponse data into json Raw message", "data", deploymentTemplateResponse.Data, "err", err)
return nil, err
}
return deploymentJson, nil
}

func (impl *DeploymentConfigurationServiceImpl) getDeploymentAndCmCsConfigDataForDefaultVersion(ctx context.Context, configDataQueryParams *bean2.ConfigDataQueryParams) (*bean2.DeploymentAndCmCsConfigDto, error) {
configData := &bean2.DeploymentAndCmCsConfigDto{}
deploymentTemplateJsonData, err := impl.getDeploymentsConfigForDefaultVersion(ctx, configDataQueryParams.IdentifierId)
if err != nil {
impl.logger.Errorw("GetAllConfigData, error in getting deployment config for default version", "chartRefId", configDataQueryParams.IdentifierId, "err", err)
return nil, err
}
deploymentConfig := bean2.NewDeploymentAndCmCsConfig().WithConfigData(deploymentTemplateJsonData).WithResourceType(bean.DeploymentTemplate)
configData.WithDeploymentTemplateData(deploymentConfig)
return configData, nil
}

func (impl *DeploymentConfigurationServiceImpl) getCmCsEditDataForPublishedOnly(ctx context.Context, configDataQueryParams *bean2.ConfigDataQueryParams, envId,
appId int, clusterId int, userHasAdminAccess bool, systemMetadata *resourceQualifiers.SystemMetadata) (*bean2.DeploymentAndCmCsConfigDto, error) {
configDataDto := &bean2.DeploymentAndCmCsConfigDto{}
Expand Down
1 change: 1 addition & 0 deletions pkg/configDiff/bean/bean.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@ type ConfigState string
const (
PublishedConfigState ConfigState = "PublishedOnly"
PreviousDeployments ConfigState = "PreviousDeployments"
DefaultVersion ConfigState = "DefaultVersion"
)

func (r ConfigState) ToString() string {
Expand Down
7 changes: 6 additions & 1 deletion pkg/pipeline/history/ConfigMapHistoryService.go
Original file line number Diff line number Diff line change
Expand Up @@ -763,7 +763,12 @@ func (impl *ConfigMapHistoryServiceImpl) getResolvedConfigData(ctx context.Conte
return nil, err
}
resolvedConfigDataReq := &bean3.ConfigDataRequest{ConfigData: resolvedConfigDataList}
resolvedConfigDataStringJson, err := utils.ConvertToJsonRawMessage(resolvedConfigDataReq)
resolvedConfigDataString, err := utils.ConvertToString(resolvedConfigDataReq)
if err != nil {
impl.logger.Errorw("getCmCsPublishedConfigResponse, error in converting config data to json raw message", "pipelineId", pipelineId, "deployedOn", deployedOn, "err", err)
return nil, err
}
resolvedConfigDataStringJson, err := utils.ConvertToJsonRawMessage(resolvedConfigDataString)
if err != nil {
impl.logger.Errorw("getCmCsPublishedConfigResponse, error in ConvertToJsonRawMessage for resolvedJson", "resolvedJson", resolvedConfigDataStringJson, "err", err)
return nil, err
Expand Down