fix(e2e): add telegramMeDelayMs mock behavior for onboarding timing tests (#202)

- Add getDelayMs/sleep utilities to mock-api-core.mjs so individual
  endpoints can honour a configurable delay set via __admin/behavior.
- Wire telegramMeDelayMs into the GET /telegram/me handler so the
  logout-relogin spec can simulate a slow profile fetch and assert that
  the onboarding overlay does not fire before the timeout threshold.
- Reformat long if-conditions and json() call sites to stay within line
  length limits (no logic changes).

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: YellowSnnowmann

scripts/mock-api-core.mjs

@@ -84,8 +84,16 @@ function getMockTeam() {
       createdBy: "test-user-123",
       isPersonal: true,
       maxMembers: 1,
-      subscription: { plan, hasActiveSubscription: isActive, planExpiry: expiry },
-      usage: { dailyTokenLimit: 1000, remainingTokens: 1000, activeSessionCount: 0 },
+      subscription: {
+        plan,
+        hasActiveSubscription: isActive,
+        planExpiry: expiry,
+      },
+      usage: {
+        dailyTokenLimit: 1000,
+        remainingTokens: 1000,
+        activeSessionCount: 0,
+      },
       createdAt: new Date().toISOString(),
       updatedAt: new Date().toISOString(),
     },
@@ -139,6 +147,15 @@ function tryParseJson(raw) {
   }
 }
 
