chore(mcp): Add telemetry for client connections.

src/mcp/index.ts

@@ -32,20 +32,31 @@
   activeFeatures?: ServerFeature[];
   detectedFeatures?: ServerFeature[];
   fixedRoot?: boolean;
+  clientInfo?: { name?: string; version?: string };
 
   constructor(options: { activeFeatures?: ServerFeature[]; projectRoot?: string }) {
     this.activeFeatures = options.activeFeatures;
     this.server = new Server({ name: "firebase", version: SERVER_VERSION });
     this.server.registerCapabilities({ tools: { listChanged: true } });
     this.server.setRequestHandler(ListToolsRequestSchema, this.mcpListTools.bind(this));
     this.server.setRequestHandler(CallToolRequestSchema, this.mcpCallTool.bind(this));
+    this.server.oninitialized = () => {
+      const clientInfo = this.server.getClientVersion();
+      this.clientInfo = clientInfo;
+      if (clientInfo?.name) {
+        trackGA4("mcp_client_connected", {
+          mcp_client_name: clientInfo.name,
+          mcp_client_version: clientInfo.version,
+        });
+      }
+    };
     this.projectRoot =
       options.projectRoot ??
       (configstore.get(PROJECT_ROOT_KEY) as string) ??
       process.env.PROJECT_ROOT ??
       process.cwd();
     if (options.projectRoot) this.fixedRoot = true;
     this.detectActiveFeatures();
   }
 
   async detectActiveFeatures(): Promise<ServerFeature[]> {
@@ -108,7 +119,10 @@
   async mcpListTools(): Promise<ListToolsResult> {
     if (!this.activeFeatures) await this.detectActiveFeatures();
     const hasActiveProject = !!(await this.getProjectId());
-    await trackGA4("mcp_list_tools", {});
+    await trackGA4("mcp_list_tools", {
+      mcp_client_name: this.clientInfo?.name,
+      mcp_client_version: this.clientInfo?.version,
+    });
     return {
       tools: this.availableTools.map((t) => t.mcp),
       _meta: {
@@ -142,10 +156,20 @@
     };
     try {
       const res = await tool.fn(toolArgs, toolsCtx);
-      await trackGA4("mcp_tool_call", { tool_name: toolName, error: res.isError ? 1 : 0 });
+      await trackGA4("mcp_tool_call", {
+        tool_name: toolName,
+        error: res.isError ? 1 : 0,
+        mcp_client_name: this.clientInfo?.name,
+        mcp_client_version: this.clientInfo?.version,
+      });
       return res;
     } catch (err: unknown) {
-      await trackGA4("mcp_tool_call", { tool_name: toolName, error: 1 });
+      await trackGA4("mcp_tool_call", {
+        tool_name: toolName,
+        error: 1,
+        mcp_client_name: this.clientInfo?.name,
+        mcp_client_version: this.clientInfo?.version,
+      });
       return mcpError(err);
     }
   }

src/track.ts

@@ -4,7 +4,7 @@
 
 import { configstore } from "./configstore";
 import { logger } from "./logger";
 const pkg = require("../package.json");
 
 type cliEventNames =
   | "command_execution"
@@ -20,7 +20,8 @@
   | "codebase_deploy"
   | "function_deploy_group"
   | "mcp_tool_call"
-  | "mcp_list_tools";
+  | "mcp_list_tools"
+  | "mcp_client_connected";
 type GA4Property = "cli" | "emulator" | "vscode";
 interface GA4Info {
   measurementId: string;
@@ -68,7 +69,7 @@
     value: process.version,
   },
   cli_version: {
     value: pkg.version,
   },
   firepit_version: {
     value: process.env.FIREPIT_VERSION || "none",
@@ -106,10 +107,10 @@
   [key: string]: string | number | undefined;
 }
 
 export async function trackGA4(
   eventName: cliEventNames,
   params: AnalyticsParams,
   duration: number = 1, // Default to 1ms duration so that events show up in realtime view.
 ): Promise<void> {
   const session = cliSession();
   if (!session) {
@@ -125,7 +126,7 @@
 }
 
 /**
  * Record an emulator-related event for Analytics.
  *
  * @param eventName the event name in snake_case. (Formal requirement:
  *                  length <= 40, alpha-numeric characters and underscores only
@@ -159,7 +160,7 @@
 }
 
 /**
  * Record a vscode-related event for Analytics.
  *
  * @param eventName the event name in snake_case. (Formal requirement:
  *                  length <= 40, alpha-numeric characters and underscores only