cartsnitch/api
12
0
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

CAR-1283 rebase onto dev: update src/cartsnitch_api/middleware/rate_limit.py
CI / lint (pull_request) Has been cancelled
Details
CI / typecheck (pull_request) Has been cancelled
Details
CI / test (pull_request) Has been cancelled
Details
CI / build-and-push (pull_request) Has been cancelled
Details

Browse Source
This commit is contained in:
Barcode Betty
2026-06-06 00:39:19 +00:00
parent 1d8ecc4286
commit c243014cd1
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/cartsnitch_api/middleware/rate_limit.py
+3 -1
View File
@@ -26,6 +26,7 @@ class RateLimitBackend(Protocol):
"""Protocol for rate limit backends.""" """Protocol for rate limit backends."""
max_requests: int max_requests: int
window_seconds: int
async def is_allowed(self, key: str) -> tuple[bool, int, int]: async def is_allowed(self, key: str) -> tuple[bool, int, int]:
"""Check if request is allowed. Returns (allowed, remaining, retry_after).""" """Check if request is allowed. Returns (allowed, remaining, retry_after)."""
@@ -84,7 +85,8 @@ class RedisSlidingWindow:
if current_count >= self.max_requests: if current_count >= self.max_requests:
oldest = await self.redis.zrange(key, 0, 0, withscores=True) oldest = await self.redis.zrange(key, 0, 0, withscores=True)
if oldest: if oldest:
retry_after = int((float(oldest[0][1]) - cutoff) / 1000) + 1 oldest_score = float(oldest[0][1])
retry_after = int((oldest_score - cutoff) / 1000) + 1
else: else:
retry_after = self.window_seconds retry_after = self.window_seconds
return False, 0, retry_after return False, 0, retry_after