refactor(runtime): rename cki → cpki and use INTELLIGENCE_USER_ID_HEADER constant

Two CR comments addressed:

- Rename the local destructure of forwardedProps.auth.copilotkitIntelligence
  from 'cki' to 'cpki' so it matches the project-wide abbreviation already
  used in metadata fields (cpki_event_id, cpki_event_seq, etc).

- Replace the inline 'X-Cpki-User-Id' string literal with the existing
  INTELLIGENCE_USER_ID_HEADER constant exported from intelligence-platform/client.
  Applies to the runtime auto-attach in agent/index.ts and to the three
  test sites in intelligence-mcp-helper.test.ts so the user-side and
  runtime-side stay in sync.

Author: mme

packages/runtime/src/agent/index.ts

@@ -51,6 +51,7 @@ import { jsonSchema as aiJsonSchema } from "ai";
 import { convertAISDKStream } from "./converters/aisdk";
 import { convertTanStackStream } from "./converters/tanstack";
 import type { StreamableHTTPClientTransportOptions } from "@modelcontextprotocol/sdk/client/streamableHttp.js";
+import { INTELLIGENCE_USER_ID_HEADER } from "../v2/runtime/intelligence-platform/client";
 import { StreamableHTTPClientTransport } from "@modelcontextprotocol/sdk/client/streamableHttp.js";
 import { SSEClientTransport } from "@modelcontextprotocol/sdk/client/sse.js";
 import { randomUUID } from "@copilotkit/shared";
@@ -1200,29 +1201,29 @@ export class BuiltInAgent extends AbstractAgent {
               | { auth?: { copilotkitIntelligence?: unknown } }
               | undefined
           )?.auth;
-          const cki = auth?.copilotkitIntelligence as
+          const cpki = auth?.copilotkitIntelligence as
             | { userId?: unknown; apiKey?: unknown; mcpUrl?: unknown }
             | undefined;
-          const ckiUserId =
-            typeof cki?.userId === "string" ? cki.userId : undefined;
-          const ckiApiKey =
-            typeof cki?.apiKey === "string" ? cki.apiKey : undefined;
-          const ckiMcpUrl =
-            typeof cki?.mcpUrl === "string" ? cki.mcpUrl : undefined;
+          const cpkiUserId =
+            typeof cpki?.userId === "string" ? cpki.userId : undefined;
+          const cpkiApiKey =
+            typeof cpki?.apiKey === "string" ? cpki.apiKey : undefined;
+          const cpkiMcpUrl =
+            typeof cpki?.mcpUrl === "string" ? cpki.mcpUrl : undefined;
           if (
-            ckiUserId &&
-            ckiApiKey &&
-            ckiMcpUrl &&
-            !allMcpServers.some((s) => s.type === "http" && s.url === ckiMcpUrl)
+            cpkiUserId &&
+            cpkiApiKey &&
+            cpkiMcpUrl &&
+            !allMcpServers.some((s) => s.type === "http" && s.url === cpkiMcpUrl)
           ) {
             allMcpServers.push({
               type: "http",
-              url: ckiMcpUrl,
+              url: cpkiMcpUrl,
               options: {
                 fetch: async (req, init) => {
                   const headers = new Headers(init?.headers);
-                  headers.set("Authorization", `Bearer ${ckiApiKey}`);
-                  headers.set("X-Cpki-User-Id", ckiUserId);
+                  headers.set("Authorization", `Bearer ${cpkiApiKey}`);
+                  headers.set(INTELLIGENCE_USER_ID_HEADER, cpkiUserId);
                   return globalThis.fetch(req, { ...init, headers });
                 },
               },

packages/runtime/src/v2/runtime/intelligence-platform/__tests__/intelligence-mcp-helper.test.ts

@@ -1,5 +1,6 @@
 import { describe, it, expect, vi, beforeEach, afterEach } from "vitest";
 import { BasicAgent } from "../../../../agent";
+import { INTELLIGENCE_USER_ID_HEADER } from "../client";
 import { LLMock, MCPMock } from "@copilotkit/aimock";
 import { streamText } from "ai";
 import {
@@ -128,7 +129,7 @@ describe("BuiltInAgent — Intelligence MCP auto-attach via forwardedProps", ()
       expect(recorder.records.length).toBeGreaterThan(0);
       for (const headers of recorder.records) {
         expect(headers["authorization"]).toBe("Bearer cpk-proj_short_long");
-        expect(headers["x-cpki-user-id"]).toBe("jordan-beamson");
+        expect(headers[INTELLIGENCE_USER_ID_HEADER]).toBe("jordan-beamson");
       }
     } finally {
       recorder.restore();
@@ -203,7 +204,7 @@ describe("BuiltInAgent — Intelligence MCP auto-attach via forwardedProps", ()
               userFetchCalls++;
               const h = new Headers(init?.headers ?? {});
               h.set("Authorization", "Bearer user-supplied");
-              h.set("X-Cpki-User-Id", "explicit-user");
+              h.set(INTELLIGENCE_USER_ID_HEADER, "explicit-user");
               return globalThis.fetch(input, { ...init, headers: h });
             },
           },
@@ -235,7 +236,7 @@ describe("BuiltInAgent — Intelligence MCP auto-attach via forwardedProps", ()
       // Only the user's fetch wrapper hit the wire — auto-attach skipped.
       for (const headers of recorder.records) {
         expect(headers["authorization"]).toBe("Bearer user-supplied");
-        expect(headers["x-cpki-user-id"]).toBe("explicit-user");
+        expect(headers[INTELLIGENCE_USER_ID_HEADER]).toBe("explicit-user");
       }
       expect(userFetchCalls).toBeGreaterThan(0);
     } finally {