[MCP] Introduce Crashlytics MCP tool list_top_issues. (firebase#8570)

Author: visumickey

src/api.ts

@@ -127,6 +127,8 @@ export const remoteConfigApiOrigin = () =>
   utils.envOverride("FIREBASE_REMOTE_CONFIG_URL", "https://firebaseremoteconfig.googleapis.com");
 export const messagingApiOrigin = () =>
   utils.envOverride("FIREBASE_MESSAGING_CONFIG_URL", "https://fcm.googleapis.com");
+export const crashlyticsApiOrigin = () =>
+  utils.envOverride("FIREBASE_CRASHLYTICS_URL", "https://firebasecrashlytics.googleapis.com");
 export const resourceManagerOrigin = () =>
   utils.envOverride("FIREBASE_RESOURCEMANAGER_URL", "https://cloudresourcemanager.googleapis.com");
 export const rulesOrigin = () =>

src/crashlytics/listTopIssues.ts

@@ -0,0 +1,53 @@
+import { Client } from "../apiv2";
+import { logger } from "../logger";
+import { FirebaseError } from "../error";
+import { crashlyticsApiOrigin } from "../api";
+
+const TIMEOUT = 10000;
+
+const apiClient = new Client({
+  urlPrefix: crashlyticsApiOrigin(),
+  apiVersion: "v1alpha",
+});
+
+export async function listTopIssues(
+  projectId: string,
+  appId: string,
+  issueCount: number,
+): Promise<string> {
+  try {
+    const queryParams = new URLSearchParams();
+    queryParams.set("page_size", `${issueCount}`);
+
+    const requestProjectId = parseProjectId(appId);
+    if (requestProjectId === undefined) {
+      throw new FirebaseError("Unable to get the projectId from the AppId.");
+    }
+
+    const response = await apiClient.request<void, string>({
+      method: "GET",
+      headers: {
+        "Content-Type": "application/json",
+      },
+      path: `/projects/${requestProjectId}/apps/${appId}/reports/topIssues`,
+      queryParams: queryParams,
+      timeout: TIMEOUT,
+    });
+
+    return response.body;
+  } catch (err: any) {
+    logger.debug(err.message);
+    throw new FirebaseError(
+      `Failed to fetch the top issues for the Firebase Project ${projectId}, AppId ${appId}. Error: ${err}.`,
+      { original: err },
+    );
+  }
+}
+
+function parseProjectId(appId: string): string | undefined {
+  const appIdParts = appId.split(":");
+  if (appIdParts.length > 1) {
+    return appIdParts[1];
+  }
+  return undefined;
+}

src/mcp/tools/crashlytics/index.ts

@@ -0,0 +1,4 @@
+import type { ServerTool } from "../../tool.js";
+import { list_top_issues } from "./list_top_issues.js";
+
+export const crashlyticsTools: ServerTool[] = [list_top_issues];

src/mcp/tools/crashlytics/list_top_issues.ts

@@ -0,0 +1,38 @@
+import { z } from "zod";
+import { tool } from "../../tool.js";
+import { mcpError, toContent } from "../../util.js";
+import { listTopIssues } from "../../../crashlytics/listTopIssues.js";
+
+export const list_top_issues = tool(
+  {
+    name: "list_top_issues",
+    description: "List the top crashes from crashlytics happening in the application.",
+    inputSchema: z.object({
+      app_id: z
+        .string()
+        .optional()
+        .describe(
+          "AppId for which the issues list is fetched. Defaults to the first appId provided by firebase_list_apps.",
+        ),
+      issue_count: z
+        .number()
+        .optional()
+        .describe("Number of issues that needs to be fetched. Defaults to 10 if unspecified."),
+    }),
+    annotations: {
+      title: "List Top Crashlytics Issues.",
+      readOnlyHint: true,
+    },
+    _meta: {
+      requiresAuth: true,
+      requiresProject: true,
+    },
+  },
+  async ({ app_id, issue_count }, { projectId }) => {
+    if (!app_id) return mcpError(`Must specify 'app_id' parameter.`);
+
+    issue_count ??= 10;
+
+    return toContent(await listTopIssues(projectId!, app_id, issue_count));
+  },
+);

src/mcp/tools/index.ts

@@ -7,6 +7,7 @@ import { coreTools } from "./core/index.js";
 import { storageTools } from "./storage/index.js";
 import { messagingTools } from "./messaging/index.js";
 import { remoteConfigTools } from "./remoteconfig/index.js";
+import { crashlyticsTools } from "./crashlytics/index.js";
 
 /** availableTools returns the list of MCP tools available given the server flags */
 export function availableTools(activeFeatures?: ServerFeature[]): ServerTool[] {
@@ -28,6 +29,7 @@ const tools: Record<ServerFeature, ServerTool[]> = {
   storage: addFeaturePrefix("storage", storageTools),
   messaging: addFeaturePrefix("messaging", messagingTools),
   remoteconfig: addFeaturePrefix("remoteconfig", remoteConfigTools),
+  crashlytics: addFeaturePrefix("crashlytics", crashlyticsTools),
 };
 
 function addFeaturePrefix(feature: string, tools: ServerTool[]): ServerTool[] {

src/mcp/types.ts

@@ -5,6 +5,7 @@ export const SERVER_FEATURES = [
   "auth",
   "messaging",
   "remoteconfig",
+  "crashlytics",
 ] as const;
 export type ServerFeature = (typeof SERVER_FEATURES)[number];
 

src/mcp/util.ts

@@ -10,6 +10,7 @@ import {
   messagingApiOrigin,
   remoteConfigApiOrigin,
   storageOrigin,
+  crashlyticsApiOrigin,
 } from "../api";
 import { check } from "../ensureApiEnabled";
 
@@ -85,6 +86,7 @@ const SERVER_FEATURE_APIS: Record<ServerFeature, string> = {
   auth: authManagementOrigin(),
   messaging: messagingApiOrigin(),
   remoteconfig: remoteConfigApiOrigin(),
+  crashlytics: crashlyticsApiOrigin(),
 };
 
 /**