Function getWebhookEmitter

server/src/training-agent/webhooks.ts:350–364

()

}

export function getWebhookEmitter(): WebhookEmitter {
  if (emitter) return emitter;
  const m = ensureMaterial();
  // Production (`NODE_ENV=production`, i.e. fly.io) refuses webhook delivery
  // to private/loopback/metadata addresses. Dev and CI need loopback for
  // conformance storyboards using `http://127.0.0.1:<port>` receivers.
  const allowPrivateIp = process.env.NODE_ENV !== 'production';
  emitter = createWebhookEmitter({
    ...(m.kind === 'kms' ? { signerProvider: m.signerProvider } : { signerKey: m.signerKey }),
    idempotencyKeyStore: memoryWebhookKeyStore(),
    userAgent: 'adcp-training-agent/1.0',
    fetch: createWebhookFetch({ allowPrivateIp }),
  });
  return emitter;
}

/** Reset state — tests only. */
export function resetWebhookSigning(): void {