});

}

async function waitForTelegramPollRetryDelay(remainingMs: number) {

await new Promise((resolve) => setTimeout(resolve, Math.min(250, Math.max(100, remainingMs))));

}

async function waitForObservedMessage(params: {

token: string;

initialOffset: number;

}) {

const startedAt = Date.now();

let offset = params.initialOffset;

let lastPollingError: unknown;

while (Date.now() - startedAt < params.timeoutMs) {

const remainingMs = Math.max(

1_000,

},

timeoutSeconds * 1000 + 5_000,

);

lastPollingError = undefined;

} catch (error) {

if (!isRecoverableTelegramQaPollError(error)) {

throw error;

}

lastPollingError = error;

await waitForTelegramPollRetryDelay(params.timeoutMs - (Date.now() - startedAt));

continue;

}

const batchObservedAtMs = Date.now();

}

}

}

throw new Error(`timed out after ${params.timeoutMs}ms waiting for Telegram message`);

const timeoutMessage = `timed out after ${params.timeoutMs}ms waiting for Telegram message`;

if (lastPollingError) {

throw new Error(

`${timeoutMessage}; last polling error: ${formatErrorMessage(lastPollingError)}`,

);

}

throw new Error(timeoutMessage);

}

async function waitForTelegramChannelRunning(

shouldLogTelegramQaLiveProgress,

formatTelegramQaProgressDetails,

renderTelegramQaMarkdown,

waitForObservedMessage,

};