mirror of
https://github.com/Mrs4s/MiraiGo.git
synced 2025-05-04 11:07:40 +08:00
52 lines
1.7 KiB
Go
52 lines
1.7 KiB
Go
package client
|
|
|
|
import (
|
|
"github.com/pkg/errors"
|
|
"google.golang.org/protobuf/proto"
|
|
|
|
"github.com/Mrs4s/MiraiGo/client/pb/cmd0x346"
|
|
"github.com/Mrs4s/MiraiGo/protocol/packets"
|
|
)
|
|
|
|
func init() {
|
|
decoders["OfflineFilleHandleSvr.pb_ftn_CMD_REQ_APPLY_DOWNLOAD-1200"] = decodeOfflineFileDownloadResponse
|
|
}
|
|
|
|
func (c *QQClient) buildOfflineFileDownloadRequestPacket(uuid []byte) (uint16, []byte) {
|
|
seq := c.nextSeq()
|
|
req := &cmd0x346.C346ReqBody{
|
|
Cmd: 1200,
|
|
Seq: int32(seq),
|
|
BusinessId: 3,
|
|
ClientType: 104,
|
|
ApplyDownloadReq: &cmd0x346.ApplyDownloadReq{
|
|
Uin: c.Uin,
|
|
Uuid: uuid,
|
|
OwnerType: 2,
|
|
},
|
|
ExtensionReq: &cmd0x346.ExtensionReq{
|
|
DownloadUrlType: 1,
|
|
},
|
|
}
|
|
payload, _ := proto.Marshal(req)
|
|
packet := packets.BuildUniPacket(c.Uin, seq, "OfflineFilleHandleSvr.pb_ftn_CMD_REQ_APPLY_DOWNLOAD-1200", 1, c.OutGoingPacketSessionId, EmptyBytes, c.sigInfo.d2Key, payload)
|
|
return seq, packet
|
|
}
|
|
|
|
func decodeOfflineFileDownloadResponse(c *QQClient, _ *incomingPacketInfo, payload []byte) (interface{}, error) {
|
|
rsp := cmd0x346.C346RspBody{}
|
|
if err := proto.Unmarshal(payload, &rsp); err != nil {
|
|
c.Error("unmarshal cmd0x346 rsp body error: %v", err)
|
|
return nil, errors.Wrap(err, "unmarshal cmd0x346 rsp body error")
|
|
}
|
|
if rsp.ApplyDownloadRsp == nil {
|
|
c.Error("decode apply download 1200 error: apply rsp is nil.")
|
|
return nil, errors.New("apply rsp is nil")
|
|
}
|
|
if rsp.ApplyDownloadRsp.RetCode != 0 {
|
|
c.Error("decode apply download 1200 error: %v", rsp.ApplyDownloadRsp.RetCode)
|
|
return nil, errors.Errorf("apply download rsp error: %d", rsp.ApplyDownloadRsp.RetCode)
|
|
}
|
|
return "http://" + rsp.ApplyDownloadRsp.DownloadInfo.DownloadDomain + rsp.ApplyDownloadRsp.DownloadInfo.DownloadUrl, nil
|
|
}
|