MCP-Server

import { createMcpSearchServer } from '@processcube-io/knowledge-sdk/mcp/server';
 
const mcp = await createMcpSearchServer(store, {
  name: 'my-docs',
  version: '1.0.0',
  baseUrl: 'https://docs.example.com',
  collectionDescriptions: {
    docs: 'Hauptdokumentation',
    blog: 'Blog-Artikel und Tutorials',
  },
  searchToolDescription: 'Durchsucht die Projekt-Dokumentation.',
  listCollectionsToolDescription: 'Listet alle verfuegbaren Collections auf.',
});

await startServer(store, {
  port: 3001,
  mcp: {
    name: 'my-docs',
    baseUrl: 'https://docs.example.com',
    collectionDescriptions: { docs: 'Dokumentation' },
  },
});
// POST /api/mcp → MCP-Endpoint

// app/api/mcp/route.ts
import { createMcpSearchServer } from '@processcube-io/knowledge-sdk/mcp/server';
import { WebStandardStreamableHTTPServerTransport } from '@modelcontextprotocol/sdk/server/webStandardStreamableHttp.js';
 
export async function POST(req: Request) {
  const mcp = await createMcpSearchServer(store, { name: 'my-docs' });
  const transport = new WebStandardStreamableHTTPServerTransport({
    sessionIdGenerator: undefined,
    enableJsonResponse: true,
  });
  await mcp.connect(transport);
  try {
    return await transport.handleRequest(req);
  } finally {
    await transport.close();
    await mcp.close();
  }
}