added subscriptions for service and device updates (mqtt updates on l…

…og) others update on connect & disconnect

src/device/ethernetip.js

@@ -32,11 +32,17 @@ class EthernetIP extends Model {
       } else {
         this.connected = false
       }
+      this.pubsub.publish('deviceUpdate', {
+        deviceUpdate: this.device
+      })
     }
   }
   async disconnect() {
     this.client.destroy()
     this.connected = false
+    this.pubsub.publish('deviceUpdate', {
+      deviceUpdate: this.device
+    })
   }
   get host() {
     this.checkInit()

src/device/modbus.js

@@ -81,6 +81,9 @@ class Modbus extends Model {
           `Connection failed to modbus device ${this.device.name}, host: ${this.host}, port: ${this.port}, with error: ${this.error}.`
         )
       }
+      this.pubsub.publish('deviceUpdate', {
+        deviceUpdate: this.device
+      })
     }
   }
   async disconnect() {
@@ -100,6 +103,9 @@ class Modbus extends Model {
       }
     })
     this.connected = false
+    this.pubsub.publish('deviceUpdate', {
+      deviceUpdate: this.device
+    })
   }
   get host() {
     this.checkInit()

src/relations.js

@@ -400,7 +400,9 @@ MqttSource.prototype.log = async function(scanClassId) {
           sql = `${sql} VALUES (?,?);`
           params = [host.id, result.lastID]
           await this.constructor.executeUpdate(sql, params)
-          this.pubsub.publish('mqttUpdate', { mqttUpdate: this.mqtt.service })
+          this.pubsub.publish('serviceUpdate', {
+            serviceUpdate: this.mqtt.service
+          })
         }
         resolve()
       })

src/resolvers/Subscription/index.js

@@ -1,7 +1,7 @@
 const tag = require('./tag')
-const mqttUpdate = require('./mqttUpdate')
+const service = require('./service')
 
 module.exports = {
-  ...mqttUpdate,
+  ...service,
   ...tag
 }

src/schema.graphql

@@ -357,5 +357,6 @@ type Mutation {
 
 type Subscription {
   tagUpdate: Tag,
-  mqttUpdate: Service
+  deviceUpdate: Device,
+  serviceUpdate: Service
 }