Class ApiClient

static/js/utils.js:175–426

// ============================================

class ApiClient {
    constructor(baseUrl = '/api') {
        this.baseUrl = baseUrl;
        this.inflightRequests = new Map();
        this.activeRequestCount = 0;
        this.maxConcurrentRequests = 6;
        this.requestQueue = [];
        this.networkOnline = typeof navigator === 'undefined' ? true : navigator.onLine !== false;
        this._networkToastState = { type: '', at: 0 };
        this.defaultTimeoutMs = 20000;
        this.defaultRetryCount = 1;
        this.defaultRetryDelayMs = 900;
        this.setupNetworkListeners();
    }

    getAdaptiveTimeoutMs() {
        const connection = navigator?.connection || navigator?.mozConnection || navigator?.webkitConnection;
        const effectiveType = String(connection?.effectiveType || '').toLowerCase();
        if (effectiveType === 'slow-2g' || effectiveType === '2g') return 45000;
        if (effectiveType === '3g') return 30000;
        return this.defaultTimeoutMs;
    }

    cleanupInflightRequest(requestKey, controller) {
        if (!requestKey) return;
        const current = this.inflightRequests.get(requestKey);
        if (current === controller) {
            this.inflightRequests.delete(requestKey);
        }
    }

    setupNetworkListeners() {
        if (typeof window === 'undefined' || !window.addEventListener) return;
        window.addEventListener('online', () => {
            this.networkOnline = true;
            this.notifyNetworkState('网络已恢复', 'success', 2000);
        });
        window.addEventListener('offline', () => {
            this.networkOnline = false;
            this.notifyNetworkState('网络已断开，后台轮询将自动降频', 'warning', 6000);
        });
    }

    notifyNetworkState(message, type, throttleMs = 3000) {
        const now = Date.now();
        if (
            this._networkToastState.type === type &&
            now - Number(this._networkToastState.at || 0) < throttleMs
        ) {
            return;
        }
        this._networkToastState = { type, at: now };
        if (type === 'warning') {
            toast.warning(message, 2500);
            return;
        }
        if (type === 'success') {
            toast.success(message, 1800);