diff --git a/redis/redis.go b/redis/redis.go index 8b6f3ee90e61adc85730839b897cbaa2a909809c..2d66e19f5d92095009757b92aa3822d6ceed2ad8 100644 --- a/redis/redis.go +++ b/redis/redis.go @@ -43,32 +43,31 @@ func GetRedisClient(isDebug bool) *ClientWithHelpers { } func connectToRedis(isDebug bool) *ClientWithHelpers { - if os.Getenv("REDIS_HOST") != "false" { - - host := os.Getenv("REDIS_HOST") - port := os.Getenv("REDIS_PORT") - - if isDebug { - env := os.Getenv("ENVIRONMENT") - switch env { - case "dev": - port = "6380" - case "stage": - port = "6381" - case "sandbox", "qa": - port = "6382" - case "prod": - port = "6383" - } + redisHost := os.Getenv("REDIS_HOST") + if redisHost == "false" || redisHost == "" { + return &ClientWithHelpers{ + Client: nil, + Available: false, } - - return NewClient(host + ":" + port) } - return &ClientWithHelpers{ - Client: nil, - Available: false, + host := redisHost + port := os.Getenv("REDIS_PORT") + + if isDebug { + env := os.Getenv("ENVIRONMENT") + switch env { + case "dev": + port = "6380" + case "stage": + port = "6381" + case "sandbox", "qa": + port = "6382" + case "prod": + port = "6383" + } } + return NewClient(host + ":" + port) } func NewClient(addr string) *ClientWithHelpers {