Add StorageConfigured field to CiWorkflowStatusLatest and update services to handle it.

Integrate `BlobStorageEnabled` from the data model and replace default hardcoded value in `WorkflowStatusUpdateServiceImpl`.

Author: prakash100198

pkg/workflow/status/workflowStatusLatest/WorkflowStatusLatestService.go

@@ -60,12 +60,12 @@ func NewWorkflowStatusLatestServiceImpl(
 	}
 }
 
-// DTOs for service layer
 type CiWorkflowStatusLatest struct {
-	PipelineId   int    `json:"pipelineId"`
-	AppId        int    `json:"appId"`
-	CiWorkflowId int    `json:"ciWorkflowId"`
-	Status       string `json:"status"` // Derived from ci_workflow table
+	PipelineId        int    `json:"pipelineId"`
+	AppId             int    `json:"appId"`
+	CiWorkflowId      int    `json:"ciWorkflowId"`
+	Status            string `json:"status"` // Derived from ci_workflow table
+	StorageConfigured bool   `json:"storageConfigured"`
 }
 
 type CdWorkflowStatusLatest struct {
@@ -153,10 +153,11 @@ func (impl *WorkflowStatusLatestServiceImpl) GetCiWorkflowStatusLatestByAppId(ap
 		}
 
 		result = append(result, &CiWorkflowStatusLatest{
-			PipelineId:   model.PipelineId,
-			AppId:        model.AppId,
-			CiWorkflowId: model.CiWorkflowId,
-			Status:       ciWorkflow.Status,
+			PipelineId:        model.PipelineId,
+			AppId:             model.AppId,
+			CiWorkflowId:      model.CiWorkflowId,
+			Status:            ciWorkflow.Status,
+			StorageConfigured: ciWorkflow.BlobStorageEnabled,
 		})
 	}
 

pkg/workflow/status/workflowStatusLatest/WorkflowStatusUpdateService.go

@@ -67,7 +67,6 @@ func (impl *WorkflowStatusUpdateServiceImpl) UpdateCdWorkflowStatusLatest(pipeli
 }
 
 func (impl *WorkflowStatusUpdateServiceImpl) FetchCiStatusForTriggerViewOptimized(appId int) ([]*pipelineConfig.CiWorkflowStatus, error) {
-	// First try to get from the optimized latest status table
 	latestStatuses, err := impl.workflowStatusLatestService.GetCiWorkflowStatusLatestByAppId(appId)
 	if err != nil {
 		impl.logger.Errorw("error in getting ci workflow status latest by app id", "err", err, "appId", appId)
@@ -78,7 +77,6 @@ func (impl *WorkflowStatusUpdateServiceImpl) FetchCiStatusForTriggerViewOptimize
 	// Convert to the expected format
 	var ciWorkflowStatuses []*pipelineConfig.CiWorkflowStatus
 	for _, latestStatus := range latestStatuses {
-		// Get pipeline name from CI pipeline repository
 		ciPipeline, err := impl.ciPipelineRepository.FindById(latestStatus.PipelineId)
 		if err != nil {
 			impl.logger.Errorw("error in getting ci pipeline", "err", err, "pipelineId", latestStatus.PipelineId)
@@ -90,7 +88,7 @@ func (impl *WorkflowStatusUpdateServiceImpl) FetchCiStatusForTriggerViewOptimize
 			CiPipelineName:    ciPipeline.Name,
 			CiStatus:          latestStatus.Status,
 			CiWorkflowId:      latestStatus.CiWorkflowId,
-			StorageConfigured: true, // Default value, can be enhanced later
+			StorageConfigured: latestStatus.StorageConfigured,
 		}
 		ciWorkflowStatuses = append(ciWorkflowStatuses, ciWorkflowStatus)
 	}