Receiving webhooks

1
import express from "express";
2
import { Webhook } from "svix";
3
4
const app = express();
5
const wh = new Webhook(process.env.PIVOTAL_WEBHOOK_SECRET!);
6
7
app.post("/webhooks/pivotal", express.raw({ type: "application/json" }), (req, res) => {
8
  try {
9
    const evt = wh.verify(req.body, {
10
      "svix-id": req.header("svix-id")!,
11
      "svix-timestamp": req.header("svix-timestamp")!,
12
      "svix-signature": req.header("svix-signature")!,
13
    }) as { id: string; type: string; data: { object: any } };
14
15
    // Idempotent: skip if you've already processed evt.id
16
    handle(evt);
17
    res.status(200).send("ok");
18
  } catch {
19
    res.status(401).send("invalid signature");
20
  }
21
});

1
from fastapi import FastAPI, Request, HTTPException
2
from svix.webhooks import Webhook, WebhookVerificationError
3
import os
4
5
app = FastAPI()
6
wh = Webhook(os.environ["PIVOTAL_WEBHOOK_SECRET"])
7
8
@app.post("/webhooks/pivotal")
9
async def receive(request: Request):
10
    body = await request.body()
11
    try:
12
        evt = wh.verify(body, {
13
            "svix-id": request.headers["svix-id"],
14
            "svix-timestamp": request.headers["svix-timestamp"],
15
            "svix-signature": request.headers["svix-signature"],
16
        })
17
    except WebhookVerificationError:
18
        raise HTTPException(401, "invalid signature")
19
20
    handle(evt)
21
    return "ok"