Skip to main content

​
createNextMcpHandler(options)

Creates handlers for Next.js App Router API routes. 
import { createNextMcpHandler } from '@mcp-ts/sdk/server';

const { GET, POST } = createNextMcpHandler({
  getIdentity: (request) => string,
  getAuthToken?: (request) => string | null,
  authenticate?: (identity, token) => Promise<boolean>,
  heartbeatInterval?: number,
});
Options:
  • getIdentity - Function to extract identity from request (required)
  • getAuthToken - Function to extract auth token from request (optional)
  • authenticate - Custom authentication logic (optional)
  • heartbeatInterval - SSE heartbeat interval in ms (default: 30000)
  • clientDefaults - Static OAuth client metadata (optional)
  • getClientMetadata - Dynamic OAuth metadata getter (optional, overrides defaults)
Returns: { GET, POST } - HTTP method handlers

​
createSSEHandler(options)

Creates an SSE handler for standard Node.js/Express applications. 
import { createSSEHandler } from '@mcp-ts/sdk/server';

const handler = createSSEHandler({
  identity: string,
  onAuth?: (identity) => Promise<boolean>,
  heartbeatInterval?: number,
});
Options:
  • identity - User/Client identifier (required)
  • onAuth - Authentication callback (optional)
  • heartbeatInterval - Heartbeat interval in ms (default: 30000)
  • clientDefaults - Static OAuth client metadata (optional)
  • getClientMetadata - Dynamic OAuth metadata getter (optional)
Returns: Request handler function

​
MCPClient

Direct MCP client class for server-side operations. 
import { MCPClient } from '@mcp-ts/sdk/server';

const client = new MCPClient({
  identity: string,
  sessionId: string,
  serverId?: string,
  serverUrl?: string,
  callbackUrl?: string,
  transportType?: 'sse' | 'streamable_http',
  onRedirect?: (authUrl: string) => void,
  // OAuth Metadata
  clientName?: string,
  clientUri?: string,
  logoUri?: string,
  policyUri?: string,
});

​
Methods

connect(): Promise<void> Connect to the MCP server. May throw UnauthorizedError if OAuth is required. 
await client.connect();
disconnect(): Promise<void> Disconnect from the MCP server. 
await client.disconnect();
listTools(): Promise<ListToolsResult> List available tools from the MCP server. 
const { tools } = await client.listTools();
callTool(name: string, args: object): Promise<CallToolResult> Call a tool with arguments. 
const result = await client.callTool('get_weather', {
  location: 'San Francisco',
});
getAITools(): Promise<ToolSet> Get all MCP tools and convert them to AI SDK compatible tools. 
const tools = await client.getAITools();
listPrompts(): Promise<ListPromptsResult> List available prompts. 
const { prompts } = await client.listPrompts();
getPrompt(name: string, args?: object): Promise<GetPromptResult> Get a prompt with optional arguments. 
const prompt = await client.getPrompt('code-review', {
  language: 'typescript',
});
listResources(): Promise<ListResourcesResult> List available resources. 
const { resources } = await client.listResources();
readResource(uri: string): Promise<ReadResourceResult> Read a specific resource by URI. 
const resource = await client.readResource('file:///path/to/file');
finishAuth(code: string): Promise<void> Complete OAuth authorization with authorization code. 
await client.finishAuth(authCode);

​
MultiSessionClient

Manages multiple MCP connections for a single user identity, allowing aggregation of tools from all connected servers. 
import { MultiSessionClient } from '@mcp-ts/sdk/server';

const mcp = new MultiSessionClient(identity, {
  timeout: 15000,
  maxRetries: 2,
  retryDelay: 1000,
});
Options:
  • timeout - Connection timeout in milliseconds (default: 15000)
  • maxRetries - Maximum number of retry attempts for each session (default: 2)
  • retryDelay - Delay between retries in milliseconds (default: 1000)

​
Methods

connect(): Promise<void> Connects to all active sessions for the user. Skips sessions that fail to connect after retries, but logs errors. 
await mcp.connect();
getClients(): MCPClient[] Returns the array of currently connected clients. 
const clients = mcp.getClients();
disconnect(): void Disconnects all active clients and clears the internal client list. 
mcp.disconnect();