From 5caf4e48174533710243e8eeaf52567795ec9d01 Mon Sep 17 00:00:00 2001 From: schneefux Date: Mon, 7 May 2018 09:06:04 +0200 Subject: move files to backend subdir, push data in submodule --- backend/index.js | 27 +++++++++++++++++++++++++++ 1 file changed, 27 insertions(+) create mode 100644 backend/index.js (limited to 'backend/index.js') diff --git a/backend/index.js b/backend/index.js new file mode 100644 index 0000000..5da0f82 --- /dev/null +++ b/backend/index.js @@ -0,0 +1,27 @@ +#!/usr/bin/node + +const R = require('ramda'), + Future = require('fluture'), + moment = require('moment'), + reduce = require('./reduce'), + source = require('./source'), + config = require('./config'); + +const loadFTimestamped = source.loadFTimestamped(config); +const deriveStatistics = reduce.deriveStatistics(config.reduce); +const aggregatePayloads = reduce.aggregatePayloads(config.reduce); + +function main() { + const firstOfMay = moment('2018-05-01'); + + const later = R.curry((base, hs) => base.clone().add(hs, 'hours')); + const hours = R.range(0, 24 * 5); + const laterMoments = R.map(later(firstOfMay), hours); + + const futures = R.map(loadFTimestamped, laterMoments); + Future.parallel(1, futures) + .map(R.compose(deriveStatistics, aggregatePayloads, R.unnest)) + .fork(console.error, (d) => console.log(JSON.stringify(d, null, 2))); +} + +main(); -- cgit v1.3.1