fix: ignore prefixed reconnect advisories

Author: Dmatut7

adapters/codex-exec.ts

@@ -4,6 +4,7 @@ import os from "node:os";
 import path from "node:path";
 import type { AgentAdapter, AdapterResult, AdapterRuntime, NormalizedAgentOpts } from "./types.ts";
 import type { EngineConfig, Usage } from "../engine/types.ts";
+import { isReconnectAdvisory } from "./stream-errors.ts";
 
 export class CodexExecAdapter implements AgentAdapter {
   readonly name = "codex-exec";
@@ -57,7 +58,7 @@ export class CodexExecAdapter implements AgentAdapter {
             if (event.type === "turn.failed") fatalMessage = event.error?.message ?? "codex exec turn failed";
             if (event.type === "error") {
               const message = String(event.message ?? event.error?.message ?? "");
-              if (!/^Reconnecting/i.test(message)) fatalMessage = message;
+              if (!isReconnectAdvisory(message)) fatalMessage = message;
             }
           }
         });

adapters/codex-sdk.ts

@@ -1,5 +1,6 @@
 import type { AgentAdapter, AdapterResult, AdapterRuntime, NormalizedAgentOpts } from "./types.ts";
 import type { EngineConfig, Usage } from "../engine/types.ts";
+import { isReconnectAdvisory } from "./stream-errors.ts";
 
 export class CodexSdkAdapter implements AgentAdapter {
   readonly name = "codex-sdk";
@@ -31,7 +32,7 @@ export class CodexSdkAdapter implements AgentAdapter {
       if (event.type === "turn.failed") throw new Error(event.error?.message ?? "codex turn failed");
       if (event.type === "error") {
         const message = String(event.message ?? event.error?.message ?? "");
-        if (!/^Reconnecting/i.test(message)) throw new Error(message || "codex stream error");
+        if (!isReconnectAdvisory(message)) throw new Error(message || "codex stream error");
       }
     }
     return { finalResponse, usage, threadId: thread.id ?? undefined };

adapters/stream-errors.ts

@@ -0,0 +1,5 @@
+const RECONNECTING_ADVISORY_RE = /^\s*(?:(?:\[[^\]\n]+]|\w[\w.-]*:)\s*)*Reconnecting\b/i;
+
+export function isReconnectAdvisory(message: string): boolean {
+  return RECONNECTING_ADVISORY_RE.test(message);
+}

tests/engine.test.ts

@@ -10,6 +10,7 @@ import { Semaphore } from "../engine/semaphore.ts";
 import { normalizeSchema, parseAndValidate } from "../engine/schema.ts";
 import { resolveBackend } from "../adapters/registry.ts";
 import { OpenAIResponsesAdapter } from "../adapters/openai-responses.ts";
+import { isReconnectAdvisory } from "../adapters/stream-errors.ts";
 
 async function tempDir(): Promise<string> {
   return mkdtemp(path.join(tmpdir(), "codex-workflow-test-"));
@@ -548,6 +549,14 @@ describe("dynamic workflow engine", () => {
     await rm(dir, { recursive: true, force: true });
   });
 
+  it("treats prefixed Reconnecting stream messages as advisory", () => {
+    assert.equal(isReconnectAdvisory("Reconnecting... 1/5"), true);
+    assert.equal(isReconnectAdvisory("error: Reconnecting... 1/5"), true);
+    assert.equal(isReconnectAdvisory("[warn] Reconnecting... 1/5"), true);
+    assert.equal(isReconnectAdvisory("fatal reconnecting failed"), false);
+    assert.equal(isReconnectAdvisory("error: authentication failed"), false);
+  });
+
   it("retries transient adapter errors without consuming schema repair attempts", async () => {
     const dir = await tempDir();
     const journalPath = path.join(dir, "journal.jsonl");