Fix proxy transport responses locking accounts

Author: gitcommit90

CHANGELOG.md

@@ -9,6 +9,12 @@ Release tags use the form `vX.Y.Z` and match `package.json`. GitHub Releases car
 
 ## [Unreleased]
 
+## [0.5.12] - 2026-08-12
+
+### Fixed
+
+- Proxy-generated HTTP 502/503/504 connection-reset responses now use the same retry, no-lock, and route-fallback behavior as thrown socket failures.
+
 ## [0.5.11] - 2026-08-12
 
 ### Fixed

package-lock.json

@@ -1,7 +1,7 @@
 {
   "name": "@gitcommit90/rerouted",
   "productName": "ReRouted",
-  "version": "0.5.11",
+  "version": "0.5.12",
   "description": "A local AI router for connected accounts, models, named routes, and automatic fallback.",
   "author": "gitcommit90",
   "license": "MIT",

package.json

@@ -274,6 +274,14 @@ function classifyFailure(status, errorText) {
       text
     );
   if (request) return { eligible: false, kind: "request", defaultCooldownMs: 0 };
+  const transportResponse =
+    [502, 503, 504].includes(Number(status)) &&
+    /upstream connect error|disconnect\/reset before headers|reset reason:\s*(?:connection|remote)|connection (?:termination|reset|refused)|socket hang up|tls (?:handshake|connection)|(?:dns|name) resolution|no healthy upstream|upstream (?:request )?timeout|gateway timeout/.test(
+      text
+    );
+  if (transportResponse) {
+    return { eligible: false, kind: "transport", defaultCooldownMs: 0 };
+  }
   const capability =
     (status === 400 || status === 404 || status === 422) &&
     (/(?:unsupported|invalid|unknown)[ _-]?model|model[ _-]?(?:not[ _-]?found|unsupported|unavailable)/.test(
@@ -1014,6 +1022,7 @@ function createRouter({
             failureKind: classification.kind,
             defaultCooldownMs: classification.defaultCooldownMs,
             resetAt: inspected.failure.resetAt,
+            transportError: classification.kind === "transport",
           };
         }
         if (inspected.openAiJson) {
@@ -1076,6 +1085,7 @@ function createRouter({
           failureKind: classification.kind,
           defaultCooldownMs: classification.defaultCooldownMs,
           resetAt: parseResetHint(res, text),
+          transportError: classification.kind === "transport",
         };
       }
 
@@ -1186,6 +1196,7 @@ function createRouter({
           failureKind: classification.kind,
           defaultCooldownMs: classification.defaultCooldownMs,
           resetAt: parseResetHint(res, JSON.stringify(raw)),
+          transportError: classification.kind === "transport",
         };
       }
       let openAiJson = raw;

src/lib/router.js

@@ -320,6 +320,43 @@ describe("Claude Code canonical named routes", () => {
 });
 
 describe("same-provider OAuth account fallback", () => {
+  it("retries an HTTP proxy connection reset without locking the account", async () => {
+    const store = createStore(tmpConfig());
+    store.seed({ providers: [chatgptAccount("prov_a", "token-a", 100)] });
+    const logger = captureLogger();
+    let calls = 0;
+    const router = createRouter({
+      store,
+      logger,
+      transportRetryDelayMs: 0,
+      fetchImpl: async () => {
+        calls += 1;
+        if (calls < 3) {
+          return new Response(
+            "upstream connect error or disconnect/reset before headers. reset reason: connection termination",
+            { status: 503 }
+          );
+        }
+        return responsesSuccessResponse("recovered");
+      },
+    });
+
+    const result = await router.chatCompletions({
+      body: {
+        model: "chatgpt/gpt-5.4",
+        messages: [{ role: "user", content: "hello" }],
+        stream: false,
+      },
+    });
+
+    assert.equal(result.ok, true, JSON.stringify(result.error));
+    assert.equal(calls, 3);
+    assert.deepEqual(store.load().providers[0].modelLocks, {});
+    const retries = logger.entries.filter((entry) => entry.meta?.event === "transport_retry_scheduled");
+    assert.equal(retries.length, 2);
+    assert.match(retries[0].meta.error, /disconnect\/reset before headers/);
+  });
+
   it("retries transport failures without locking the account", async () => {
     const store = createStore(tmpConfig());
     store.seed({ providers: [chatgptAccount("prov_a", "token-a", 100)] });