import { Server, StdioServerTransport } from "@modelcontextprotocol/sdk/server"; const server = new Server({ name: "crm-tools", version: "1.0.0" }); server.setRequestHandler(ListToolsRequestSchema, async () => ({ tools: [{ name: "search_customer", description: "Search CRM for a customer by email or name. Use when asked about a specific customer.", inputSchema: { type: "object", properties: { query: { type: "string", description: "Email address or customer name" }, limit: { type: "number", description: "Max results to return", default: 5 } }, required: ["query"] } }] })); server.setRequestHandler(CallToolRequestSchema, async (req) => { if (req.params.name === "search_customer") { const customers = await db.query( `SELECT * FROM customers WHERE email LIKE $1 OR name LIKE $1 LIMIT $2`, [`%${req.params.arguments.query}%`, req.params.arguments.limit] ); return { content: [{ type: "text", text: JSON.stringify(customers) }] }; } }); await server.connect(new StdioServerTransport());