vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-05 04:20:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: dedupe discord media-only delivery helper

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-06 18:20:14 +01:00
parent 4c8bb05c89
commit 81b0f280be
1 changed files with 46 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
extensions/discord/src/monitor/reply-delivery.ts
View File

@@ -113,6 +113,32 @@ async function sendWithRetry(
});
}
async function sendDiscordMediaOnly(params: {
target: string;
cfg: OpenClawConfig;
token: string;
rest: RequestClient;
mediaUrl: string;
accountId: string;
mediaLocalRoots?: string[];
replyTo?: string;
retryConfig: ResolvedRetryConfig;
}): Promise<void> {
await sendWithRetry(
() =>
sendMessageDiscord(params.target, "", {
cfg: params.cfg,
token: params.token,
rest: params.rest,
mediaUrl: params.mediaUrl,
accountId: params.accountId,
mediaLocalRoots: params.mediaLocalRoots,
replyTo: params.replyTo,
}),
params.retryConfig,
);
}
function resolveTargetChannelId(target: string): string | undefined {
if (!target.startsWith("channel:")) {
return undefined;
@@ -410,20 +436,17 @@ export async function deliverDiscordReply(params: {
mediaUrls: reply.mediaUrls.slice(1),
caption: "",
send: async ({ mediaUrl }) => {
const replyTo = resolvePayloadReplyTo();
await sendWithRetry(
() =>
sendMessageDiscord(params.target, "", {
cfg: params.cfg,
token: params.token,
rest: params.rest,
mediaUrl,
accountId: params.accountId,
mediaLocalRoots: params.mediaLocalRoots,
replyTo,
}),
await sendDiscordMediaOnly({
target: params.target,
cfg: params.cfg,
token: params.token,
rest: params.rest,
mediaUrl,
accountId: params.accountId,
mediaLocalRoots: params.mediaLocalRoots,
replyTo: resolvePayloadReplyTo(),
retryConfig,
);
});
},
});
continue;
@@ -454,20 +477,17 @@ export async function deliverDiscordReply(params: {
mediaUrls: reply.mediaUrls,
caption: "",
send: async ({ mediaUrl }) => {
const replyTo = resolvePayloadReplyTo();
await sendWithRetry(
() =>
sendMessageDiscord(params.target, "", {
cfg: params.cfg,
token: params.token,
rest: params.rest,
mediaUrl,
accountId: params.accountId,
mediaLocalRoots: params.mediaLocalRoots,
replyTo,
}),
await sendDiscordMediaOnly({
target: params.target,
cfg: params.cfg,
token: params.token,
rest: params.rest,
mediaUrl,
accountId: params.accountId,
mediaLocalRoots: params.mediaLocalRoots,
replyTo: resolvePayloadReplyTo(),
retryConfig,
);
});
},
});
deliveredAny = true;