@@ -835,6 +835,7 @@ async function sendMessageSlackQueuedInner(params: {
|
835 | 835 | let lastMessageId = ""; |
836 | 836 | let deliveredChannelId = channelId; |
837 | 837 | let canonicalDeliveredThreadTs: string | undefined; |
| 838 | +let chunksToPost: string[]; |
838 | 839 | if (opts.mediaUrl) { |
839 | 840 | const [firstChunk, ...rest] = resolvedChunks; |
840 | 841 | lastMessageId = await uploadSlackFile({ |
@@ -851,42 +852,27 @@ async function sendMessageSlackQueuedInner(params: {
|
851 | 852 | maxBytes: mediaMaxBytes, |
852 | 853 | }); |
853 | 854 | sentMessageIds.push(lastMessageId); |
854 | | -for (const chunk of rest) { |
855 | | -const response = await postSlackMessageBestEffort({ |
856 | | - client, |
857 | | - channelId, |
858 | | -text: chunk, |
859 | | -threadTs: opts.threadTs, |
860 | | -replyBroadcast: sentMessageIds.length === 0 ? opts.replyBroadcast : undefined, |
861 | | - identity, |
862 | | -metadata: sentMessageIds.length === 0 ? opts.metadata : undefined, |
863 | | - unfurl, |
864 | | -}); |
865 | | -lastMessageId = response.ts ?? lastMessageId; |
866 | | -deliveredChannelId = resolvePostedMessageChannelId(response, deliveredChannelId); |
867 | | -canonicalDeliveredThreadTs ??= resolvePostedMessageThreadTs(response); |
868 | | -if (response.ts) { |
869 | | -sentMessageIds.push(response.ts); |
870 | | -} |
871 | | -} |
| 855 | +chunksToPost = rest; |
872 | 856 | } else { |
873 | | -for (const chunk of resolvedChunks.length ? resolvedChunks : [""]) { |
874 | | -const response = await postSlackMessageBestEffort({ |
875 | | - client, |
876 | | - channelId, |
877 | | -text: chunk, |
878 | | -threadTs: opts.threadTs, |
879 | | -replyBroadcast: sentMessageIds.length === 0 ? opts.replyBroadcast : undefined, |
880 | | - identity, |
881 | | -metadata: sentMessageIds.length === 0 ? opts.metadata : undefined, |
882 | | - unfurl, |
883 | | -}); |
884 | | -lastMessageId = response.ts ?? lastMessageId; |
885 | | -deliveredChannelId = resolvePostedMessageChannelId(response, deliveredChannelId); |
886 | | -canonicalDeliveredThreadTs ??= resolvePostedMessageThreadTs(response); |
887 | | -if (response.ts) { |
888 | | -sentMessageIds.push(response.ts); |
889 | | -} |
| 857 | +chunksToPost = resolvedChunks.length ? resolvedChunks : [""]; |
| 858 | +} |
| 859 | + |
| 860 | +for (const chunk of chunksToPost) { |
| 861 | +const response = await postSlackMessageBestEffort({ |
| 862 | + client, |
| 863 | + channelId, |
| 864 | +text: chunk, |
| 865 | +threadTs: opts.threadTs, |
| 866 | +replyBroadcast: sentMessageIds.length === 0 ? opts.replyBroadcast : undefined, |
| 867 | + identity, |
| 868 | +metadata: sentMessageIds.length === 0 ? opts.metadata : undefined, |
| 869 | + unfurl, |
| 870 | +}); |
| 871 | +lastMessageId = response.ts ?? lastMessageId; |
| 872 | +deliveredChannelId = resolvePostedMessageChannelId(response, deliveredChannelId); |
| 873 | +canonicalDeliveredThreadTs ??= resolvePostedMessageThreadTs(response); |
| 874 | +if (response.ts) { |
| 875 | +sentMessageIds.push(response.ts); |
890 | 876 | } |
891 | 877 | } |
892 | 878 | |
|
