Webhooks

import express from "express";
const app = express();

app.post("/webhooks/zavu", express.json(), (req, res) => {
  // 1. Verify signature (see Security guide)
  const signature = req.headers["x-zavu-signature"];
  if (!verifySignature(signature, req.body, process.env.WEBHOOK_SECRET)) {
    return res.status(401).send("Invalid signature");
  }

  // 2. Acknowledge receipt immediately
  res.status(200).send("OK");

  // 3. Process the event asynchronously
  const event = req.body;
  processEvent(event).catch(console.error);
});

async function processEvent(event) {
  switch (event.type) {
    case "message.inbound":
      await handleInboundMessage(event.data);
      break;
    case "message.delivered":
      await handleDeliveryConfirmation(event.data);
      break;
    case "message.failed":
      await handleDeliveryFailure(event.data);
      break;
  }
}

from flask import Flask, request
import threading

app = Flask(__name__)

@app.route("/webhooks/zavu", methods=["POST"])
def handle_webhook():
    # 1. Verify signature (see Security guide)
    signature = request.headers.get("X-Zavu-Signature")
    if not verify_signature(signature, request.data, WEBHOOK_SECRET):
        return "Invalid signature", 401

    # 2. Acknowledge receipt immediately
    event = request.json

    # 3. Process the event asynchronously
    thread = threading.Thread(target=process_event, args=(event,))
    thread.start()

    return "OK", 200

def process_event(event):
    if event["type"] == "message.inbound":
        handle_inbound_message(event["data"])
    elif event["type"] == "message.delivered":
        handle_delivery_confirmation(event["data"])
    elif event["type"] == "message.failed":
        handle_delivery_failure(event["data"])

require "sinatra"
require "json"

post "/webhooks/zavu" do
  # 1. Verify signature (see Security guide)
  signature = request.env["HTTP_X_ZAVU_SIGNATURE"]
  raw_body = request.body.read
  unless verify_signature(signature, raw_body, ENV["WEBHOOK_SECRET"])
    halt 401, "Invalid signature"
  end

  # 2. Acknowledge receipt immediately
  event = JSON.parse(raw_body)

  # 3. Process the event asynchronously
  Thread.new { process_event(event) }

  status 200
  "OK"
end

def process_event(event)
  case event["type"]
  when "message.inbound"
    handle_inbound_message(event["data"])
  when "message.delivered"
    handle_delivery_confirmation(event["data"])
  when "message.failed"
    handle_delivery_failure(event["data"])
  end
end

package main

import (
	"encoding/json"
	"io"
	"net/http"
)

func webhookHandler(w http.ResponseWriter, r *http.Request) {
	// 1. Verify signature (see Security guide)
	signature := r.Header.Get("X-Zavu-Signature")
	body, _ := io.ReadAll(r.Body)
	if !verifySignature(signature, body, webhookSecret) {
		http.Error(w, "Invalid signature", http.StatusUnauthorized)
		return
	}

	// 2. Acknowledge receipt immediately
	w.WriteHeader(http.StatusOK)
	w.Write([]byte("OK"))

	// 3. Process the event asynchronously
	var event map[string]interface{}
	json.Unmarshal(body, &event)
	go processEvent(event)
}

func processEvent(event map[string]interface{}) {
	switch event["type"] {
	case "message.inbound":
		handleInboundMessage(event["data"])
	case "message.delivered":
		handleDeliveryConfirmation(event["data"])
	case "message.failed":
		handleDeliveryFailure(event["data"])
	}
}

<?php
// 1. Verify signature (see Security guide)
$signature = $_SERVER['HTTP_X_ZAVU_SIGNATURE'] ?? '';
$rawBody = file_get_contents('php://input');
if (!verifySignature($signature, $rawBody, getenv('WEBHOOK_SECRET'))) {
    http_response_code(401);
    echo "Invalid signature";
    exit;
}

// 2. Acknowledge receipt
$event = json_decode($rawBody, true);

// 3. Process the event
switch ($event['type']) {
    case 'message.inbound':
        handleInboundMessage($event['data']);
        break;
    case 'message.delivered':
        handleDeliveryConfirmation($event['data']);
        break;
    case 'message.failed':
        handleDeliveryFailure($event['data']);
        break;
}

http_response_code(200);
echo "OK";