From 5a976e3ef7abac9a1a760d757fce472af4cd547b Mon Sep 17 00:00:00 2001
From: skiffer-git <44203734@qq.com>
Date: Mon, 13 May 2024 15:04:59 +0800
Subject: [PATCH] Add etcd as a service discovery mechanism

---
 internal/msggateway/n_ws_server.go        | 1 +
 internal/push/onlinepusher.go             | 1 +
 pkg/common/discoveryregister/etcd/etcd.go | 3 ++-
 3 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/internal/msggateway/n_ws_server.go b/internal/msggateway/n_ws_server.go
index 515e1f7e8..defec16df 100644
--- a/internal/msggateway/n_ws_server.go
+++ b/internal/msggateway/n_ws_server.go
@@ -211,6 +211,7 @@ func (ws *WsServer) sendUserOnlineInfoToOtherNode(ctx context.Context, client *C
 
 	// Online push user online message to other node
 	for _, v := range conns {
+		v := v
 		log.ZDebug(ctx, " sendUserOnlineInfoToOtherNode conn ", "target", v.Target())
 		if v.Target() == ws.disCov.GetSelfConnTarget() {
 			log.ZDebug(ctx, "Filter out this node", "node", v.Target())
diff --git a/internal/push/onlinepusher.go b/internal/push/onlinepusher.go
index a61399fb6..adeff3737 100644
--- a/internal/push/onlinepusher.go
+++ b/internal/push/onlinepusher.go
@@ -86,6 +86,7 @@ func (d *DefaultAllNode) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.M
 
 	// Online push message
 	for _, conn := range conns {
+		log.ZDebug(ctx, "get gateway conn detail ", "conn ", *conn)
 		conn := conn // loop var safe
 		ctx := ctx
 		wg.Go(func() error {
diff --git a/pkg/common/discoveryregister/etcd/etcd.go b/pkg/common/discoveryregister/etcd/etcd.go
index bf510051f..7baac73f3 100644
--- a/pkg/common/discoveryregister/etcd/etcd.go
+++ b/pkg/common/discoveryregister/etcd/etcd.go
@@ -107,8 +107,9 @@ func (r *SvcDiscoveryRegistryImpl) GetConns(ctx context.Context, serviceName str
 			return nil, err
 		}
 		conns = append(conns, conn)
+		fmt.Println("GetConns detail ", *conn)
+
 	}
-	fmt.Println("GetConns number ", len(conns))
 	return conns, nil
 }