| 268 | } |
| 269 | |
| 270 | function createRedisStore() { |
| 271 | try { |
| 272 | const runtimeRedisOverridesEnabled = hasRuntimeRedisOverrides(); |
| 273 | const clusterConfig = getRuntimeRedisClusterOptions(); |
| 274 | const resolvedEnvPrefix = runtimeRedisOverridesEnabled ? RUNTIME_REDIS_ENV_PREFIX : "CB_REDIS"; |
| 275 | let redisClient; |
| 276 | const attachClient = () => { |
| 277 | redisClient.on("error", (error) => { |
| 278 | console.error("[runtime-cache] Redis client error", error); // oxlint-disable-line no-console |
| 279 | }); |
| 280 | |
| 281 | return { |
| 282 | backend: clusterConfig?.cluster?.nodes?.length > 0 ? "redis-cluster" : "redis", |
| 283 | envPrefix: resolvedEnvPrefix, |
| 284 | get: (...args) => redisClient.get(...args), |
| 285 | set: (key, value, ttlMs = 0) => { |
| 286 | if (ttlMs > 0) { |
| 287 | return redisClient.set(key, value, "PX", ttlMs); |
| 288 | } |
| 289 | return redisClient.set(key, value); |
| 290 | }, |
| 291 | del: (...args) => redisClient.del(...args), |
| 292 | hset: (...args) => redisClient.hset(...args), |
| 293 | hget: (...args) => redisClient.hget(...args), |
| 294 | hgetall: (...args) => redisClient.hgetall(...args), |
| 295 | hdel: (...args) => redisClient.hdel(...args), |
| 296 | zscore: (...args) => redisClient.zscore(...args), |
| 297 | zincrby: (...args) => redisClient.zincrby(...args), |
| 298 | zrevrange: (...args) => redisClient.zrevrange(...args), |
| 299 | zrem: (...args) => redisClient.zrem(...args), |
| 300 | zcard: (...args) => redisClient.zcard(...args), |
| 301 | zremrangebyrank: (...args) => redisClient.zremrangebyrank(...args), |
| 302 | }; |
| 303 | }; |
| 304 | |
| 305 | const createMemoryStore = () => { |
| 306 | const memoryStore = new InMemoryRuntimeStore(); |
| 307 | return { |
| 308 | backend: "memory", |
| 309 | envPrefix: resolvedEnvPrefix, |
| 310 | clear: () => { |
| 311 | memoryStore.values.clear(); |
| 312 | memoryStore.sortedSets.clear(); |
| 313 | memoryStore.hashes.clear(); |
| 314 | }, |
| 315 | get: (...args) => memoryStore.get(...args), |
| 316 | set: (...args) => memoryStore.set(...args), |
| 317 | del: (...args) => memoryStore.del(...args), |
| 318 | hset: (...args) => memoryStore.hset(...args), |
| 319 | hget: (...args) => memoryStore.hget(...args), |
| 320 | hgetall: (...args) => memoryStore.hgetall(...args), |
| 321 | hdel: (...args) => memoryStore.hdel(...args), |
| 322 | zscore: (...args) => memoryStore.zscore(...args), |
| 323 | zincrby: (...args) => memoryStore.zincrby(...args), |
| 324 | zrevrange: (...args) => memoryStore.zrevrange(...args), |
| 325 | zrem: (...args) => memoryStore.zrem(...args), |
| 326 | zcard: (...args) => memoryStore.zcard(...args), |
| 327 | zremrangebyrank: (...args) => memoryStore.zremrangebyrank(...args), |