From 1ea5aea6b31bb95b7b537128691ecbd39112d201 Mon Sep 17 00:00:00 2001
From: LittleSheep <littlesheep.code@hotmail.com>
Date: Sat, 29 Mar 2025 15:11:07 +0800
Subject: [PATCH] :zap: Prevent from creating multiple redis client

---
 pkg/nex/cachekit/rdb.go | 20 +++++++++++++++++++-
 1 file changed, 19 insertions(+), 1 deletion(-)

diff --git a/pkg/nex/cachekit/rdb.go b/pkg/nex/cachekit/rdb.go
index 1bac9b5..766afa1 100644
--- a/pkg/nex/cachekit/rdb.go
+++ b/pkg/nex/cachekit/rdb.go
@@ -3,24 +3,41 @@ package cachekit
 import (
 	"context"
 	"fmt"
+	"sync"
 	"time"
 
 	"git.solsynth.dev/hypernet/nexus/pkg/nex"
 	"github.com/redis/go-redis/v9"
 )
 
+// The global variable below is used to keep there will only be one redis client exist in a single instance
+// Prevent if other DirectAccess™ SDK creating too many redis clients
+// And able to recreate the conn with different options
+var (
+	rdc *redis.Client
+	rdl *sync.Mutex
+)
+
 type Conn struct {
 	n       *nex.Conn
 	Rd      *redis.Client
 	Timeout time.Duration
 }
 
-func NewCaConn(conn *nex.Conn, timeout time.Duration) (*Conn, error) {
+func NewConn(conn *nex.Conn, timeout time.Duration) (*Conn, error) {
+	rdl.Lock()
+	defer rdl.Unlock()
+
 	c := &Conn{
 		n:       conn,
 		Timeout: timeout,
 	}
 
+	if rdc != nil {
+		c.Rd = rdc
+		return c, nil
+	}
+
 	rdb := conn.AllocResource(nex.AllocatableResourceCache)
 	if rdb == nil {
 		return nil, fmt.Errorf("unable to allocate resource: cache")
@@ -28,6 +45,7 @@ func NewCaConn(conn *nex.Conn, timeout time.Duration) (*Conn, error) {
 		return nil, fmt.Errorf("allocated cache resource is not a redis client")
 	} else {
 		c.Rd = client
+		rdc = client
 	}
 
 	return c, nil