Fix ping pong sample

Author: Brayden

examples/sockets/src/index.html

@@ -36,7 +36,7 @@ <h1>Actor Sockets Demo</h1>
         const statusElement = document.getElementById('connectionStatus');
 
         // Replace with your deployed Worker URL below:
-        const wsUrl = `wss://actor-sockets.YOUR-IDENTIFIER.workers.dev/ws`;
+        const wsUrl = `wss://actor-sockets.brayden-b8b.workers.dev/ws`;
 
         function getUrlParameter(name) {
             const urlParams = new URLSearchParams(window.location.search);

examples/sockets/src/index.ts

@@ -7,8 +7,8 @@ export class MySocketsActor extends Actor<Env> {
             sockets: {
                 upgradePath: '/ws', // Also defaults to `/ws` when not present,
                 autoResponse: {
-                    ping: 'pong',
-                    pong: 'ping'
+                    ping: 'ping',
+                    pong: 'pong'
                 }
             }
         };
@@ -31,9 +31,8 @@ export class MySocketsActor extends Actor<Env> {
     }
 
     protected onSocketMessage(ws: WebSocket, message: any) {
-        // Echo message back when recieved
-        const senderSocketId = ws.deserializeAttachment?.()?.connectionId;
-        this.sockets.message('Received!', ['*'], [senderSocketId]);
+        // Echo message back to everyone except the sender
+        this.sockets.message('Received!', '*', [ws]);
     }
 }
 

packages/sockets/src/index.ts

@@ -42,7 +42,8 @@ export class Sockets<P extends DurableObject<any>> {
 
     message(message: string, to?: RecipientType[] | '*', exclude?: RecipientType[]) {
         for (const [id, socket] of this.connections.entries()) {
-            if (to?.length === 0 || !to || to === '*') {
+            // If no `to` recipient is defined, default send message to everyone
+            if (to === '*' || !to || to?.length === 0) {
                 // If the `id` is in the exclude list then skip this iteration
                 if (exclude?.includes(id)) {
                     continue;
@@ -53,6 +54,7 @@ export class Sockets<P extends DurableObject<any>> {
                     continue;
                 }
 
+                // Send message if the `to` is not excluded
                 socket.send(message);
             } else if (to?.includes(id)) {
                 // When `to` is defined we only send the message to the