conn

internal/api/auth.go

@@ -12,11 +12,11 @@ import (
 )
 
 func NewAuth(discov discoveryregistry.SvcDiscoveryRegistry) *Auth {
-	conn, err := discov.GetConn(context.Background(), config.Config.RpcRegisterName.OpenImAuthName)
+	// conn, err := discov.GetConn(context.Background(), config.Config.RpcRegisterName.OpenImAuthName)
-	if err != nil {
+	// if err != nil {
-		// panic(err)
+	// panic(err)
-	}
+	// }
-	return &Auth{conn: conn, discov: discov}
+	return &Auth{discov: discov}
 }
 
 type Auth struct {

internal/api/conversation.go

@@ -12,11 +12,11 @@ import (
 )
 
 func NewConversation(discov discoveryregistry.SvcDiscoveryRegistry) *Conversation {
-	conn, err := discov.GetConn(context.Background(), config.Config.RpcRegisterName.OpenImConversationName)
+	// conn, err := discov.GetConn(context.Background(), config.Config.RpcRegisterName.OpenImConversationName)
-	if err != nil {
+	// if err != nil {
-		// panic(err)
+	// panic(err)
-	}
+	// }
-	return &Conversation{conn: conn, discov: discov}
+	return &Conversation{discov: discov}
 }
 
 type Conversation struct {

internal/api/friend.go

@@ -13,11 +13,11 @@ import (
 )
 
 func NewFriend(discov discoveryregistry.SvcDiscoveryRegistry) *Friend {
-	conn, err := discov.GetConn(context.Background(), config.Config.RpcRegisterName.OpenImFriendName)
+	// conn, err := discov.GetConn(context.Background(), config.Config.RpcRegisterName.OpenImFriendName)
-	if err != nil {
+	// if err != nil {
-		// panic(err)
+	// panic(err)
-	}
+	// }
-	return &Friend{conn: conn, discov: discov}
+	return &Friend{discov: discov}
 }
 
 type Friend struct {

internal/api/group.go

@@ -13,11 +13,11 @@ import (
 )
 
 func NewGroup(discov discoveryregistry.SvcDiscoveryRegistry) *Group {
-	conn, err := discov.GetConn(context.Background(), config.Config.RpcRegisterName.OpenImGroupName)
+	// conn, err := discov.GetConn(context.Background(), config.Config.RpcRegisterName.OpenImGroupName)
-	if err != nil {
+	// if err != nil {
-		// panic(err)
+	// panic(err)
-	}
+	// }
-	return &Group{conn: conn, discov: discov}
+	return &Group{discov: discov}
 }
 
 type Group struct {

internal/api/msg.go

@@ -22,11 +22,11 @@ import (
 )
 
 func NewMsg(discov discoveryregistry.SvcDiscoveryRegistry) *Message {
-	conn, err := discov.GetConn(context.Background(), config.Config.RpcRegisterName.OpenImMsgName)
+	// conn, err := discov.GetConn(context.Background(), config.Config.RpcRegisterName.OpenImMsgName)
-	if err != nil {
+	// if err != nil {
-		// panic(err)
+	// panic(err)
-	}
+	// }
-	return &Message{conn: conn, validate: validator.New(), discov: discov}
+	return &Message{validate: validator.New(), discov: discov}
 }
 
 type Message struct {

internal/api/third.go

@@ -18,11 +18,11 @@ import (
 )
 
 func NewThird(discov discoveryregistry.SvcDiscoveryRegistry) *Third {
-	conn, err := discov.GetConn(context.Background(), config.Config.RpcRegisterName.OpenImThirdName)
+	// conn, err := discov.GetConn(context.Background(), config.Config.RpcRegisterName.OpenImThirdName)
-	if err != nil {
+	// if err != nil {
-		// panic(err)
+	// panic(err)
-	}
+	// }
-	return &Third{conn: conn, discov: discov}
+	return &Third{discov: discov}
 }
 
 type Third struct {

internal/api/user.go

@@ -5,7 +5,6 @@ import (
 
 	"github.com/OpenIMSDK/Open-IM-Server/pkg/apiresp"
 	"github.com/OpenIMSDK/Open-IM-Server/pkg/apistruct"
-	"github.com/OpenIMSDK/Open-IM-Server/pkg/common/log"
 	"github.com/OpenIMSDK/Open-IM-Server/pkg/common/tokenverify"
 	"github.com/OpenIMSDK/Open-IM-Server/pkg/errs"
 	"google.golang.org/grpc"
@@ -18,12 +17,11 @@ import (
 )
 
 func NewUser(discov discoveryregistry.SvcDiscoveryRegistry) *User {
-	conn, err := discov.GetConn(context.Background(), config.Config.RpcRegisterName.OpenImUserName)
+	// conn, err := discov.GetConn(context.Background(), config.Config.RpcRegisterName.OpenImUserName)
-	if err != nil {
+	// if err != nil {
-		// panic(err)
+	// panic(err)
-	}
+	// }
-	log.ZInfo(context.Background(), "user rpc conn", "conn", conn)
+	return &User{discov: discov}
-	return &User{conn: conn, discov: discov}
 }
 
 type User struct {