Merge pull request #264 from it-can/master

add pusher private-encrypted #263

Author: taylorotwell

src/channel/index.ts

@@ -2,6 +2,7 @@ export * from './channel';
 export * from './presence-channel';
 export * from './pusher-channel';
 export * from './pusher-private-channel';
+export * from './pusher-encrypted-private-channel';
 export * from './pusher-presence-channel';
 export * from './socketio-channel';
 export * from './socketio-private-channel';

src/channel/pusher-encrypted-private-channel.ts

@@ -0,0 +1,15 @@
+import { PusherChannel } from './pusher-channel';
+
+/**
+ * This class represents a Pusher private channel.
+ */
+export class PusherEncryptedPrivateChannel extends PusherChannel {
+    /**
+     * Trigger client event on the channel.
+     */
+    whisper(eventName: string, data: any): PusherEncryptedPrivateChannel {
+        this.pusher.channels.channels[this.name].trigger(`client-${eventName}`, data);
+
+        return this;
+    }
+}

src/connector/pusher-connector.ts

@@ -1,5 +1,11 @@
 import { Connector } from './connector';
-import { PusherChannel, PusherPrivateChannel, PusherPresenceChannel, PresenceChannel } from './../channel';
+import {
+    PusherChannel,
+    PusherPrivateChannel,
+    PusherEncryptedPrivateChannel,
+    PusherPresenceChannel,
+    PresenceChannel,
+} from './../channel';
 
 /**
  * This class creates a connector to Pusher.
@@ -55,6 +61,21 @@ export class PusherConnector extends Connector {
         return this.channels['private-' + name];
     }
 
+    /**
+     * Get a private encrypted channel instance by name.
+     */
+    encryptedPrivateChannel(name: string): PusherChannel {
+        if (!this.channels['private-encrypted-' + name]) {
+            this.channels['private-encrypted-' + name] = new PusherEncryptedPrivateChannel(
+                this.pusher,
+                'private-encrypted-' + name,
+                this.options
+            );
+        }
+
+        return this.channels['private-encrypted-' + name];
+    }
+
     /**
      * Get a presence channel instance by name.
      */

src/echo.ts

@@ -91,6 +91,13 @@ export default class Echo {
         return this.connector.privateChannel(channel);
     }
 
+    /**
+     * Get a private encrypted channel instance by name.
+     */
+    encryptedPrivate(channel: string): Channel {
+        return this.connector.encryptedPrivateChannel(channel);
+    }
+
     /**
      * Get the Socket ID for the connection.
      */
@@ -133,7 +140,7 @@ export default class Echo {
      * Register an Axios HTTP interceptor to add the X-Socket-ID header.
      */
     registerAxiosRequestInterceptor(): any {
-        axios.interceptors.request.use(config => {
+        axios.interceptors.request.use((config) => {
             if (this.socketId()) {
                 config.headers['X-Socket-Id'] = this.socketId();
             }