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{}