WhatsApp no Pipedream: gatilho HTTP, passo Node.js e variáveis de ambiente

Passo a passo

1. 1

   Crie as variáveis de ambiente

   Em Settings > Environment Variables (ou Variables dentro de um projeto), crie ZAPZAP_API_KEY, ZAPZAP_API_SECRET e ZAPZAP_INSTANCE_ID. A documentação informa que variáveis novas são secretas por padrão e que o valor não pode ser alterado depois. As chaves vêm de Settings > API em app.zapzapapi.com.

2. 2

   Crie o workflow com gatilho HTTP

   O Pipedream gera uma URL de endpoint só do workflow. A documentação avisa que, por padrão, gatilhos HTTP são públicos e não exigem autorização, e que corpos acima de 512 KB retornam 413.

3. 3

   Cadastre a URL na instância

   Chame PUT https://api.zapzapapi.com/api/v1/instances/{id}/webhook com webhook_url (a URL do passo anterior) e events (por exemplo, messages). A resposta traz o webhook_secret (whsec_). Teste com POST /instances/{id}/webhook/test e veja a execução no Pipedream.

4. 4

   Responda o webhook primeiro

   Se $.respond nunca for chamado, a documentação diz que o endpoint devolve erro 400. Use $.respond com immediate: true para responder logo e deixar os demais passos rodarem depois. A ZapZap tenta de novo quando o seu endpoint falha.

5. 5

   Envie a resposta em um passo Node.js

   Use o código do exemplo: process.env para as chaves, fetch para POST /{instanceId}/send/text com number e text. Troque o número fixo pelo remetente do evento, lendo os campos de data do envelope que você receber.

6. 6

   Proteja o endpoint

   Como o gatilho é público por padrão, valide a origem. A ZapZap assina cada entrega no cabeçalho X-ZapZap-Signature sobre o corpo bruto; a documentação que li não explica como obter o corpo bruto no gatilho, então confirme essa opção na sua conta, ou configure o token de autorização que o Pipedream oferece.

// 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 };
  },
});