Migrate webhooks to queue-based processing without breaking production

// Migration shim: keep your existing URL stable, but forward payloads to Hooque for queue-based processing.
// npm i express
import express from "express";

const app = express();

const HOOQUE_INGEST_URL =
  process.env.HOOQUE_INGEST_URL ??
  "https://app.hooque.io/hooks/wh_replace_me?token=replace_me";

app.post(
  "/provider/webhook",
  express.raw({ type: "*/*", limit: "2mb" }),
  async (req, res) => {
    const rawBody = Buffer.isBuffer(req.body) ? req.body : Buffer.from(req.body ?? "");

    // TODO: keep your existing verification here (signature + timestamp) during the migration.
    // If you change verification semantics, do it separately from “move to async”.

    // Ack fast so the provider stops retrying.
    res.sendStatus(202);

    // Forward to Hooque asynchronously.
    // IMPORTANT: forward the provider signature headers that Hooque needs for verification (if configured).
    const forwardHeaders = {
      "content-type": req.header("content-type") ?? "application/json",
      // Example provider headers (adjust to your provider):
      "stripe-signature": req.header("stripe-signature") ?? "",
      "x-github-event": req.header("x-github-event") ?? "",
      "x-github-delivery": req.header("x-github-delivery") ?? "",
    };

    try {
      await fetch(HOOQUE_INGEST_URL, {
        method: "POST",
        headers: forwardHeaders,
        body: rawBody,
      });
    } catch (err) {
      // TODO: log + alert (forwarding failures mean you are dropping events)
      console.error("forwarding to hooque failed", err);
    }
  }
);

app.listen(3000, () => console.log("migration shim listening on :3000"));

# Migration shim: keep your existing URL stable, but forward payloads to Hooque for queue-based processing.
# pip install fastapi uvicorn httpx
import os
import httpx
from fastapi import FastAPI, Request, Response

app = FastAPI()

HOOQUE_INGEST_URL = os.getenv(
    "HOOQUE_INGEST_URL",
    "https://app.hooque.io/hooks/wh_replace_me?token=replace_me",
)

@app.post("/provider/webhook")
async def webhook(request: Request) -> Response:
    raw_body = await request.body()

    # TODO: keep your existing verification here (signature + timestamp) during the migration.

    # Ack fast so the provider stops retrying.
    resp = Response(status_code=202)

    # Forward to Hooque asynchronously.
    forward_headers = {
        "content-type": request.headers.get("content-type", "application/json"),
        # Example provider headers (adjust to your provider):
        "stripe-signature": request.headers.get("stripe-signature", ""),
        "x-github-event": request.headers.get("x-github-event", ""),
        "x-github-delivery": request.headers.get("x-github-delivery", ""),
    }

    try:
        async with httpx.AsyncClient(timeout=10) as client:
            await client.post(HOOQUE_INGEST_URL, content=raw_body, headers=forward_headers)
    except Exception as err:
        # TODO: log + alert (forwarding failures mean you are dropping events)
        print("forwarding to hooque failed", err)

    return resp