Receive webhook events

import Relay, { type RelayWebhookEvent } from "@relaymessenger/sdk";

const relay = new Relay({
  apiKey: process.env.RELAY_AGENT_TOKEN!,
  baseURL: "https://api.relayapp.im",
  webhookSecret: process.env.RELAY_WEBHOOK_SECRET!,
});

export async function receive(
  request: Request,
  acceptOnce: (event: RelayWebhookEvent) => Promise<void>,
): Promise<Response> {
  const rawBody = await request.text();
  let event: RelayWebhookEvent;
  try {
    event = relay.webhooks.unwrap(rawBody, { headers: request.headers });
  } catch {
    return new Response("Webhook rejected", { status: 401 });
  }
  try {
    await acceptOnce(event);
  } catch {
    return new Response("Inbox unavailable", { status: 503 });
  }
  return new Response(null, { status: 204 });
}