Prepare electron releases

backend/src/DataSource/DataSource.ts

@@ -1,10 +1,10 @@
-import { DataSourceState } from './'
+import { DataSourceStateMachine } from './'
 
 type MessageCallback = (topic: string, payload: Buffer) => void
 
 // A DataSource should automatically reconnect if connection was broken
 interface DataSource<DataSourceOptions> {
-  connect(options: DataSourceOptions): DataSourceState
+  connect(options: DataSourceOptions): DataSourceStateMachine
   disconnect(): void
   onMessage(messageCallback: MessageCallback): void
   topicSeparator: string

backend/src/DataSource/DataSourceState.ts

@@ -1,11 +1,13 @@
-interface InternalState {
+import { EventEmitter } from 'events'
+
+export interface DataSourceState {
   connecting: boolean
   connected: boolean
   error?: Error
 }
 
-export class DataSourceState {
-  private state: InternalState = {
+export class DataSourceStateMachine extends EventEmitter {
+  private state: DataSourceState = {
     error: undefined,
     connected: false,
     connecting: false

backend/src/DataSource/MqttSource.ts

@@ -1,5 +1,5 @@
 import { Client, connect as mqttConnect } from 'mqtt'
-import { DataSource, DataSourceState } from './'
+import { DataSource, DataSourceStateMachine } from './'
 
 export interface MqttOptions {
   url: string
@@ -15,8 +15,8 @@ export class MqttSource implements DataSource<MqttOptions> {
     this.messageCallback = messageCallback
   }
 
-  public connect(options: MqttOptions): DataSourceState {
-    const state = new DataSourceState()
+  public connect(options: MqttOptions): DataSourceStateMachine {
+    const state = new DataSourceStateMachine()
 
     const client = mqttConnect(options.url, {
       resubscribe: false

backend/src/DataSource/index.ts

@@ -1,10 +1,11 @@
 import { DataSource } from './DataSource'
-import { DataSourceState } from './DataSourceState'
+import { DataSourceState, DataSourceStateMachine } from './DataSourceState'
 import { MqttOptions, MqttSource } from './MqttSource'
 
 export {
   DataSource,
   DataSourceState,
+  DataSourceStateMachine,
   MqttOptions,
   MqttSource,
 }