Message Events

const express = require('express');
const app = express();

app.use(express.json());

const seen = new Set(); // in production, use Redis or a DB

app.post('/webhook/callkaro', (req, res) => {
  // Acknowledge first, process after -- a slow response burns the timeout.
  res.sendStatus(200);

  const { event, data } = req.body;

  switch (event) {
    case 'message_received':
      console.log(`Inbound from ${data.contact_number}: ${data.body}`);
      break;

    case 'message_sent':
    case 'template_sent': {
      // Retries and multiple destinations both mean you can see this twice.
      const key = data.message_id;
      if (seen.has(key)) return;
      seen.add(key);

      if (data.status === 'failed' || data.status === 'not sent') {
        console.error(`Send FAILED to ${data.contact_number}`);
      } else {
        console.log(`Sent to ${data.contact_number}: ${data.template || data.body}`);
      }
      break;
    }

    default:
      // Ignore unknown events so new ones cannot break this handler.
      break;
  }
});

app.listen(3000);

from fastapi import FastAPI, Request

app = FastAPI()

MESSAGE_EVENTS = {"message_received", "message_sent", "template_sent"}


@app.post("/webhook/callkaro")
async def handle_webhook(request: Request):
    payload = await request.json()
    event = payload.get("event")
    data = payload.get("data", {})

    if event in MESSAGE_EVENTS:
        print("event          :", event)
        print("contact        :", data.get("contact_number"))
        print("direction      :", data.get("direction"))
        print("type           :", data.get("type"))
        print("body           :", data.get("body"))
        print("status         :", data.get("status"))
        print("campaign       :", data.get("wa_campaign_id"))

        if data.get("type") == "template":
            print("template       :", data.get("template"))
            # already an object -- no json.loads needed
            print("template_json  :", data.get("template_json"))

        if data.get("status") in ("failed", "not sent"):
            print("!! send did not reach the user")

    # 2xx for everything, including events you do not handle.
    return {"status": "success"}