aaronrene / knowtation public
http-server.mjs
53 lines 1.9 KB
Raw
sha256:b5f647cb9c409f563d4671fe3fc05ddea01fabfed9b41fc11cb923588e1c1baf mirror: GitHub Phase A durable MCP OAuth (#270) Human minor ⚠ breaking 11 days ago
1 /**
2 * Knowtation MCP — Streamable HTTP (Issue #1 Phase D1).
3 * One McpServer + transport per session (Mcp-Session-Id). No vault file watcher (multi-session).
4 */
5
6 import '../lib/load-env.mjs';
7 import { randomUUID } from 'node:crypto';
8 import { createMcpExpressApp } from '@modelcontextprotocol/sdk/server/express.js';
9 import { StreamableHTTPServerTransport } from '@modelcontextprotocol/sdk/server/streamableHttp.js';
10 import { loadConfig } from '../lib/config.mjs';
11 import { createKnowtationMcpServer } from './create-server.mjs';
12
13 /** @type {Map<string, import('@modelcontextprotocol/sdk/server/streamableHttp.js').StreamableHTTPServerTransport>} */
14 const transports = new Map();
15
16 function resolveListen() {
17 try {
18 const c = loadConfig();
19 return { host: c.mcp.http_host, port: c.mcp.http_port };
20 } catch {
21 const p = parseInt(process.env.KNOWTATION_MCP_HTTP_PORT || '3334', 10);
22 return { host: '127.0.0.1', port: Number.isFinite(p) ? p : 3334 };
23 }
24 }
25
26 export async function startKnowtationMcpHttp() {
27 const { host, port } = resolveListen();
28 const app = createMcpExpressApp({ host });
29
30 app.all('/mcp', async (req, res) => {
31 const sessionHeader = req.headers['mcp-session-id'];
32 let transport = sessionHeader ? transports.get(String(sessionHeader)) : undefined;
33 if (!transport) {
34 transport = new StreamableHTTPServerTransport({
35 sessionIdGenerator: () => randomUUID(),
36 onsessioninitialized: (id) => {
37 transports.set(id, transport);
38 },
39 });
40 const mcp = createKnowtationMcpServer();
41 await mcp.connect(transport);
42 }
43 await transport.handleRequest(req, res, req.body);
44 });
45
46 return new Promise((resolve, reject) => {
47 const srv = app.listen(port, host, () => {
48 console.error(`Knowtation MCP (Streamable HTTP) http://${host}:${port}/mcp`);
49 resolve(srv);
50 });
51 srv.on('error', reject);
52 });
53 }
File History 4 commits
sha256:b5f647cb9c409f563d4671fe3fc05ddea01fabfed9b41fc11cb923588e1c1baf mirror: GitHub Phase A durable MCP OAuth (#270) Human minor ⚠ 11 days ago
sha256:d8c648b20a4d53b2673c5c082ee7edfa7b2fc9b11080832da1f38807b6bf940b fix(7C-L1b): route hosted delegation proposals through cani… Human minor ⚠ 31 days ago
sha256:2827ba9e7632a4b141c50caf1e8f7d77abbc3515be20e7465f2bccb0ac4edf91 fix: repair endpoint now sets has_active_subscription when … Human minor ⚠ 51 days ago
sha256:6a102aafafdfe7e70a24f4e59740200f0ee713ce7915f1b53e9d4ba5ee8b4410 Initial Muse snapshot Human 83 days ago