From 968bd7a4370e3d4f56dd5953bf1087fbd984c91c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=89=8B=E7=93=9C=E4=B8=80=E5=8D=81=E9=9B=AA?=
 <nanaeonn@outlook.com>
Date: Sat, 12 Oct 2024 15:27:58 +0800
Subject: [PATCH] fix

---
 src/core/apis/group.ts    |  4 ++--
 src/core/apis/packet.ts   | 17 ++++++++++++++++-
 src/core/helper/packet.ts |  2 +-
 src/onebot/index.ts       |  8 ++++----
 4 files changed, 23 insertions(+), 8 deletions(-)

diff --git a/src/core/apis/group.ts b/src/core/apis/group.ts
index 3a22f0c7e..672220484 100644
--- a/src/core/apis/group.ts
+++ b/src/core/apis/group.ts
@@ -56,8 +56,8 @@ export class NTQQGroupApi {
     async sendPacketPoke(group: string, peer: string) {
         let data = encodeGroupPoke(group, peer);
         let hex = Buffer.from(data).toString('hex');
-        let retdata = await this.core.apis.PacketApi.sendPacket('OidbSvcTrpcTcp.0xed3_1', hex, true);
-        console.log('sendPacketPoke', retdata);
+        let retdata = await this.core.apis.PacketApi.sendPacket('OidbSvcTrpcTcp.0xed3_1', hex, false);
+        //console.log('sendPacketPoke', retdata);
     }
     async fetchGroupEssenceList(groupCode: string) {
         const pskey = (await this.core.apis.UserApi.getPSkey(['qun.qq.com'])).domainPskeyMap.get('qun.qq.com')!;
diff --git a/src/core/apis/packet.ts b/src/core/apis/packet.ts
index c169a574f..62e78f101 100644
--- a/src/core/apis/packet.ts
+++ b/src/core/apis/packet.ts
@@ -51,7 +51,22 @@ export class NTQQPacketApi {
         return text;
     }
     async sendPacket(cmd: string, data: string, rsp = false) {
-        return new Promise((resolve, reject) => {
+        // wtfk tx
+        // 校验失败和异常 可能返回undefined
+        return new Promise<undefined | {
+            type: string,//仅recv含有data
+            trace_id: string,
+            data: {
+                trace_id: string,
+                seq: number,
+                hex_data: string,
+                cmd: string
+            }
+        }>((resolve, reject) => {
+            if (!this.isInit || !this.PacketClient?.isConnected) {
+                this.core.context.logger.logError('PacketClient is not init');
+                return undefined;
+            }
             let md5 = crypto.createHash('md5').update(data).digest('hex');
             let trace_id = (this.randText(4) + md5 + data).slice(0, data.length / 2);
             this.PacketClient?.sendCommand(cmd, data, trace_id, rsp, 5000, async () => {
diff --git a/src/core/helper/packet.ts b/src/core/helper/packet.ts
index 6d386aa35..05b7b7104 100644
--- a/src/core/helper/packet.ts
+++ b/src/core/helper/packet.ts
@@ -4,7 +4,7 @@ import WebSocket from "ws";
 
 export class PacketClient {
     private websocket: WebSocket | undefined;
-    private isConnected: boolean = false;
+    public isConnected: boolean = false;
     private reconnectAttempts: number = 0;
     private maxReconnectAttempts: number = 5;
     private cb = new LRUCache<string, { type: string, callback: any }>(500);
diff --git a/src/onebot/index.ts b/src/onebot/index.ts
index 188d0fd5b..0882589be 100644
--- a/src/onebot/index.ts
+++ b/src/onebot/index.ts
@@ -540,10 +540,10 @@ export class NapCatOneBot11Adapter {
             if (isSelfMsg) {
                 ob11Msg.target_id = parseInt(message.peerUin);
             }
-            if(ob11Msg.raw_message.startsWith('!poke')){
-                console.log('poke',message.peerUin, message.senderUin);
-                this.core.apis.GroupApi.sendPacketPoke(message.peerUin, message.senderUin);
-            }
+            // if(ob11Msg.raw_message.startsWith('!poke')){
+            //     console.log('poke',message.peerUin, message.senderUin);
+            //     this.core.apis.GroupApi.sendPacketPoke(message.peerUin, message.senderUin);
+            // }
             this.networkManager.emitEvent(ob11Msg);
         }).catch(e => this.context.logger.logError.bind(this.context.logger)('constructMessage error: ', e));