Function createUnifiedMCPServer

server/src/mcp/server.ts:161–224

(authContext?: MCPAuthContext)

 * - Validation tools: Schema and adagents.json validation
 */
export function createUnifiedMCPServer(authContext?: MCPAuthContext): Server {
  const server = new Server(
    {
      name: 'addie',
      version: '1.0.0',
    },
    {
      capabilities: {
        resources: {},
        tools: {},
      },
    }
  );

  const tools = getAllTools();
  const { handlers, directoryHandler } = getHandlers();

  // List available tools
  server.setRequestHandler(ListToolsRequestSchema, async () => {
    logger.debug({ toolCount: tools.all.length }, 'MCP: Listing tools');
    return { tools: tools.all };
  });

  // Handle tool calls
  server.setRequestHandler(CallToolRequestSchema, async (request) => {
    const { name, arguments: args } = request.params;
    logger.debug({ tool: name }, 'MCP: Tool call');

    const handler = handlers.get(name);
    if (!handler) {
      logger.warn({ tool: name }, 'MCP: Unknown tool');
      return {
        content: [{ type: 'text', text: JSON.stringify({ error: `Unknown tool: ${name}` }) }],
        isError: true,
      };
    }

    try {
      const result = await handler(args as Record<string, unknown> || {}, authContext);
      return result as {
        content: Array<{ type: string; text?: string; resource?: { uri: string; mimeType: string; text: string } }>;
        isError?: boolean;
      };
    } catch (error) {
      logger.error({ error, tool: name }, 'MCP: Tool execution error');
      return {
        content: [{ type: 'text', text: JSON.stringify({ error: error instanceof Error ? error.message : 'Unknown error' }) }],
        isError: true,
      };
    }
  });

  // List available resources (from directory)
  server.setRequestHandler(ListResourcesRequestSchema, async () => {
    return { resources: RESOURCE_DEFINITIONS };
  });

  // Read resource contents (from directory)