@@ -202,6 +202,12 @@ export const registerTelegramHandlers = ({
202202};
203203const normalizePromptContextMinTimestampMs = (timestampMs?: number) =>
204204typeof timestampMs === "number" && Number.isFinite(timestampMs) ? timestampMs : undefined;
205+const promptContextBoundaryOptions = (
206+timestampMs?: number,
207+): Pick<TelegramMessageContextOptions, "promptContextMinTimestampMs"> => {
208+const promptContextMinTimestampMs = normalizePromptContextMinTimestampMs(timestampMs);
209+return promptContextMinTimestampMs === undefined ? {} : { promptContextMinTimestampMs };
210+};
205211const latestPromptContextMinTimestampMs = (
206212 ...timestamps: Array<number | undefined>
207213): number | undefined => {
@@ -411,13 +417,10 @@ export const registerTelegramHandlers = ({
411417return;
412418}
413419if (entries.length === 1) {
414-const promptContextMinTimestampMs = normalizePromptContextMinTimestampMs(
415-last.promptContextMinTimestampMs,
416-);
417420await processMessageWithReplyChain(last.ctx, last.msg, last.allMedia, last.storeAllowFrom, {
418421receivedAtMs: last.receivedAtMs,
419422ingressBuffer: "inbound-debounce",
420- ...(promptContextMinTimestampMs !== undefined ? { promptContextMinTimestampMs } : {}),
423+ ...promptContextBoundaryOptions(last.promptContextMinTimestampMs),
421424});
422425return;
423426}
@@ -450,7 +453,7 @@ export const registerTelegramHandlers = ({
450453 ...(messageIdOverride ? { messageIdOverride } : {}),
451454receivedAtMs: first.receivedAtMs,
452455ingressBuffer: "inbound-debounce",
453- ...(promptContextMinTimestampMs !== undefined ? { promptContextMinTimestampMs } : {}),
456+ ...promptContextBoundaryOptions(promptContextMinTimestampMs),
454457},
455458);
456459},
@@ -611,9 +614,7 @@ export const registerTelegramHandlers = ({
611614primaryEntry.msg,
612615allMedia,
613616storeAllowFrom,
614-entry.promptContextMinTimestampMs !== undefined
615- ? { promptContextMinTimestampMs: entry.promptContextMinTimestampMs }
616- : undefined,
617+promptContextBoundaryOptions(entry.promptContextMinTimestampMs),
617618);
618619} catch (err) {
619620runtime.error?.(danger(`media group handler failed: ${String(err)}`));
@@ -649,9 +650,7 @@ export const registerTelegramHandlers = ({
649650messageIdOverride: String(last.msg.message_id),
650651receivedAtMs: first.receivedAtMs,
651652ingressBuffer: "text-fragment",
652- ...(entry.promptContextMinTimestampMs !== undefined
653- ? { promptContextMinTimestampMs: entry.promptContextMinTimestampMs }
654- : {}),
653+ ...promptContextBoundaryOptions(entry.promptContextMinTimestampMs),
655654});
656655} catch (err) {
657656runtime.error?.(danger(`text fragment handler failed: ${String(err)}`));
@@ -1377,7 +1376,7 @@ export const registerTelegramHandlers = ({
13771376const entry: TextFragmentEntry = {
13781377 key,
13791378messages: [{ msg, ctx, receivedAtMs: nowMs }],
1380- ...(promptContextMinTimestampMs !== undefined ? { promptContextMinTimestampMs } : {}),
1379+ ...promptContextBoundaryOptions(promptContextMinTimestampMs),
13811380timer: setTimeout(() => {}, TELEGRAM_TEXT_FRAGMENT_MAX_GAP_MS),
13821381};
13831382textFragmentBuffer.set(key, entry);
@@ -1409,7 +1408,7 @@ export const registerTelegramHandlers = ({
14091408} else {
14101409const entry: MediaGroupEntry = {
14111410messages: [{ msg, ctx }],
1412- ...(promptContextMinTimestampMs !== undefined ? { promptContextMinTimestampMs } : {}),
1411+ ...promptContextBoundaryOptions(promptContextMinTimestampMs),
14131412timer: setTimeout(async () => {
14141413mediaGroupBuffer.delete(mediaGroupId);
14151414mediaGroupProcessing = mediaGroupProcessing
@@ -1506,7 +1505,7 @@ export const registerTelegramHandlers = ({
15061505 debounceKey,
15071506 debounceLane,
15081507botUsername: ctx.me?.username,
1509- ...(promptContextMinTimestampMs !== undefined ? { promptContextMinTimestampMs } : {}),
1508+ ...promptContextBoundaryOptions(promptContextMinTimestampMs),
15101509});
15111510};
15121511bot.on("callback_query", async (ctx) => {
@@ -2397,7 +2396,7 @@ export const registerTelegramHandlers = ({
23972396 storeAllowFrom,
23982397sendOversizeWarning: event.sendOversizeWarning,
23992398oversizeLogMessage: event.oversizeLogMessage,
2400- ...(promptContextMinTimestampMs !== undefined ? { promptContextMinTimestampMs } : {}),
2399+ ...promptContextBoundaryOptions(promptContextMinTimestampMs),
24012400});
24022401} catch (err) {
24032402runtime.error?.(danger(`${event.errorMessage}: ${String(err)}`));
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。