371 lines
9.3 KiB
Markdown
371 lines
9.3 KiB
Markdown
# CopilotKit v2 Runtime API Reference
|
|
|
|
Package: `@copilotkit/runtime/v2` (`createCopilotExpressHandler` from `@copilotkit/runtime/v2/express`)
|
|
|
|
---
|
|
|
|
## Runtime Classes
|
|
|
|
### CopilotRuntime
|
|
|
|
Compatibility shim that auto-detects the mode based on whether `intelligence` is provided. Delegates to `CopilotSseRuntime` or `CopilotIntelligenceRuntime`.
|
|
|
|
```ts
|
|
import { CopilotRuntime } from "@copilotkit/runtime/v2";
|
|
|
|
const runtime = new CopilotRuntime({
|
|
agents: { myAgent: new LangGraphAgent({ ... }) },
|
|
// If intelligence is provided, uses Intelligence mode; otherwise SSE mode
|
|
});
|
|
```
|
|
|
|
### CopilotSseRuntime
|
|
|
|
Explicit SSE-mode runtime. Agents run in-memory via `InMemoryAgentRunner`.
|
|
|
|
```ts
|
|
import { CopilotSseRuntime } from "@copilotkit/runtime/v2";
|
|
|
|
const runtime = new CopilotSseRuntime({
|
|
agents: { myAgent: agent },
|
|
runner?: AgentRunner, // default: InMemoryAgentRunner
|
|
});
|
|
```
|
|
|
|
### CopilotIntelligenceRuntime
|
|
|
|
Intelligence-mode runtime with durable threads, realtime events, and persistent state.
|
|
|
|
```ts
|
|
import {
|
|
CopilotIntelligenceRuntime,
|
|
CopilotKitIntelligence,
|
|
} from "@copilotkit/runtime/v2";
|
|
|
|
const runtime = new CopilotIntelligenceRuntime({
|
|
agents: { myAgent: agent },
|
|
intelligence: new CopilotKitIntelligence({ ... }),
|
|
identifyUser: async (request) => ({
|
|
id: getUserIdFromRequest(request),
|
|
name: getUserNameFromRequest(request),
|
|
}),
|
|
generateThreadNames?: boolean, // default: true
|
|
});
|
|
```
|
|
|
|
---
|
|
|
|
## Runtime Options
|
|
|
|
All runtime constructors accept these base options:
|
|
|
|
```ts
|
|
interface BaseCopilotRuntimeOptions {
|
|
// Map of available agents. Can be a promise for lazy loading.
|
|
agents: MaybePromise<Record<string, AbstractAgent>>;
|
|
|
|
// Optional transcription service for audio processing
|
|
transcriptionService?: TranscriptionService;
|
|
|
|
// Middleware hooks
|
|
beforeRequestMiddleware?: BeforeRequestMiddleware;
|
|
afterRequestMiddleware?: AfterRequestMiddleware;
|
|
|
|
// Auto-apply A2UI middleware to agents
|
|
a2ui?: {
|
|
agents?: string[]; // Limit to specific agents; omit for all
|
|
// ... A2UIMiddlewareConfig from @ag-ui/a2ui-middleware
|
|
};
|
|
|
|
// Auto-apply MCP Apps middleware
|
|
mcpApps?: {
|
|
servers: McpAppsServerConfig[];
|
|
};
|
|
}
|
|
```
|
|
|
|
### McpAppsServerConfig
|
|
|
|
```ts
|
|
type McpAppsServerConfig = MCPClientConfig & {
|
|
agentId?: string; // Bind to specific agent; omit for all agents
|
|
};
|
|
```
|
|
|
|
---
|
|
|
|
## Endpoint Factories
|
|
|
|
### createCopilotHonoHandler (Hono)
|
|
|
|
```ts
|
|
import { createCopilotHonoHandler } from "@copilotkit/runtime/v2";
|
|
|
|
const app = createCopilotHonoHandler({
|
|
runtime: CopilotRuntimeLike,
|
|
basePath: string,
|
|
mode?: "multi-route" | "single-route", // default: "multi-route"
|
|
cors?: {
|
|
origin: string | string[] | ((origin: string) => string | null);
|
|
credentials?: boolean;
|
|
},
|
|
});
|
|
```
|
|
|
|
Returns a Hono app instance with all CopilotKit routes mounted under `basePath`. Defaults to multi-route mode; pass `mode: "single-route"` to expose a single combined route.
|
|
|
|
### createCopilotExpressHandler (Express)
|
|
|
|
```ts
|
|
import { createCopilotExpressHandler } from "@copilotkit/runtime/v2/express";
|
|
|
|
const router = createCopilotExpressHandler({
|
|
runtime: CopilotRuntimeLike,
|
|
basePath: string,
|
|
mode?: "multi-route" | "single-route", // default: "multi-route"
|
|
});
|
|
|
|
// Use in Express app:
|
|
app.use(router);
|
|
```
|
|
|
|
Returns an Express `Router` with all CopilotKit routes mounted under `basePath`.
|
|
|
|
---
|
|
|
|
## HTTP Routes
|
|
|
|
Both endpoint factories create these routes under `basePath`:
|
|
|
|
| Method | Path | Description |
|
|
| -------- | -------------------------------- | ------------------------------------------------------------ |
|
|
| `GET` | `/info` | Runtime info: available agents, mode, capabilities |
|
|
| `POST` | `/agent/:agentId/run` | Run an agent (SSE stream response) |
|
|
| `POST` | `/agent/:agentId/connect` | Connect to an agent (initial handshake for existing threads) |
|
|
| `POST` | `/agent/:agentId/stop/:threadId` | Stop a running agent |
|
|
| `POST` | `/transcribe` | Transcribe audio file |
|
|
| `GET` | `/threads` | List threads (Intelligence mode) |
|
|
| `POST` | `/threads/subscribe` | Subscribe to thread updates (Intelligence mode) |
|
|
| `PATCH` | `/threads/:threadId` | Update thread metadata |
|
|
| `POST` | `/threads/:threadId/archive` | Archive a thread |
|
|
| `DELETE` | `/threads/:threadId` | Permanently delete a thread |
|
|
|
|
---
|
|
|
|
## Middleware
|
|
|
|
### BeforeRequestMiddleware
|
|
|
|
Called before each request handler. Can modify or replace the request.
|
|
|
|
```ts
|
|
type BeforeRequestMiddleware = (params: {
|
|
runtime: CopilotRuntimeLike;
|
|
request: Request;
|
|
path: string;
|
|
}) => MaybePromise<Request | void>;
|
|
```
|
|
|
|
If a `Request` is returned, it replaces the original request for the handler.
|
|
|
|
### AfterRequestMiddleware
|
|
|
|
Called after each request handler. Receives the response and parsed SSE messages.
|
|
|
|
```ts
|
|
type AfterRequestMiddleware = (params: {
|
|
runtime: CopilotRuntimeLike;
|
|
response: Response;
|
|
path: string;
|
|
messages?: Message[]; // Reconstructed from SSE stream
|
|
threadId?: string; // From RUN_STARTED event
|
|
runId?: string; // From RUN_STARTED event
|
|
}) => MaybePromise<void>;
|
|
```
|
|
|
|
### Example
|
|
|
|
```ts
|
|
const runtime = new CopilotRuntime({
|
|
agents: { myAgent: agent },
|
|
beforeRequestMiddleware: async ({ request, path }) => {
|
|
console.log(`Incoming request to ${path}`);
|
|
// Optionally return a modified Request
|
|
},
|
|
afterRequestMiddleware: async ({ response, path, threadId, messages }) => {
|
|
console.log(
|
|
`Response from ${path}, thread: ${threadId}, ${messages?.length} messages`,
|
|
);
|
|
},
|
|
});
|
|
```
|
|
|
|
---
|
|
|
|
## Intelligence Platform
|
|
|
|
### CopilotKitIntelligence
|
|
|
|
Client for the CopilotKit Intelligence platform (durable threads, realtime WebSocket).
|
|
|
|
```ts
|
|
import { CopilotKitIntelligence } from "@copilotkit/runtime/v2";
|
|
|
|
const intelligence = new CopilotKitIntelligence({
|
|
// Configuration for the Intelligence platform
|
|
// (API keys, URLs, etc.)
|
|
});
|
|
```
|
|
|
|
### identifyUser
|
|
|
|
Required for Intelligence mode. Resolves the authenticated user from the incoming request.
|
|
|
|
```ts
|
|
type IdentifyUserCallback = (
|
|
request: Request,
|
|
) => MaybePromise<{ id: string; name: string }>;
|
|
```
|
|
|
|
### Thread Management Types
|
|
|
|
```ts
|
|
interface CreateThreadRequest {
|
|
/* platform-specific */
|
|
}
|
|
interface ThreadSummary {
|
|
/* id, name, timestamps */
|
|
}
|
|
interface ListThreadsResponse {
|
|
/* thread list */
|
|
}
|
|
interface UpdateThreadRequest {
|
|
/* name updates */
|
|
}
|
|
interface SubscribeToThreadsRequest {
|
|
/* WebSocket subscription params */
|
|
}
|
|
interface SubscribeToThreadsResponse {
|
|
/* realtime thread updates */
|
|
}
|
|
```
|
|
|
|
---
|
|
|
|
## Agent Runners
|
|
|
|
### AgentRunner (abstract)
|
|
|
|
Base class for executing agents. Custom runners can be implemented for custom execution environments.
|
|
|
|
### InMemoryAgentRunner
|
|
|
|
Default runner for SSE mode. Runs agents in the Node.js process.
|
|
|
|
### IntelligenceAgentRunner
|
|
|
|
Runner for Intelligence mode. Delegates execution to the Intelligence platform via WebSocket.
|
|
|
|
---
|
|
|
|
## Transcription Service
|
|
|
|
### TranscriptionService (abstract)
|
|
|
|
```ts
|
|
interface TranscribeFileOptions {
|
|
audioFile: File;
|
|
mimeType?: string;
|
|
size?: number;
|
|
}
|
|
|
|
abstract class TranscriptionService {
|
|
abstract transcribeFile(options: TranscribeFileOptions): Promise<string>;
|
|
}
|
|
```
|
|
|
|
Implement this class to provide audio-to-text transcription. The runtime exposes it via the `/transcribe` endpoint.
|
|
|
|
---
|
|
|
|
## CORS Configuration
|
|
|
|
The Hono endpoint factory accepts explicit CORS configuration:
|
|
|
|
```ts
|
|
createCopilotHonoHandler({
|
|
runtime,
|
|
basePath: "/api/copilotkit",
|
|
cors: {
|
|
origin: "https://myapp.com", // or array, or function
|
|
credentials: true, // for HTTP-only cookies
|
|
},
|
|
});
|
|
```
|
|
|
|
When `credentials` is `true`, `origin` must be explicitly specified (cannot be `"*"`).
|
|
|
|
The Express endpoint factory uses `cors({ origin: "*" })` by default. Override by wrapping or configuring the Express cors middleware separately.
|
|
|
|
---
|
|
|
|
## Complete Example: Next.js API Route (using Hono)
|
|
|
|
```ts
|
|
// app/api/copilotkit/[[...path]]/route.ts
|
|
import {
|
|
CopilotRuntime,
|
|
createCopilotHonoHandler,
|
|
} from "@copilotkit/runtime/v2";
|
|
import { LangGraphAgent } from "@copilotkit/runtime/langgraph";
|
|
import { handle } from "hono/vercel";
|
|
|
|
const runtime = new CopilotRuntime({
|
|
agents: {
|
|
researcher: new LangGraphAgent({
|
|
graphId: "researcher",
|
|
deploymentUrl: process.env.LANGGRAPH_URL!,
|
|
}),
|
|
},
|
|
});
|
|
|
|
const app = createCopilotHonoHandler({
|
|
runtime,
|
|
basePath: "/api/copilotkit",
|
|
});
|
|
|
|
export const GET = handle(app);
|
|
export const POST = handle(app);
|
|
export const PATCH = handle(app);
|
|
export const DELETE = handle(app);
|
|
```
|
|
|
|
## Complete Example: Express
|
|
|
|
```ts
|
|
import express from "express";
|
|
import { CopilotRuntime } from "@copilotkit/runtime/v2";
|
|
import { createCopilotExpressHandler } from "@copilotkit/runtime/v2/express";
|
|
import { LangGraphAgent } from "@copilotkit/runtime/langgraph";
|
|
|
|
const app = express();
|
|
|
|
const runtime = new CopilotRuntime({
|
|
agents: {
|
|
researcher: new LangGraphAgent({
|
|
graphId: "researcher",
|
|
deploymentUrl: process.env.LANGGRAPH_URL!,
|
|
}),
|
|
},
|
|
});
|
|
|
|
app.use(
|
|
createCopilotExpressHandler({
|
|
runtime,
|
|
basePath: "/api/copilotkit",
|
|
}),
|
|
);
|
|
|
|
app.listen(3000);
|
|
```
|