From 6382ed01e9db8f975b72c9c2c8db4013cd0156c2 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Tue, 22 May 2018 14:07:25 +0200
Subject: Add metadata file to data

---
 backend/index.js | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

(limited to 'backend/index.js')

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();
-- 
cgit v1.3.1