Function proxyWithRetry

worker.js:767–794

(request, info)

    if (b.state === 'OPEN') {
        if (now - b.lastFailureTime >= CIRCUIT_BREAKER.TIMEOUT) {
            b.state = 'HALF_OPEN';
            b.halfOpenAttempts = 0;
            return 'HALF_OPEN';
        }
        return 'OPEN';
    }

    if (b.state === 'HALF_OPEN') {
        if (b.halfOpenAttempts >= CIRCUIT_BREAKER.HALF_OPEN_MAX_CALLS) return 'OPEN';
        b.halfOpenAttempts++;
    }

    return b.state;
}

function updateCircuitBreaker(clientIP, success) {
    let b = circuitBreakers.get(clientIP);
    if (!b) {
        if (circuitBreakers.size >= CACHE_MAX_SIZE) {
            circuitBreakers.delete(circuitBreakers.keys().next().value);
        }
        b = { state: 'CLOSED', failureCount: 0, lastFailureTime: 0, halfOpenAttempts: 0 };
        circuitBreakers.set(clientIP, b);
    }

    if (success) {
        if (b.state === 'HALF_OPEN')   { b.state = 'CLOSED'; b.failureCount = 0; }
        else if (b.state === 'CLOSED') b.failureCount = Math.max(0, b.failureCount - 1);
    } else {
        b.failureCount++;
        b.lastFailureTime = Date.now();