45 lines
1.1 KiB
JavaScript
45 lines
1.1 KiB
JavaScript
|
const uniq = require('lodash.uniq');
|
||
|
|
const flatten = require('lodash.flatten');
|
||
|
|
const argv = require('minimist')(process.argv);
|
||
|
|
const moment = require('moment');
|
||
|
|
const path = require('path');
|
||
|
|
const fs = require('fs');
|
||
|
|
|
||
|
|
if (!argv.file) {
|
||
|
|
throw new Error('--file required');
|
||
|
|
}
|
||
|
|
|
||
|
|
const filename = path.resolve(__dirname, argv.file);
|
||
|
|
|
||
|
|
if (!fs.existsSync(filename)) {
|
||
|
|
throw new Error('--file does not exist');
|
||
|
|
}
|
||
|
|
|
||
|
|
const data = require(filename);
|
||
|
|
const metrics = flatten(uniq(Object.keys(data.leak).map((service) => {
|
||
|
|
return Object.keys(data.leak[service]);
|
||
|
|
})));
|
||
|
|
|
||
|
|
const aggregated = metrics.reduce((agg, name) => Object.assign(agg, {
|
||
|
|
[name]: []
|
||
|
|
}), {});
|
||
|
|
|
||
|
|
const sort = (set) => {
|
||
|
|
return set.sort((a, b) => {
|
||
|
|
return moment(a[0], 'X').isAfter(moment(b[0], 'X')) ? 1 : -1;
|
||
|
|
});
|
||
|
|
};
|
||
|
|
|
||
|
|
Object.keys(data.leak).forEach((service) => {
|
||
|
|
Object.keys(data.leak[service]).forEach((metric) => {
|
||
|
|
aggregated[metric] = aggregated[metric].concat(data.leak[service][metric]);
|
||
|
|
});
|
||
|
|
});
|
||
|
|
|
||
|
|
Object.keys(aggregated).forEach((metric) => {
|
||
|
|
console.error(metric);
|
||
|
|
aggregated[metric] = sort(aggregated[metric]);
|
||
|
|
});
|
||
|
|
|
||
|
|
console.log(JSON.stringify(aggregated, null, 2));
|