summaryrefslogtreecommitdiff
path: root/backend/index.js
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2018-05-22 14:07:25 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2018-12-13 16:59:39 +0100
commit6382ed01e9db8f975b72c9c2c8db4013cd0156c2 (patch)
tree0007030148e27fe9152ccb28a91c3497d62b27d8 /backend/index.js
parent60186a7bb45a0063f605f8d4b05c2f08418733af (diff)
downloadbrokentalents-6382ed01e9db8f975b72c9c2c8db4013cd0156c2.tar.gz
brokentalents-6382ed01e9db8f975b72c9c2c8db4013cd0156c2.zip
Add metadata file to data
Diffstat (limited to 'backend/index.js')
-rw-r--r--backend/index.js12
1 files changed, 11 insertions, 1 deletions
diff --git a/backend/index.js b/backend/index.js
index c8be64e..8480f28 100644
--- a/backend/index.js
+++ b/backend/index.js
@@ -3,6 +3,7 @@
const R = require('ramda'),
Future = require('fluture'),
moment = require('moment'),
+ fsPath = require('fs-path'),
reduce = require('./reduce'),
source = require('./source'),
file = require('./file'),
@@ -23,11 +24,20 @@ function main() {
const hours = R.range(0, Math.floor(duration.asHours()));
const laterMoments = R.map(later(start), hours);
+ const metadata = {
+ lastUpdate: moment().toISOString(),
+ config,
+ };
+ const saveMetadata = (path, data) =>
+ Future.node((cb) => fsPath.writeFile(path, JSON.stringify(data), cb))
+ .map(() => data);
+
const futures = R.map(loadFTimestamped, laterMoments);
Future.parallel(1, futures)
.map(R.compose(deriveStatistics, aggregatePayloads, cleanPayloads, R.unnest))
.chain(saveFPayloads(config.file.reportPattern()))
- .fork(console.error, (d) => console.log(JSON.stringify(d, null, 2)));
+ .chain((data) => saveMetadata(config.file.metadataPattern(), metadata))
+ .fork(console.error, (d) => {});
}
main();