From f7965c70f041616df16f09caf5aa96b2d9c7f1e5 Mon Sep 17 00:00:00 2001
From: sclausen <github@sebastian-clausen.de>
Date: Sat, 8 Sep 2018 16:50:34 +0200
Subject: [PATCH] Implements offline event #111.

---
 src/mqtt.service.ts | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/src/mqtt.service.ts b/src/mqtt.service.ts
index 7c16e31..32e48b8 100644
--- a/src/mqtt.service.ts
+++ b/src/mqtt.service.ts
@@ -59,6 +59,7 @@ export class MqttService {
 
   private _onConnect: EventEmitter<IOnConnectEvent> = new EventEmitter<IOnConnectEvent>();
   private _onClose: EventEmitter<void> = new EventEmitter<void>();
+  private _onOffline: EventEmitter<void> = new EventEmitter<void>();
   private _onError: EventEmitter<IOnErrorEvent> = new EventEmitter<IOnErrorEvent>();
   private _onReconnect: EventEmitter<void> = new EventEmitter<void>();
   private _onMessage: EventEmitter<IOnMessageEvent> = new EventEmitter<IOnMessageEvent>();
@@ -115,6 +116,7 @@ export class MqttService {
     this.client.stream.on('error', this._handleOnError);
     this.client.on('reconnect', this._handleOnReconnect);
     this.client.on('message', this._handleOnMessage);
+    this.client.on('offline', this._handleOnOffline);
   }
 
   /**
@@ -285,6 +287,11 @@ export class MqttService {
     return this._onClose;
   }
 
+  /** An EventEmitter to listen to offline events */
+  public get onOffline(): EventEmitter<void> {
+    return this._onOffline;
+  }
+
   /** An EventEmitter to listen to connect messages */
   public get onConnect(): EventEmitter<IOnConnectEvent> {
     return this._onConnect;
@@ -315,6 +322,11 @@ export class MqttService {
     this._onClose.emit();
   }
 
+  private _handleOnOffline = () => {
+    this.state.next(MqttConnectionState.CLOSED);
+    this._onOffline.emit();
+  }
+
   private _handleOnConnect = (e: IOnConnectEvent) => {
     if (this.options.connectOnCreate === true) {
       Object.keys(this.observables).forEach((filter: string) => {