fix(webhooks): give session deliveries the whd_ delivery id and the provider's id

A webhook delivery routed to an agent session now carries both ids on
its envelope:

```ts
onAction: async ({ action }) => {
  action.deliveryId; // "whd_...": the delivery in the dashboard and deliveries API, new on a replay
  action.externalDeliveryId; // the provider's id, e.g. Stripe's "evt_...", the same across replays
},
```

`deliveryId` previously held the provider's id. It now matches the id
`webhook()` tasks, waiters and the deliveries API use.

Mono-RevId: bc4eb9c3b90fc4b3fe15e3084d637819467a24f7

Author: ericallam

apps/webapp/app/v3/webhookEngine.server.ts

@@ -197,6 +197,7 @@ function createWebhookEngine() {
       source,
       headers,
       deliveryId,
+      externalDeliveryId,
       partId,
       endpoint,
       triggerConfigTemplate,
@@ -243,13 +244,29 @@ function createWebhookEngine() {
             ? {
                 chatId: externalId,
                 trigger: "submit-message",
-                channelEvent: { connectorId, event, source, headers, deliveryId, endpoint },
+                channelEvent: {
+                  connectorId,
+                  event,
+                  source,
+                  headers,
+                  deliveryId,
+                  externalDeliveryId,
+                  endpoint,
+                },
               }
             : {
                 chatId: externalId,
                 trigger: "action",
                 actionSource: "webhook",
-                action: { type: actionType, event, source, headers, deliveryId, endpoint },
+                action: {
+                  type: actionType,
+                  event,
+                  source,
+                  headers,
+                  deliveryId,
+                  externalDeliveryId,
+                  endpoint,
+                },
               };
         const part = JSON.stringify({ kind: "message", payload });
 

internal-packages/webhook-engine/src/engine/fanout.test.ts

@@ -239,7 +239,8 @@ containerTestWithIsolatedRedisNoClickhouse(
         targetId: "agent-x:order-events",
         externalId: "cus_1",
         actionType: "order.event",
-        deliveryId: "evt_fan_1",
+        deliveryId: delivery.friendlyId,
+        externalDeliveryId: "evt_fan_1",
         partId: `${deliveryId}:agent-x:order-events`,
         endpoint: endpointContext,
       });

internal-packages/webhook-engine/src/engine/index.ts

@@ -1903,7 +1903,8 @@ export class WebhookEngine {
       event: delivery.parsedEvent,
       source: endpoint.source,
       headers: (delivery.headers as Record<string, string> | null) ?? {},
-      deliveryId: delivery.externalDeliveryId,
+      deliveryId: delivery.friendlyId,
+      externalDeliveryId: delivery.externalDeliveryId,
       triggerConfigTemplate: target.triggerConfigTemplate,
       idempotencyKey: delivery.idempotencyKey,
       isSessionStart: this.#evaluateSessionStart(target.startOn, delivery, endpoint),

internal-packages/webhook-engine/src/engine/ingest.test.ts

@@ -855,9 +855,10 @@ containerTestWithIsolatedRedisNoClickhouse(
       expect(calls[0]?.taskIdentifier).toBe("agent-x");
       expect(calls[0]?.actionType).toBe("order.event");
       expect((calls[0]!.event as { id: string }).id).toBe(eventId);
-      expect(calls[0]?.deliveryId).toBe(eventId);
-
       const d = await prisma.webhookDelivery.findFirst({ where: { id: result.deliveryId } });
+      expect(calls[0]?.deliveryId).toBe(d?.friendlyId);
+      expect(calls[0]?.deliveryId).toMatch(/^whd_/);
+      expect(calls[0]?.externalDeliveryId).toBe(eventId);
       expect(d?.runId).toBe("srun_1"); // the session's run, from the port
     } finally {
       await engine.quit();

internal-packages/webhook-engine/src/engine/types.ts

@@ -216,7 +216,10 @@ export type DeliverWebhookToSessionParams = {
   event: unknown; // delivery.parsedEvent
   source: string; // provider tag
   headers: Record<string, string>;
-  deliveryId: string; // externalDeliveryId, surfaced on the envelope
+  /** The delivery's friendly id (`whd_`): new on a replay, the same across retries of one delivery. */
+  deliveryId: string;
+  /** The provider's id for the delivery (e.g. Stripe's `evt_`), the same across replays. */
+  externalDeliveryId: string;
   triggerConfigTemplate?: Record<string, unknown>;
   idempotencyKey: string;
   // Evaluated startOn: true (default) allows creating a new session; false means resume-only, so a