[DEBUG] Add more logs from both WS transport and cube container in tests

Author: mcheshkov

.github/workflows/push.yml

@@ -612,7 +612,7 @@ jobs:
           cd packages/cubejs-testing/
           export BIRDBOX_CUBEJS_VERSION=${{ matrix.tag }}
           export BIRDBOX_CUBEJS_REGISTRY_PATH=localhost:5000/
-          export DEBUG=testcontainers
+          export DEBUG="testcontainers*"
           yarn run dataset:minimal
           yarn run birdbox:postgresql
           yarn run birdbox:postgresql-pre-aggregations

packages/cubejs-client-ws-transport/src/index.ts

@@ -90,6 +90,8 @@ class WebSocketTransport implements ITransport<WebSocketTransportResult> {
   }
 
   public async close(): Promise<void> {
+    // TODO sync with timeout in sendMessage: either flush or drop
+    console.log("close call, left queue", this.messageQueue);
     if (this.ws) {
       this.ws.close();
     }
@@ -191,7 +193,12 @@ class WebSocketTransport implements ITransport<WebSocketTransportResult> {
       this.messageQueue.push(message);
     }
 
+    console.log("sendMessage call, message", message);
+    console.log("sendMessage call, queue before timeout", this.messageQueue);
+
     setTimeout(async () => {
+      console.log("sendMessage call, message", message);
+      console.log("sendMessage call, queue after timeout", this.messageQueue);
       await this.initSocket();
       this.ws.sendQueue();
     }, 100);
@@ -242,6 +249,8 @@ class WebSocketTransport implements ITransport<WebSocketTransportResult> {
         return callback(result, () => this.subscribe(callback));
       },
       async unsubscribe() {
+        // TODO await unsub from server
+        console.log("unsubscribe call: ", message.messageId);
         transport.sendMessage({ unsubscribe: message.messageId });
         delete transport.messageIdToSubscription[message.messageId];
       }