From d5f49ccaa1a65abc14170735dd1fa5adddf41487 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Joakim=20J=C3=A4derberg?=
 <joakim.jaderberg@scandichotels.com>
Date: Wed, 18 Jun 2025 06:38:48 +0000
Subject: [PATCH] Merged in fix/batch-size-in-env (pull request #2384)

fix: able to set batch delete size via env

* fix: able to set batch delete size via env


Approved-by: Linus Flood
---
 apps/redis-api/src/env.ts              | 5 +++--
 apps/redis-api/src/routes/api/cache.ts | 3 ++-
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/apps/redis-api/src/env.ts b/apps/redis-api/src/env.ts
index 18d32ed61..0dbb888fe 100644
--- a/apps/redis-api/src/env.ts
+++ b/apps/redis-api/src/env.ts
@@ -12,7 +12,7 @@ export const env = createEnv({
             .transform(
                 () =>
                     process.env.BUN_ENV === "production" ||
-                    process.env.NODE_ENV === "production"
+                    process.env.NODE_ENV === "production",
             ),
         IS_DEV: z
             .boolean()
@@ -20,7 +20,7 @@ export const env = createEnv({
             .transform(
                 () =>
                     process.env.BUN_ENV === "development" ||
-                    process.env.NODE_ENV === "development"
+                    process.env.NODE_ENV === "development",
             ),
         VERSION: z.string().min(1).default("development"),
         PORT: z.coerce.number().default(3001),
@@ -44,6 +44,7 @@ export const env = createEnv({
             .refine((s) => s === "true" || s === "false")
             .transform((s) => s === "true"),
         SENTRY_TRACE_SAMPLE_RATE: z.coerce.number().default(0.001),
+        DELETE_BATCH_SIZE: z.coerce.number().default(2000),
     },
     createFinalSchema: (shape) => {
         return z.object(shape).transform((env, ctx) => {
diff --git a/apps/redis-api/src/routes/api/cache.ts b/apps/redis-api/src/routes/api/cache.ts
index c1966a636..173a19f94 100644
--- a/apps/redis-api/src/routes/api/cache.ts
+++ b/apps/redis-api/src/routes/api/cache.ts
@@ -6,6 +6,7 @@ import { redis } from "@/services/redis";
 import { loggerModule } from "@/utils/logger";
 import { timeout } from "@/utils/timeout";
 import { truncate } from "@/utils/truncate";
+import { env } from "@/env";
 
 const MIN_LENGTH = 1;
 
@@ -112,7 +113,7 @@ function validateKey(key: string) {
 
 async function deleteWithPattern(pattern: string) {
     let cursor = "0";
-    const SCAN_SIZE = 1000;
+    const SCAN_SIZE = env.DELETE_BATCH_SIZE;
 
     let totalDeleteCount = 0;