+function getDelayMs(key) {
+  const value = Number(mockBehavior[key] || 0);
+  return Number.isFinite(value) && value > 0 ? value : 0;
+}
+
+function sleep(ms) {
+  return new Promise((resolve) => setTimeout(resolve, ms));
+}
+
 async function handleRequest(req, res) {
   const method = req.method ?? "GET";
   const url = req.url ?? "/";
@@ -174,7 +191,10 @@ async function handleRequest(req, res) {
     if (!keepRequests) clearRequestLog();
     json(res, 200, {
       success: true,
-      data: { behavior: getMockBehavior(), requestCount: getRequestLog().length },
+      data: {
+        behavior: getMockBehavior(),
+        requestCount: getRequestLog().length,
+      },
     });
     return;
   }
@@ -202,7 +222,10 @@ async function handleRequest(req, res) {
     return;
   }
 
-  if (method === "POST" && /^\/telegram\/login-tokens\/[^/]+\/consume\/?$/.test(url)) {
+  if (
+    method === "POST" &&
+    /^\/telegram\/login-tokens\/[^/]+\/consume\/?$/.test(url)
+  ) {
     if (mockBehavior.token === "expired") {
       json(res, 401, { success: false, error: "Token expired or invalid" });
       return;
@@ -225,6 +248,10 @@ async function handleRequest(req, res) {
   }
 
   if (method === "GET" && /^\/telegram\/me\/?(\?.*)?$/.test(url)) {
+    const delayMs = getDelayMs("telegramMeDelayMs");
+    if (delayMs > 0) {
+      await sleep(delayMs);
+    }
     if (mockBehavior.telegramMeStatus) {
       const status = Number(mockBehavior.telegramMeStatus) || 500;
       json(res, status, {
@@ -242,7 +269,10 @@ async function handleRequest(req, res) {
   }
 
   if (method === "GET" && /^\/settings\/?(\?.*)?$/.test(url)) {
-    json(res, 200, { success: true, data: { _id: "e2e-user-1", username: "e2e" } });
+    json(res, 200, {
+      success: true,
+      data: { _id: "e2e-user-1", username: "e2e" },
+    });
     return;
   }
 
@@ -275,7 +305,10 @@ async function handleRequest(req, res) {
 
   // --- Payments / Credits / Billing ---
 
-  if (method === "GET" && /^\/payments\/credits\/balance\/?(\?.*)?$/.test(url)) {
+  if (
+    method === "GET" &&
+    /^\/payments\/credits\/balance\/?(\?.*)?$/.test(url)
+  ) {
     json(res, 200, {
       success: true,
       data: { balanceUsd: 10, topUpBalanceUsd: 0, topUpBaselineUsd: 0 },
@@ -364,7 +397,10 @@ async function handleRequest(req, res) {
     return;
   }
 
-  if (method === "GET" && /^\/payments\/credits\/auto-recharge\/?(\?.*)?$/.test(url)) {
+  if (
+    method === "GET" &&
+    /^\/payments\/credits\/auto-recharge\/?(\?.*)?$/.test(url)
+  ) {
     json(res, 200, {
       success: true,
       data: {
@@ -388,7 +424,10 @@ async function handleRequest(req, res) {
     return;
   }
 
-  if (method === "GET" && /^\/payments\/credits\/auto-recharge\/cards\/?(\?.*)?$/.test(url)) {
+  if (
+    method === "GET" &&
+    /^\/payments\/credits\/auto-recharge\/cards\/?(\?.*)?$/.test(url)
+  ) {
     json(res, 200, { success: true, data: { cards: [], defaultCardId: null } });
     return;
   }
@@ -400,7 +439,11 @@ async function handleRequest(req, res) {
 
   if (method === "POST" && /^\/openai\/v1\/chat\/completions\/?$/.test(url)) {
     json(res, 200, {
-      choices: [{ message: { role: "assistant", content: "Hello from e2e mock agent" } }],
+      choices: [
+        {
+          message: { role: "assistant", content: "Hello from e2e mock agent" },
+        },
+      ],
     });
     return;
   }
@@ -419,10 +462,16 @@ async function handleRequest(req, res) {
 
   if (method === "GET" && /^\/auth\/telegram\/connect\/?(\?.*)?$/.test(url)) {
     if (mockBehavior.telegramDuplicate === "true") {
-      json(res, 409, { success: false, error: "Telegram account already linked to another user" });
+      json(res, 409, {
+        success: false,
+        error: "Telegram account already linked to another user",
+      });
       return;
     }
-    json(res, 200, { success: true, data: { oauthUrl: `${origin}/mock-telegram-oauth` } });
+    json(res, 200, {
+      success: true,
+      data: { oauthUrl: `${origin}/mock-telegram-oauth` },
+    });
     return;
   }
 
@@ -448,36 +497,53 @@ async function handleRequest(req, res) {
       json(res, 401, { success: false, error: "OAuth token has expired" });
       return;
     }
-    json(res, 200, { success: true, data: { oauthUrl: `${origin}/mock-google-oauth` } });
+    json(res, 200, {
+      success: true,
+      data: { oauthUrl: `${origin}/mock-google-oauth` },
+    });
     return;
   }
 
   if (method === "POST" && /^\/telegram\/command\/?$/.test(url)) {
     if (mockBehavior.telegramUnauthorized === "true") {
-      json(res, 403, { success: false, error: "Unauthorized: insufficient permissions" });
+      json(res, 403, {
+        success: false,
+        error: "Unauthorized: insufficient permissions",
+      });
       return;
     }
     if (mockBehavior.telegramCommandError === "true") {
       json(res, 400, { success: false, error: "Invalid command format" });
       return;
     }
-    json(res, 200, { success: true, data: { result: "Command executed successfully" } });
+    json(res, 200, {
+      success: true,
+      data: { result: "Command executed successfully" },
+    });
     return;
   }
 
   if (method === "GET" && /^\/telegram\/permissions\/?(\?.*)?$/.test(url)) {
     const level = mockBehavior.telegramPermission || "read";
     json(res, 200, {
       success: true,
-      data: { level, canRead: true, canWrite: level !== "read", canInitiate: level === "admin" },
+      data: {
+        level,
+        canRead: true,
+        canWrite: level !== "read",
+        canInitiate: level === "admin",
+      },
     });
     return;
   }
 
   if (method === "POST" && /^\/telegram\/webhook\/configure\/?$/.test(url)) {
     json(res, 200, {
       success: true,
-      data: { webhookUrl: "https://api.example.com/webhook/telegram", active: true },
+      data: {
+        webhookUrl: "https://api.example.com/webhook/telegram",
+        active: true,
+      },
     });
     return;
   }
@@ -491,7 +557,12 @@ async function handleRequest(req, res) {
     const level = mockBehavior.notionPermission || "read";
     json(res, 200, {
       success: true,
-      data: { level, canRead: true, canWrite: level !== "read", canCreate: level !== "read" },
+      data: {
+        level,
+        canRead: true,
+        canWrite: level !== "read",
+        canCreate: level !== "read",
+      },
     });
     return;
   }
@@ -500,7 +571,12 @@ async function handleRequest(req, res) {
     const level = mockBehavior.gmailPermission || "read";
     json(res, 200, {
       success: true,
-      data: { level, canRead: true, canWrite: level !== "read", canInitiate: level === "admin" },
+      data: {
+        level,
+        canRead: true,
+        canWrite: level !== "read",
+        canInitiate: level === "admin",
+      },
     });
     return;
   }
@@ -555,7 +631,10 @@ async function handleRequest(req, res) {
   }
 
   if (method === "POST" && /^\/invite\/redeem\/?$/.test(url)) {
-    json(res, 200, { success: true, data: { message: "Invite code redeemed successfully" } });
+    json(res, 200, {
+      success: true,
+      data: { message: "Invite code redeemed successfully" },
+    });
     return;
   }
   if (method === "GET" && /^\/invite\/my-codes\/?(\?.*)?$/.test(url)) {
@@ -566,7 +645,10 @@ async function handleRequest(req, res) {
     json(res, 200, { success: true, data: { valid: true } });
     return;
   }
-  if (method === "POST" && /^\/telegram\/settings\/onboarding-complete\/?$/.test(url)) {
+  if (
+    method === "POST" &&
+    /^\/telegram\/settings\/onboarding-complete\/?$/.test(url)
+  ) {
     json(res, 200, { success: true, data: {} });
     return;
   }
@@ -590,7 +672,8 @@ async function handleRequest(req, res) {
           ? {
               id: "sub_mock_123",
               status: "active",
-              currentPeriodEnd: expiry || new Date(Date.now() + 30 * 86400000).toISOString(),
+              currentPeriodEnd:
+                expiry || new Date(Date.now() + 30 * 86400000).toISOString(),
             }
           : null,
       },
@@ -602,15 +685,23 @@ async function handleRequest(req, res) {
   // consolidated handlers (with mockBehavior checks). Only the coinbase
   // charge-status polling endpoint remains here.
 
-  if (method === "GET" && /^\/payments\/coinbase\/charge\/[^/]+\/?(\?.*)?$/.test(url)) {
+  if (
+    method === "GET" &&
+    /^\/payments\/coinbase\/charge\/[^/]+\/?(\?.*)?$/.test(url)
+  ) {
     const status = mockBehavior.cryptoStatus || "NEW";
     json(res, 200, {
       success: true,
       data: {
         status,
         payment: {
           status,
-          amountPaid: status === "UNDERPAID" ? "150.00" : status === "OVERPAID" ? "350.00" : "250.00",
+          amountPaid:
+            status === "UNDERPAID"
+              ? "150.00"
+              : status === "OVERPAID"
+                ? "350.00"
+                : "250.00",
           amountExpected: "250.00",
           currency: "USDC",
           underpaidAmount: mockBehavior.cryptoUnderpaidAmount || "0",
@@ -622,7 +713,10 @@ async function handleRequest(req, res) {
     return;
   }
 
-  if (method === "GET" && /^\/mock-(telegram|notion|google)-oauth\/?(\?.*)?$/.test(url)) {
+  if (
+    method === "GET" &&
+    /^\/mock-(telegram|notion|google)-oauth\/?(\?.*)?$/.test(url)
+  ) {
     html(res, 200, "<html><body><h1>Mock OAuth</h1></body></html>");
     return;
   }
@@ -633,7 +727,10 @@ async function handleRequest(req, res) {
 
   // Catch-all: fail fast so tests notice missing mock endpoints.
   console.log(`[MockServer] UNHANDLED ${method} ${url}`);
-  json(res, 404, { success: false, error: `Mock server: no handler for ${method} ${url}` });
+  json(res, 404, {
+    success: false,
+    error: `Mock server: no handler for ${method} ${url}`,
+  });
 }
 
 function handleSocketIOMessage(socket, text, sid) {