Webhooks

import express from "express";
import { verifyReyGrid } from "./verify-reygrid.js"; // see "Verifying signatures"

const app = express();

// Keep the raw body: the signature is computed over the exact bytes we send.
app.post("/webhooks/reygrid", express.raw({ type: "application/json" }), (req, res) => {
  const signature = req.get("X-ReyGrid-Signature");
  if (!verifyReyGrid(signature, req.body.toString("utf8"), process.env.REYGRID_WEBHOOK_SECRET)) {
    return res.status(400).send("Invalid signature");
  }

  const event = JSON.parse(req.body);

  switch (event.type) {
    case "chat.completed":
      // e.g. record usage for event.data.agent.id
      break;
    case "credits.low":
      // e.g. alert your team or top up
      break;
  }

  res.sendStatus(200); // acknowledge quickly; do heavy work in the background
});

app.listen(3000);

import json, os
from flask import Flask, request, abort
from verify_reygrid import verify_reygrid  # see "Verifying signatures"

app = Flask(__name__)

@app.post("/webhooks/reygrid")
def reygrid_webhook():
    body = request.get_data()  # raw bytes, before any parsing
    signature = request.headers.get("X-ReyGrid-Signature", "")
    if not verify_reygrid(signature, body, os.environ["REYGRID_WEBHOOK_SECRET"]):
        abort(400)

    event = json.loads(body)
    if event["type"] == "chat.completed":
        pass  # e.g. record usage for event["data"]["agent"]["id"]
    elif event["type"] == "credits.low":
        pass  # e.g. alert your team

    return "", 200