GuanM/NapCatQQ
1
0
Fork 0
mirror of https://github.com/NapNeko/NapCatQQ.git synced 2025-07-19 12:03:37 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: 注释掉无用代码

Browse Source
This commit is contained in:
手瓜一十雪
2024-10-12 19:57:51 +08:00
parent cdd00d665d
commit 978d2c24ee
2 changed files with 16 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/core/apis/group.ts
View File

@@ -46,11 +46,11 @@ export class NTQQGroupApi {
this.groupCache.set(group.groupCode, group); this.groupCache.set(group.groupCode, group);
} }
this.context.logger.logDebug(`加载${this.groups.length}个群组缓存完成`); this.context.logger.logDebug(`加载${this.groups.length}个群组缓存完成`);
console.log('pid', process.pid); //console.log('pid', process.pid);
// this.session = await frida.attach(process.pid); // this.session = await frida.attach(process.pid);
setTimeout(async () => { // setTimeout(async () => {
this.sendPocketRkey(); // this.sendPocketRkey();
}, 10000); // }, 10000);
} }
async getCoreAndBaseInfo(uids: string[]) { async getCoreAndBaseInfo(uids: string[]) {
return await this.core.eventWrapper.callNoListenerEvent( return await this.core.eventWrapper.callNoListenerEvent(
@@ -62,7 +62,7 @@ export class NTQQGroupApi {
async sendPocketRkey() { async sendPocketRkey() {
let hex = '08E7A00210CA01221D0A130A05080110CA011206A80602B006011A0208022206080A081408022A006001'; let hex = '08E7A00210CA01221D0A130A05080110CA011206A80602B006011A0208022206080A081408022A006001';
let ret = await this.core.apis.PacketApi.sendPacket('OidbSvcTrpcTcp.0x9067_202', hex, true); let ret = await this.core.apis.PacketApi.sendPacket('OidbSvcTrpcTcp.0x9067_202', hex, true);
console.log('ret: ', ret); //console.log('ret: ', ret);
} }
async sendPacketPoke(group: number, peer: number) { async sendPacketPoke(group: number, peer: number) {
let data = encodeGroupPoke(group, peer); let data = encodeGroupPoke(group, peer);

5
src/core/helper/packet.ts
View File

@@ -17,6 +17,7 @@ export class PacketClient {
this.logger.log.bind(this.logger)(`Attempting to connect to ${this.url}`); this.logger.log.bind(this.logger)(`Attempting to connect to ${this.url}`);
this.websocket = new WebSocket(this.url); this.websocket = new WebSocket(this.url);
this.websocket.on('error', (err) => this.logger.logError.bind(this.logger)('[Core] [Packet Server] Error:', err.message)); this.websocket.on('error', (err) => this.logger.logError.bind(this.logger)('[Core] [Packet Server] Error:', err.message));
this.websocket.onopen = () => { this.websocket.onopen = () => {
this.isConnected = true; this.isConnected = true;
this.reconnectAttempts = 0; this.reconnectAttempts = 0;
@@ -44,6 +45,7 @@ export class PacketClient {
} }
private attemptReconnect(): void { private attemptReconnect(): void {
try {
if (this.reconnectAttempts < this.maxReconnectAttempts) { if (this.reconnectAttempts < this.maxReconnectAttempts) {
this.reconnectAttempts++; this.reconnectAttempts++;
this.logger.logError.bind(this.logger)(`Reconnecting attempt ${this.reconnectAttempts}`); this.logger.logError.bind(this.logger)(`Reconnecting attempt ${this.reconnectAttempts}`);
@@ -51,6 +53,9 @@ export class PacketClient {
} else { } else {
this.logger.logError.bind(this.logger)(`Max reconnect attempts reached. Could not reconnect to ${this.url}`); this.logger.logError.bind(this.logger)(`Max reconnect attempts reached. Could not reconnect to ${this.url}`);
} }
} catch (error) {
this.logger.logError.bind(this.logger)(`Error attempting to reconnect: ${error}`);
}
} }
async registerCallback(trace_id: string, type: string, callback: any): Promise<void> { async registerCallback(trace_id: string, type: string, callback: any): Promise<void> {
this.cb.put(createHash('md5').update(trace_id).digest('hex') + type, callback); this.cb.put(createHash('md5').update(trace_id).digest('hex') + type, callback);