/**
* 🎯 SEMANTIC INTENT: MCP Protocol Message Handler
*
* PURPOSE: Handle MCP/JSON-RPC protocol semantics
*
* APPLICATION RESPONSIBILITY:
* - Parse and validate MCP requests
* - Dispatch to appropriate handlers
* - Format responses per MCP specification
* - Maintain protocol compliance
*/
import type { ToolExecutionHandler } from './ToolExecutionHandler';
import { CORSMiddleware } from '../../infrastructure/middleware/CORSMiddleware';
// MCP tool definitions
const TOOL_DEFINITIONS = [
{
name: "save_context",
description: "Save conversation context with AI enhancement",
inputSchema: {
type: "object",
properties: {
project: { type: "string", description: "Project identifier" },
content: { type: "string", description: "Context content to save" },
source: { type: "string", description: "Source of the context", default: "mcp" },
metadata: { type: "object", description: "Additional metadata" }
},
required: ["project", "content"]
}
},
{
name: "load_context",
description: "Load relevant context for a project",
inputSchema: {
type: "object",
properties: {
project: { type: "string", description: "Project identifier" },
limit: { type: "number", description: "Maximum contexts to return", default: 1 }
},
required: ["project"]
}
},
{
name: "search_context",
description: "Search contexts using keyword matching",
inputSchema: {
type: "object",
properties: {
query: { type: "string", description: "Search query" },
project: { type: "string", description: "Project to search within" }
},
required: ["query"]
}
}
];
export class MCPProtocolHandler {
constructor(private readonly toolHandler: ToolExecutionHandler) {}
async handle(body: any): Promise<Response> {
console.log('MCP Request:', JSON.stringify(body, null, 2));
switch (body.method) {
case 'initialize':
return this.handleInitialize(body);
case 'notifications/initialized':
case 'notifications/cancelled':
return this.handleNotification();
case 'tools/list':
return this.handleToolsList(body);
case 'tools/call':
return this.handleToolsCall(body);
default:
return this.handleMethodNotFound(body);
}
}
private handleInitialize(request: any): Response {
return CORSMiddleware.jsonResponse({
jsonrpc: "2.0",
id: request.id,
result: {
protocolVersion: "2025-06-18",
capabilities: { tools: {} },
serverInfo: {
name: "Semantic Context MCP",
version: "1.0.0"
}
}
});
}
private handleNotification(): Response {
return new Response('', { status: 204 });
}
private handleToolsList(request: any): Response {
return CORSMiddleware.jsonResponse({
jsonrpc: "2.0",
id: request.id,
result: { tools: TOOL_DEFINITIONS }
});
}
private async handleToolsCall(request: any): Promise<Response> {
try {
const { name, arguments: args } = request.params;
const result = await this.toolHandler.execute(name, args);
return CORSMiddleware.jsonResponse({
jsonrpc: "2.0",
id: request.id,
result
});
} catch (error: any) {
return CORSMiddleware.jsonResponse({
jsonrpc: "2.0",
id: request.id,
error: {
code: -32000,
message: error.message
}
}, 500);
}
}
private handleMethodNotFound(request: any): Response {
return CORSMiddleware.jsonResponse({
jsonrpc: "2.0",
id: request.id,
error: {
code: -32601,
message: `Method not found: ${request.method}`
}
}, 400);
}
}
