From 3f90abe19652f092a43098b727290610ed575001 Mon Sep 17 00:00:00 2001
From: Atridad Lahiji <me@atri.dad>
Date: Mon, 8 Apr 2024 23:19:24 -0600
Subject: [PATCH] Switched to REDIS_URL for ease of config

---
 .env.example                       |  3 +--
 lib/pubsub/adapters/redispubsub.go | 17 +++++++++--------
 2 files changed, 10 insertions(+), 10 deletions(-)

diff --git a/.env.example b/.env.example
index 9514569..536f073 100644
--- a/.env.example
+++ b/.env.example
@@ -5,8 +5,7 @@ SMTP_PORT=""
 SMTP_USERNAME=""
 SMTP_PASSWORD=""
 STRIPE_SECRET_KEY=""
-REDIS_HOST=""
-REDIS_PASSWORD=""
+REDIS_URL=""
 BUCKET_NAME=
 AWS_REGION=
 AWS_ENDPOINT_URL_S3=
diff --git a/lib/pubsub/adapters/redispubsub.go b/lib/pubsub/adapters/redispubsub.go
index 552e36a..6166c01 100644
--- a/lib/pubsub/adapters/redispubsub.go
+++ b/lib/pubsub/adapters/redispubsub.go
@@ -27,15 +27,16 @@ func NewRedisClient() *redis.Client {
 	}
 
 	godotenv.Load(".env")
-	redis_host := os.Getenv("REDIS_HOST")
-	redis_password := os.Getenv("REDIS_PASSWORD")
+	redis_url := os.Getenv("REDIS_URL")
 
-	lib.LogInfo.Printf("\n[PUBSUB/REDIS]Connecting to Redis at %s\n", redis_host)
-	RedisClient = redis.NewClient(&redis.Options{
-		Addr:     redis_host,
-		Password: redis_password,
-		DB:       0,
-	})
+	opts, err := redis.ParseURL(redis_url)
+
+	if err != nil {
+		return nil
+	}
+
+	lib.LogInfo.Printf("\n[PUBSUB/REDIS]Connecting to Redis at %s\n", opts.ClientName)
+	RedisClient = redis.NewClient(opts)
 
 	return RedisClient
 }