Merge pull request #284 from laravel/subscription-errors

Implement error handling

Author: taylorotwell

src/channel/channel.ts

@@ -32,9 +32,14 @@ export abstract class Channel {
     abstract stopListening(event: string): Channel;
 
     /**
-     * Stop listening for a whispser event on the channel instance.
+     * Stop listening for a whisper event on the channel instance.
      */
     stopListeningForWhisper(event: string): Channel {
         return this.stopListening('.client-' + event);
     }
+
+    /**
+     * Register a callback to be called anytime an error occurs.
+     */
+    abstract error(callback: Function): Channel;
 }

src/channel/null-channel.ts

@@ -32,6 +32,13 @@ export class NullChannel extends Channel {
         return this;
     }
 
+    /**
+     * Register a callback to be called anytime an error occurs.
+     */
+    error(callback: Function): NullChannel {
+        return this;
+    }
+
     /**
      * Bind a channel to an event.
      */

src/channel/pusher-channel.ts

@@ -1,4 +1,4 @@
-import { EventFormatter } from './../util';
+import { EventFormatter } from '../util';
 import { Channel } from './channel';
 
 /**
@@ -76,6 +76,17 @@ export class PusherChannel extends Channel {
         return this;
     }
 
+    /**
+     * Register a callback to be called anytime a subscription error occurs.
+     */
+    error(callback: Function): PusherChannel {
+        this.on('pusher:subscription_error', (status) => {
+            callback(status);
+        });
+
+        return this;
+    }
+
     /**
      * Bind a channel to an event.
      */

src/channel/socketio-channel.ts

@@ -1,4 +1,4 @@
-import { EventFormatter } from './../util';
+import { EventFormatter } from '../util';
 import { Channel } from './channel';
 
 /**
@@ -87,6 +87,13 @@ export class SocketIoChannel extends Channel {
         return this;
     }
 
+    /**
+     * Register a callback to be called anytime an error occurs.
+     */
+    error(callback: Function): SocketIoChannel {
+        return this;
+    }
+
     /**
      * Bind the channel's socket to an event and store the callback.
      */