Automatisch MCP Server

Instructions

Implementation Reference

• src/handlers.ts:337-345 (handler)

  MCP tool handler for 'create_connection': invokes the API helper method and formats the response as JSON text.
  case "create_connection": return { content: [ { type: "text", text: JSON.stringify(await main.api.createConnection(args), null, 2) } ] };
• src/handlers.ts:118-139 (schema)

  Input schema definition for the 'create_connection' tool, specifying required parameters: appKey, name, credentials.
  { name: "create_connection", description: "Create a new app connection", inputSchema: { type: "object", properties: { appKey: { type: "string", description: "App identifier (e.g., 'slack', 'github')" }, name: { type: "string", description: "Connection name" }, credentials: { type: "object", description: "App-specific credentials and configuration" } }, required: ["appKey", "name", "credentials"] } },
• src/api.ts:27-29 (helper)

  API helper method 'createConnection' that is called by the tool handler (currently a placeholder for the core implementation logic).
  createConnection: async function(data: any) { // ... copy createConnection logic from index.ts ... },
• src/handlers.ts:32-279 (registration)

  Registration of the CallToolRequestHandler which dispatches to specific tool cases, including 'create_connection'.
  type: "object", properties: { workflowId: { type: "string", description: "Workflow ID to retrieve" } }, required: ["workflowId"] } }, { name: "create_workflow", description: "Create a new workflow", inputSchema: { type: "object", properties: { name: { type: "string", description: "Workflow name" }, description: { type: "string", description: "Workflow description" }, active: { type: "boolean", description: "Whether workflow should be active", default: false } }, required: ["name"] } }, { name: "update_workflow", description: "Update an existing workflow", inputSchema: { type: "object", properties: { workflowId: { type: "string", description: "Workflow ID to update" }, name: { type: "string", description: "New workflow name" }, description: { type: "string", description: "New workflow description" }, active: { type: "boolean", description: "Workflow active status" } }, required: ["workflowId"] } }, { name: "delete_workflow", description: "Delete a workflow", inputSchema: { type: "object", properties: { workflowId: { type: "string", description: "Workflow ID to delete" } }, required: ["workflowId"] } }, { name: "list_connections", description: "List all app connections", inputSchema: { type: "object", properties: { appKey: { type: "string", description: "Filter by specific app" } } } }, { name: "create_connection", description: "Create a new app connection", inputSchema: { type: "object", properties: { appKey: { type: "string", description: "App identifier (e.g., 'slack', 'github')" }, name: { type: "string", description: "Connection name" }, credentials: { type: "object", description: "App-specific credentials and configuration" } }, required: ["appKey", "name", "credentials"] } }, { name: "list_executions", description: "List workflow executions", inputSchema: { type: "object", properties: { workflowId: { type: "string", description: "Filter by workflow ID" }, status: { type: "string", enum: ["success", "failure", "running"], description: "Filter by execution status" }, limit: { type: "number", description: "Limit number of results" } } } }, { name: "get_available_apps", description: "Get list of available apps and their capabilities", inputSchema: { type: "object", properties: { category: { type: "string", description: "Filter by app category" } } } }, { name: "test_workflow", description: "Test a workflow with sample data", inputSchema: { type: "object", properties: { workflowId: { type: "string", description: "Workflow ID to test" }, testData: { type: "object", description: "Sample data for testing" } }, required: ["workflowId"] } } ] }; }); // List available resources server.setRequestHandler(ListResourcesRequestSchema, async () => { return { resources: [ { uri: "automatisch://workflows", mimeType: "application/json", name: "Workflows Overview", description: "Overview of all workflows and their status" }, { uri: "automatisch://connections", mimeType: "application/json", name: "App Connections", description: "List of configured app connections" }, { uri: "automatisch://apps", mimeType: "application/json", name: "Available Apps", description: "Catalog of available apps and integrations" }, { uri: "automatisch://executions/recent", mimeType: "application/json", name: "Recent Executions", description: "Recent workflow executions and their results" } ] }; }); // Handle resource reading server.setRequestHandler(ReadResourceRequestSchema, async (request: any) => { const { uri } = request.params; switch (uri) { case "automatisch://workflows": return { contents: [ { uri, mimeType: "application/json", text: JSON.stringify(await main.api.getWorkflowsOverview(), null, 2) } ] }; case "automatisch://connections": return { contents: [ { uri, mimeType: "application/json", text: JSON.stringify(await main.api.getConnectionsOverview(), null, 2) } ] }; case "automatisch://apps": return { contents: [ { uri, mimeType: "application/json", text: JSON.stringify(await main.api.getAvailableApps(), null, 2) } ] }; case "automatisch://executions/recent": return { contents: [ { uri, mimeType: "application/json", text: JSON.stringify(await main.api.getRecentExecutions(), null, 2) } ] }; default: throw new McpError(ErrorCode.InvalidRequest, `Unknown resource: ${uri}`); } }); // Handle tool calls server.setRequestHandler(CallToolRequestSchema, async (request: any) => {
• src/server.ts:35-36 (helper)

  Initializes the 'api' object on the main server instance with API helpers, providing 'createConnection' method.
  public api = apiHelpers(this);