summaryrefslogtreecommitdiff
path: root/reduce.js
diff options
context:
space:
mode:
Diffstat (limited to 'reduce.js')
-rw-r--r--reduce.js51
1 files changed, 0 insertions, 51 deletions
diff --git a/reduce.js b/reduce.js
deleted file mode 100644
index 3ac9da2..0000000
--- a/reduce.js
+++ /dev/null
@@ -1,51 +0,0 @@
-#!/usr/bin/node
-
-const R = require('ramda'),
- utils = require('./utils');
-
-function aggregatePayloads(config) {
- // Ramda group() only groups neighbors, so sort beforehand
- const sorter = R.props(config.group);
- const grouper = utils.eqPropses(config.group);
-
- // sum & count
- const aggregator = R.pipe(
- R.sortBy(sorter),
- R.groupWith(grouper),
- R.map(
- R.converge(utils.mergeAllArgs, [
- R.pipe(
- R.project(config.group),
- R.prop(0),
- ),
- R.pipe(
- R.project(R.concat(config.sum, R.of('Count'))),
- utils.mergeAllWith(R.add),
- utils.unlist,
- ),
- ]),
- ),
- );
-
- return aggregator;
-}
-
-function deriveStatistics(config) {
- const sorter = R.compose(R.defaultTo(0), R.prop('Winner'));
-
- // divide sums by counts = averages
- const transformer = R.map(
- R.converge(utils.mergeAllArgs, [
- utils.projectProps(config.group),
- utils.divPropsByProp('Count', config.sum),
- utils.projectProps(['Count']),
- ])
- );
-
- return R.compose(transformer, R.sortBy(sorter));
-}
-
-module.exports = {
- aggregatePayloads,
- deriveStatistics,
-};