fix: enhanced api response

Author: SATYAsasini

api/cluster/EnvironmentRestHandler.go

@@ -447,11 +447,15 @@ func (impl EnvironmentRestHandlerImpl) GetCombinedEnvironmentListForDropDownByCl
 			id, err := strconv.Atoi(clusterId)
 			if err != nil {
 				impl.logger.Errorw("request err, GetCombinedEnvironmentListForDropDownByClusterIds", "err", err, "clusterIdString", clusterIdString)
-				common.WriteJsonResp(w, err, "please send valid cluster Ids", http.StatusBadRequest)
+				common.HandleParameterError(w, r, "ids", clusterIdString)
 				return
 			}
 			clusterIds = append(clusterIds, id)
 		}
+	} else {
+		impl.logger.Errorw("request err empty query param, GetCombinedEnvironmentListForDropDownByClusterIds", "err", err, "clusterIdString", clusterIdString)
+		common.HandleParameterError(w, r, "ids", clusterIdString)
+		return
 	}
 	token := r.Header.Get("token")
 	clusters, err := impl.environmentClusterMappingsService.GetCombinedEnvironmentListForDropDownByClusterIds(token, clusterIds, impl.rbacEnforcementUtil.CheckAuthorizationForGlobalEnvironment)

api/devtronResource/DevtronResourceHistoryRestHandler.go

@@ -54,9 +54,16 @@ func (handler *HistoryRestHandlerImpl) GetDeploymentHistory(w http.ResponseWrite
 	queryParams := apiBean.GetHistoryQueryParams{}
 	err := decoder.Decode(&queryParams, v)
 	if err != nil {
+		handler.logger.Errorw("error in decoding query parameters", "queryParams", v, "err", err)
 		common.WriteJsonResp(w, err, nil, http.StatusBadRequest)
 		return
 	}
+	// Validating that filterCriteria is provided
+	if len(queryParams.FilterCriteria) == 0 {
+		handler.logger.Errorw("missing required filterCriteria parameter")
+		common.HandleParameterError(w, r, "filterCriteria", "")
+		return
+	}
 	decodedReqBean, err := handler.apiReqDecoderService.GetFilterCriteriaParamsForDeploymentHistory(queryParams.FilterCriteria)
 	if err != nil {
 		handler.logger.Errorw("error in getting filter criteria params", "err", err, "filterCriteria", queryParams.FilterCriteria)

api/restHandler/app/pipeline/AutoCompleteRestHandler.go

@@ -136,7 +136,11 @@ func (handler DevtronAppAutoCompleteRestHandlerImpl) GetAppListForAutocomplete(w
 			return
 		}
 	} else {
-		teamIdInt, err = strconv.Atoi(teamId)
+		teamIdInt, err = common.ExtractIntPathParamWithContext(w, r, "teamId", teamId+" team")
+		if err != nil {
+			// Error already written by ExtractIntPathParamWithContext
+			return
+		}
 		if err != nil {
 			common.WriteJsonResp(w, err, nil, http.StatusBadRequest)
 			return

api/restHandler/app/pipeline/configure/BuildPipelineRestHandler.go

@@ -1209,15 +1209,21 @@ func (handler *PipelineConfigRestHandlerImpl) FetchMaterialInfo(w http.ResponseW
 
 func (handler *PipelineConfigRestHandlerImpl) GetCIPipelineById(w http.ResponseWriter, r *http.Request) {
 	token := r.Header.Get("token")
-	vars := mux.Vars(r)
-	appId, err := strconv.Atoi(vars["appId"])
+	// vars := mux.Vars(r)
+	//appId, err := strconv.Atoi(vars["appId"])
+	appId, err := common.ExtractIntPathParamWithContext(w, r, "appId", "app")
 	if err != nil {
-		common.WriteJsonResp(w, err, nil, http.StatusBadRequest)
+		// response already written by ExtractIntPathParamWithContext
+		//common.WriteJsonResp(w, err, nil, http.StatusBadRequest)
+		handler.Logger.Error("request err getting , GetCIPipelineById", "appId", appId, "err", err)
 		return
 	}
-	pipelineId, err := strconv.Atoi(vars["pipelineId"])
+	//pipelineId, err := strconv.Atoi(vars["pipelineId"])
+	pipelineId, err := common.ExtractIntPathParamWithContext(w, r, "pipelineId", "pipeline")
 	if err != nil {
-		common.WriteJsonResp(w, err, nil, http.StatusBadRequest)
+		// response already written by ExtractIntPathParamWithContext
+		// common.WriteJsonResp(w, err, nil, http.StatusBadRequest)
+		handler.Logger.Error("request err getting , GetCIPipelineById", "pipelineId", pipelineId, "err", err)
 		return
 	}
 
@@ -1711,20 +1717,29 @@ func (handler *PipelineConfigRestHandlerImpl) FetchWorkflowDetails(w http.Respon
 		common.HandleUnauthorized(w, r)
 		return
 	}
-	vars := mux.Vars(r)
-	appId, err := strconv.Atoi(vars["appId"])
+	// vars := mux.Vars(r)
+	// appId, err = strconv.Atoi(vars["appId"])
+	appId, err := common.ExtractIntPathParamWithContext(w, r, "appId", "app")
 	if err != nil {
-		common.WriteJsonResp(w, err, nil, http.StatusBadRequest)
+		// response already written by ExtractIntPathParamWithContext
+		// common.WriteJsonResp(w, err, nil, http.StatusBadRequest)
+		handler.Logger.Error("request err getting , FetchWorkflowDetails", "appId", appId, "err", err)
 		return
 	}
-	pipelineId, err := strconv.Atoi(vars["pipelineId"])
+	// pipelineId, err := strconv.Atoi(vars["pipelineId"])
+	pipelineId, err := common.ExtractIntPathParamWithContext(w, r, "pipelineId", "pipeline")
 	if err != nil {
-		common.WriteJsonResp(w, err, nil, http.StatusBadRequest)
+		// response already written by ExtractIntPathParamWithContext
+		// common.WriteJsonResp(w, err, nil, http.StatusBadRequest)
+		handler.Logger.Error("request err getting , FetchWorkflowDetails", "pipelineId", pipelineId, "err", err)
 		return
 	}
-	buildId, err := strconv.Atoi(vars["workflowId"])
+	// buildId, err := strconv.Atoi(vars["workflowId"])
+	buildId, err := common.ExtractIntPathParamWithContext(w, r, "workflowId", "workflow")
 	if err != nil || buildId == 0 {
-		common.WriteJsonResp(w, err, nil, http.StatusBadRequest)
+		// response already written by ExtractIntPathParamWithContext
+		// common.WriteJsonResp(w, err, nil, http.StatusBadRequest)
+		handler.Logger.Error("request err getting , FetchWorkflowDetails", "buildId", buildId, "err", err)
 		return
 	}
 	handler.Logger.Infow("request payload, FetchWorkflowDetails", "appId", appId, "pipelineId", pipelineId, "buildId", buildId, "buildId", buildId)