fix init cache automatically

Author: ochom

cache/cache.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"time"
 
+	"github.com/ochom/gutils/env"
 	"github.com/ochom/gutils/helpers"
 	"github.com/redis/go-redis/v9"
 )
@@ -22,27 +23,27 @@ var conn Cache
 
 // default to memory cache
 func init() {
-	conn = newMemoryCache()
-
-	go conn.cleanUp()
-}
-
-// NewCache ...
-func Init(driver CacheDriver, url ...string) error {
-	if driver == Memory {
-		// cache is already running return nil
-		return nil
+	driver := env.Get("CACHE_DRIVER", "memory")
+	if driver == "memory" {
+		conn = newMemoryCache()
+	} else {
+		url := env.Get("REDIS_URL", "localhost:6379")
+		password := env.Get("REDIS_PASSWORD", "")
+		dbIndex := env.Int("REDIS_DB_INDEX", 0)
+		con, err := newRedisCache(&Config{
+			Url:      url,
+			DbIndex:  dbIndex,
+			Password: password,
+		})
+
+		if err != nil {
+			panic(err)
+		}
+
+		conn = con
 	}
 
-	cn, err := newRedisCache(url...)
-	if err != nil {
-		return err
-	}
-
-	conn = cn
-
 	go conn.cleanUp()
-	return nil
 }
 
 // Client ...

cache/redis.go

@@ -2,7 +2,6 @@ package cache
 
 import (
 	"context"
-	"errors"
 	"time"
 
 	"github.com/ochom/gutils/logs"
@@ -14,19 +13,12 @@ type redisCache struct {
 	client *redis.Client
 }
 
-func newRedisCache(url ...string) (Cache, error) {
-	if len(url) == 0 {
-		logs.Error("newRedisCache: url is empty")
-		return nil, errors.New("url is empty")
-	}
-
-	opt, err := redis.ParseURL(url[0])
-	if err != nil {
-		logs.Error("newRedisCache: %s", err.Error())
-		return nil, err
-	}
-
-	cl := redis.NewClient(opt)
+func newRedisCache(cfg *Config) (Cache, error) {
+	cl := redis.NewClient(&redis.Options{
+		Addr:     cfg.Url,
+		Password: cfg.Password,
+		DB:       cfg.DbIndex,
+	})
 	return &redisCache{
 		client: cl,
 	}, nil

cache/domain.go cache/types.go

@@ -23,3 +23,10 @@ type cacheItem struct {
 func (c cacheItem) expired() bool {
 	return time.Since(c.createdAt) > c.expiry
 }
+
+// Config ...
+type Config struct {
+	Url      string
+	DbIndex  int
+	Password string
+}