feature: allow configuration on the nmea2000 output event (#121)

This also makes so either string actisense or json formats can be sent to the same event
canboat · Aug 13, 2020 · 5963dcd · 5963dcd
1 parent 685d449
commit 5963dcd
Show file tree

Hide file tree

Showing 4 changed files with 31 additions and 13 deletions.
diff --git a/lib/canbus.js b/lib/canbus.js
@@ -83,7 +83,7 @@ function CanbusStream (options) {
   var that = this
 
   if ( options.app ) {
-    options.app.on('nmea2000out', (msg) => {
+    options.app.on(options.outEvent || 'nmea2000out', (msg) => {
       that.sendPGN(msg)
     })
     options.app.on('nmea2000JsonOut', (msg) => {

diff --git a/lib/ikonvert.js b/lib/ikonvert.js
@@ -70,8 +70,12 @@ function iKonvertStream (options) {
   var that = this
 
   if ( this.options.app ) {
-    options.app.on('nmea2000out', (msg) => {
-      that.sendActisensePGN(msg)
+    options.app.on(this.options.outEevent || 'nmea2000out', (msg) => {
+      if ( typeof msg === 'string' ) {
+        that.sendActisensePGN(msg)
+      } else {
+        that.sendPGN(msg)
+      }
     })
     options.app.on('nmea2000JsonOut', (msg) => {
       that.sendPGN(msg)

diff --git a/lib/serial.js b/lib/serial.js
@@ -129,22 +129,34 @@ SerialStream.prototype.start = function () {
     })
 
     if ( this.options.app ) {
-      this.options.app.on('nmea2000out', msg => {
+      function writeString(msg) {
         debugOut(`sending ${msg}`)
         var buf = parseInput(msg)
         buf = composeMessage(N2K_MSG_SEND, buf, buf.length)
         that.serial.write(buf)
-      })
-
-      this.options.app.on('nmea2000JsonOut', msg => {
+      }
+      
+      function writeObject(msg) {
         var data = toPgn(msg)
         var actisense = encodeActisense({ pgn: msg.pgn, data, dst: msg.dst})
         debugOut(`sending ${actisense}`)
         var buf = parseInput(actisense)
         buf = composeMessage(N2K_MSG_SEND, buf, buf.length)
         that.serial.write(buf)
+      }
+
+      this.options.app.on(this.options.outEevent || 'nmea2000out', msg => {
+        if ( typeof msg === 'string' ) {
+          writeString(msg)
+        } else {
+          writeObject(msg)
+        }
       })
-
+
+      this.options.app.on('nmea2000JsonOut', msg => {
+        writeObject(msg)
+      })
+
       this.options.app.emit('nmea2000OutAvailable')
     }
 

diff --git a/lib/ydgw02.js b/lib/ydgw02.js
@@ -47,17 +47,19 @@ function Ydgw02Stream (options) {
   })
 
 
-  if ( this.options.app ) {
-    options.app.on('nmea2000out', (msg) => {
-      this.sendYdgwPGN(msg)
+  if ( options.app ) {
+    options.app.on(this.options.outEevent || 'nmea2000out', (msg) => {
+      if ( typeof msg === 'string' ) {
+        this.sendYdgwPGN(msg)
+      } else {
+        this.sendPGN(msg)
+      }
     })
 
     options.app.on('nmea2000JsonOut', (msg) => {
       this.sendPGN(msg)
     })
 
-    //this.sendString('$PDGY,N2NET_OFFLINE')
-
     debug('started')
   }