البروتوكول الذي يجعل وكلاء الذكاء الاصطناعي جاهزين للمؤسسات.

// ohy-crm-mcp-server/index.ts
import { Server } from "@modelcontextprotocol/sdk/server/index.js"
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js"
import { CallToolRequestSchema, ListToolsRequestSchema } from "@modelcontextprotocol/sdk/types.js"

const server = new Server(
  { name: "ohy-crm-server", version: "1.0.0" },
  { capabilities: { tools: {} } }
)

server.setRequestHandler(ListToolsRequestSchema, async () => ({
  tools: [
    {
      name: "get_lead",
      description: "Retrieve a qualified lead from the CRM pipeline",
      inputSchema: {
        type: "object",
        required: ["leadId"],
        properties: {
          leadId:        { type: "string", description: "CRM lead identifier" },
          includeHistory:{ type: "boolean", default: false },
        },
      },
    },
    {
      name: "update_deal_stage",
      description: "Move a deal to a new pipeline stage with audit trail",
      inputSchema: {
        type: "object",
        required: ["dealId", "stage"],
        properties: {
          dealId: { type: "string" },
          stage:  { type: "string", enum: ["prospecting", "qualified", "proposal", "closed_won"] },
          note:   { type: "string" },
        },
      },
    },
  ],
}))

server.setRequestHandler(CallToolRequestSchema, async (req) => {
  const { name, arguments: args } = req.params

  if (name === "get_lead") {
    const lead = await crm.getLead(args.leadId, { history: args.includeHistory })
    return { content: [{ type: "text", text: JSON.stringify(lead, null, 2) }] }
  }

  if (name === "update_deal_stage") {
    await crm.moveDeal(args.dealId, args.stage, args.note)
    await auditLog.record({ action: "deal.stage_update", ...args, agent: "layla" })
    return { content: [{ type: "text", text: "Deal updated successfully" }] }
  }
})

const transport = new StdioServerTransport()
await server.connect(transport)