Merge pull request #24 from Risto-Stevcev/master

Added most

Author: davidchambers

README.md

@@ -24,6 +24,7 @@ The solutions are best read in the following order:
   - [__righto.js__](./righto.js)
   - [__promises.js__](./promises.js)
   - [__promises-ramda.js__](./promises-ramda.js)
+  - [__most.js__](./most.js)
   - [__coroutines-co.js__](./coroutines-co.js)
   - [__coroutines-bluebird.js__](./coroutines-bluebird.js)
   - [__await.js__](./await.js)

most.js

@@ -0,0 +1,42 @@
+'use strict';
+
+const fs = require('fs');
+const path = require('path');
+
+const most = require('most');
+const R = require('ramda');
+const S = require('sanctuary');
+
+
+//    join :: String -> String -> String
+const join = R.curryN(2, path.join);
+
+//    readFile :: String -> String -> Promise Error String
+const readFile = R.curry((encoding, filename) =>
+  new Promise((resolve, reject) =>
+    fs.readFile(filename, { encoding: encoding }, (err, data) =>
+      err != null ? reject(err) : resolve(data)
+    )));
+
+//    concatFiles :: String -> Promise Error String
+const concatFiles = dir =>
+  R.pipe(R.pipe(readFile('utf8'), most.fromPromise),
+         R.map(S.lines),
+         R.map(R.map(join(dir))),
+         R.chain(R.pipe(R.map(readFile('utf8')), most.from)),
+         stream => stream.await(),
+         R.reduce(R.concat, '')
+  )(join(dir, 'index.txt'));
+
+
+const main = () => {
+  concatFiles(process.argv[2]).then(value => {
+    process.stdout.write(value);
+    process.exit(0);
+  }, err => {
+    process.stderr.write(String(err) + '\n');
+    process.exit(1);
+  });
+};
+
+if (process.mainModule.filename === __filename) main();

package.json

@@ -12,6 +12,7 @@
     "foreign": "1.0.x",
     "kgo": "3.1.x",
     "lazy-either": "1.0.x",
+    "most": "0.18.x",
     "ramda": "0.19.x",
     "righto": "0.3.x",
     "sanctuary": "0.9.x"

test

@@ -57,6 +57,7 @@ test kgo.js
 test righto.js
 test promises.js
 test promises-ramda.js
+test most.js
 test coroutines-co.js
 test coroutines-bluebird.js
 test await.compiled.js