Implement error handling

Author: driesvints

src/channel/channel.ts

@@ -32,7 +32,7 @@ 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);

src/channel/null-presence-channel.ts

@@ -12,6 +12,13 @@ export class NullPresenceChannel extends NullChannel implements PresenceChannel
         return this;
     }
 
+    /**
+     * Register a callback to be called anytime an error occurs.
+     */
+    error(callback: Function): NullPresenceChannel {
+        return this;
+    }
+
     /**
      * Listen for someone joining the channel.
      */

src/channel/presence-channel.ts

@@ -7,6 +7,11 @@ export interface PresenceChannel {
      */
     here(callback: Function): PresenceChannel;
 
+    /**
+     * Register a callback to be called anytime an error occurs.
+     */
+    error(callback: Function): PresenceChannel;
+
     /**
      * Listen for someone joining the channel.
      */

src/channel/pusher-channel.ts

@@ -1,4 +1,4 @@
-import { EventFormatter } from './../util';
+import { EventFormatter } from '../util';
 import { Channel } from './channel';
 
 /**

src/channel/pusher-presence-channel.ts

@@ -16,6 +16,17 @@ export class PusherPresenceChannel extends PusherChannel implements PresenceChan
         return this;
     }
 
+    /**
+     * Register a callback to be called anytime a subscription error occurs.
+     */
+    error(callback: Function): PusherPresenceChannel {
+        this.on('pusher:subscription_error', (status) => {
+            callback(status);
+        });
+
+        return this;
+    }
+
     /**
      * Listen for someone joining the channel.
      */

src/channel/socketio-channel.ts

@@ -1,4 +1,4 @@
-import { EventFormatter } from './../util';
+import { EventFormatter } from '../util';
 import { Channel } from './channel';
 
 /**

src/channel/socketio-presence-channel.ts

@@ -16,6 +16,13 @@ export class SocketIoPresenceChannel extends SocketIoPrivateChannel implements P
         return this;
     }
 
+    /**
+     * Register a callback to be called anytime an error occurs.
+     */
+    error(callback: Function): SocketIoPresenceChannel {
+        return this;
+    }
+
     /**
      * Listen for someone joining the channel.
      */