import { cacheSticker, describeStickerImage } from "./sticker-cache.js";

import {

beginTelegramReplyFence,

buildTelegramNonInterruptingReplyFenceKey,

buildTelegramReplyFenceLaneKey,

endTelegramReplyFence,

getTelegramReplyFenceSizeForTests,

accountId: route.accountId,

sequentialKey: replyFenceLaneKey,

});

let activeReplyFenceKey = replyFenceKey.activeKey;

let replyFenceGeneration: number | undefined;

const replyAbortController = new AbortController();

let replyAbortControllerQueued = false;

let dispatchWasSuperseded = false;

const isDispatchSuperseded = () =>

replyFenceGeneration !== undefined &&

isTelegramReplyFenceSuperseded({

key: replyFenceKey.activeKey,

key: activeReplyFenceKey,

generation: replyFenceGeneration,

});

const releaseReplyFence = () => {

if (replyFenceGeneration === undefined) {

return;

}

endTelegramReplyFence(

replyFenceKey.activeKey,

activeReplyFenceKey,

replyAbortControllerQueued ? undefined : replyAbortController,

);

replyFenceGeneration = undefined;

const chunkMode = resolveChunkMode(cfg, "telegram", route.accountId);

const supersedeReplyFence = shouldSupersedeTelegramReplyFence(ctxPayload);

activeReplyFenceKey = supersedeReplyFence

? replyFenceKey.activeKey

: buildTelegramNonInterruptingReplyFenceKey({

activeKey: replyFenceKey.activeKey,

laneKey: scopedReplyFenceLaneKey,

});

if (!isRoomEvent && supersedeReplyFence) {

supersedeTelegramReplyFence(replyFenceKey.roomEventKey);

}

replyFenceGeneration = beginTelegramReplyFence({

key: replyFenceKey.activeKey,

key: activeReplyFenceKey,

supersede: supersedeReplyFence,

abortController: replyAbortController,

laneKey: scopedReplyFenceLaneKey,

onComplete: () => {

replyAbortControllerQueued = false;

releaseTelegramReplyFenceAbortController(

replyFenceKey.activeKey,

activeReplyFenceKey,

replyAbortController,

);

},