shkong/MiraiGo
1
0
Fork 0
mirror of https://github.com/Mrs4s/MiraiGo.git synced 2025-05-04 19:17:38 +08:00
Code Issues Projects Releases Wiki Activity

fix: more token failed type check.

Browse Source
This commit is contained in:
Mrs4s 2021-04-10 20:32:18 +08:00
parent 8c7432a6f4
commit 55ea6ca204
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
client/client.go
View File

@ -388,12 +388,17 @@ func (c *QQClient) init(tokenLogin bool) error {
d := c.waitPacket("StatSvc.ReqMSFOffline", func(i interface{}, err error) { d := c.waitPacket("StatSvc.ReqMSFOffline", func(i interface{}, err error) {
notify <- struct{}{} notify <- struct{}{}
}) })
d2 := c.waitPacket("MessageSvc.PushForceOffline", func(i interface{}, err error) {
notify <- struct{}{}
})
select { select {
case <-notify: case <-notify:
d() d()
d2()
return errors.New("token failed") return errors.New("token failed")
case <-time.After(time.Second): case <-time.After(time.Second):
d() d()
d2()
} }
} }
c.groupSysMsgCache, _ = c.GetGroupSystemMessages() c.groupSysMsgCache, _ = c.GetGroupSystemMessages()

2
client/decoders.go
View File

@ -737,8 +737,8 @@ func decodeForceOfflinePacket(c *QQClient, _ *incomingPacketInfo, payload []byte
data.ReadFrom(jce.NewJceReader(request.SBuffer)) data.ReadFrom(jce.NewJceReader(request.SBuffer))
r := jce.NewJceReader(data.Map["req_PushForceOffline"]["PushNotifyPack.RequestPushForceOffline"][1:]) r := jce.NewJceReader(data.Map["req_PushForceOffline"]["PushNotifyPack.RequestPushForceOffline"][1:])
tips := r.ReadString(2) tips := r.ReadString(2)
c.dispatchDisconnectEvent(&ClientDisconnectedEvent{Message: tips})
c.Disconnect() c.Disconnect()
go c.dispatchDisconnectEvent(&ClientDisconnectedEvent{Message: tips})
return nil, nil return nil, nil
} }