From beb53da43ff3b3a85f2273eb86148d53e229c6c6 Mon Sep 17 00:00:00 2001 From: luhaoling <2198702716@qq.com> Date: Mon, 29 Jan 2024 10:15:24 +0800 Subject: [PATCH] fix: find error --- internal/rpc/msg/revoke.go | 3 +++ pkg/common/db/unrelation/msg.go | 2 +- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/internal/rpc/msg/revoke.go b/internal/rpc/msg/revoke.go index 5dfd1f618..2a87a2061 100644 --- a/internal/rpc/msg/revoke.go +++ b/internal/rpc/msg/revoke.go @@ -57,6 +57,7 @@ func (m *msgServer) RevokeMsg(ctx context.Context, req *msg.RevokeMsgReq) (*msg. if err != nil { return nil, err } + log.ZDebug(ctx, "RevokeMsg", "msgs", msgs) if len(msgs) == 0 || msgs[0] == nil { return nil, errs.ErrRecordNotFound.Wrap("msg not found") } @@ -114,6 +115,7 @@ func (m *msgServer) RevokeMsg(ctx context.Context, req *msg.RevokeMsgReq) (*msg. return nil, err } revokerUserID := mcontext.GetOpUserID(ctx) + log.ZDebug(ctx, "RevokeMsgRevokeMsg", "revokerUserID", revokerUserID) var flag bool if config.Config.Manager.UserID[0] != "" { flag = utils.Contain(revokerUserID, config.Config.Manager.UserID...) @@ -121,6 +123,7 @@ func (m *msgServer) RevokeMsg(ctx context.Context, req *msg.RevokeMsgReq) (*msg. if config.Config.Manager.UserID[0] == "" && len(config.Config.IMAdmin.UserID) > 0 { flag = utils.Contain(revokerUserID, config.Config.IMAdmin.UserID...) } + log.ZDebug(ctx, "RevokeMsgRevokeMsg", "flag", flag) tips := sdkws.RevokeMsgTips{ RevokerUserID: revokerUserID, ClientMsgID: msgs[0].ClientMsgID, diff --git a/pkg/common/db/unrelation/msg.go b/pkg/common/db/unrelation/msg.go index 9b461dd1f..fc4c70fc4 100644 --- a/pkg/common/db/unrelation/msg.go +++ b/pkg/common/db/unrelation/msg.go @@ -59,7 +59,7 @@ func (m *MsgMongoDriver) PushMsgsToDoc(ctx context.Context, docID string, msgsTo func (m *MsgMongoDriver) Create(ctx context.Context, model *table.MsgDocModel) error { _, err := m.MsgCollection.InsertOne(ctx, model) - return err + return errs.Wrap(err) } func (m *MsgMongoDriver) UpdateMsg(