);

}

function resolveTelegramQaScenarioTimeoutMs(

fallbackMs: number,

env: NodeJS.ProcessEnv = process.env,

) {

return parsePositiveTelegramQaEnvMs(env, "OPENCLAW_QA_TELEGRAM_SCENARIO_TIMEOUT_MS", fallbackMs);

}

function formatTelegramQaTimeoutSeconds(timeoutMs: number) {

return `${Math.round(timeoutMs / 1_000)}s`;

}

);

assertLeaseHealthy();

const scenarioRun = scenario.buildRun(sutUsername);

const scenarioTimeoutMs = scenarioRun.expectReply

? resolveTelegramQaScenarioTimeoutMs(scenario.timeoutMs)

: scenario.timeoutMs;

try {

const requestStartedAtMs = Date.now();

const sent = await sendGroupMessage(

const matched = await waitForObservedMessage({

token: runtimeEnv.driverToken,

initialOffset: driverOffset,

timeoutMs: scenario.timeoutMs,

timeoutMs: scenarioTimeoutMs,

observedMessages,

observationScenarioId: scenario.id,

observationScenarioTitle: scenario.title,

if (!scenarioRun.expectReply) {

const details = formatErrorMessage(error);

if (

details === `timed out after ${scenario.timeoutMs}ms waiting for Telegram message`

details === `timed out after ${scenarioTimeoutMs}ms waiting for Telegram message`

) {

const result = {

id: scenario.id,

parseTelegramQaProgressBooleanEnv,

parseTelegramQaCredentialPayload,

resolveTelegramQaCanaryTimeoutMs,

resolveTelegramQaScenarioTimeoutMs,

resolveTelegramQaRuntimeEnv,

sanitizeTelegramQaProgressValue,

shouldLogTelegramQaLiveProgress,