github/openclaw
1
1
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-02-19 18:39:20 -05:00
Code Issues Packages Projects Releases Wiki Activity

refactor(outbound): dedupe delivery mirror type

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-15 16:09:21 +00:00
parent 41d053a06f
commit c3340a3894
1 changed files with 10 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
src/infra/outbound/delivery-queue.ts
View File

@@ -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<string> {
@@ -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<unknown>;