From 9e94a9e418d4e980bfbdc6ffe96777dd8f7aa878 Mon Sep 17 00:00:00 2001
From: Ayaan Zaidi <hi@obviy.us>
Date: Fri, 1 May 2026 11:15:48 +0530
Subject: [PATCH] test(qa): allow telegram scenario timeout override

---
 .../telegram/telegram-live.runtime.test.ts        | 14 ++++++++++++++
 .../telegram/telegram-live.runtime.ts             | 15 +++++++++++++--
 2 files changed, 27 insertions(+), 2 deletions(-)

diff --git a/extensions/qa-lab/src/live-transports/telegram/telegram-live.runtime.test.ts b/extensions/qa-lab/src/live-transports/telegram/telegram-live.runtime.test.ts
index 869e252b3b3..71bb3f6460a 100644
--- a/extensions/qa-lab/src/live-transports/telegram/telegram-live.runtime.test.ts
+++ b/extensions/qa-lab/src/live-transports/telegram/telegram-live.runtime.test.ts
@@ -114,6 +114,20 @@ describe("telegram live qa runtime", () => {
     ).toBe(30_000);
   });
 
+  it("normalizes the Telegram QA scenario timeout env", () => {
+    expect(__testing.resolveTelegramQaScenarioTimeoutMs(45_000, {})).toBe(45_000);
+    expect(
+      __testing.resolveTelegramQaScenarioTimeoutMs(45_000, {
+        OPENCLAW_QA_TELEGRAM_SCENARIO_TIMEOUT_MS: "180000",
+      }),
+    ).toBe(180_000);
+    expect(
+      __testing.resolveTelegramQaScenarioTimeoutMs(45_000, {
+        OPENCLAW_QA_TELEGRAM_SCENARIO_TIMEOUT_MS: "nope",
+      }),
+    ).toBe(45_000);
+  });
+
   it("sanitizes and truncates Telegram live progress details", () => {
     expect(__testing.sanitizeTelegramQaProgressValue("scenario\nid\tvalue")).toBe(
       "scenario id value",
diff --git a/extensions/qa-lab/src/live-transports/telegram/telegram-live.runtime.ts b/extensions/qa-lab/src/live-transports/telegram/telegram-live.runtime.ts
index a0bfd1f0c0a..8d719893d8a 100644
--- a/extensions/qa-lab/src/live-transports/telegram/telegram-live.runtime.ts
+++ b/extensions/qa-lab/src/live-transports/telegram/telegram-live.runtime.ts
@@ -376,6 +376,13 @@ function resolveTelegramQaCanaryTimeoutMs(env: NodeJS.ProcessEnv = process.env)
   );
 }
 
+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`;
 }
@@ -1308,6 +1315,9 @@ export async function runTelegramQaLive(params: {
           );
           assertLeaseHealthy();
           const scenarioRun = scenario.buildRun(sutUsername);
+          const scenarioTimeoutMs = scenarioRun.expectReply
+            ? resolveTelegramQaScenarioTimeoutMs(scenario.timeoutMs)
+            : scenario.timeoutMs;
           try {
             const requestStartedAtMs = Date.now();
             const sent = await sendGroupMessage(
@@ -1322,7 +1332,7 @@ export async function runTelegramQaLive(params: {
             const matched = await waitForObservedMessage({
               token: runtimeEnv.driverToken,
               initialOffset: driverOffset,
-              timeoutMs: scenario.timeoutMs,
+              timeoutMs: scenarioTimeoutMs,
               observedMessages,
               observationScenarioId: scenario.id,
               observationScenarioTitle: scenario.title,
@@ -1368,7 +1378,7 @@ export async function runTelegramQaLive(params: {
             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,
@@ -1537,6 +1547,7 @@ export const __testing = {
   parseTelegramQaProgressBooleanEnv,
   parseTelegramQaCredentialPayload,
   resolveTelegramQaCanaryTimeoutMs,
+  resolveTelegramQaScenarioTimeoutMs,
   resolveTelegramQaRuntimeEnv,
   sanitizeTelegramQaProgressValue,
   shouldLogTelegramQaLiveProgress,