Fixed testing

new-connection.sh

@@ -0,0 +1,6 @@
+#!/bin/bash
+
+websocat -t - autoreconnect:ws://127.0.0.1:$1/app/app-key -v --ping-interval=15
+
+# Send this event for testing:
+# {"event": "pusher:subscribe", "data": { "channel": "public" } }

src/adapters/horizontal-adapter.ts

@@ -161,7 +161,7 @@ export abstract class HorizontalAdapter extends LocalAdapter {
                 }
             },
             resolveValue: (request: Request, response: Response) => {
-                return request.channels;
+                return request.channelsWithSocketsCount;
             },
         },
         [RequestType.CHANNEL_MEMBERS]: {

src/adapters/local-adapter.ts

@@ -7,7 +7,6 @@ import { WebSocket } from 'uWebSockets.js';
 export class LocalAdapter implements AdapterInterface {
     // TODO: Force disconnect a specific socket
     // TODO: Force disconnect all sockets from an app.
-    // TODO: Add a getChannelsWithSocketsCount to fetch fewer data from other nodes
 
     /**
      * The app connections storage class to manage connections.