Вебхуки WhatsApp: как принимать входящие сообщения и статусы доставки

{
  "event": "message",
  "timestamp": 1792154662123,
  "payload": {
    "id": "false_77011234567@c.us_3EB0B7C1D2E3F4A5",
    "from": "77011234567@c.us",
    "fromMe": false,
    "body": "Здравствуйте, заказ ещё в силе?",
    "hasMedia": false
  },
  "me": { "id": "77010000000@c.us", "pushName": "Магазин" },
  "wapi": { "number_id": 1, "phone": "77010000000", "message_id": 1843, "peer": "77011234567", "peer_lid": null, "name": "Айгерим", "is_group": false }
}

curl -G https://wapi.kz/api/v1/messages \
  -H "Authorization: Bearer $WAPI_KEY" \
  --data-urlencode "since=2026-10-17T06:00:00Z" \
  -d direction=in -d limit=500

import express from "express";

const HOOK_TOKEN = process.env.WAPI_HOOK_TOKEN;
if (!HOOK_TOKEN) throw new Error("Задайте WAPI_HOOK_TOKEN");

const app = express();

app.post("/whatsapp/webhook", express.json({ limit: "1mb" }), (req, res) => {
  if (req.query.token !== HOOK_TOKEN) return res.sendStatus(403);
  res.sendStatus(200); // ответить сразу, обработать — после
  handleEvent(req.body).catch((err) => console.error("webhook:", err));
});

async function handleEvent(e) {
  const p = e.payload || {};
  if (e.event === "message" && /@(c\.us|lid)$/.test(String(p.from))) {
    // у @c.us телефон — в адресе чата; у скрытого номера (@lid) цифры — не телефон, берём wapi.peer
    const client = p.from.endsWith("@c.us") ? p.from.split("@")[0] : e.wapi.peer ?? p.from;
    console.log(`#${e.wapi.number_id} ← ${client}: ${p.body ?? ""}${p.hasMedia ? " [вложение]" : ""}`);
  } else if (e.event === "message.out") {
    console.log(`Менеджер сам ответил ${e.wapi.peer ?? p.from} — бот молчит`);
  } else if (e.event === "message.ack") {
    const waMessageId = String(p.id).split("_")[2];
    console.log(`Статус ${waMessageId}: ${p.ack}`);
  } else if (e.event === "session.status" && ["FAILED", "STOPPED"].includes(p.status)) {
    console.error(`Номер ${e.wapi.phone} отключился: ${p.status}`);
  }
}

app.listen(3000);

import hmac
import os
import threading

from flask import Flask, abort, request

app = Flask(__name__)
HOOK_TOKEN = os.environ["WAPI_HOOK_TOKEN"]


@app.post("/whatsapp/webhook")
def webhook():
    token = request.args.get("token", "")
    if not hmac.compare_digest(token.encode(), HOOK_TOKEN.encode()):
        abort(403)
    event = request.get_json(silent=True) or {}
    threading.Thread(target=handle_event, args=(event,), daemon=True).start()
    return "", 200


def handle_event(e):
    p = e.get("payload") or {}
    kind = e.get("event")
    if kind == "message" and p.get("from", "").endswith(("@c.us", "@lid")):
        # у скрытого номера (@lid) цифры — не телефон: берём wapi.peer, если он известен
        client = p["from"].split("@")[0] if p["from"].endswith("@c.us") else e["wapi"].get("peer") or p["from"]
        print(f"#{e['wapi']['number_id']} <- {client}: {p.get('body') or ''}")
    elif kind == "message.ack":
        parts = p.get("id", "").split("_")
        print("Статус", parts[2] if len(parts) >= 3 else None, "->", p.get("ack"))
    elif kind == "session.status" and p.get("status") in ("FAILED", "STOPPED"):
        print("Номер отключился:", e["wapi"]["phone"], p["status"])


if __name__ == "__main__":
    app.run(port=3000)

<?php
// Адрес вебхука: https://example.kz/whatsapp-webhook.php?token=СЕКРЕТ
$secret = getenv("WAPI_HOOK_TOKEN");
if (!$secret || !hash_equals($secret, (string) ($_GET["token"] ?? ""))) {
    http_response_code(403);
    exit;
}

$event = json_decode(file_get_contents("php://input"), true) ?: [];
http_response_code(200);
if (function_exists("fastcgi_finish_request")) {
    fastcgi_finish_request();
}

$p = $event["payload"] ?? [];
switch ($event["event"] ?? "") {
    case "message":
        $from = $p["from"] ?? "";
        if (str_ends_with($from, "@c.us") || str_ends_with($from, "@lid")) {
            // у скрытого номера (@lid) цифры — не телефон: берём wapi.peer, если он известен
            $client = str_ends_with($from, "@c.us") ? explode("@", $from)[0] : ($event["wapi"]["peer"] ?? $from);
            error_log("WhatsApp от {$client}: " . ($p["body"] ?? ""));
        }
        break;
    case "message.ack":
        $waMessageId = explode("_", $p["id"] ?? "")[2] ?? null;
        error_log("Статус {$waMessageId}: " . ($p["ack"] ?? ""));
        break;
    case "session.status":
        error_log("Номер {$event['wapi']['phone']}: " . ($p["status"] ?? ""));
        break;
}

async function getMedia(messageId) {
  for (let i = 0; i < 5; i++) {
    const m = await fetch(`https://wapi.kz/api/v1/messages/${messageId}`, {
      headers: { Authorization: `Bearer ${process.env.WAPI_KEY}` },
    }).then((r) => r.json());
    if (m.media) return m.media; // { id, kind, mimetype, filename, size, url }
    if (!m.media_pending) return null; // не сохранён — причина в m.media_skip_reason
    await new Promise((r) => setTimeout(r, 3000));
  }
  return null;
}

# Тестовое событие на локальный обработчик
curl -X POST "http://localhost:3000/whatsapp/webhook?token=$WAPI_HOOK_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{"event":"message","payload":{"id":"false_77011234567@c.us_TEST1","from":"77011234567@c.us","fromMe":false,"body":"Тест","hasMedia":false},"wapi":{"number_id":1,"phone":"77010000000","message_id":null}}'

# Временный публичный https-адрес для порта 3000 (любой из вариантов)
ngrok http 3000
cloudflared tunnel --url http://localhost:3000