Webhook verifier

from algovoi_webhook_verifier import verify_webhook, WebhookVerificationError

def handle_webhook(raw_body: bytes, signature_header: str, secret: str):
    try:
        event = verify_webhook(
            payload=raw_body,
            secret=secret,
            signature_header=signature_header,
        )
    except WebhookVerificationError as e:
        # e.code is one of the six typed error codes
        return {"error": e.code}, 400

    if event["type"] == "payment.confirmed":
        data = event["data"]
        print(f"Payment confirmed: {data['resource_id']} on {data['chain']}")
    return {"ok": True}, 200

import { verifyWebhook, WebhookVerificationError } from "@algovoi/webhook-verifier";

function handleWebhook(rawBody: Buffer, signatureHeader: string, secret: string) {
  try {
    const event = verifyWebhook({
      payload: rawBody,
      secret,
      signatureHeader,
    });

    if (event.type === "payment.confirmed") {
      const { resource_id, chain } = event.data as Record<string, string>;
      console.log(`Payment confirmed: ${resource_id} on ${chain}`);
    }
    return { ok: true };
  } catch (err) {
    if (err instanceof WebhookVerificationError) {
      return { error: err.code };
    }
    throw err;
  }
}

from flask import Flask, request
from algovoi_webhook_verifier import verify_webhook, WebhookVerificationError
import os

app = Flask(__name__)

@app.route("/webhook", methods=["POST"])
def webhook():
    try:
        event = verify_webhook(
            payload=request.get_data(),
            secret=os.environ["ALGOVOI_WEBHOOK_SECRET"],
            signature_header=request.headers.get("X-AlgoVoi-Signature", ""),
        )
    except WebhookVerificationError as e:
        return {"error": e.code}, 400

    # process event["type"]
    return {"received": True}, 200

import express from "express";
import { verifyWebhook, WebhookVerificationError } from "@algovoi/webhook-verifier";

const app = express();
// Important: use raw body parser, not json()
app.use("/webhook", express.raw({ type: "application/json" }));

app.post("/webhook", (req, res) => {
  try {
    const event = verifyWebhook({
      payload: req.body,
      secret: process.env.ALGOVOI_WEBHOOK_SECRET!,
      signatureHeader: req.headers["x-algovoi-signature"] as string,
    });
    res.json({ received: true });
  } catch (err) {
    if (err instanceof WebhookVerificationError) {
      res.status(400).json({ error: err.code });
    } else {
      res.status(500).end();
    }
  }
});