Mirrors/unleash.unleash
1
0
Fork 0
mirror of https://github.com/Unleash/unleash.git synced 2025-01-01 00:08:27 +01:00
Code Issues Projects Releases Wiki Activity

remove internal storage

Browse Source
This commit is contained in:
sveisvei 2016-11-04 16:17:11 +01:00
parent ab201db754
commit cd5c2e3914
1 changed files with 14 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
packages/unleash-api/lib/client-metrics-service.js
View File

@ -3,42 +3,32 @@
const POLL_INTERVAL = 10000;
const { EventEmitter } = require('events');
module.exports = class UnleashClientMetricsService extends EventEmitter {
module.exports = class UnleashClientMetrics extends EventEmitter {
constructor (metricsDb) {
super();
this.metricsDb = metricsDb;
this.metrics = [];
this.db = metricsDb;
this.highestIdSeen = 0;
this.fetch();
}
fetch () {
return this.metricsDb
.getNewMetrics(this.highestIdSeen)
.then(metrics => {
this.startTimer();
this.addMetrics(metrics);
return metrics;
});
this.db.getMetricsLastWeek().then(metrics => {
this.addMetrics(metrics);
this.startPoller();
});
}
addMetrics (metrics) {
metrics.forEach(m => this.metrics.push(m));
if (this.metrics && this.metrics.length > 0) {
this.highestIdSeen = this.metrics[this.metrics.length - 1].id;
if (metrics && metrics.length > 0) {
this.highestIdSeen = metrics[metrics.length - 1].id;
}
this.emit('metrics', metrics);
}
startTimer () {
setInterval(() => this.fetch(), POLL_INTERVAL).unref();
}
getMetrics () {
return this.metrics;
startPoller () {
setInterval(() => {
this.db.getNewMetrics(this.highestIdSeen)
.then(metrics => this.addMetrics(metrics));
}, POLL_INTERVAL).unref();
}
insert (metrics) {
return this.metricsDb.insert(metrics);
return this.db.insert(metrics);
}
};