From 83f2eb02e6be0ae6c9315346e331a9d3b722bcef Mon Sep 17 00:00:00 2001 From: Mrs4s <1844812067@qq.com> Date: Wed, 20 Jan 2021 23:27:24 +0800 Subject: [PATCH] fix err. --- client/decoders.go | 4 ++++ client/sync.go | 19 ++++++------------- 2 files changed, 10 insertions(+), 13 deletions(-) diff --git a/client/decoders.go b/client/decoders.go index 874d6e93..dbf6acaa 100644 --- a/client/decoders.go +++ b/client/decoders.go @@ -1018,3 +1018,7 @@ func decodeAppInfoResponse(_ *QQClient, _ uint16, payload []byte) (interface{}, } return rsp.AppInfo, nil } + +func ignoreDecoder(_ *QQClient, _ uint16, _ []byte) (interface{}, error) { + return nil, nil +} diff --git a/client/sync.go b/client/sync.go index dd1b07a4..20f409bf 100644 --- a/client/sync.go +++ b/client/sync.go @@ -13,7 +13,10 @@ import ( func init() { decoders["StatSvc.GetDevLoginInfo"] = decodeDevListResponse decoders["StatSvc.SvcReqMSFLoginNotify"] = decodeLoginNotifyPacket - decoders["RegPrxySvc.getOffMsg"] = decodeOfflineMsgResponse + decoders["RegPrxySvc.getOffMsg"] = ignoreDecoder + decoders["RegPrxySvc.GetMsgV2"] = ignoreDecoder + decoders["RegPrxySvc.PbGetMsg"] = ignoreDecoder + decoders["RegPrxySvc.NoticeEnd"] = ignoreDecoder decoders["RegPrxySvc.PushParam"] = decodePushParamPacket } @@ -37,9 +40,8 @@ func (c *QQClient) GetAllowedClients() ([]*OtherClientInfo, error) { // RefreshClientStatus 刷新客户端状态 func (c *QQClient) RefreshStatus() error { - _, pkt := c.buildGetOfflineMsgRequest() - c.send(pkt) - return nil + _, err := c.sendAndWait(c.buildGetOfflineMsgRequest()) + return err } // StatSvc.GetDevLoginInfo @@ -143,15 +145,6 @@ func decodeDevListResponse(_ *QQClient, _ uint16, payload []byte) (interface{}, return nil, errors.New("not any device") } -// RegPrxySvc.getOffMsg -func decodeOfflineMsgResponse(c *QQClient, _ uint16, payload []byte) (interface{}, error) { - /* - request := &jce.RequestPacket{} - request.ReadFrom(jce.NewJceReader(payload)) - */ - return nil, nil -} - // RegPrxySvc.PushParam func decodePushParamPacket(c *QQClient, _ uint16, payload []byte) (interface{}, error) { request := &jce.RequestPacket{}