[update] fix conflict

Author: zicorn

.env.example

@@ -74,6 +74,12 @@ REDIS_SENTINEL_USERNAME=
 REDIS_SENTINEL_PASSWORD=
 REDIS_SENTINEL_SOCKET_TIMEOUT=0.1
 
+# redis cluster
+# Cluster Format: `<ip1>:<port1>,<ip2:<port2>`
+REDIS_USE_CLUSTERS=false
+REDIS_CLUSTERS=
+REDIS_CLUSTERS_PASSWORD=
+
 DB_USERNAME=postgres
 DB_PASSWORD=difyai123456
 DB_HOST=localhost

internal/utils/cache/redis.go

@@ -83,7 +83,7 @@ func InitRedisClusterClient(addrs []string, password string, useSsl bool) error
 		opts.TLSConfig = &tls.Config{}
 	}
 
-	client := redis.NewClusterClient(opts)
+	client = redis.NewClusterClient(opts)
 
 	if _, err := client.Ping(context.Background()).Result(); err != nil {
 		return err
@@ -526,8 +526,15 @@ func Publish(channel string, message any, context ...redis.Cmdable) error {
 }
 
 func Subscribe[T any](channel string) (<-chan T, func()) {
-	pubsub := client.Subscribe(ctx, channel)
 	ch := make(chan T)
+
+	if client == nil {
+		log.Error("redis client not initialized")
+		close(ch)
+		return ch, func() {}
+	}
+
+	pubsub := client.Subscribe(ctx, channel)
 	connectionEstablished := make(chan bool)
 
 	go func() {

internal/utils/cache/redis_auto_type.go

@@ -10,7 +10,7 @@ import (
 
 // Set the value with key
 func AutoSet[T any](key string, value T, context ...redis.Cmdable) error {
-	if redisClient == nil {
+	if client == nil {
 		return ErrDBNotInit
 	}
 
@@ -32,7 +32,7 @@ func AutoGet[T any](key string, context ...redis.Cmdable) (*T, error) {
 
 // Get the value with key, fallback to getter if not found, and set the value to cache
 func AutoGetWithGetter[T any](key string, getter func() (*T, error), context ...redis.Cmdable) (*T, error) {
-	if redisClient == nil {
+	if client == nil {
 		return nil, ErrDBNotInit
 	}
 
@@ -66,7 +66,7 @@ func AutoGetWithGetter[T any](key string, getter func() (*T, error), context ...
 
 // Delete the value with key
 func AutoDelete[T any](key string, context ...redis.Cmdable) (int64, error) {
-	if redisClient == nil {
+	if client == nil {
 		return 0, ErrDBNotInit
 	}