1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
|
const express = require('express');
const router = express.Router();
const deviceManager = require('../services/device-manager');
const moment = require('moment');
router.get('/:deviceId/realtime', function(req, res, next) {
let deviceId = req.params.deviceId;
let realtimeUsage = {};
// TODO - cache results with a short TTL so we don't hammer the plug if multiple clients are requesting data
deviceManager.getDevice(deviceId).emeter.getRealtime().then(response => {
// Voltage seems to be reported as its peak to peak value, not RMS.
// Show the RMS value since thats what would you expect to see.
// i.e. 220v not 310v (in the U.K)
response.voltage = response.voltage / Math.sqrt(2);
res.json(response);
});
});
router.get('/:deviceId/day-stats', function(req, res, next) {
let deviceId = req.params.deviceId;
// Get last x days
let totalDaysRequired = 30; // TODO currently only works for up to 2 months spans
let currentMoment = moment();
let previousMoment = moment().subtract(totalDaysRequired, 'days');
// Month + 1 as the API months are index 1 based.
deviceManager.getDevice(deviceId).emeter.getDayStats(currentMoment.year(), currentMoment.month() +1).then(currentPeriodStats => {
// Check if we also need the previous month to meet the required total number of samples
if(currentMoment.month() !== previousMoment.month()) {
// Get previous month. This currently wont work if the previousMoment is more than 1 month before the currentMoment (see above)
deviceManager.getDevice(deviceId).emeter.getDayStats(previousMoment.year(), previousMoment.month() +1).then(previousPeriodStats => {
let currentMonthStats = fillMissingDays(currentPeriodStats, currentMoment);
let previousMonthStats = fillMissingDays(previousPeriodStats, previousMoment);
let combinedStats = previousMonthStats.concat(currentMonthStats);
res.json(trimStatResults(combinedStats, totalDaysRequired));
});
}
else {
let dayStats = fillMissingDays(currentPeriodStats, currentMoment);
res.json(trimStatResults(dayStats, totalDaysRequired));
}
});
});
router.get('/:deviceId/month-stats', function(req, res, next) {
let deviceId = req.params.deviceId;
// Get last x months
let totalMonthsRequired = 12; // TODO currently only works for up to 14 month (2 year) spans
let currentMoment = moment();
let previousMoment = moment().subtract(totalMonthsRequired, 'months');
deviceManager.getDevice(deviceId).emeter.getMonthStats(currentMoment.year()).then(currentPeriodStats => {
// Check if we also need the previous year to meet the required total number of samples
if(currentMoment.month() + 1 < totalMonthsRequired) {
// Get previous year (assuming the totalMonthsRequired limit described above).
deviceManager.getDevice(deviceId).emeter.getMonthStats(previousMoment.year()).then(previousPeriodStats => {
let currentYearStats = fillMissingMonths(currentPeriodStats, currentMoment);
let previousYearStats = fillMissingMonths(previousPeriodStats, previousMoment);
let combinedStats = previousYearStats.concat(currentYearStats);
res.json(trimStatResults(combinedStats, totalMonthsRequired));
});
}
else {
let monthStats = fillMissingMonths(currentPeriodStats, currentMoment);
res.json(trimStatResults(monthStats, totalMonthsRequired));
}
});
});
function fillMissingDays(sparseDayStats, statsMoment) {
let denseDayStats = [];
let totalDays;
// If these stats are for the current month, fill up to the current day of the month
// Otherwise fill the whole month
if(moment().month() === statsMoment.month()) {
totalDays = statsMoment.date();
}
else {
totalDays = statsMoment.daysInMonth();
}
Array.from({length: totalDays}, (x,i) => i + 1).forEach(d => {
let stat = sparseDayStats.day_list.find(i => i.day === d);
if(stat === undefined) {
denseDayStats.push({
year: statsMoment.year(),
month: statsMoment.month() +1,
day: d,
energy: 0
})
}
else {
denseDayStats.push(stat);
}
});
return denseDayStats;
}
function fillMissingMonths(sparseMonthStats, statsMoment) {
let denseMonthStats = [];
let maxMonths;
// Dont fill months in months which havent happened yet
if(statsMoment.year() === moment().year()) {
maxMonths = moment().month();
}
else {
maxMonths = 12;
}
// Fill in any missing months up to the max amount
Array.from({length: maxMonths}, (x,i) => i + 1).forEach(m => {
let stat = sparseMonthStats.month_list.find(i => i.month === m);
if(stat === undefined) {
denseMonthStats.push({
year: statsMoment.year(),
month: m,
energy: 0
})
}
else {
denseMonthStats.push(stat);
}
});
return denseMonthStats;
}
function trimStatResults(stats, maxSamples) {
return stats.splice(stats.length - maxSamples, stats.length);
}
module.exports = router;
|