From 25446be189dfb8284bc06ce8f51045a03e039972 Mon Sep 17 00:00:00 2001 From: yassine20011 Date: Thu, 5 Feb 2026 01:12:55 +0100 Subject: [PATCH] refactor: rename `skipSeen` parameter to `bypassSeenCheck` in `sendPayload` for improved clarity. --- src/auto-reply/reply/block-reply-pipeline.ts | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/auto-reply/reply/block-reply-pipeline.ts b/src/auto-reply/reply/block-reply-pipeline.ts index df289f54179..c0b097d5fdd 100644 --- a/src/auto-reply/reply/block-reply-pipeline.ts +++ b/src/auto-reply/reply/block-reply-pipeline.ts @@ -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 }) => {