Add redisPrefix Option for Laravel Echo Socket.io Redis Connection

src/connector/connector.ts

@@ -1,4 +1,4 @@
-import { Channel, PresenceChannel } from './../channel';
+import { Channel, PresenceChannel } from '../channel';
 
 export abstract class Connector {
     /**

src/connector/socketio-connector.ts

@@ -1,8 +1,8 @@
 import { Connector } from './connector';
-import { SocketIoChannel, SocketIoPrivateChannel, SocketIoPresenceChannel } from './../channel';
+import { SocketIoChannel, SocketIoPrivateChannel, SocketIoPresenceChannel } from '../channel';
 
 /**
- * This class creates a connnector to a Socket.io server.
+ * This class creates a connector to a Socket.io server.
  */
 export class SocketIoConnector extends Connector {
     /**
@@ -11,10 +11,12 @@ export class SocketIoConnector extends Connector {
     socket: any;
 
     /**
-     * All of the subscribed channel names.
+     * All the subscribed channel names.
      */
     channels: { [name: string]: SocketIoChannel } = {};
 
+    redisPrefix = this.options.redisPrefix ?? '';
+
     /**
      * Create a fresh Socket.io connection.
      */
@@ -58,10 +60,10 @@ export class SocketIoConnector extends Connector {
      * Get a channel instance by name.
      */
     channel(name: string): SocketIoChannel {
+        name = this.redisPrefix + name;
         if (!this.channels[name]) {
             this.channels[name] = new SocketIoChannel(this.socket, name, this.options);
         }
-
         return this.channels[name];
     }
 
@@ -70,32 +72,32 @@ export class SocketIoConnector extends Connector {
      */
     privateChannel(name: string): SocketIoPrivateChannel {
         if (!this.channels['private-' + name]) {
-            this.channels['private-' + name] = new SocketIoPrivateChannel(this.socket, 'private-' + name, this.options);
+            name = this.redisPrefix + 'private-' + name;
+            this.channels[name] = new SocketIoPrivateChannel(this.socket, name, this.options);
         }
-
-        return this.channels['private-' + name] as SocketIoPrivateChannel;
+        return this.channels[name] as SocketIoPrivateChannel;
     }
 
     /**
      * Get a presence channel instance by name.
      */
     presenceChannel(name: string): SocketIoPresenceChannel {
         if (!this.channels['presence-' + name]) {
-            this.channels['presence-' + name] = new SocketIoPresenceChannel(
-                this.socket,
-                'presence-' + name,
-                this.options
-            );
+            name = this.redisPrefix + 'private-' + name;
+            this.channels[name] = new SocketIoPresenceChannel(this.socket, name, this.options);
         }
-
-        return this.channels['presence-' + name] as SocketIoPresenceChannel;
+        return this.channels[name] as SocketIoPresenceChannel;
     }
 
     /**
      * Leave the given channel, as well as its private and presence variants.
      */
     leave(name: string): void {
-        let channels = [name, 'private-' + name, 'presence-' + name];
+        let channels = [
+            this.redisPrefix + name,
+            this.redisPrefix + 'private-' + name,
+            this.redisPrefix + 'presence-' + name,
+        ];
 
         channels.forEach((name) => {
             this.leaveChannel(name);