Function methodAttrs

apps/cloud/src/mcp/telemetry.ts:163–213

(envelope: JsonRpcEnvelope)

};

const methodAttrs = (envelope: JsonRpcEnvelope): Record<string, unknown> => {
  const params = envelope.params ?? {};
  return Match.value(envelope.method).pipe(
    Match.when("initialize", () =>
      Option.match(decodeInitializeParams(params), {
        onNone: () => ({}) as Record<string, unknown>,
        onSome: (init) => ({
          ...(init.protocolVersion && { "mcp.client.protocol_version": init.protocolVersion }),
          ...(init.clientInfo?.name && { "mcp.client.name": init.clientInfo.name }),
          ...(init.clientInfo?.version && { "mcp.client.version": init.clientInfo.version }),
          ...(init.clientInfo?.title && { "mcp.client.title": init.clientInfo.title }),
          "mcp.client.capability.keys": Object.keys(init.capabilities ?? {})
            .sort()
            .join(","),
        }),
      }),
    ),
    Match.when("tools/call", () =>
      Option.match(decodeNamedParams(params), {
        onNone: () => ({}) as Record<string, unknown>,
        onSome: ({ name, arguments: args }) => ({
          ...(name ? { "mcp.tool.name": name } : {}),
          ...executeCodeAttrs(name, args),
        }),
      }),
    ),
    Match.whenOr("resources/read", "resources/subscribe", () =>
      Option.match(decodeUriParams(params), {
        onNone: () => ({}) as Record<string, unknown>,
        onSome: ({ uri }) => (uri ? { "mcp.resource.uri": uri } : {}),
      }),
    ),
    Match.when("prompts/get", () =>
      Option.match(decodeNamedParams(params), {
        onNone: () => ({}) as Record<string, unknown>,
        onSome: ({ name }) => (name ? { "mcp.prompt.name": name } : {}),
      }),
    ),
    Match.when("notifications/cancelled", () =>
      Option.match(decodeCancelledParams(params), {
        onNone: () => ({}) as Record<string, unknown>,
        onSome: ({ requestId, reason }) => ({
          ...(requestId !== undefined && { "mcp.rpc.cancelled_id": String(requestId) }),
          ...(reason && { "mcp.rpc.cancelled_reason": reason }),
        }),
      }),
    ),
    Match.option,
    Option.getOrElse(() => ({}) as Record<string, unknown>),
  );
};

const replyAttrs = (envelope: JsonRpcEnvelope): Record<string, unknown> => {
  if (!envelope.result || envelope.method) return {};