From a88490f9d1802dba049f9df7df6cd140a4c919ab Mon Sep 17 00:00:00 2001
From: wkj <278599135@.com>
Date: Wed, 23 Oct 2024 14:45:01 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=20subscriber=20emit=20sub?=
 =?UTF-8?q?=E5=9B=9E=E8=B0=83=E6=9C=AA=E8=BF=9B=E5=85=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 es/features/subscriber.js  | 29 ++++++++++++++++-------------
 lib/features/subscriber.js | 28 +++++++++++++++-------------
 src/features/subscriber.ts | 29 ++++++++++++++++-------------
 3 files changed, 47 insertions(+), 39 deletions(-)

diff --git a/es/features/subscriber.js b/es/features/subscriber.js
index bfd914ec..6c014b68 100644
--- a/es/features/subscriber.js
+++ b/es/features/subscriber.js
@@ -183,19 +183,22 @@ export class SubScriber extends Feature {
         }
         else if (this.socketState === 'connected' && newEvents.length > 0) {
             await new Promise((resolve, reject) => {
-                this.socket.emit('sub', newEvents, (result) => {
-                    if (result) {
-                        this.message.setMessage({
-                            type: 'error',
-                            title: 'sub data error',
-                            content: result,
-                        });
-                        reject();
-                    }
-                    else {
-                        resolve(undefined);
-                    }
-                });
+                // this.socket.emit('sub', newEvents, (result) => {
+                //     if (result) {
+                //         this.message.setMessage({
+                //             type: 'error',
+                //             title: 'sub data error',
+                //             content: result,
+                //         });
+                //         reject();
+                //     }
+                //     else {
+                //         resolve(undefined);
+                //     }
+                // });
+                // TODO 临时代码 后续结合文档再解决
+                this.socket.emit('sub', newEvents);
+                resolve(undefined);
             });
         }
         return () => {
diff --git a/lib/features/subscriber.js b/lib/features/subscriber.js
index 4db7061d..fb427912 100644
--- a/lib/features/subscriber.js
+++ b/lib/features/subscriber.js
@@ -187,19 +187,21 @@ class SubScriber extends Feature_1.Feature {
         }
         else if (this.socketState === 'connected' && newEvents.length > 0) {
             await new Promise((resolve, reject) => {
-                this.socket.emit('sub', newEvents, (result) => {
-                    if (result) {
-                        this.message.setMessage({
-                            type: 'error',
-                            title: 'sub data error',
-                            content: result,
-                        });
-                        reject();
-                    }
-                    else {
-                        resolve(undefined);
-                    }
-                });
+                // this.socket.emit('sub', newEvents, (result) => {
+                //     if (result) {
+                //         this.message.setMessage({
+                //             type: 'error',
+                //             title: 'sub data error',
+                //             content: result,
+                //         });
+                //         reject();
+                //     }
+                //     else {
+                //         resolve(undefined);
+                //     }
+                // });
+                this.socket.emit('sub', newEvents);
+                resolve(undefined);
             });
         }
         return () => {
diff --git a/src/features/subscriber.ts b/src/features/subscriber.ts
index 36863273..c638a76e 100644
--- a/src/features/subscriber.ts
+++ b/src/features/subscriber.ts
@@ -226,19 +226,22 @@ export class SubScriber<ED extends EntityDict & BaseEntityDict> extends Feature
         else if (this.socketState === 'connected' && newEvents.length > 0) {
             await new Promise(
                 (resolve, reject) => {
-                    this.socket!.emit('sub', newEvents, (result: string) => {
-                        if (result) {
-                            this.message.setMessage({
-                                type: 'error',
-                                title: 'sub data error',
-                                content: result,
-                            });
-                            reject();
-                        }
-                        else {
-                            resolve(undefined);
-                        }
-                    });
+                    // this.socket!.emit('sub', newEvents, (result: string) => {
+                    //     if (result) {
+                    //         this.message.setMessage({
+                    //             type: 'error',
+                    //             title: 'sub data error',
+                    //             content: result,
+                    //         });
+                    //         reject();
+                    //     }
+                    //     else {
+                    //         resolve(undefined);
+                    //     }
+                    // });
+                    // TODO 临时代码 后续结合文档再解决
+                    this.socket!.emit('sub', newEvents);
+                    resolve(undefined);
                 }
             );
         }