Spaces:
Paused
Paused
File size: 2,628 Bytes
abe58f1 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 | /**
* Direct-connection fallback for proxied requests.
*
* When a global proxy is configured, some endpoints (e.g. auth.openai.com)
* may reject the proxy IP via Cloudflare challenge or cause TLS errors.
* This module provides a generic wrapper that retries with a direct connection.
*/
import { getProxyUrl } from "./curl-binary.js";
/** Detect if an HTTP response is a Cloudflare challenge page. */
export function isCloudflareChallengeResponse(status: number, body: string): boolean {
if (status !== 403) return false;
const lower = body.toLowerCase();
return (
lower.includes("cf-mitigated") ||
lower.includes("cf-chl-bypass") ||
lower.includes("_cf_chl") ||
lower.includes("attention required") ||
lower.includes("just a moment")
);
}
/** Detect if an error is a proxy/TLS network failure worth retrying direct. */
export function isProxyNetworkError(error: unknown): boolean {
const msg = (error instanceof Error ? error.message : String(error)).toLowerCase();
return (
msg.includes("econnreset") ||
msg.includes("econnrefused") ||
msg.includes("ssl_error_syscall") ||
msg.includes("schannel") ||
msg.includes("connection reset by peer") ||
msg.includes("socket hang up") ||
msg.includes("curl exited with code 35") || // TLS handshake failure
msg.includes("curl exited with code 56") // network receive error
);
}
export interface DirectFallbackOptions<T> {
/** Label for log messages. */
tag?: string;
/** Check if a successful (non-thrown) result should trigger fallback (e.g. CF 403). */
shouldFallback?: (result: T) => boolean;
}
/**
* Execute an async operation with automatic direct-connection fallback.
*
* The callback receives `proxyUrl`:
* - First call: `undefined` (use global proxy default)
* - Fallback call: `null` (force direct, bypass proxy)
*
* If no global proxy is configured, runs once with no fallback.
*/
export async function withDirectFallback<T>(
fn: (proxyUrl: string | null | undefined) => Promise<T>,
options?: DirectFallbackOptions<T>,
): Promise<T> {
const label = options?.tag ?? "DirectFallback";
const hasProxy = getProxyUrl() !== null;
try {
const result = await fn(undefined);
if (hasProxy && options?.shouldFallback?.(result)) {
console.warn(`[${label}] Cloudflare challenge via proxy, retrying direct`);
return await fn(null);
}
return result;
} catch (err) {
if (hasProxy && isProxyNetworkError(err)) {
console.warn(`[${label}] Network/TLS error via proxy, retrying direct`);
return await fn(null);
}
throw err;
}
}
|