From aa47344a9d4f659a9f046fadbeae39f9c9e88ae4 Mon Sep 17 00:00:00 2001 From: Xi Xu Date: Wed, 11 Mar 2026 14:18:04 +0800 Subject: [PATCH] Revert "Await proxy endpoints and simplify delayRequest" This reverts commit 0d7a0267618bdcc8ad338215b83434b14b601b34. --- src/lib/rateLimit.ts | 21 ++++++++++++++++----- 1 file changed, 16 insertions(+), 5 deletions(-) diff --git a/src/lib/rateLimit.ts b/src/lib/rateLimit.ts index cbd5d17..477dc22 100644 --- a/src/lib/rateLimit.ts +++ b/src/lib/rateLimit.ts @@ -33,8 +33,8 @@ export interface RateLimitResult { * @param env Environment bindings containing proxy configuration * @returns Object containing calculated rate limits */ -async function getDynamicRateLimits(env: Env) { - const proxyEndpoints = await getProxyEndpoints(env); +function getDynamicRateLimits(env: Env) { + const proxyEndpoints = getProxyEndpoints(env); return calculateDynamicRateLimits(proxyEndpoints.length); } @@ -81,7 +81,7 @@ async function checkRateLimit(clientIP: string, env: Env): Promise { const now = Date.now(); try { - const rateLimits = await getDynamicRateLimits(env); + const rateLimits = getDynamicRateLimits(env); const maxTokens = rateLimits.TOKENS_PER_MINUTE; // Check in-memory cache @@ -167,8 +167,19 @@ async function checkRateLimit(clientIP: string, env: Env): Promise { * @returns Promise that resolves after the specified delay */ export async function delayRequest(seconds: number): Promise { - const delayMs = Math.max(0, Math.round(seconds * 1000)); - await new Promise((resolve) => setTimeout(resolve, delayMs)); + return new Promise((resolve) => { + // Use a simple delay implementation for Workers environment + const start = Date.now(); + const checkTime = () => { + if (Date.now() - start >= seconds * 1000) { + resolve(); + } else { + // Use minimal delay to prevent blocking + Promise.resolve().then(checkTime); + } + }; + checkTime(); + }); } /**