aboutsummaryrefslogtreecommitdiff
path: root/routes/ws.js
diff options
context:
space:
mode:
authorJames Barnett <james.barnett@fivium.co.uk>2018-10-21 19:19:21 +0100
committerGitHub <noreply@github.com>2018-10-21 19:19:21 +0100
commit70f8a9aefe5ff56c44a871cdeef702f904e118f6 (patch)
treedea50b1cfb3af425cdf8fa12df553ae7b5377c6d /routes/ws.js
parent7b699c8ca08aba2b400ce2cc04a5315c96ffae61 (diff)
parentc571c1d59031eaf510e560f3bdc62df2374ba45f (diff)
downloadtplink-energy-monitor-70f8a9aefe5ff56c44a871cdeef702f904e118f6.tar.xz
tplink-energy-monitor-70f8a9aefe5ff56c44a871cdeef702f904e118f6.zip
Merge pull request #9 from jamesbarnett91/log-realtime-usage
Log realtime usage
Diffstat (limited to 'routes/ws.js')
-rw-r--r--routes/ws.js7
1 files changed, 6 insertions, 1 deletions
diff --git a/routes/ws.js b/routes/ws.js
index 08b0a18..1599721 100644
--- a/routes/ws.js
+++ b/routes/ws.js
@@ -4,6 +4,7 @@ const router = express.Router();
const deviceManager = require('../services/device-manager');
const dataFetcher = require('../services/data-fetcher');
const dataBroadcaster = require('../services/data-broadcaster');
+const dataLogger = require('../services/data-logger.js');
router.ws('/', function(ws, req) {
@@ -15,11 +16,15 @@ router.ws('/', function(ws, req) {
if(message.requestType === 'getCachedData') {
let deviceId = message.deviceId;
let cachedData = dataFetcher.getCachedData(deviceId);
-
+
ws.send(dataBroadcaster.generatePayload('realtimeUsage', deviceId, cachedData.realtimeUsage));
ws.send(dataBroadcaster.generatePayload('dailyUsage', deviceId, cachedData.dailyUsage));
ws.send(dataBroadcaster.generatePayload('monthlyUsage', deviceId, cachedData.monthlyUsage));
ws.send(dataBroadcaster.generatePayload('powerState', deviceId, cachedData.powerState));
+ dataLogger.getLogEntriesForDevice(deviceId, (loggedData) => {
+ ws.send(dataBroadcaster.generatePayload('loggedData', deviceId, loggedData));
+ });
+
}
});