diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2018-05-22 14:07:25 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2018-12-13 16:59:39 +0100 |
| commit | 6382ed01e9db8f975b72c9c2c8db4013cd0156c2 (patch) | |
| tree | 0007030148e27fe9152ccb28a91c3497d62b27d8 /backend/index.js | |
| parent | 60186a7bb45a0063f605f8d4b05c2f08418733af (diff) | |
| download | brokentalents-6382ed01e9db8f975b72c9c2c8db4013cd0156c2.tar.gz brokentalents-6382ed01e9db8f975b72c9c2c8db4013cd0156c2.zip | |
Add metadata file to data
Diffstat (limited to 'backend/index.js')
| -rw-r--r-- | backend/index.js | 12 |
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(); |
