dilim/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-08-07 02:22:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(slack): share posted chunk loop

Browse Source
This commit is contained in:
Vincent Koc
2026-06-22 19:16:49 +08:00
parent 77f4e45c35
commit f378de9d5b
1 changed files with 21 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

56
extensions/slack/src/send.ts
View File

@@ -835,6 +835,7 @@ async function sendMessageSlackQueuedInner(params: {
let lastMessageId = "";
let deliveredChannelId = channelId;
let canonicalDeliveredThreadTs: string | undefined;
let chunksToPost: string[];
if (opts.mediaUrl) {
const [firstChunk, ...rest] = resolvedChunks;
lastMessageId = await uploadSlackFile({
@@ -851,42 +852,27 @@ async function sendMessageSlackQueuedInner(params: {
maxBytes: mediaMaxBytes,
});
sentMessageIds.push(lastMessageId);
for (const chunk of rest) {
const response = await postSlackMessageBestEffort({
client,
channelId,
text: chunk,
threadTs: opts.threadTs,
replyBroadcast: sentMessageIds.length === 0 ? opts.replyBroadcast : undefined,
identity,
metadata: sentMessageIds.length === 0 ? opts.metadata : undefined,
unfurl,
});
lastMessageId = response.ts ?? lastMessageId;
deliveredChannelId = resolvePostedMessageChannelId(response, deliveredChannelId);
canonicalDeliveredThreadTs ??= resolvePostedMessageThreadTs(response);
if (response.ts) {
sentMessageIds.push(response.ts);
}
}
chunksToPost = rest;
} else {
for (const chunk of resolvedChunks.length ? resolvedChunks : [""]) {
const response = await postSlackMessageBestEffort({
client,
channelId,
text: chunk,
threadTs: opts.threadTs,
replyBroadcast: sentMessageIds.length === 0 ? opts.replyBroadcast : undefined,
identity,
metadata: sentMessageIds.length === 0 ? opts.metadata : undefined,
unfurl,
});
lastMessageId = response.ts ?? lastMessageId;
deliveredChannelId = resolvePostedMessageChannelId(response, deliveredChannelId);
canonicalDeliveredThreadTs ??= resolvePostedMessageThreadTs(response);
if (response.ts) {
sentMessageIds.push(response.ts);
}
chunksToPost = resolvedChunks.length ? resolvedChunks : [""];
}
for (const chunk of chunksToPost) {
const response = await postSlackMessageBestEffort({
client,
channelId,
text: chunk,
threadTs: opts.threadTs,
replyBroadcast: sentMessageIds.length === 0 ? opts.replyBroadcast : undefined,
identity,
metadata: sentMessageIds.length === 0 ? opts.metadata : undefined,
unfurl,
});
lastMessageId = response.ts ?? lastMessageId;
deliveredChannelId = resolvePostedMessageChannelId(response, deliveredChannelId);
canonicalDeliveredThreadTs ??= resolvePostedMessageThreadTs(response);
if (response.ts) {
sentMessageIds.push(response.ts);
}
}