mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-11-05 21:02:11 +08:00
fix uncorrect contents.
This commit is contained in:
parent
b578958f3e
commit
6b41879387
@ -172,22 +172,23 @@ func (s *authServer) forceKickOff(ctx context.Context, userID string, platformID
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
log.ZError(ctx, "forceKickOff", err, "kickReq", kickReq)
|
log.ZError(ctx, "forceKickOff", err, "kickReq", kickReq)
|
||||||
}
|
}
|
||||||
m, err := s.authDatabase.GetTokensWithoutError(ctx, userID, int(platformID))
|
}
|
||||||
if err != nil && err != redis.Nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
if m == nil {
|
|
||||||
return errs.New("token map is empty").Wrap()
|
|
||||||
}
|
|
||||||
for k := range m {
|
|
||||||
m[k] = constant.KickedToken
|
|
||||||
log.ZDebug(ctx, "set token map is ", "token map", m, "userID",
|
|
||||||
userID, "token", k)
|
|
||||||
|
|
||||||
err = s.authDatabase.SetTokenMapByUidPid(ctx, userID, int(platformID), m)
|
m, err := s.authDatabase.GetTokensWithoutError(ctx, userID, int(platformID))
|
||||||
if err != nil {
|
if err != nil && err != redis.Nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
if m == nil {
|
||||||
|
return errs.New("token map is empty").Wrap()
|
||||||
|
}
|
||||||
|
for k := range m {
|
||||||
|
m[k] = constant.KickedToken
|
||||||
|
log.ZDebug(ctx, "set token map is ", "token map", m, "userID",
|
||||||
|
userID, "token", k)
|
||||||
|
|
||||||
|
err = s.authDatabase.SetTokenMapByUidPid(ctx, userID, int(platformID), m)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user