|
|
@ -57,6 +57,7 @@ func (m *msgServer) RevokeMsg(ctx context.Context, req *msg.RevokeMsgReq) (*msg.
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
log.ZDebug(ctx, "RevokeMsg", "msgs", msgs)
|
|
|
|
if len(msgs) == 0 || msgs[0] == nil {
|
|
|
|
if len(msgs) == 0 || msgs[0] == nil {
|
|
|
|
return nil, errs.ErrRecordNotFound.Wrap("msg not found")
|
|
|
|
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
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
revokerUserID := mcontext.GetOpUserID(ctx)
|
|
|
|
revokerUserID := mcontext.GetOpUserID(ctx)
|
|
|
|
|
|
|
|
log.ZDebug(ctx, "RevokeMsgRevokeMsg", "revokerUserID", revokerUserID)
|
|
|
|
var flag bool
|
|
|
|
var flag bool
|
|
|
|
if config.Config.Manager.UserID[0] != "" {
|
|
|
|
if config.Config.Manager.UserID[0] != "" {
|
|
|
|
flag = utils.Contain(revokerUserID, config.Config.Manager.UserID...)
|
|
|
|
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 {
|
|
|
|
if config.Config.Manager.UserID[0] == "" && len(config.Config.IMAdmin.UserID) > 0 {
|
|
|
|
flag = utils.Contain(revokerUserID, config.Config.IMAdmin.UserID...)
|
|
|
|
flag = utils.Contain(revokerUserID, config.Config.IMAdmin.UserID...)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
log.ZDebug(ctx, "RevokeMsgRevokeMsg", "flag", flag)
|
|
|
|
tips := sdkws.RevokeMsgTips{
|
|
|
|
tips := sdkws.RevokeMsgTips{
|
|
|
|
RevokerUserID: revokerUserID,
|
|
|
|
RevokerUserID: revokerUserID,
|
|
|
|
ClientMsgID: msgs[0].ClientMsgID,
|
|
|
|
ClientMsgID: msgs[0].ClientMsgID,
|
|
|
|