fix: added logs

push-protocol · Nov 6, 2024 · 2918445 · 2918445
1 parent d233844
commit 2918445
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/packages/restapi/src/lib/pushstream/PushStream.ts b/packages/restapi/src/lib/pushstream/PushStream.ts
@@ -168,6 +168,8 @@ export class PushStream extends EventEmitter {
               'RestAPI::PushStream::connect - Emitted STREAM.CONNECT'
             );
             resolve();
+          } else {
+            console.log('RestAPI::PushStream::s-7');
           }
         };
 
@@ -331,11 +333,14 @@ export class PushStream extends EventEmitter {
         };
 
         if (this.pushChatSocket) {
+          console.log('RestAPI::PushStream::s-1');
           this.pushChatSocket.off(EVENTS.CONNECT);
           this.pushChatSocket.on(EVENTS.CONNECT, async () => {
+            console.log('RestAPI::PushStream::s-2');
             isChatSocketConnected = true;
             this.chatSocketCount++;
             this.chatSocketConnected = true;
+            console.log('RestAPI::PushStream::s-3');
             checkAndEmitConnectEvent();
             console.log(
               `RestAPI::PushStream::EVENTS.CONNECT::Chat Socket Connected (ID: ${this.pushChatSocket.id})`
@@ -344,6 +349,7 @@ export class PushStream extends EventEmitter {
 
           this.pushChatSocket.off(EVENTS.DISCONNECT);
           this.pushChatSocket.on(EVENTS.DISCONNECT, async () => {
+            console.log('RestAPI::PushStream::s-4');
             console.log(
               'RestAPI::PushStream::ChatSocket::Disconnect - Chat socket disconnected.'
             );
@@ -502,6 +508,8 @@ export class PushStream extends EventEmitter {
         if (this.pushNotificationSocket) {
           this.pushNotificationSocket.off(EVENTS.CONNECT);
           this.pushNotificationSocket.on(EVENTS.CONNECT, async () => {
+            console.log('RestAPI::PushStream::s-5');
+
             console.log(
               `RestAPI::PushStream::NotifSocket::Connect - Notification Socket Connected (ID: ${this.pushNotificationSocket.id})`
             );
@@ -513,6 +521,8 @@ export class PushStream extends EventEmitter {
 
           this.pushNotificationSocket.off(EVENTS.DISCONNECT);
           this.pushNotificationSocket.on(EVENTS.DISCONNECT, async () => {
+            console.log('RestAPI::PushStream::s-6');
+
             console.log(
               'RestAPI::PushStream::NotifSocket::Disconnect - Notification socket disconnected.'
             );