diff options
| author | James Barnett <james.barnett@fivium.co.uk> | 2018-10-21 19:19:21 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-10-21 19:19:21 +0100 |
| commit | 70f8a9aefe5ff56c44a871cdeef702f904e118f6 (patch) | |
| tree | dea50b1cfb3af425cdf8fa12df553ae7b5377c6d /routes | |
| parent | 7b699c8ca08aba2b400ce2cc04a5315c96ffae61 (diff) | |
| parent | c571c1d59031eaf510e560f3bdc62df2374ba45f (diff) | |
| download | tplink-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')
| -rw-r--r-- | routes/ws.js | 7 |
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)); + }); + } }); |