Get notified with webhooks

from fastapi import FastAPI, Header, HTTPException, Request
from hai_agents import WebhookEventData, WebhookVerificationError, verify_webhook

app = FastAPI()

@app.post("/hooks/h")
async def receive(
    request: Request,
    x_h_webhook_signature: str = Header(""),
    x_h_webhook_timestamp: str = Header(""),
):
    body = await request.body()
    try:
        event = verify_webhook(body, x_h_webhook_signature, x_h_webhook_timestamp, secret="whsec_...")
    except WebhookVerificationError:
        raise HTTPException(status_code=400, detail="invalid signature")
    # event.data is the raw payload; its shape depends on event.type.
    if event.type == "session.status_updated":
        data = WebhookEventData.model_validate(event.data)
        if data.status == "completed":
            print(f"session {data.session_id} finished")
    return {"ok": True}

import express from "express";
import { type WebhookEventData, WebhookVerificationError, verifyWebhook } from "hai-agents";

const app = express();
app.use("/hooks/h", express.raw({ type: "application/json" }));

app.post("/hooks/h", (req, res) => {
  try {
    const event = verifyWebhook(
      req.body,
      req.header("X-H-Webhook-Signature") ?? "",
      req.header("X-H-Webhook-Timestamp") ?? "",
      "whsec_...",
    );
    // event.data is the raw payload; its shape depends on event.type.
    if (event.type === "session.status_updated") {
      const data = event.data as unknown as WebhookEventData;
      if (data.status === "completed") {
        console.log(`session ${data.session_id} finished`);
      }
    }
    res.json({ ok: true });
  } catch (e) {
    if (e instanceof WebhookVerificationError) {
      res.status(400).json({ error: "invalid signature" });
      return;
    }
    throw e;
  }
});