github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-04-18 07:57:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(discord): share attachment media resolution loop

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-16 22:43:30 +00:00
parent 1aabe9712a
commit abbe04b184
1 changed files with 46 additions and 48 deletions
Download Patch File Download Diff File Expand all files Collapse all files

94
src/discord/monitor/message-utils.ts
View File

@@ -131,28 +131,12 @@ export async function resolveMediaList(
return [];
}
const out: DiscordMediaInfo[] = [];
for (const attachment of attachments) {
try {
const fetched = await fetchRemoteMedia({
url: attachment.url,
filePathHint: attachment.filename ?? attachment.url,
});
const saved = await saveMediaBuffer(
fetched.buffer,
fetched.contentType ?? attachment.content_type,
"inbound",
maxBytes,
);
out.push({
path: saved.path,
contentType: saved.contentType,
placeholder: inferPlaceholder(attachment),
});
} catch (err) {
const id = attachment.id ?? attachment.url;
logVerbose(`discord: failed to download attachment ${id}: ${String(err)}`);
}
}
await appendResolvedMediaFromAttachments({
attachments,
maxBytes,
out,
errorPrefix: "discord: failed to download attachment",
});
return out;
}
@@ -166,36 +150,50 @@ export async function resolveForwardedMediaList(
}
const out: DiscordMediaInfo[] = [];
for (const snapshot of snapshots) {
const attachments = snapshot.message?.attachments;
if (!attachments || attachments.length === 0) {
continue;
}
for (const attachment of attachments) {
try {
const fetched = await fetchRemoteMedia({
url: attachment.url,
filePathHint: attachment.filename ?? attachment.url,
});
const saved = await saveMediaBuffer(
fetched.buffer,
fetched.contentType ?? attachment.content_type,
"inbound",
maxBytes,
);
out.push({
path: saved.path,
contentType: saved.contentType,
placeholder: inferPlaceholder(attachment),
});
} catch (err) {
const id = attachment.id ?? attachment.url;
logVerbose(`discord: failed to download forwarded attachment ${id}: ${String(err)}`);
}
}
await appendResolvedMediaFromAttachments({
attachments: snapshot.message?.attachments,
maxBytes,
out,
errorPrefix: "discord: failed to download forwarded attachment",
});
}
return out;
}
async function appendResolvedMediaFromAttachments(params: {
attachments?: APIAttachment[] | null;
maxBytes: number;
out: DiscordMediaInfo[];
errorPrefix: string;
}) {
const attachments = params.attachments;
if (!attachments || attachments.length === 0) {
return;
}
for (const attachment of attachments) {
try {
const fetched = await fetchRemoteMedia({
url: attachment.url,
filePathHint: attachment.filename ?? attachment.url,
});
const saved = await saveMediaBuffer(
fetched.buffer,
fetched.contentType ?? attachment.content_type,
"inbound",
params.maxBytes,
);
params.out.push({
path: saved.path,
contentType: saved.contentType,
placeholder: inferPlaceholder(attachment),
});
} catch (err) {
const id = attachment.id ?? attachment.url;
logVerbose(`${params.errorPrefix} ${id}: ${String(err)}`);
}
}
}
function inferPlaceholder(attachment: APIAttachment): string {
const mime = attachment.content_type ?? "";
if (mime.startsWith("image/")) {