MakeSync MCP Server

// src/index.ts import { Server } from "@modelcontextprotocol/sdk/server/index.js"; import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js"; import { CallToolRequestSchema, ListToolsRequestSchema, ToolSchema, } from "@modelcontextprotocol/sdk/types.js"; import { z } from "zod"; import { zodToJsonSchema } from "zod-to-json-schema"; const MAKE_API_KEY = process.env.MAKE_DOT_COM_API_KEY!; const MAKE_BASE_URL = process.env.MAKE_DOT_COM_BASE_URL || "eu2.make.com"; const MAKE_TEAM_ID = process.env.MAKE_DOT_COM_TEAM_ID; if (!MAKE_API_KEY || !MAKE_TEAM_ID) { throw new Error("Missing Make.com credentials or team ID"); } function makeHeaders() { return { Authorization: `Token ${MAKE_API_KEY}`, "Content-Type": "application/json", Accept: "application/json", }; } // ========== Zod Schemas ========== const ScenarioIdSchema = z.object({ scenario_id: z.number(), draft: z.boolean().optional().default(false), }); const CreateScenarioSchema = z.object({ name: z.string(), folderId: z.number().optional(), description: z.string().optional(), }); const UpdateScenarioSchema = z.object({ scenario_id: z.number(), name: z.string().optional(), description: z.string().optional(), }); const DescribeModuleSchema = z.object({ scenario_id: z.number(), module_id: z.number(), draft: z.boolean().optional().default(false), }); const UpdateScenarioInterfaceArgsSchema = z.object({ scenario_id: z.number(), inputs: z.array( z.object({ name: z.string(), type: z.string(), label: z.string().optional(), required: z.boolean().optional(), multiline: z.boolean().optional(), default: z.union([z.string(), z.number(), z.boolean(), z.null()]).optional(), }) ), }); const CheckModuleSchema = z.object({ scenario_id: z.number(), module_id: z.number(), draft: z.boolean().optional().default(false), }); const PatchModuleOperation = z.object({ path: z.string().describe("Dot-separated path inside module object to patch, e.g., parameters.sheetId"), value: z.string().describe("Value to apply at the given path") }); const PatchModuleToolSchema = z.object({ scenario_id: z.number(), module_id: z.number(), operations: z.array(PatchModuleOperation), draft: z.boolean().optional().default(false), }); // ========== Server ========== const server = new Server( { name: "mcp-server-make-dot-com", version: "1.0.0" }, { capabilities: { tools: {} } } ); // ========== Tool List ========== const tools = [ { name: "read_make_dot_com_scenario_blueprint", description: "Retrieve blueprint for a scenario", inputSchema: zodToJsonSchema(ScenarioIdSchema), }, { name: "create_make_dot_com_scenario", description: "Create a new Make.com scenario", inputSchema: zodToJsonSchema(CreateScenarioSchema), }, { name: "update_make_dot_com_scenario", description: "Update an existing Make.com scenario", inputSchema: zodToJsonSchema(UpdateScenarioSchema), }, { name: "describe_make_dot_com_module", description: "Describe module parameters from blueprint", inputSchema: zodToJsonSchema(DescribeModuleSchema), }, { name: "update_make_dot_com_scenario_interface", description: "Updates the input interface (form fields) for a scenario using Make's on-demand input feature.", inputSchema: zodToJsonSchema(UpdateScenarioInterfaceArgsSchema), }, { name: "check_make_dot_com_module_data", description: "Check if module required fields are filled", inputSchema: zodToJsonSchema(CheckModuleSchema), }, { name: "list_make_dot_com_scenarios", description: "List available Make.com scenarios", inputSchema: { type: "object", properties: {}, required: [] }, }, { name: "list_make_dot_com_connections", description: "List Make.com connections and their validity", inputSchema: { type: "object", properties: {}, required: [] }, }, { name: "patch_make_dot_com_module_in_blueprint", description: "Patches fields in a specific module of a Make.com scenario blueprint using dot-paths.", inputSchema: zodToJsonSchema(PatchModuleToolSchema), } ]; function applyPatch(target: any, path: string, value: any) { const keys = path.split("."); let ref = target; for (let i = 0; i < keys.length - 1; i++) { const key = keys[i]; if (!(key in ref)) ref[key] = {}; ref = ref[key]; } ref[keys[keys.length - 1]] = value; } async function patchBlueprint(scenario_id: number, blueprint: any, draft: boolean): Promise<string> { const url = `https://${MAKE_BASE_URL}/api/v2/scenarios/${scenario_id}/blueprint?teamId=${MAKE_TEAM_ID}&includeDraft=${draft}`; const body = JSON.stringify({ blueprint }); const headers = { Authorization: `Token ${MAKE_API_KEY}`, "Content-Type": "application/json", Accept: "application/json", }; // 🪵 Full verbose log console.log("---- PATCH BLUEPRINT DEBUG ----"); console.log("URL:", url); console.log("Method: PATCH"); console.log("Headers:", headers); console.log("Body:", body); console.log("CURL:\n" + [ `curl -X PATCH '${url}'`, `-H 'Authorization: Token ${MAKE_API_KEY}'`, `-H 'Content-Type: application/json'`, `-H 'Accept: application/json'`, `--data-raw '${body.replace(/'/g, `'\\''`)}'` ].join(" \\\n")); const res = await fetch(url, { method: "PATCH", headers, body, }); if (!res.ok) { const errorText = await res.text(); console.error("PATCH failed:", errorText); throw new Error(errorText); } return `✅ Blueprint updated for module(s).`; } async function getBlueprint(scenario_id: number, draft: boolean = false) { const url = `https://${MAKE_BASE_URL}/api/v2/scenarios/${scenario_id}/blueprint?includeDraft=${draft}&teamId=${MAKE_TEAM_ID}`; const res = await fetch(url, { headers: makeHeaders() }); if (!res.ok) { throw new Error(`Failed to get blueprint: ${res.status} ${res.statusText}`); } const data = await res.json(); return data.response?.blueprint || data; } async function getModule(scenario_id: number, module_id: number, draft: boolean = false) { const blueprint = await getBlueprint(scenario_id, draft); const module = blueprint.flow?.find((m: any) => m.id === module_id); if (!module) { throw new Error(`Module ${module_id} not found in blueprint`); } return module; } async function createScenario(name: string, folderId?: number, description?: string) { const res = await fetch(`https://${MAKE_BASE_URL}/api/v2/scenarios`, { method: "POST", headers: makeHeaders(), body: JSON.stringify({ name, folderId, description, teamId: MAKE_TEAM_ID }) }); if (!res.ok) { throw new Error(`Failed to create scenario: ${res.status} ${res.statusText}`); } return await res.json(); } async function updateScenario(scenario_id: number, updates: { name?: string, description?: string }) { const url = `https://${MAKE_BASE_URL}/api/v2/scenarios/${scenario_id}?teamId=${MAKE_TEAM_ID}`; const res = await fetch(url, { method: "PATCH", headers: makeHeaders(), body: JSON.stringify(updates) }); if (!res.ok) { throw new Error(`Failed to update scenario: ${res.status} ${res.statusText}`); } return await res.json(); } async function listScenarios() { const url = `https://${MAKE_BASE_URL}/api/v2/scenarios?teamId=${MAKE_TEAM_ID}`; const res = await fetch(url, { headers: makeHeaders() }); if (!res.ok) { throw new Error(`Failed to list scenarios: ${res.status} ${res.statusText}`); } return await res.json(); } async function listConnections() { const url = `https://${MAKE_BASE_URL}/api/v2/connections?teamId=${MAKE_TEAM_ID}`; const res = await fetch(url, { headers: makeHeaders() }); if (!res.ok) { throw new Error(`Failed to list connections: ${res.status} ${res.statusText}`); } return await res.json(); } async function updateScenarioInterface(scenario_id: number, inputs: any[]) { const response = await fetch( `https://${MAKE_BASE_URL}/api/v2/scenarios/${scenario_id}/interface?teamId=${MAKE_TEAM_ID}`, { method: "PATCH", headers: makeHeaders(), body: JSON.stringify({ interface: { input: inputs, }, }), } ); if (!response.ok) { throw new Error( `Make.com API error: ${response.status} ${response.statusText}\n${await response.text()}` ); } return await response.json(); } server.setRequestHandler(ListToolsRequestSchema, async () => ({ tools })); server.setRequestHandler(CallToolRequestSchema, async ({ params: { name, arguments: args } }) => { switch (name) { case "read_make_dot_com_scenario_blueprint": { const { scenario_id, draft } = ScenarioIdSchema.parse(args); const blueprint = await getBlueprint(scenario_id, draft); return { content: [{ type: "text", text: JSON.stringify(blueprint, null, 2) }] }; } case "create_make_dot_com_scenario": { const { name, folderId, description } = CreateScenarioSchema.parse(args); const result = await createScenario(name, folderId, description); return { content: [{ type: "text", text: JSON.stringify(result, null, 2) }] }; } case "update_make_dot_com_scenario": { const { scenario_id, name, description } = UpdateScenarioSchema.parse(args); const result = await updateScenario(scenario_id, { name, description }); return { content: [{ type: "text", text: JSON.stringify(result, null, 2) }] }; } case "describe_make_dot_com_module": { const { scenario_id, module_id, draft } = DescribeModuleSchema.parse(args); const module = await getModule(scenario_id, module_id, draft); return { content: [{ type: "text", text: JSON.stringify(module, null, 2) }] }; } case "update_module_parameters": { const { scenario_id, inputs } = UpdateScenarioInterfaceArgsSchema.parse(args); const data = await updateScenarioInterface(scenario_id, inputs); return { content: [ { type: "text", text: `✅ Scenario interface updated successfully. Inputs: ${data.interface?.input?.length ?? 0}`, }, ], }; } case "check_make_dot_com_module_data": { const { scenario_id, module_id, draft } = CheckModuleSchema.parse(args); const module = await getModule(scenario_id, module_id, draft); const required = module.metadata?.interface?.filter((f: any) => f.required)?.map((f: any) => f.name) || []; const filled = required.filter((name: string) => module.parameters?.[name] !== undefined); return { content: [{ type: "text", text: `${filled.length}/${required.length} required fields filled.` }] }; } case "list_make_dot_com_scenarios": { const data = await listScenarios(); const result = data?.scenarios?.map((s: any) => `• ${s.name} (ID: ${s.id})`)?.join("\n") || "No scenarios found."; return { content: [{ type: "text", text: result }] }; } case "list_make_dot_com_connections": { const data = await listConnections(); const result = data.map((c: any) => `• ${c.label || c.name} (${c.id}) ${c.valid ? "✅" : "❌"}`).join("\n"); return { content: [{ type: "text", text: result }] }; } case "patch_make_dot_com_module_in_blueprint": { const { scenario_id, module_id, operations, draft } = PatchModuleToolSchema.parse(args); const blueprint = await getBlueprint(scenario_id, draft); const module = blueprint.flow.find((m: any) => m.id === module_id); if (!module) throw new Error(`Module ${module_id} not found in blueprint`); for (const { path, value } of operations) { applyPatch(module, path, value); } const result = await patchBlueprint(scenario_id, blueprint, draft); return { content: [{ type: "text", text: result }], }; } default: throw new Error(`Unknown tool: ${name}`); } }); // Start the server (async () => { const transport = new StdioServerTransport(); await server.connect(transport); console.error("✅ Make.com MCP Server running..."); })();