From 9546790fb4c3b3e88e711dd56caa8bd51bdf4b20 Mon Sep 17 00:00:00 2001
From: Igor Zibarev <zibarev.i@gmail.com>
Date: Fri, 1 Dec 2023 15:45:14 +0200
Subject: [PATCH] Add default port if not present in redis-cluster-nodes

---
 cmd/asynqmon/main.go | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/cmd/asynqmon/main.go b/cmd/asynqmon/main.go
index 47fed83..a120ff9 100644
--- a/cmd/asynqmon/main.go
+++ b/cmd/asynqmon/main.go
@@ -111,8 +111,18 @@ func makeRedisConnOpt(cfg *Config) (asynq.RedisConnOpt, error) {
 	// Connecting to redis-cluster
 	if len(cfg.RedisClusterNodes) > 0 {
 		cfg.RedisClusterNodes = cleanUpClusterNodes(cfg.RedisClusterNodes)
+
+		addrs := strings.Split(cfg.RedisClusterNodes, ",")
+
+		// Add default port if not present.
+		for i := range addrs {
+			if !strings.Contains(addrs[i], ":") {
+				addrs[i] = addrs[i] + ":6379"
+			}
+		}
+
 		return asynq.RedisClusterClientOpt{
-			Addrs:     strings.Split(cfg.RedisClusterNodes, ","),
+			Addrs:     addrs,
 			Password:  cfg.RedisPassword,
 			Username:  cfg.RedisUsername,
 			TLSConfig: makeTLSConfig(cfg),