WhatsApp en Pipedream: disparador HTTP, paso Node.js y variables de entorno

Paso a paso

1. 1

   Crea las variables de entorno

   En Settings > Environment Variables (o Variables dentro de un proyecto), crea ZAPZAP_API_KEY, ZAPZAP_API_SECRET y ZAPZAP_INSTANCE_ID. La documentación informa que las variables nuevas son secretas por defecto y que el valor no se puede modificar después. Las claves salen de Settings > API en app.zapzapapi.com.

2. 2

   Crea el workflow con disparador HTTP

   Pipedream genera una URL de endpoint solo para el workflow. La documentación advierte que, por defecto, los disparadores HTTP son públicos y no exigen autorización, y que los cuerpos de más de 512 KB devuelven 413.

3. 3

   Registra la URL en la instancia

   Llama a PUT https://api.zapzapapi.com/api/v1/instances/{id}/webhook con webhook_url (la URL del paso anterior) y events (por ejemplo, messages). La respuesta trae el webhook_secret (whsec_). Prueba con POST /instances/{id}/webhook/test y mira la ejecución en Pipedream.

4. 4

   Responde primero al webhook

   Si $.respond nunca se llama, la documentación dice que el endpoint devuelve error 400. Usa $.respond con immediate: true para responder enseguida y dejar que los demás pasos corran después. ZapZap reintenta cuando tu endpoint falla.

5. 5

   Envía la respuesta en un paso Node.js

   Usa el código del ejemplo: process.env para las claves, fetch para POST /{instanceId}/send/text con number y text. Cambia el número fijo por el remitente del evento, leyendo los campos de data del envelope que recibas.

6. 6

   Protege el endpoint

   Como el disparador es público por defecto, valida el origen. ZapZap firma cada entrega en la cabecera X-ZapZap-Signature sobre el cuerpo bruto; la documentación que leí no explica cómo obtener el cuerpo bruto en el disparador, así que confirma esa opción en tu cuenta, o configura el token de autorización que ofrece Pipedream.

// Pipedream Node.js code step. Environment variables (Settings > Environment Variables): ZAPZAP_API_KEY, ZAPZAP_API_SECRET, ZAPZAP_INSTANCE_ID
export default defineComponent({
  async run({ steps, $ }) {
    await $.respond({ status: 200, body: "ok", immediate: true }); // answer the webhook first
    const base = "https://api.zapzapapi.com/api/v1/" + process.env.ZAPZAP_INSTANCE_ID;
    const r = await fetch(base + "/send/text", {
      method: "POST",
      headers: {
        "Content-Type": "application/json",
        "x-api-key": process.env.ZAPZAP_API_KEY,
        "x-api-secret": process.env.ZAPZAP_API_SECRET,
      },
      body: JSON.stringify({ number: "5511999999999", text: "Received: " + steps.trigger.event.body.event }),
    });
    return { status: r.status };
  },
});