feat: add tool call params logging

Author: yulunz

src/index.ts

@@ -254,6 +254,8 @@ export async function createMcpServer(
         } finally {
           void clearcutLogger?.logToolInvocation({
             toolName: tool.name,
+            params,
+            schema,
             success,
             latencyMs: bucketizeLatency(Date.now() - startTime),
           });

src/telemetry/ClearcutLogger.ts

@@ -207,6 +207,8 @@ export class ClearcutLogger {
 
   async logToolInvocation(args: {
     toolName: string;
+    params: ShapeOutput<zod.ZodRawShape>;
+    schema: zod.ZodRawShape;
     success: boolean;
     latencyMs: number;
   }): Promise<void> {
@@ -216,6 +218,7 @@ export class ClearcutLogger {
         mcp_client: this.#mcpClient,
         tool_invocation: {
           tool_name: args.toolName,
+          tool_params: sanitizeParams(args.params, args.schema),
           success: args.success,
           latency_ms: args.latencyMs,
         },

src/telemetry/types.ts

@@ -22,6 +22,7 @@ export interface ToolInvocation {
   tool_name: string;
   success: boolean;
   latency_ms: number;
+  tool_params?: object;
 }
 
 export interface ServerStart {

tests/telemetry/ClearcutLogger.test.ts

@@ -46,6 +46,8 @@ describe('ClearcutLogger', () => {
       });
       await logger.logToolInvocation({
         toolName: 'test_tool',
+        params: {},
+        schema: {},
         success: true,
         latencyMs: 123,
       });
@@ -57,6 +59,38 @@ describe('ClearcutLogger', () => {
       assert.strictEqual(msg.payload.tool_invocation?.success, true);
       assert.strictEqual(msg.payload.tool_invocation?.latency_ms, 123);
     });
+    it('sends sanitized params', async () => {
+      const logger = new ClearcutLogger({
+        persistence: mockPersistence,
+        appVersion: '1.0.0',
+        watchdogClient: mockWatchdogClient,
+      });
+
+      const schema = {
+        uid: zod.string(),
+        myString: zod.string(),
+      };
+
+      const params = {
+        uid: 'sensitive',
+        myString: 'hello',
+      };
+
+      await logger.logToolInvocation({
+        toolName: 'test_tool',
+        params,
+        schema,
+        success: true,
+        latencyMs: 123,
+      });
+
+      assert(mockWatchdogClient.send.calledOnce);
+      const msg = mockWatchdogClient.send.firstCall.args[0];
+      assert.strictEqual(msg.type, WatchdogMessageType.LOG_EVENT);
+      assert.deepStrictEqual(msg.payload.tool_invocation?.tool_params, {
+        my_string_length: 5,
+      });
+    });
   });
 
   describe('setClientName', () => {