fix(tui): show startup initialization activity

steipete · ml12580 · steipete · commit 5ec2bb19ff5d · 2026-07-06T00:03:15.000-04:00
Co-authored-by: ml12580 &lt;long.xinyuan3@xydigit.com&gt;
diff --git a/src/tui/tui-pty-harness.e2e.test.ts b/src/tui/tui-pty-harness.e2e.test.ts
@@ -83,6 +83,7 @@ async function writeTuiPtyFixtureScript(dir: string) {
 
       const actionLogPath = process.env.OPENCLAW_TUI_PTY_LOG_PATH;
       const gatewayStatus = process.env.OPENCLAW_TUI_PTY_GATEWAY_STATUS ?? "fixture gateway ok";
+      const startupDelayMs = Number(process.env.OPENCLAW_TUI_PTY_STARTUP_DELAY_MS ?? 0);
       const xaiLimitError = '403 {"code":"The caller does not have permission to execute the specified operation","error":"Your team team-redacted has either used all available credits or reached its monthly spending limit. To continue making API requests, please purchase more credits or raise your spending limit."}';
       let currentModel = "fixture-provider/fixture-model";
       let fastMode = process.env.OPENCLAW_TUI_PTY_FAST_MODE === "true";
@@ -271,6 +272,9 @@ async function writeTuiPtyFixtureScript(dir: string) {
 
         async loadHistory() {
           record("loadHistory");
+          if (startupDelayMs > 0) {
+            await new Promise((resolve) => setTimeout(resolve, startupDelayMs));
+          }
           return { messages: [], fastMode };
         }
 
@@ -445,6 +449,22 @@ describe.sequential("TUI PTY harness", () => {
     expect(fixture.run.output()).not.toContain("host local");
   });
 
+  it(
+    "shows startup activity while post-connect initialization is pending",
+    async () => {
+      const slow = await startTuiFixture({
+        env: { OPENCLAW_TUI_PTY_STARTUP_DELAY_MS: "400" },
+      });
+      try {
+        await slow.run.waitForOutput("starting up", STARTUP_TIMEOUT_MS);
+        await slow.run.waitForOutput("local ready | idle", STARTUP_TIMEOUT_MS);
+      } finally {
+        await slow.cleanup();
+      }
+    },
+    STARTUP_TEST_TIMEOUT_MS,
+  );
+
   it("refreshes pending approvals before loading history", async () => {
     await fixture.waitForLogEntry((entry) => entry.method === "listPluginApprovals");
     await fixture.waitForLogEntry((entry) => entry.method === "loadHistory");
diff --git a/src/tui/tui.test.ts b/src/tui/tui.test.ts
@@ -188,6 +188,10 @@ describe("isTuiBusyActivityStatus", () => {
   it("treats finishing context as a visible busy status", () => {
     expect(isTuiBusyActivityStatus("finishing context")).toBe(true);
   });
+
+  it("treats post-connect initialization as a visible busy status", () => {
+    expect(isTuiBusyActivityStatus("starting up")).toBe(true);
+  });
 });
 
 describe("resolveTuiToolsToggleActivityStatus", () => {
diff --git a/src/tui/tui.ts b/src/tui/tui.ts
@@ -425,6 +425,7 @@ const TUI_BUSY_ACTIVITY_STATUSES = new Set([
   "streaming",
   "running",
   "finishing context",
+  "starting up",
 ]);
 
 export function isTuiBusyActivityStatus(status: string): boolean {
@@ -1573,6 +1574,11 @@ export async function runTui(opts: RunTuiOptions): Promise<TuiResult> {
       reconnectStreamingWatchdog();
     }
     setConnectionStatus(isLocalMode ? "local ready" : "connected");
+    // A reconnect may already have restored a live run's busy status. Only
+    // claim the status line when startup owns it, then release that exact state.
+    if (!isTuiBusyActivityStatus(activityStatus)) {
+      setActivityStatus("starting up");
+    }
     void (async () => {
       try {
         await client.subscribeSessionEvents?.();
@@ -1589,6 +1595,9 @@ export async function runTui(opts: RunTuiOptions): Promise<TuiResult> {
         chatLog.addSystem(`plugin approval refresh failed: ${String(err)}`);
       }
       await loadHistory();
+      if (activityStatus === "starting up") {
+        setActivityStatus("idle");
+      }
       setConnectionStatus(
         isLocalMode ? "local ready" : reconnected ? "gateway reconnected" : "gateway connected",
         4000,
@@ -1604,6 +1613,9 @@ export async function runTui(opts: RunTuiOptions): Promise<TuiResult> {
       tui.requestRender();
     })().catch((err: unknown) => {
       chatLog.addSystem(`startup failed: ${String(err)}`);
+      if (activityStatus === "starting up") {
+        setActivityStatus("idle");
+      }
       setConnectionStatus("startup failed", 5000);
       tui.requestRender();
     });
