const MAX_POLL_STALL_THRESHOLD_MS = 600_000;

const POLL_WATCHDOG_INTERVAL_MS = 30_000;

const POLL_STOP_GRACE_MS = 15_000;

const CONFIRM_PERSISTED_OFFSET_TIMEOUT_MS = 10_000;

type TelegramBot = ReturnType<typeof createTelegramBot>;

type TelegramApiAbortSignal = Parameters<TelegramBot["api"]["getUpdates"]>[1];

const waitForGracefulStop = async (stop: () => Promise<void>) => {

let timer: ReturnType<typeof setTimeout> | undefined;

}

};

const telegramApiTimeoutSignal = (timeoutMs: number): TelegramApiAbortSignal =>

AbortSignal.timeout(timeoutMs) as unknown as TelegramApiAbortSignal;

const resolvePollingStallThresholdMs = (value: number | undefined): number => {

if (typeof value !== "number" || !Number.isFinite(value)) {

return DEFAULT_POLL_STALL_THRESHOLD_MS;

}

}

async #confirmPersistedOffset(bot: TelegramBot): Promise<void> {

const lastUpdateId = this.opts.getLastUpdateId();

if (lastUpdateId === null || lastUpdateId >= Number.MAX_SAFE_INTEGER) {

return;

}

try {

await bot.api.getUpdates(

{ offset: lastUpdateId + 1, limit: 1, timeout: 0 },

telegramApiTimeoutSignal(CONFIRM_PERSISTED_OFFSET_TIMEOUT_MS),

);

} catch {

// Non-fatal: runner middleware still skips duplicates via shouldSkipUpdate.

}

}

async #runPollingCycle(bot: TelegramBot): Promise<"continue" | "exit"> {

await this.#confirmPersistedOffset(bot);

const liveness = new TelegramPollingLivenessTracker({

onPollSuccess: (finishedAt) => this.#status.notePollSuccess(finishedAt),

});