refactor(metrics): update deployment metrics structures and date handling, enhance query ordering logic in repository

Author: prakash100198

lens/api/RestHandler.go

@@ -164,7 +164,7 @@ func (impl *RestHandlerImpl) GetBulkDeploymentMetrics(w http.ResponseWriter, r *
 		return
 	}
 
-	if bulkRequest.From == "" || bulkRequest.To == "" {
+	if bulkRequest.From == nil || bulkRequest.To == nil {
 		impl.writeJsonResp(w, fmt.Errorf("from and to dates are required"), nil, http.StatusBadRequest)
 		return
 	}

lens/internal/dto/deploymentMetricsDto.go

@@ -55,19 +55,19 @@ type MetricRequest struct {
 }
 
 type AppEnvPair struct {
-	AppId int `json:"app_id"`
-	EnvId int `json:"env_id"`
+	AppId int `json:"appId"`
+	EnvId int `json:"envId"`
 }
 
 type BulkMetricRequest struct {
 	AppEnvPairs []AppEnvPair `json:"appEnvPairs"`
-	From        string       `json:"from"`
-	To          string       `json:"to"`
+	From        *time.Time   `json:"from"`
+	To          *time.Time   `json:"to"`
 }
 
 type AppEnvMetrics struct {
-	AppId   int      `json:"app_id"`
-	EnvId   int      `json:"env_id"`
+	AppId   int      `json:"appId"`
+	EnvId   int      `json:"envId"`
 	Metrics *Metrics `json:"metrics"`
 	Error   string   `json:"error,omitempty"`
 }

lens/internal/sql/AppReleaseRepository.go

@@ -165,7 +165,7 @@ func (impl *AppReleaseRepositoryImpl) GetReleaseBetweenBulk(appEnvPairs []dto.Ap
 	whereClause := "(" + strings.Join(conditions, " OR ") + ")"
 	query = query.Where(whereClause, args...)
 
-	err := query.Order("app_id, environment_id, id desc").Select()
+	err := query.Order("app_id").Order("environment_id").Order("id desc").Select()
 	return appReleases, err
 }
 

lens/pkg/DeploymentMetricService.go

@@ -104,22 +104,15 @@ func (impl DeploymentMetricServiceImpl) GetBulkDeploymentMetrics(request *dto.Bu
 		return &dto.BulkMetricsResponse{Results: []dto.AppEnvMetrics{}}, nil
 	}
 
-	response := &dto.BulkMetricsResponse{
-		Results: make([]dto.AppEnvMetrics, len(request.AppEnvPairs)),
-	}
-
-	return impl.getBulkDeploymentMetricsWithBulkQueries(request, response)
+	return impl.getBulkDeploymentMetricsWithBulkQueries(request)
 }
 
-func (impl DeploymentMetricServiceImpl) getBulkDeploymentMetricsWithBulkQueries(request *dto.BulkMetricRequest, response *dto.BulkMetricsResponse) (*dto.BulkMetricsResponse, error) {
-	from, to, err := utils2.ParseDateRange(request.From, request.To)
-	if err != nil {
-		impl.logger.Errorw("error parsing date range", "from", request.From, "to", request.To, "err", err)
-		return nil, err
+func (impl DeploymentMetricServiceImpl) getBulkDeploymentMetricsWithBulkQueries(request *dto.BulkMetricRequest) (*dto.BulkMetricsResponse, error) {
+	response := &dto.BulkMetricsResponse{
+		Results: make([]dto.AppEnvMetrics, len(request.AppEnvPairs)),
 	}
-
 	// Step 1: Get all releases for all app-env pairs in one query
-	allReleases, err := impl.appReleaseRepository.GetReleaseBetweenBulk(request.AppEnvPairs, from, to)
+	allReleases, err := impl.appReleaseRepository.GetReleaseBetweenBulk(request.AppEnvPairs, *request.From, *request.To)
 	if err != nil {
 		impl.logger.Errorw("error getting bulk releases from db", "err", err)
 		return nil, err