feat: [fme-7194]: Added CCM GraphQL for budget, metadata and recommendations (#47)

* [fme-7194] - Return NewToolResultError instead of generic error

* [fme-7194] - Merge with master

* [fme-7194] - Fixing view id issue

* [fme-7168] - Fixing tool name. fetch_ccm_metadata to get_ccm_metadata

* [fme-7168] - Adding Perspective Recommendations operation

* [fme-7168] - Added Fetch CCM Metadata Tool (FetchCcmMetadata  graphQL Operation)

* [fme-7154] Adding master changes

* [fme-7154] - Added GraphQL perspective Budget tool

* [fme-7133] - Using MM/DD/YYYY format in LastPeriodCostCcmPerspective tool. Removing unused imports

* [fme-7133] - Merge with master

* [fme-7133] Added Get Perspective Grid with budget graphql query

* [fme-5745] - Added perspective time series graphql API

* [fme-4352] - Fixing group by AWS fields constants

* [fme-4352] Fix for key values filter parameter config

* [fme-4352] Improving description for MCP tool for ccm_perspective_grid

* [fme-4352] Fixing filter field description

* [fme-4352] - Adding filtering and grouping by key/value field

Author: javrudsky

README.md

@@ -99,6 +99,7 @@ Toolset Name: `cloudcostmanagement`
 - `ccm_perspective_summary_with_budget`: Query a summary of cost perspectives with budget information in Harness Cloud Cost Management, including detailed cost and budget data grouped by time.
 - `ccm_perspective_budget`: Query the budget information for a perspective in Harness Cloud Cost Management.
 - `get_ccm_metadata`: Retrieves metadata about available cloud connectors, cost data sources, default perspectives, and currency preferences in Harness Cloud Cost Management.
+- `ccm_perspective_recommendations`: PerspectiveRecommendations: Returns monthly cost, savings, and a list of open recommendations for a perspective in Harness Cloud Cost Management.
 - `get_ccm_commitment_coverage`: Get commitment coverage information for an account in Harness Cloud Cost Management
 
 #### Chaos Engineering Toolset

client/ccmcommons/ccmgraphqlqueries.go

@@ -192,3 +192,26 @@ query FetchCcmMetaData {
   }
 }
 `
+const CCMPerspectiveRecommendationsQuery = `
+query PerspectiveRecommendations($filter: RecommendationFilterDTOInput) {
+	recommendationStatsV2(filter: $filter) {
+		totalMonthlyCost
+		totalMonthlySaving
+		count
+		__typename
+	}
+	recommendationsV2(filter: $filter) {
+		items {
+			clusterName
+			namespace
+			id
+			resourceType
+			resourceName
+			monthlyCost
+			monthlySaving
+			__typename
+		}
+		__typename
+	}
+}
+`

client/ccmgraphqlperspectives.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 	"time"
 	"strings"
+	"encoding/json"
 	"log/slog"
 	"github.com/harness/harness-mcp/client/dto"
 	"github.com/harness/harness-mcp/client/ccmcommons"
@@ -20,7 +21,7 @@ func (r *CloudCostManagementService) PerspectiveGrid(ctx context.Context, scope
 
 	gqlQuery := ccmcommons.CCMPerspectiveGridQuery
 	variables := map[string]any{
-		"filters":            buildFilters(options.TimeFilter, options.Filters, options.KeyValueFilters),
+		"filters":            buildFilters(options.ViewId, options.TimeFilter, options.Filters, options.KeyValueFilters),
 		"groupBy":            buildGroupBy(options.GroupBy, outputFields, outputKeyValueFields),
 		"limit":              options.Limit,
 		"offset":             options.Offset,
@@ -36,7 +37,7 @@ func (r *CloudCostManagementService) PerspectiveGrid(ctx context.Context, scope
 		"variables":     variables,
 	}
 
-	slog.Debug("PerspectiveGrid", "Payload", payload)
+	debugPayload("PerspectiveGrid", payload)
 	result := new(dto.CCMPerspectiveGridResponse)
 	err := r.Client.Post(ctx, path, nil, payload, &result)
 	if err != nil {
@@ -60,7 +61,7 @@ func (r *CloudCostManagementService) PerspectiveTimeSeries(ctx context.Context,
 	}
 
 	variables := map[string]any{
-		"filters":            buildFilters(options.TimeFilter, options.Filters, options.KeyValueFilters),
+		"filters":            buildFilters(options.ViewId, options.TimeFilter, options.Filters, options.KeyValueFilters),
 		"groupBy":           []map[string]any{timeTruncGroupBy, entityGroupBy[0]},
 		"limit":              options.Limit,
 		"offset":             options.Offset,
@@ -90,7 +91,7 @@ func (r *CloudCostManagementService) PerspectiveSummaryWithBudget(ctx context.Co
 
 	gqlQuery := ccmcommons.CCMPerspectiveSummaryWithBudgetQuery
 	variables := map[string]any{
-		"filters":            buildFilters(options.TimeFilter, options.Filters, options.KeyValueFilters),
+		"filters":            buildFilters(options.ViewId, options.TimeFilter, options.Filters, options.KeyValueFilters),
 		"groupBy":            buildGroupBy(options.GroupBy, outputFields, outputKeyValueFields),
 		"limit":              options.Limit,
 		"offset":             options.Offset,
@@ -106,7 +107,7 @@ func (r *CloudCostManagementService) PerspectiveSummaryWithBudget(ctx context.Co
 		"variables":     variables,
 	}
 
-	slog.Debug("PerspectiveSummaryWithBudget", "Payload", payload)
+	debugPayload("PerspectiveSummaryWithBudget", payload)
 	result := new(dto.CCMPerspectiveSummaryWithBudgetResponse)
 	err := r.Client.Post(ctx, path, nil, payload, &result)
 	if err != nil {
@@ -129,7 +130,7 @@ func (r *CloudCostManagementService) PerspectiveBudget(ctx context.Context, scop
 		"variables":     variables,
 	}
 
-	slog.Debug("PerspectiveBudget", "Payload", payload)
+	debugPayload("PerspectiveBudget", payload)
 	result := new(dto.CCMPerspectiveBudgetResponse)
 	err := r.Client.Post(ctx, path, nil, payload, &result)
 	if err != nil {
@@ -151,7 +152,7 @@ func (r *CloudCostManagementService) GetCcmMetadata(ctx context.Context, scope d
 		"variables":     variables,
 	}
 
-	slog.Debug("FetchCcmMetadata", "Payload", payload)
+	debugPayload("FetchCcmMetadata", payload)
 	result := new(dto.CCMMetadataResponse)
 	err := r.Client.Post(ctx, path, nil, payload, &result)
 	if err != nil {
@@ -160,13 +161,42 @@ func (r *CloudCostManagementService) GetCcmMetadata(ctx context.Context, scope d
 	return result, nil
 }
 
-func buildFilters(timeFilters string, idFilters dto.CCMGraphQLFilters, keyValueFilters dto.CCMGraphQLKeyValueFilters) ([]map[string]any) {
+func (r *CloudCostManagementService) PerspectiveRecommendations(ctx context.Context, scope dto.Scope, options *dto.CCMPerspectiveRecommendationsOptions) (*dto.CCMPerspectiveRecommendationsResponse, error) {
+	path := fmt.Sprintf(ccmPerspectiveGraphQLPath, options.AccountId, options.AccountId) 
+
+	gqlQuery := ccmcommons.CCMPerspectiveRecommendationsQuery
+
+	variables := map[string]any{
+		"filter": map[string]any{
+			"perspectiveFilters": buildFilters(options.ViewId, options.TimeFilter, options.Filters, options.KeyValueFilters),
+			"limit":              options.Limit,
+			"offset":             options.Offset,
+			"minSaving":     options.MinSaving, 
+			"recommendationStates": options.RecommendationStates,
+		},
+	}
+
+	payload := map[string]any{
+		"query":         gqlQuery,
+		"operationName": "PerspectiveRecommendations",
+		"variables":     variables,
+	}
+
+	debugPayload("PerspectiveRecommendations", payload)
+	result := new(dto.CCMPerspectiveRecommendationsResponse)
+	err := r.Client.Post(ctx, path, nil, payload, &result)
+	if err != nil {
+		return nil, fmt.Errorf("failed to get perspective recommendations: %w", err)
+	}
+	return result, nil
+}
+
+func buildFilters(viewId string ,timeFilters string, idFilters dto.CCMGraphQLFilters, keyValueFilters dto.CCMGraphQLKeyValueFilters) ([]map[string]any) {
 	filters := []map[string]any{}
 	viewFilter := []map[string]any{
 		{
 			"viewMetadataFilter": map[string]any{
-				//"viewId": options.ViewId,
-				"viewId": "VZf-WROOTyeczYa4FMkhYg",
+				"viewId": viewId,
 				"isPreview": false,
 			},
 		},
@@ -177,8 +207,6 @@ func buildFilters(timeFilters string, idFilters dto.CCMGraphQLFilters, keyValueF
 	filters = append(filters, buildFieldFilters(idFilters, outputFields)...)
 	filters = append(filters, buildKeyValueFieldFilters(keyValueFilters, outputKeyValueFields)...)
 
-	slog.Debug("PerspectiveGrid", "FILTERS", filters)
-
 	return filters
 }
 
@@ -470,3 +498,18 @@ func buildGroupBy(input map[string]any, outputFields []map[string]string, output
 	}
 	return defaultGroupBy 
 }
+
+func debugPayload(operation string, payload map[string]any) {
+	jsonPayload := mapToJSONString(payload)
+	slog.Debug("-----------", "----------", "--------------")
+	slog.Debug(operation, "Payload", jsonPayload)
+	slog.Debug("-----------", "----------", "--------------")
+}
+
+func mapToJSONString(m map[string]any) (string) {
+	b, err := json.MarshalIndent(m, "", "  ")
+	if err != nil {
+		return ""
+	}
+	return string(b)
+}

client/dto/ccmgraphqlperspectives.go

@@ -211,3 +211,34 @@ type CCMMetadataResponse struct {
 		CCMMetadata CCMMetadata `json:"ccmMetaData"`
 	} `json:"data"`
 }
+
+type CCMPerspectiveRecommendationsOptions struct {
+	AccountId             string `json:"account_id"`
+	ViewId                string `json:"view_id"`
+	TimeFilter            string `json:"time_filter"`
+	Limit                 int32  `json:"limit"`
+	Offset                int32  `json:"offset"`
+	MinSaving int 		`json:"min_saving"`
+	Filters CCMGraphQLFilters 
+	KeyValueFilters CCMGraphQLKeyValueFilters
+	RecommendationStates []string
+}
+
+type CCMRecommendationStatsV2 struct {
+	TotalMonthlyCost   float64 `json:"totalMonthlyCost"`
+	TotalMonthlySaving float64 `json:"totalMonthlySaving"`
+	Count              int     `json:"count"`
+	Typename           string  `json:"__typename"`
+}
+
+type CCMRecommendationsV2 struct {
+	Items    []any  `json:"items"`
+	Typename string `json:"__typename"`
+}
+
+type CCMPerspectiveRecommendationsResponse struct {
+	Data struct {
+		RecommendationStatsV2 CCMRecommendationStatsV2 `json:"recommendationStatsV2"`
+		RecommendationsV2     CCMRecommendationsV2     `json:"recommendationsV2"`
+	} `json:"data"`
+}

pkg/ccmcommons/ccmconstants.go

@@ -23,6 +23,13 @@ Query detailed time series perspective data in Harness Cloud Cost Management.
 var CCMPerspectiveSummaryWithBudgetDescription = `
 Query detailed time series perspective data in Harness Cloud Cost Management.
 `
+var CCMGetCcmMetadataDescription = `
+Get metadata about available cloud connectors, cost data sources, default perspectives, and currency preferences in Harness Cloud Cost Management.
+`
+
+var CCMPerspectiveRecommendationsDescription = `
+Returns monthly cost, savings, and a list of open recommendations for a perspective in Harness Cloud Cost Management.
+`
 
 var commonFilterDesc = `It is applied using LIKE operator in an array. Example: ["value1", "value2", ...]`
 var CCMFilterFields = []map[string]string{