const activeHandledUpdateKeys = new Map<string, boolean>();

const pendingUpdateIds = new Set<number>();

const failedUpdateIds = new Set<number>();

const completedFloorReplayUpdateIds = new Set<number>();

let highestAcceptedUpdateId: number | null = initialUpdateId;

let highestPersistedAcceptedUpdateId: number | null = persistenceFloorUpdateId;

let highestPersistenceRequestedUpdateId: number | null = persistenceFloorUpdateId;

highestAcceptedUpdateId = updateId;

};

const isFloorReplayUpdateId = (updateId: number) =>

initialUpdateId === null &&

persistenceFloorUpdateId !== null &&

updateId <= persistenceFloorUpdateId;

function resolveSafeCompletedUpdateId() {

if (highestCompletedUpdateId === null) {

return null;

const updateKey = buildTelegramUpdateKey(ctx);

if (typeof updateId === "number") {

if (highestAcceptedUpdateId !== null && updateId <= highestAcceptedUpdateId) {

if (!failedUpdateIds.has(updateId)) {

const floorReplay = isFloorReplayUpdateId(updateId);

if (!floorReplay && !failedUpdateIds.has(updateId)) {

skip(`update:${updateId}`);

return { accepted: false, reason: "accepted-watermark" };

}

if (floorReplay && completedFloorReplayUpdateIds.has(updateId)) {

skip(`update:${updateId}`);

return { accepted: false, reason: "accepted-watermark" };

}

pendingUpdateIds.delete(update.updateId);

if (finish.completed) {

failedUpdateIds.delete(update.updateId);

if (isFloorReplayUpdateId(update.updateId)) {

completedFloorReplayUpdateIds.add(update.updateId);

}

if (highestCompletedUpdateId === null || update.updateId > highestCompletedUpdateId) {

highestCompletedUpdateId = update.updateId;

}