From c3340a3894f18581dcfd4b4ffe33055b8f02569c Mon Sep 17 00:00:00 2001 From: Peter Steinberger Date: Sun, 15 Feb 2026 16:09:21 +0000 Subject: [PATCH] refactor(outbound): dedupe delivery mirror type --- src/infra/outbound/delivery-queue.ts | 28 ++++++++++------------------ 1 file changed, 10 insertions(+), 18 deletions(-) diff --git a/src/infra/outbound/delivery-queue.ts b/src/infra/outbound/delivery-queue.ts index 7303d82724..57565e338c 100644 --- a/src/infra/outbound/delivery-queue.ts +++ b/src/infra/outbound/delivery-queue.ts @@ -18,6 +18,13 @@ const BACKOFF_MS: readonly number[] = [ 600_000, // retry 4: 10m ]; +type DeliveryMirrorPayload = { + sessionKey: string; + agentId?: string; + text?: string; + mediaUrls?: string[]; +}; + export interface QueuedDelivery { id: string; enqueuedAt: number; @@ -35,12 +42,7 @@ export interface QueuedDelivery { bestEffort?: boolean; gifPlayback?: boolean; silent?: boolean; - mirror?: { - sessionKey: string; - agentId?: string; - text?: string; - mediaUrls?: string[]; - }; + mirror?: DeliveryMirrorPayload; retryCount: number; lastError?: string; } @@ -74,12 +76,7 @@ export async function enqueueDelivery( bestEffort?: boolean; gifPlayback?: boolean; silent?: boolean; - mirror?: { - sessionKey: string; - agentId?: string; - text?: string; - mediaUrls?: string[]; - }; + mirror?: DeliveryMirrorPayload; }, stateDir?: string, ): Promise { @@ -205,12 +202,7 @@ export type DeliverFn = (params: { bestEffort?: boolean; gifPlayback?: boolean; silent?: boolean; - mirror?: { - sessionKey: string; - agentId?: string; - text?: string; - mediaUrls?: string[]; - }; + mirror?: DeliveryMirrorPayload; skipQueue?: boolean; }) => Promise;