Better handle redis error events (#1652)

triggerdotdev · Jan 29, 2025 · 3eede3c · 3eede3c
1 parent b3afbcf
commit 3eede3c
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/apps/webapp/app/redis.server.ts b/apps/webapp/app/redis.server.ts
@@ -18,6 +18,8 @@ export function createRedisClient(
   connectionName: string,
   options: RedisWithClusterOptions
 ): Redis | Cluster {
+  let redis: Redis | Cluster;
+
   if (options.clusterMode) {
     const nodes: ClusterNode[] = [
       {
@@ -32,7 +34,7 @@ export function createRedisClient(
       port: options.port,
     });
 
-    return new Redis.Cluster(nodes, {
+    redis = new Redis.Cluster(nodes, {
       ...options.clusterOptions,
       redisOptions: {
         connectionName,
@@ -59,7 +61,7 @@ export function createRedisClient(
       port: options.port,
     });
 
-    return new Redis({
+    redis = new Redis({
       connectionName,
       host: options.host,
       port: options.port,
@@ -69,4 +71,10 @@ export function createRedisClient(
       ...(options.tlsDisabled ? {} : { tls: {} }),
     });
   }
+
+  redis.on("error", (error) => {
+    logger.error("Redis client error", { connectionName, error });
+  });
+
+  return redis;
 }