LLM/moltbot
1
0
Fork 0
mirror of https://github.com/moltbot/moltbot.git synced 2026-03-20 16:15:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: rename skipSeen parameter to bypassSeenCheck in sendPayload for improved clarity.

Browse Source
This commit is contained in:
yassine20011
2026-02-05 01:12:55 +01:00
committed by Josh Lehman
parent b03a38a774
commit 25446be189
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/auto-reply/reply/block-reply-pipeline.ts
View File

@@ -90,12 +90,12 @@ export function createBlockReplyPipeline(params: {
let didStream = false;
let didLogTimeout = false;
const sendPayload = (payload: ReplyPayload, skipSeen?: boolean) => {
const sendPayload = (payload: ReplyPayload, bypassSeenCheck: boolean = false) => {
if (aborted) {
return;
}
const payloadKey = createBlockReplyPayloadKey(payload);
if (!skipSeen) {
if (!bypassSeenCheck) {
if (seenKeys.has(payloadKey)) {
return;
}
@@ -155,7 +155,7 @@ export function createBlockReplyPipeline(params: {
shouldAbort: () => aborted,
onFlush: (payload) => {
bufferedKeys.clear();
sendPayload(payload, true);
sendPayload(payload, /* bypassSeenCheck */ true);
},
})
: null;
@@ -186,7 +186,7 @@ export function createBlockReplyPipeline(params: {
}
for (const payload of bufferedPayloads) {
const finalPayload = buffer?.finalize?.(payload) ?? payload;
sendPayload(finalPayload, true);
sendPayload(finalPayload, /* bypassSeenCheck */ true);
}
bufferedPayloads.length = 0;
bufferedPayloadKeys.clear();
@@ -202,7 +202,7 @@ export function createBlockReplyPipeline(params: {
const hasMedia = Boolean(payload.mediaUrl) || (payload.mediaUrls?.length ?? 0) > 0;
if (hasMedia) {
void coalescer?.flush({ force: true });
sendPayload(payload);
sendPayload(payload, /* bypassSeenCheck */ false);
return;
}
if (coalescer) {
@@ -215,7 +215,7 @@ export function createBlockReplyPipeline(params: {
coalescer.enqueue(payload);
return;
}
sendPayload(payload);
sendPayload(payload, /* bypassSeenCheck */ false);
};
const flush = async (options?: { force?: boolean }) => {