#forceRestarted = false;

#activeRunner: ReturnType<typeof run> | undefined;

#activeFetchAbort: AbortController | undefined;

#spooledUpdatesInFlight = new Set<number>();

#spooledUpdateLanesInFlight = new Set<string>();

#spooledUpdateHandlerPromises = new Set<Promise<boolean>>();

#spooledUpdateHandlersByLane = new Map<string, Promise<boolean>>();

#transportState: TelegramPollingTransportState;

#status: ReturnType<typeof createTelegramPollingStatusPublisher>;

#stallThresholdMs: number;

async #handleSpooledUpdate(params: {

bot: TelegramBot;

update: TelegramSpooledUpdate;

laneKey: string;

}): Promise<boolean> {

try {

await params.bot.handleUpdate(

`[telegram][diag] spooled update ${params.update.updateId} failed; keeping for retry: ${formatErrorMessage(err)}`,

);

return false;

} finally {

this.#spooledUpdatesInFlight.delete(params.update.updateId);

this.#spooledUpdateLanesInFlight.delete(params.laneKey);

}

}

async #waitForSpooledUpdateHandlers(): Promise<void> {

const pending = [...this.#spooledUpdateHandlerPromises];

if (pending.length === 0) {

return;

}

await Promise.allSettled(pending);

await Promise.allSettled(this.#spooledUpdateHandlersByLane.values());

}

async #drainSpooledUpdates(params: { bot: TelegramBot; spoolDir: string }): Promise<number> {

if (this.opts.abortSignal?.aborted) {

break;

}

if (this.#spooledUpdatesInFlight.has(update.updateId)) {

continue;

}

if (this.#spooledUpdateLanesInFlight.has(laneKey)) {

if (this.#spooledUpdateHandlersByLane.has(laneKey)) {

continue;

}

this.#spooledUpdatesInFlight.add(update.updateId);

this.#spooledUpdateLanesInFlight.add(laneKey);

const handler = this.#handleSpooledUpdate({

bot: params.bot,

update,

laneKey,

});

this.#spooledUpdateHandlerPromises.add(handler);

this.#spooledUpdateHandlersByLane.set(laneKey, handler);

void handler.finally(() => {

this.#spooledUpdateHandlerPromises.delete(handler);

this.#spooledUpdateHandlersByLane.delete(laneKey);

});

started += 1;

}