feat: added the host url in the pre post ci cd steps (#5864)

* added the host url in the pre post ci cd steps

* added host url field in wf request during the  pre post ci step

Author: RajeevRanjan27

pkg/deployment/trigger/devtronApps/PreStageTriggerService.go

@@ -27,6 +27,7 @@ import (
 	"github.com/devtron-labs/devtron/internal/sql/repository/pipelineConfig"
 	"github.com/devtron-labs/devtron/internal/sql/repository/pipelineConfig/bean/cdWorkflow"
 	"github.com/devtron-labs/devtron/internal/util"
+	bean6 "github.com/devtron-labs/devtron/pkg/attributes/bean"
 	bean4 "github.com/devtron-labs/devtron/pkg/bean"
 	repository2 "github.com/devtron-labs/devtron/pkg/cluster/repository"
 	bean5 "github.com/devtron-labs/devtron/pkg/deployment/common/bean"
@@ -564,6 +565,12 @@ func (impl *TriggerServiceImpl) buildWFRequest(runner *pipelineConfig.CdWorkflow
 	if digestPolicyConfigurations.UseDigestForTrigger() {
 		image = ReplaceImageTagWithDigest(image, artifact.ImageDigest)
 	}
+
+	host, err := impl.attributeService.GetByKey(bean6.HostUrlKey)
+	if err != nil {
+		impl.logger.Errorw("error in getting hostUrl", "err", err)
+		return nil, err
+	}
 	cdStageWorkflowRequest := &types.WorkflowRequest{
 		EnvironmentId:         cdPipeline.EnvironmentId,
 		AppId:                 cdPipeline.AppId,
@@ -588,6 +595,7 @@ func (impl *TriggerServiceImpl) buildWFRequest(runner *pipelineConfig.CdWorkflow
 			WorkflowId:   artifact.WorkflowId,
 		},
 		OrchestratorHost:  impl.config.OrchestratorHost,
+		HostUrl:           host.Value,
 		OrchestratorToken: impl.config.OrchestratorToken,
 		CloudProvider:     impl.config.CloudProvider,
 		WorkflowExecutor:  workflowExecutor,

pkg/deployment/trigger/devtronApps/TriggerService.go

@@ -47,6 +47,7 @@ import (
 	bean4 "github.com/devtron-labs/devtron/pkg/app/bean"
 	"github.com/devtron-labs/devtron/pkg/app/status"
 	statusBean "github.com/devtron-labs/devtron/pkg/app/status/bean"
+	"github.com/devtron-labs/devtron/pkg/attributes"
 	"github.com/devtron-labs/devtron/pkg/auth/user"
 	bean2 "github.com/devtron-labs/devtron/pkg/bean"
 	chartRepoRepository "github.com/devtron-labs/devtron/pkg/chartRepo/repository"
@@ -163,6 +164,7 @@ type TriggerServiceImpl struct {
 	deploymentConfigService       common.DeploymentConfigService
 	deploymentServiceTypeConfig   *util3.DeploymentServiceTypeConfig
 	ciCdPipelineOrchestrator      pipeline.CiCdPipelineOrchestrator
+	attributeService              attributes.AttributesService
 }
 
 func NewTriggerServiceImpl(logger *zap.SugaredLogger,
@@ -217,7 +219,7 @@ func NewTriggerServiceImpl(logger *zap.SugaredLogger,
 	K8sUtil *util5.K8sServiceImpl,
 	transactionUtilImpl *sql.TransactionUtilImpl,
 	deploymentConfigService common.DeploymentConfigService,
-	ciCdPipelineOrchestrator pipeline.CiCdPipelineOrchestrator,
+	ciCdPipelineOrchestrator pipeline.CiCdPipelineOrchestrator, attributeService attributes.AttributesService,
 ) (*TriggerServiceImpl, error) {
 	impl := &TriggerServiceImpl{
 		logger:                              logger,
@@ -274,6 +276,7 @@ func NewTriggerServiceImpl(logger *zap.SugaredLogger,
 		deploymentConfigService:             deploymentConfigService,
 		deploymentServiceTypeConfig:         envVariables.DeploymentServiceTypeConfig,
 		ciCdPipelineOrchestrator:            ciCdPipelineOrchestrator,
+		attributeService:                    attributeService,
 	}
 	config, err := types.GetCdConfig()
 	if err != nil {

pkg/pipeline/CiService.go

@@ -24,6 +24,8 @@ import (
 	"github.com/devtron-labs/common-lib/utils"
 	bean3 "github.com/devtron-labs/common-lib/utils/bean"
 	"github.com/devtron-labs/devtron/internal/sql/repository/pipelineConfig/bean/cdWorkflow"
+	"github.com/devtron-labs/devtron/pkg/attributes"
+	bean4 "github.com/devtron-labs/devtron/pkg/attributes/bean"
 	"github.com/devtron-labs/devtron/pkg/infraConfig"
 	"github.com/devtron-labs/devtron/pkg/pipeline/adapter"
 	"github.com/devtron-labs/devtron/pkg/pipeline/bean/CiPipeline"
@@ -96,6 +98,7 @@ type CiServiceImpl struct {
 	infraProvider                infraProviders.InfraProvider
 	ciCdPipelineOrchestrator     CiCdPipelineOrchestrator
 	buildxCacheFlags             *BuildxCacheFlags
+	attributeService             attributes.AttributesService
 }
 
 func NewCiServiceImpl(Logger *zap.SugaredLogger, workflowService WorkflowService,
@@ -112,7 +115,7 @@ func NewCiServiceImpl(Logger *zap.SugaredLogger, workflowService WorkflowService
 	pluginInputVariableParser PluginInputVariableParser,
 	globalPluginService plugin.GlobalPluginService,
 	infraProvider infraProviders.InfraProvider,
-	ciCdPipelineOrchestrator CiCdPipelineOrchestrator,
+	ciCdPipelineOrchestrator CiCdPipelineOrchestrator, attributeService attributes.AttributesService,
 ) *CiServiceImpl {
 	buildxCacheFlags := &BuildxCacheFlags{}
 	err := env.Parse(buildxCacheFlags)
@@ -141,6 +144,7 @@ func NewCiServiceImpl(Logger *zap.SugaredLogger, workflowService WorkflowService
 		infraProvider:                infraProvider,
 		ciCdPipelineOrchestrator:     ciCdPipelineOrchestrator,
 		buildxCacheFlags:             buildxCacheFlags,
+		attributeService:             attributeService,
 	}
 	config, err := types.GetCiConfig()
 	if err != nil {
@@ -595,7 +599,11 @@ func (impl *CiServiceImpl) buildWfRequestForCiPipeline(pipeline *pipelineConfig.
 		impl.Logger.Errorw("error in getting infra configuration using scope ", "ciPipelineId", pipeline.Id, "scope", infraConfigScope, "err", err)
 		return nil, err
 	}
-
+	host, err := impl.attributeService.GetByKey(bean4.HostUrlKey)
+	if err != nil {
+		impl.Logger.Errorw("error in getting host url", "err", err, "hostUrl", host.Value)
+		return nil, err
+	}
 	if ciWorkflowConfig.CiCacheBucket == "" {
 		ciWorkflowConfig.CiCacheBucket = impl.config.DefaultCacheBucket
 	}
@@ -796,6 +804,7 @@ func (impl *CiServiceImpl) buildWfRequestForCiPipeline(pipeline *pipelineConfig.
 		ExtraEnvironmentVariables:   trigger.ExtraEnvironmentVariables,
 		EnableBuildContext:          impl.config.EnableBuildContext,
 		OrchestratorHost:            impl.config.OrchestratorHost,
+		HostUrl:                     host.Value,
 		OrchestratorToken:           impl.config.OrchestratorToken,
 		ImageRetryCount:             impl.config.ImageRetryCount,
 		ImageRetryInterval:          impl.config.ImageRetryInterval,

pkg/pipeline/types/Workflow.go

@@ -144,9 +144,10 @@ type WorkflowRequest struct {
 	Env                         *repository.Environment
 	AppLabels                   map[string]string
 	Scope                       resourceQualifiers.Scope
-	BuildxCacheModeMin          bool `json:"buildxCacheModeMin"`
-	AsyncBuildxCacheExport      bool `json:"asyncBuildxCacheExport"`
-	UseDockerApiToGetDigest     bool `json:"useDockerApiToGetDigest"`
+	BuildxCacheModeMin          bool   `json:"buildxCacheModeMin"`
+	AsyncBuildxCacheExport      bool   `json:"asyncBuildxCacheExport"`
+	UseDockerApiToGetDigest     bool   `json:"useDockerApiToGetDigest"`
+	HostUrl                     string `json:"hostUrl"`
 }
 
 func (workflowRequest *WorkflowRequest) updateExternalRunMetadata() {