+11

src/runner/loop-completion.ts

View file Reviewed

··· 612 612 promptTooLargeAttempts++ 613 613 if (recovered) continue 614 614 } 615 615 + if (shouldFallback(fallbackErr)) { 616 616 + const retryAfter = retryDelayMs(fallbackErr) 617 617 + console.warn( 618 618 + `[fallback] transient failure (${errorSummary(fallbackErr)}); retrying after ${Math.ceil(retryAfter / 1000)}s`, 619 619 + ) 620 620 + console.log( 621 621 + `[runner] backing off ${Math.ceil(retryAfter / 1000)}s (until ${formatRetryAt(retryAfter)}) before retrying fallback...`, 622 622 + ) 623 623 + await sleep(retryAfter) 624 624 + continue 625 625 + } 615 626 logApiError(fallbackErr, `model=${FALLBACK_MODEL} api=${FALLBACK_BASE}`) 616 627 throw fallbackErr 617 628 }

+2 -1

src/runner/loop.ts

View file Reviewed

··· 41 41 } 42 42 43 43 async function stopLoopForGuard(state: LoopState, hooks: LoopHooks, reason: string): Promise<RunLoopExit> { 44 44 - const guardMessage = `[system] safety stop: ${reason}. pausing until a new external event wakes niri again.` 44 44 + const guardMessage = 45 45 + `[system] hey, you've been going for a while (${reason}). are you stuck and need to tell who you're talking to there's a problem? or is nothing happening and maybe it's time for a rest? remember to tell your important people you are resting if you are going to.` 45 46 console.warn(`[runner] ${reason}`) 46 47 state.conversation.push({ 47 48 role: "user",

+17 -1

src/runner/util.test.ts

View file Reviewed

··· 1 1 import assert from "node:assert/strict" 2 2 import test from "node:test" 3 3 - import { sanitizeMessages } from "./util.js" 3 3 + import { isTransientTransportError, sanitizeMessages, shouldFallback } from "./util.js" 4 4 5 5 test("sanitizeMessages backfills empty reasoning_content for assistant history", () => { 6 6 const messages = sanitizeMessages([ ··· 21 21 assert.equal(assistant.role, "assistant") 22 22 assert.equal(assistant.reasoning_content, "") 23 23 }) 24 24 + 25 25 + test("terminated fetch errors are treated as retryable transport failures", () => { 26 26 + const err = new TypeError("terminated") 27 27 + 28 28 + assert.equal(isTransientTransportError(err), true) 29 29 + assert.equal(shouldFallback(err), true) 30 30 + }) 31 31 + 32 32 + test("nested undici errors are treated as retryable transport failures", () => { 33 33 + const cause = new Error("other side closed") 34 34 + const nested = new TypeError("fetch failed") as TypeError & { cause?: unknown } 35 35 + nested.cause = cause 36 36 + 37 37 + assert.equal(isTransientTransportError(nested), true) 38 38 + assert.equal(shouldFallback(nested), true) 39 39 + })

+26 -4

src/runner/util.ts

View file Reviewed

··· 632 632 if (!err.status || err.status === 429 || err.status >= 500) return true 633 633 return false 634 634 } 635 635 - // Node fetch errors (ECONNREFUSED, ENOTFOUND, ETIMEDOUT…) 636 636 - if (err instanceof Error) { 637 637 - return /ECONNREFUSED|ENOTFOUND|ETIMEDOUT|ECONNRESET|fetch failed/i.test(err.message) 635 635 + return isTransientTransportError(err) 636 636 + } 637 637 + 638 638 + function errorCauseChainText(err: unknown): string { 639 639 + const parts: string[] = [] 640 640 + let current: unknown = err 641 641 + 642 642 + for (let depth = 0; depth < 4 && current instanceof Error; depth++) { 643 643 + parts.push(current.name, current.message) 644 644 + const withMetadata = current as Error & { code?: unknown; cause?: unknown } 645 645 + if (typeof withMetadata.code === "string") parts.push(withMetadata.code) 646 646 + current = withMetadata.cause 638 647 } 639 639 - return false 648 648 + 649 649 + return parts.join("\n") 650 650 + } 651 651 + 652 652 + /** 653 653 + * Detects retryable network/stream failures thrown below the OpenAI SDK. 654 654 + */ 655 655 + export function isTransientTransportError(err: unknown): boolean { 656 656 + if (!(err instanceof Error)) return false 657 657 + 658 658 + const text = errorCauseChainText(err) 659 659 + return /ECONNREFUSED|ENOTFOUND|ETIMEDOUT|ECONNRESET|EPIPE|UND_ERR|fetch failed|terminated|socket hang up|other side closed|aborted/i.test( 660 660 + text, 661 661 + ) 640 662 } 641 663 642 664 const PROMPT_TOO_LARGE_PHRASES = [