Function startRefillJob

lib/api/apiUtils/rateLimit/refillJob.js:71–109

* Main refill job loop * Runs periodically to proactively refill token buckets

(logger)

 * Runs periodically to proactively refill token buckets
 */
function startRefillJob(logger) {
    logger.info('starting token refill job', {
        refillIntervalMs: REFILL_INTERVAL_MS,
        cleanupIntervalMs: CLEANUP_INTERVAL_MS,
    });

    const tick = async () => {
        try {
            const stats = await refillTokenBuckets(logger);

            if (stats.refilled > 0) {
                logger.trace('refill tick completed', stats);
            }

            // Periodic cleanup (every CLEANUP_INTERVAL_MS)
            cleanupCounter++;
            if (cleanupCounter * REFILL_INTERVAL_MS >= CLEANUP_INTERVAL_MS) {
                const removed = cleanupTokenBuckets();
                if (removed > 0) {
                    logger.debug('cleaned up expired token buckets', {
                        removed,
                    });
                }
                cleanupCounter = 0;
            }
        } catch (err) {
            logger.error('refill job error', {
                method: 'rateLimit.refillJob',
                error: err.message,
                stack: err.stack,
            });
        }

        refillTimer = setTimeout(tick, REFILL_INTERVAL_MS);
    };

    // Start timer
    refillTimer = setTimeout(tick, REFILL_INTERVAL_MS);
}

/**
 * Stop the refill job