From a92644b01df5852e2f9e2f76231bd45f23e75f90 Mon Sep 17 00:00:00 2001
From: "google-labs-jules[bot]"
 <161369871+google-labs-jules[bot]@users.noreply.github.com>
Date: Sun, 31 May 2026 05:35:17 +0000
Subject: [PATCH] =?UTF-8?q?=E2=9A=A1=20Bolt:=20optimize=20rate=20limiter?=
 =?UTF-8?q?=20by=20consolidating=20Redis=20calls?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Consolidate the `zrange` call into the existing Redis pipeline in `SlidingWindowRateLimiter`.
This reduces network round-trips from 2 to 1 for allowed requests, and from 3 to 2 for blocked requests,
measurably improving latency for rate-limited endpoints.

Co-authored-by: hackerxj2010 <198651211+hackerxj2010@users.noreply.github.com>
---
 .jules/bolt.md              |  0
 packages/cache/src/index.ts | 10 ++++++----
 2 files changed, 6 insertions(+), 4 deletions(-)
 create mode 100644 .jules/bolt.md

diff --git a/.jules/bolt.md b/.jules/bolt.md
new file mode 100644
index 0000000..e69de29
diff --git a/packages/cache/src/index.ts b/packages/cache/src/index.ts
index 1d0be6e..8860552 100644
--- a/packages/cache/src/index.ts
+++ b/packages/cache/src/index.ts
@@ -132,17 +132,21 @@ export class SlidingWindowRateLimiter {
       const member = `${now}:${crypto.randomUUID()}`;
       const cutoff = now - limit.windowMs;
 
+      // ⚡ Bolt: Consolidate all Redis operations into a single pipeline to reduce network round-trips.
+      // This reduces round-trips from 2 to 1 for allowed requests, and 3 to 2 for blocked requests.
       const pipeline = this.redis.pipeline();
       pipeline.zremrangebyscore(key, 0, cutoff);
       pipeline.zadd(key, now, member);
       pipeline.zcard(key);
       pipeline.pexpire(key, limit.windowMs);
+      pipeline.zrange(key, 0, 0, "WITHSCORES");
       const results = await pipeline.exec();
+
       const count = Number(results?.[2]?.[1] ?? 0);
+      const oldestRaw = (results?.[4]?.[1] as string[]) ?? [];
+      const oldest = oldestRaw.length >= 2 ? Number(oldestRaw[1]) : now;
 
       if (count <= limit.limit) {
-        const oldestRaw = await this.redis.zrange(key, 0, 0, "WITHSCORES");
-        const oldest = oldestRaw.length >= 2 ? Number(oldestRaw[1]) : now;
         return {
           allowed: true,
           identifier,
@@ -154,8 +158,6 @@ export class SlidingWindowRateLimiter {
       }
 
       await this.redis.zrem(key, member);
-      const oldestRaw = await this.redis.zrange(key, 0, 0, "WITHSCORES");
-      const oldest = oldestRaw.length >= 2 ? Number(oldestRaw[1]) : now;
       const stableCount = Math.max(0, count - 1);
       return {
         allowed: false,