Four stages.
Each one has a boundary.

import { createSeamwardCollector } from "@seamward/collector";

const webhookCollector = createSeamwardCollector({
  connectionKey: process.env.SEAMWARD_CONNECTION_KEY,
  ingestToken: process.env.SEAMWARD_INGEST_TOKEN,
  deployment: { service: "candidate-api", commitSha: process.env.GITHUB_SHA },
});

// Wrap the handler you already have. The response you return is what your
// caller receives. Seamward records structure after it has been sent.
export const handleCandidateWebhook = webhookCollector.observeWebhook(
  { routeTemplate: "/webhooks/candidates" },
  async (payload) => {
    const candidate = await candidateService.accept(payload);

    return {
      statusCode: 202,
      eventType: "candidate.create",
      outcome: {
        accepted: true,
        businessObjectType: "candidate",
        businessObjectId: candidate.id,
      },
    };
  },
);