From 6e92891f6c16c1f2b0554c49d32fbce7341bd125 Mon Sep 17 00:00:00 2001
From: sparks-alec <sparks.alec@gmail.com>
Date: Mon, 12 Jun 2023 01:13:13 -0400
Subject: [PATCH] signal when data is received

previously we only signaled when sent!
---
 src/device.js | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/device.js b/src/device.js
index a6a54ea..0af3756 100644
--- a/src/device.js
+++ b/src/device.js
@@ -129,6 +129,7 @@ function initDeviceConnection(id) {
       } catch (err) {
         console.error(err);
       }
+      device.trafficSignal(device);
       device.lastMessage = Date.now();
     });
     device.send = (address, args) => {
@@ -162,6 +163,7 @@ function initDeviceConnection(id) {
       // log("SOCK IN", message);
       plugins[type].data(device, message);
       device.lastMessage = Date.now();
+      device.trafficSignal(device);
       infoUpdate(device, 'status', 'ok');
     });
     device.send = (data) => {
@@ -180,6 +182,7 @@ function initDeviceConnection(id) {
       device.connection.on('message', (msg, info) => {
         plugins[type].data(device, msg);
         device.lastMessage = Date.now();
+        device.trafficSignal(device);
         infoUpdate(device, 'status', 'ok');
       });
     });
@@ -201,6 +204,7 @@ function initDeviceConnection(id) {
       device.connection.on('message', (msg, info) => {
         plugins[type].data(device, msg);
         device.lastMessage = Date.now();
+        device.trafficSignal(device);
         infoUpdate(device, 'status', 'ok');
       });
     });
@@ -215,6 +219,7 @@ function initDeviceConnection(id) {
 
     device.connection.on('connected', () => {
       infoUpdate(device, 'status', 'ok');
+      device.trafficSignal(device);
       plugins[type].ready(device);
     });