MCP N8N Webhook Server

Instructions

Implementation Reference

• index.ts:21-50 (registration)

  Registers the MCP tool 'n8n_save_data' with Zod input schema, description, and inline handler function that delegates to webhookTools.saveDataToWebhook and formats the markdown response.

  server.tool(
    "n8n_save_data",
    "Guardar información en n8n a través de webhook para indexación y almacenamiento",
    {
      projectName: z.string().describe("Nombre del proyecto"),
      title: z.string().describe("Título del contenido"),
      text: z.string().describe("Texto completo del contenido a guardar")
    },
    async (args) => {
      console.error(`📤 Guardando datos en n8n: ${args.title}`);
      
      const result = await webhookTools.saveDataToWebhook({
        projectName: args.projectName,
        title: args.title,
        text: args.text
      });
  
      const statusIcon = result.success ? '✅' : '❌';
      const content = result.success 
        ? `${statusIcon} **Datos guardados exitosamente**\n\n**Proyecto:** ${args.projectName}\n**Título:** ${args.title}\n**ID:** ${result.id}\n**Timestamp:** ${result.timestamp}\n\n${result.message}`
        : `${statusIcon} **Error al guardar datos**\n\n**Error:** ${result.message}\n**Timestamp:** ${result.timestamp}`;
  
      return {
        content: [{ 
          type: "text", 
          text: content
        }],
      };
    }
  );

• tools/webhook-client.ts:55-113 (handler)

  Core handler function that constructs the webhook payload, sends POST request to n8n webhook URL using fetch, handles HTTP responses, errors, and returns success/failure status with details.

  export async function saveDataToWebhook(args: SaveDataArgs): Promise<WebhookResponse> {
    try {
      console.error(`📤 Enviando datos al webhook n8n...`);
      console.error(`URL: ${WEBHOOK_URL}/${WEBHOOK_ID}`);
      
      const payload = buildWebhookPayload(args);
      
      console.error(`📋 Payload generado:`, JSON.stringify(payload, null, 2));
      
      const response = await fetch(`${WEBHOOK_URL}/${WEBHOOK_ID}`, {
        method: 'POST',
        headers: {
          'Content-Type': 'application/json',
          'Authorization-n8n-api-key': API_KEY,
          'User-Agent': 'MCP-N8N-Webhook/1.0'
        },
        body: JSON.stringify(payload)
      });
      
      console.error(`📡 Respuesta HTTP: ${response.status} ${response.statusText}`);
      
      if (!response.ok) {
        const errorText = await response.text();
        console.error(`❌ Error en respuesta:`, errorText);
        
        return {
          success: false,
          message: `Error HTTP ${response.status}: ${response.statusText}. ${errorText}`,
          timestamp: generateTimestamp()
        };
      }
      
      let responseData: any;
      try {
        responseData = await response.json();
      } catch (parseError) {
        // Si no es JSON válido, usar el texto de respuesta
        const textResponse = await response.text();
        responseData = { message: textResponse };
      }
      
      console.error(`✅ Datos enviados exitosamente:`, responseData);
      
      return {
        success: true,
        message: 'Datos guardados exitosamente en n8n',
        id: responseData.id || payload.project.id,
        timestamp: generateTimestamp()
      };
      
    } catch (error) {
      console.error(`❌ Error enviando datos al webhook:`, error);
      
      return {
        success: false,
        message: `Error de conexión: ${(error as Error).message}`,
        timestamp: generateTimestamp()
      };
    }

• index.ts:24-28 (schema)

  Zod schema defining input parameters for the 'n8n_save_data' tool: projectName, title, text.

  {
    projectName: z.string().describe("Nombre del proyecto"),
    title: z.string().describe("Título del contenido"),
    text: z.string().describe("Texto completo del contenido a guardar")
  },

• types/webhook.ts:32-36 (schema)

  TypeScript interface defining the input arguments for saveDataToWebhook, matching the tool schema.

  export interface SaveDataArgs {
    projectName: string;
    title: string;
    text: string;
  }

• tools/webhook-client.ts:32-50 (helper)

  Helper function to build the complete WebhookPayload object from input args, including metadata, project ID generation, and content.

  function buildWebhookPayload(args: SaveDataArgs): WebhookPayload {
    const timestamp = generateTimestamp();
    
    return {
      metadata: {
        timestamp,
        source: 'mcp_assistant',
        version: '1.0'
      },
      project: {
        id: generateProjectId(args.projectName),
        name: args.projectName
      },
      content: {
        title: args.title,
        text: args.text
      }
    };
  }