feat: comment out logic that is not currently needed

This commit is contained in:
pk5ls20
2024-11-13 17:48:42 +08:00
parent f7f7e09cab
commit 2ea025047f

View File

@@ -75,7 +75,7 @@ export class NapCatOneBot11Adapter {
}; };
this.actions = createActionMap(this, core); this.actions = createActionMap(this, core);
this.networkManager = new OB11NetworkManager(); this.networkManager = new OB11NetworkManager();
this.registerNative(core, context).catch(e => this.context.logger.logWarn.bind(this.context.logger)('初始化Native失败', e)).then(); // this.registerNative(core, context).catch(e => this.context.logger.logWarn.bind(this.context.logger)('初始化Native失败', e)).then();
this.InitOneBot() this.InitOneBot()
.catch(e => this.context.logger.logError.bind(this.context.logger)('初始化OneBot失败', e)); .catch(e => this.context.logger.logError.bind(this.context.logger)('初始化OneBot失败', e));
@@ -84,27 +84,27 @@ export class NapCatOneBot11Adapter {
try { try {
this.nativeCore = new Native(context.pathWrapper.binaryPath); this.nativeCore = new Native(context.pathWrapper.binaryPath);
if (!this.nativeCore.inited) throw new Error('Native Not Init'); if (!this.nativeCore.inited) throw new Error('Native Not Init');
this.nativeCore.registerRecallCallback(async (hex: string) => { // this.nativeCore.registerRecallCallback(async (hex: string) => {
try { // try {
const data = decodeMessage(Buffer.from(hex, 'hex')); // const data = decodeMessage(Buffer.from(hex, 'hex'));
//data.MsgHead.BodyInner.MsgType SubType // //data.MsgHead.BodyInner.MsgType SubType
const bodyInner = data.msgHead?.bodyInner; // const bodyInner = data.msgHead?.bodyInner;
//context.logger.log("[appNative] Parse MsgType:" + bodyInner.msgType + " / SubType:" + bodyInner.subType); // //context.logger.log("[appNative] Parse MsgType:" + bodyInner.msgType + " / SubType:" + bodyInner.subType);
if (bodyInner && bodyInner.msgType == 732 && bodyInner.subType == 17 && data?.msgHead?.noifyData?.innerData) { // if (bodyInner && bodyInner.msgType == 732 && bodyInner.subType == 17 && data?.msgHead?.noifyData?.innerData) {
const RecallData = Buffer.from(data?.msgHead?.noifyData?.innerData); // const RecallData = Buffer.from(data?.msgHead?.noifyData?.innerData);
//跳过 4字节 群号 + 不知道的1字节 +2字节 长度 // //跳过 4字节 群号 + 不知道的1字节 +2字节 长度
const uid = RecallData.readUint32BE(); // const uid = RecallData.readUint32BE();
const buffer = Buffer.from(RecallData.toString('hex').slice(14), 'hex'); // const buffer = Buffer.from(RecallData.toString('hex').slice(14), 'hex');
const seq: number = decodeRecallGroup(buffer).recallDetails.subDetail.msgSeq; // const seq: number = decodeRecallGroup(buffer).recallDetails.subDetail.msgSeq;
const peer: Peer = { chatType: ChatType.KCHATTYPEGROUP, peerUid: uid.toString() }; // const peer: Peer = { chatType: ChatType.KCHATTYPEGROUP, peerUid: uid.toString() };
context.logger.log("[Native] 群消息撤回 Peer: " + uid.toString() + " / MsgSeq:" + seq); // context.logger.log("[Native] 群消息撤回 Peer: " + uid.toString() + " / MsgSeq:" + seq);
const msgs = await core.apis.MsgApi.queryMsgsWithFilterExWithSeq(peer, seq.toString()); // const msgs = await core.apis.MsgApi.queryMsgsWithFilterExWithSeq(peer, seq.toString());
this.recallMsgCache.put(msgs.msgList[0].msgId, msgs.msgList[0]); // this.recallMsgCache.put(msgs.msgList[0].msgId, msgs.msgList[0]);
} // }
} catch (error: any) { // } catch (error: any) {
context.logger.logWarn("[Native] Error:", (error as Error).message, ' HEX:', hex); // context.logger.logWarn("[Native] Error:", (error as Error).message, ' HEX:', hex);
} // }
}); // });
} catch (error) { } catch (error) {
context.logger.logWarn("[Native] Error:", (error as Error).message); context.logger.logWarn("[Native] Error:", (error as Error).message);
return; return;