chore: merge main

CHANGELOG.md

@@ -1,3 +1,11 @@
+## v4.0.0-alpha.27 - 06/09/2025
+
+- Fix: assign to `const`
+
+## v4.0.0-alpha.26 - 05/09/2025
+
+- Fix: improve reconnect strategy in case of socket connection failure
+
 ## v4.0.0-alpha.25 - 24/05/2025
 
 - Fix: better default behavior for WebSocket connection URL

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@soundworks/core",
-  "version": "4.0.0-alpha.25",
+  "version": "4.0.0-alpha.27",
   "description": "Open-source creative coding framework for distributed applications based on Web technologies",
   "authors": [
     "Benjamin Matuszewski",

src/client/ClientSocket.js

@@ -97,6 +97,8 @@ class ClientSocket {
       }
 
       webSocketOptions = {
+        // handshakeTimeout: 2000,
+        // do not reject self-signed certificates
         rejectUnauthorized: false,
       };
     }
@@ -132,18 +134,17 @@ class ClientSocket {
               return; // do not propagate ping pong messages
             }
 
-            // Parse incoming message and dispatch in pubsub system.
+            // Parse incoming message, dispatch in pubsub system and propagate raw event.
             const [channel, args] = unpackStringMessage(e.data);
             this.#dispatchEvent(channel, ...args);
+            this.#dispatchEvent('message', e);
           });
 
-          // @todo - propagate raw 'message' events in the callback above, no
-          // need to execute to function instad of one per message...
-          ['close', 'error', 'upgrade', 'message'].forEach(eventName => {
-            this.#socket.addEventListener(eventName, e => {
-              this.#dispatchEvent(eventName, e);
-            });
-          })
+          // Propagate other "native" events
+          this.#socket.addEventListener('close', e => this.#dispatchEvent('close', e));
+          this.#socket.addEventListener('error', e => this.#dispatchEvent('close', e));
+          // @note - isn't it too late for this one?
+          this.#socket.addEventListener('upgrade', e => this.#dispatchEvent('upgrade', e));
 
           // Forward open event and continue initialization
           this.#dispatchEvent('open', openEvent);

src/common/version.js

@@ -1,2 +1,2 @@
 // [WARNING] This file is generated, do not edit
-export default '4.0.0-alpha.25';
+export default '4.0.0-alpha.27';

src/server/ServerSockets.js

@@ -182,7 +182,7 @@ class ServerSockets {
    *  JSON compatible data types (i.e. string, number, boolean, object, array and null).
    */
   broadcast(roomIds, excludeSocket, channel, ...args) {
-    const targets = new Set();
+    let targets = new Set();
 
     if (typeof roomIds === 'string' || Array.isArray(roomIds)) {
       if (typeof roomIds === 'string') {