From bd73661fbef3fbd2bc386a0740c174b36cffbbea Mon Sep 17 00:00:00 2001 From: truongpx-Mac Date: Fri, 27 Oct 2023 18:01:17 +0700 Subject: [PATCH] update --- pkg/common/startrpc/start.go | 2 +- pkg/rpcclient/user.go | 5 +++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/pkg/common/startrpc/start.go b/pkg/common/startrpc/start.go index 3ef6e569d..4528c03a1 100644 --- a/pkg/common/startrpc/start.go +++ b/pkg/common/startrpc/start.go @@ -68,7 +68,7 @@ func Start( if err != nil { return utils.Wrap1(err) } - defer zkClient.CloseZK() + defer zkClient.Close() zkClient.AddOption(mw.GrpcClient(), grpc.WithTransportCredentials(insecure.NewCredentials())) registerIP, err := network.GetRpcRegisterIP(config.Config.Rpc.RegisterIP) if err != nil { diff --git a/pkg/rpcclient/user.go b/pkg/rpcclient/user.go index 6929b4fd9..30fcfd98d 100644 --- a/pkg/rpcclient/user.go +++ b/pkg/rpcclient/user.go @@ -173,6 +173,7 @@ func (u *UserRpcClient) GetAllUserIDs(ctx context.Context, pageNumber, showNumbe // SetUserStatus sets the status for a user based on the provided user ID, status, and platform ID. func (u *UserRpcClient) SetUserStatus(ctx context.Context, userID string, status int32, platformID int) error { - _, err := u.Client.SetUserStatus(ctx, &user.SetUserStatusReq{StatusList: []*user.OnlineStatus{{UserID: userID, Status: status, PlatformIDs: []int32{int32(platformID)}}}}) - return err + // _, err := u.Client.SetUserStatus(ctx, &user.SetUserStatusReq{StatusList: []*user.OnlineStatus{{UserID: userID, Status: status, PlatformIDs: []int32{int32(platformID)}}}}) + // return err + return nil }