Feat: Network Resilience Retry Timeout

src/plugin.ts

@@ -20,13 +20,18 @@ import { accessTokenExpired, isOAuthAuth } from './plugin/auth';
 import { logDebug, logError } from './plugin/debug';
 import { fetchBergetModels } from './plugin/models';
 import { createPkceAuthorizeMethod } from './plugin/pkce-flow';
+import { resilientFetch } from './plugin/resilient-fetch';
 import { refreshAccessTokenDirect } from './plugin/token';
 
 type FetchInput = Request | string | URL;
 
 /**
- * Wraps a native fetch call while preserving headers from both Request
+ * Wraps a resilient fetch call while preserving headers from both Request
  * objects and init, then injecting (or overwriting) Authorization.
+ *
+ * Uses resilientFetch which retries transient network errors (ECONNRESET,
+ * ETIMEDOUT, socket hang up) and server errors (502/503/504) with
+ * exponential backoff and jitter.
  */
 async function fetchWithAuth(
   authToken: string,
@@ -38,7 +43,7 @@ async function fetchWithAuth(
 
   const headers = new Headers(request.headers);
   headers.set('Authorization', `Bearer ${authToken}`);
-  return fetch(request, { headers });
+  return resilientFetch(request, { headers });
 }
 
 /**

src/plugin/auth.test.ts

@@ -1,8 +1,9 @@
 import { describe, expect, it } from 'vitest';
 
+import type { OAuthAuthDetails } from './types';
+
 import { ACCESS_TOKEN_EXPIRY_BUFFER_MS } from '../constants';
 import { accessTokenExpired } from './auth';
-import type { OAuthAuthDetails } from './types';
 
 describe('accessTokenExpired - Issue #5', () => {
   // With raw expiry storage, the buffer lives ONLY in the check.

src/plugin/models.ts

@@ -4,6 +4,7 @@
 
 import { getModelsEndpoint } from '../constants';
 import { logDebug, logError } from './debug';
+import { resilientFetch } from './resilient-fetch';
 
 // Response from /v1/models/chat endpoint
 interface ChatModel {
@@ -49,7 +50,7 @@ export async function fetchBergetModels(): Promise<Record<string, object>> {
   logDebug('Fetching chat models from Berget API');
 
   try {
-    const response = await fetch(getModelsEndpoint(), {
+    const response = await resilientFetch(getModelsEndpoint(), {
       headers: {
         'Content-Type': 'application/json',
       },