fix(openai-native): add resume logging and abort polling on 401/403; remove duplicate backgroundStatus test

Author: hannesrudolph

src/api/providers/openai-native.ts

@@ -1256,6 +1256,9 @@ export class OpenAiNativeHandler extends BaseProvider implements SingleCompletio
 		for (let attempt = 0; attempt < resumeMaxRetries; attempt++) {
 			try {
 				const resumeUrl = `${baseUrl}/v1/responses/${responseId}?stream=true&starting_after=${lastSeq}`
+				console.warn(
+					`[OpenAI Native] Resume attempt ${attempt + 1}/${resumeMaxRetries} for response ${responseId} (starting_after=${lastSeq})`,
+				)
 				const res = await fetch(resumeUrl, {
 					method: "GET",
 					headers: {
@@ -1295,9 +1298,17 @@ export class OpenAiNativeHandler extends BaseProvider implements SingleCompletio
 				} catch (e) {
 					// Resume stream failed mid-flight; reset and throw to retry
 					this.resumeCutoffSequence = undefined
+					console.warn(
+						`[OpenAI Native] Resume stream failed on attempt ${attempt + 1}/${resumeMaxRetries} for ${responseId}:`,
+						e,
+					)
 					throw e
 				}
-			} catch {
+			} catch (err) {
+				console.warn(
+					`[OpenAI Native] Resume attempt ${attempt + 1}/${resumeMaxRetries} failed for ${responseId}:`,
+					err,
+				)
 				// Wait with backoff before next attempt
 				const delay = resumeBaseDelayMs * Math.pow(2, attempt)
 				if (delay > 0) {
@@ -1307,6 +1318,9 @@ export class OpenAiNativeHandler extends BaseProvider implements SingleCompletio
 		}
 
 		// Resume failed - begin polling fallback
+		console.warn(
+			`[OpenAI Native] Resume failed after ${resumeMaxRetries} attempts for ${responseId}; falling back to polling.`,
+		)
 		yield {
 			type: "status",
 			mode: "background",
@@ -1330,15 +1344,26 @@ export class OpenAiNativeHandler extends BaseProvider implements SingleCompletio
 				})
 
 				if (!pollRes.ok) {
-					// transient; wait and retry
+					// Bail on permanent auth/permission failures
+					if (pollRes.status === 401 || pollRes.status === 403) {
+						throw new Error(`Background polling aborted (${pollRes.status}) for ${responseId}`)
+					}
+					// Log and retry for transient errors (rate limits, server errors, etc.)
+					console.warn(
+						`[OpenAI Native] Polling HTTP ${pollRes.status} for ${responseId}; retrying in ${pollIntervalMs}ms`,
+					)
 					await new Promise((r) => setTimeout(r, pollIntervalMs))
 					continue
 				}
 
 				let raw: any
 				try {
 					raw = await pollRes.json()
-				} catch {
+				} catch (err) {
+					console.warn(
+						`[OpenAI Native] Polling JSON parse error for ${responseId}; retrying in ${pollIntervalMs}ms`,
+						err,
+					)
 					await new Promise((r) => setTimeout(r, pollIntervalMs))
 					continue
 				}
@@ -1415,8 +1440,13 @@ export class OpenAiNativeHandler extends BaseProvider implements SingleCompletio
 				if (status === "failed" || status === "canceled") {
 					throw new Error(`Response ${status}: ${respId || responseId}`)
 				}
-			} catch {
-				// ignore transient poll errors
+			} catch (err) {
+				// Bail out on permanent failures propagated from above
+				if (err instanceof Error && err.message.startsWith("Background polling aborted")) {
+					throw err
+				}
+				// Otherwise, ignore transient poll errors but log for diagnosis
+				console.warn(`[OpenAI Native] Polling error for ${responseId}; retrying`, err)
 			}
 
 			await new Promise((r) => setTimeout(r, pollIntervalMs))