Delivery Status Event

{
  "event": "message_status_updated",
  "data": {
    "userId": "6803fa770b666a64ab1694c1e",
    "agentId": "7103fa770b666a64ab1694c1e",
    "channel": "whatsapp",
    "message_id": "9f2c1b7e5a4d3f8c6b0e2a13",
    "msg_id": "wamid.HBgMOTE5ODc2NTQzMjEwFQIAEBgg",
    "type": "template",
    "template": "order_shipped",
    "from": "919000000000",
    "to": "919876543210",
    "contact_number": "919876543210",
    "status": "delivered",
    "previous_status": "sent",
    "agent_phone_number_id": "123456789012345",
    "wa_campaign_id": "spring_sale_2026",
    "timestamp": "1772345678"
  }
}

app.post('/webhook/callkaro', (req, res) => {
  res.sendStatus(200); // acknowledge first

  const { event, data } = req.body;
  if (event !== 'message_status_updated') return;

  // previous_status makes the transition explicit -- no need to keep
  // your own state machine to know what just changed.
  console.log(
    `${data.msg_id}: ${data.previous_status} -> ${data.status}`
  );

  if (data.status === 'failed') {
    alertOps(`Delivery failed to ${data.contact_number}`);
  }

  if (data.status === 'read' && data.wa_campaign_id) {
    trackCampaignRead(data.wa_campaign_id, data.contact_number);
  }
});

from datetime import datetime, timezone

REACHED_USER = {"delivered", "read"}


@app.post("/webhook/callkaro")
async def handle_webhook(request: Request):
    payload = await request.json()
    if payload.get("event") != "message_status_updated":
        return {"status": "success"}

    data = payload.get("data", {})

    # NOTE: unlike the other events, this timestamp is Unix epoch seconds.
    raw = data.get("timestamp") or "0"
    changed_at = datetime.fromtimestamp(int(raw), tz=timezone.utc)

    print(
        data.get("msg_id"),
        data.get("previous_status"), "->", data.get("status"),
        "at", changed_at.isoformat(),
    )

    if data.get("status") in REACHED_USER:
        mark_delivered(data.get("message_id"))
    elif data.get("status") == "failed":
        mark_failed(data.get("message_id"), data.get("contact_number"))

    return {"status": "success"}