Merge pull request #12 from InternetMaximalism/tls-support

push redis

Author: signature18632

packages/shared/src/lib/redis.ts

@@ -11,7 +11,9 @@ export class RedisClient {
       return;
     }
 
-    this.client = new Redis(config.REDIS_URL, {
+    const redisUrl = this.getRedisURL();
+
+    this.client = new Redis(redisUrl, {
       reconnectOnError: (err) => {
         const targetError = "READONLY";
         if (err.message.includes(targetError)) {
@@ -30,6 +32,16 @@ export class RedisClient {
     });
   }
 
+  private getRedisURL(): string {
+    const hasQueryParams = config.REDIS_URL.includes("?");
+
+    if (config.REDIS_URL.includes("rediss")) {
+      return hasQueryParams ? `${config.REDIS_URL}&tls=true` : `${config.REDIS_URL}?tls=true`;
+    }
+
+    return config.REDIS_URL;
+  }
+
   public static getInstance(): RedisClient {
     if (!RedisClient.instance) {
       RedisClient.instance = new RedisClient();