chore: 有笨蛋

This commit is contained in:
pk5ls20 2024-10-23 16:33:05 +08:00
parent e9332e7646
commit 5cca8457e7
No known key found for this signature in database
GPG Key ID: 6370ED7A169F493A
3 changed files with 5 additions and 1 deletions

View File

@ -111,6 +111,7 @@ export class NTQQPacketApi {
await this.sendPacket('OidbSvcTrpcTcp.0x8fc_2', data!, true);
}
// TODO: can simplify this
async uploadResources(msg: PacketMsg[], groupUin: number = 0) {
const reqList = [];
for (const m of msg) {
@ -135,7 +136,7 @@ export class NTQQPacketApi {
}
}
}
return Promise.all(reqList);
return Promise.all(reqList); // TODO: use promise.allSettled
}
async sendUploadForwardMsg(msg: PacketMsg[], groupUin: number = 0) {

View File

@ -94,6 +94,7 @@ export class HighwayTcpUploader extends HighwayUploader {
const handleRspHeader = (header: Buffer) => {
const rsp = new NapProtoMsg(RespDataHighwayHead).decode(header);
if (rsp.errorCode !== 0) {
// TODO: immediately reject promise if error code is not 0
this.logger.logWarn(`[Highway] tcpUpload failed (code: ${rsp.errorCode})`);
}
const percent = ((Number(rsp.msgSegHead?.dataOffset) + Number(rsp.msgSegHead?.dataLength)) / Number(rsp.msgSegHead?.filesize)).toFixed(2);
@ -159,6 +160,7 @@ export class HighwayHttpUploader extends HighwayUploader {
const headData = new NapProtoMsg(RespDataHighwayHead).decode(head);
this.logger.logDebug(`[Highway] httpUploadBlock: ${headData.errorCode} | ${headData.msgSegHead?.retCode} | ${headData.bytesRspExtendInfo} | ${head.toString('hex')} | ${body.toString('hex')}`);
if (headData.errorCode !== 0) {
// TODO: immediately throw error if error code is not 0
this.logger.logError(`[Highway] httpUploadBlock failed (code=${headData.errorCode})`);
}
}

View File

@ -34,6 +34,7 @@ export class PacketPacker {
this.packetConverter = new PacketMsgConverter(logger);
}
// TODO: 一步到位多好ww
private toHexStr(byteArray: Uint8Array): PacketHexStr {
return Buffer.from(byteArray).toString('hex') as PacketHexStr;
}