type TelegramReplyFenceState = {

generation: number;

activeDispatches: number;

abortControllers?: Set<AbortController>;

};

type TelegramReplyFenceKey = {

};

}

function beginTelegramReplyFence(params: { key: string; supersede: boolean }): number {

function abortTelegramReplyFenceControllers(state: TelegramReplyFenceState): void {

for (const controller of state.abortControllers ?? []) {

controller.abort();

}

state.abortControllers?.clear();

}

function beginTelegramReplyFence(params: {

key: string;

supersede: boolean;

abortController?: AbortController;

}): number {

const existing = telegramReplyFenceByKey.get(params.key);

const state: TelegramReplyFenceState = existing ?? {

generation: 0,

activeDispatches: 0,

};

if (params.supersede) {

state.generation += 1;

abortTelegramReplyFenceControllers(state);

}

if (params.abortController) {

(state.abortControllers ??= new Set()).add(params.abortController);

}

state.activeDispatches += 1;

telegramReplyFenceByKey.set(params.key, state);

return;

}

state.generation += 1;

abortTelegramReplyFenceControllers(state);

telegramReplyFenceByKey.set(key, state);

}

function isTelegramReplyFenceSuperseded(params: { key: string; generation: number }): boolean {

return (telegramReplyFenceByKey.get(params.key)?.generation ?? 0) !== params.generation;

}

function endTelegramReplyFence(key: string): void {

function endTelegramReplyFence(key: string, abortController?: AbortController): void {

const state = telegramReplyFenceByKey.get(key);

if (!state) {

return;

}

if (abortController) {

state.abortControllers?.delete(abortController);

}

state.activeDispatches -= 1;

if (state.activeDispatches <= 0) {

telegramReplyFenceByKey.delete(key);

threadSpec,

});

let replyFenceGeneration: number | undefined;

const roomEventAbortController = isRoomEvent ? new AbortController() : undefined;

let dispatchWasSuperseded = false;

const isDispatchSuperseded = () =>

replyFenceGeneration !== undefined &&

if (replyFenceGeneration === undefined) {

return;

}

endTelegramReplyFence(replyFenceKey.activeKey);

endTelegramReplyFence(replyFenceKey.activeKey, roomEventAbortController);

replyFenceGeneration = undefined;

};

const draftMaxChars = Math.min(textLimit, 4096);

replyFenceGeneration = beginTelegramReplyFence({

key: replyFenceKey.activeKey,

supersede: supersedeReplyFence,

abortController: roomEventAbortController,

});

const implicitQuoteReplyTargetId =

replyOptions: {

skillFilter,

disableBlockStreaming,

abortSignal: roomEventAbortController?.signal,

sourceReplyDeliveryMode: isRoomEvent ? "message_tool_only" : undefined,

suppressTyping: isRoomEvent,

onPartialReply: