save output as report

2 files changed, 5 insertions, 1 deletions

diff --git a/backend/config.js b/backend/config.js
index fe51ca3..cecbe05 100644
--- a/backend/config.js
+++ b/backend/config.js
@@ -55,5 +55,6 @@ module.exports = {
   },
   file: {
     pattern: (moment) => `../data/${hashSettings(module.exports)}/${moment.toISOString()}.json`,
+    reportPattern: () => `../data/${hashSettings(module.exports)}/report.json`,
   },
 };
diff --git a/backend/index.js b/backend/index.js
index 5da0f82..0befe86 100644
--- a/backend/index.js
+++ b/backend/index.js
@@ -5,22 +5,25 @@ const R  = require('ramda'),
   moment = require('moment'),
   reduce = require('./reduce'),
   source = require('./source'),
+  file   = require('./file'),
   config = require('./config');
 
 const loadFTimestamped = source.loadFTimestamped(config);
 const deriveStatistics = reduce.deriveStatistics(config.reduce);
 const aggregatePayloads = reduce.aggregatePayloads(config.reduce);
+const saveFPayloads = file.saveFPayloads(config.file);
 
 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 hours = R.range(0, 24 * 5 + 20);
   const laterMoments = R.map(later(firstOfMay), hours);
 
   const futures = R.map(loadFTimestamped, laterMoments);
   Future.parallel(1, futures)
     .map(R.compose(deriveStatistics, aggregatePayloads, R.unnest))
+    .chain(saveFPayloads(config.file.reportPattern()))
     .fork(console.error, (d) => console.log(JSON.stringify(d, null, 2)));
 }