Extract API functions into separate files that can be required independently

Author: j5ndev

CHANGELOG.md

@@ -9,6 +9,7 @@ This project adheres to [Semantic Versioning](http://semver.org/).
 ### Major
 
 ### Minor
+- Extract API functions into separate files that can be required independently
 
 ### Patch
 

README.md

@@ -7,9 +7,17 @@ Also see [default values for array destructuring][5].
 
 [Change Log][6]
 
-## Example
+## Require
+
+### Require an Object With All Functions
+
+    const catchify = require('catchify');
+
+### Require Functions Individually
 
-### 
+    const all = require('catchify/all');
+
+## Example
 
 ```
 const catchify = require('catchify');
@@ -22,6 +30,8 @@ async function example(promise){
 
 ```
 
+
+
 ## API
 
 * **catchify(value)**

all.js

@@ -0,0 +1,25 @@
+'use strict';
+
+const arrayToObj = require('./lib/arrayToObj');
+const objToArray = require('./lib/objToArray');
+
+function onThenAllFactory (keys) {
+  return function onThenAll (value) {
+    return [null, arrayToObj(keys, value)];
+  };
+}
+
+function onCatchAllFactory (keys) {
+  return function onCatchAll (error) {
+    return [error, keys ? {} : []];
+  };
+}
+
+function all (iterable) {
+  const [keys, values] = objToArray(iterable);
+  return Promise
+    .all(values)
+    .then(onThenAllFactory(keys), onCatchAllFactory(keys));
+}
+
+module.exports = all;

index.js

@@ -1,126 +1,12 @@
 'use strict';
 
-const arrayToObj = require('./lib/arrayToObj');
-const objToArray = require('./lib/objToArray');
-
-function onThenAllFactory (keys) {
-  return function onThenAll (value) {
-    return [null, arrayToObj(keys, value)];
-  };
-}
-
-function onThen (value) {
-  return [null, value];
-}
-
-function onCatch (error) {
-  return [error, null];
-}
-
-function onCatchAllFactory (keys) {
-  return function onCatchAll (error) {
-    return [error, keys ? {} : []];
-  };
-}
-
-function catchify (p) {
-  return Promise
-    .resolve(p)
-    .then(onThen, onCatch);
-}
+const catchify = require('./resolve');
 
+catchify.all = require('./all');
+catchify.limit = require('./limit');
+catchify.race = require('./race');
+catchify.reject = require('./reject');
 catchify.resolve = catchify;
-
-catchify.race = function catchifyRace (iterable) {
-  return Promise
-    .race(iterable)
-    .then(onThen, onCatch);
-};
-
-catchify.all = function catchifyAll (iterable) {
-  const [keys, values] = objToArray(iterable);
-  return Promise
-    .all(values)
-    .then(onThenAllFactory(keys), onCatchAllFactory(keys));
-};
-
-catchify.reject = function catchifyReject (reason) {
-  return Promise
-    .reject(reason)
-    .catch(onCatch);
-};
-
-function onValue (value) {
-  return {
-    error: null,
-    value: value
-  };
-}
-
-function onError (error) {
-  return {
-    error: error,
-    value: null
-  };
-}
-
-function extractValue (result) {
-  return result.value || null;
-}
-
-function extractError (result) {
-  return result.error || null;
-}
-
-function onThenWithErrorsFactory (keys) {
-  return function onThenWithErrors (results) {
-    return [
-      arrayToObj(keys, results.map(extractError)),
-      arrayToObj(keys, results.map(extractValue))
-    ];
-  };
-}
-
-catchify.some = function catchifySome (iterable) {
-  const [keys, items] = objToArray(iterable);
-  const promises = [];
-  for (let value of items) {
-    promises.push(Promise
-      .resolve(value)
-      .then(onValue, onError)
-    );
-  }
-  return Promise
-    .all(promises)
-    .then(onThenWithErrorsFactory(keys));
-};
-
-catchify.limit = async function catchifyLimit (iterable, limit = 2, exitOnError = false) {
-  const [keys, items] = objToArray(iterable);
-  const allErrors = [];
-  const allValues = [];
-  const queue = [];
-  for (let value of items) {
-    queue.push(typeof value === 'function' ? value() : value);
-    if (queue.length === limit) {
-      const [errors, values] = await catchify.some(queue);
-      allErrors.push(...errors);
-      allValues.push(...values);
-      queue.length = 0;
-      if (exitOnError && errors.filter((err) => err).length > 0) {
-        break;
-      }
-    }
-  }
-  if (queue.length > 0) {
-    const [errors, values] = await catchify.some(queue);
-    allErrors.push(...errors);
-    allValues.push(...values);
-  }
-  return [
-    arrayToObj(keys, allErrors),
-    arrayToObj(keys, allValues)
-  ];
-};
+catchify.some = require('./some');
 
 module.exports = catchify;

lib/onCatch.js

@@ -0,0 +1,7 @@
+'use strict';
+
+function onCatch (error) {
+  return [error, null];
+}
+
+module.exports = onCatch;

lib/onCatch.test.js

@@ -0,0 +1,10 @@
+'use strict';
+
+const subject = require('./onCatch');
+const test = require('ava');
+
+test('onCatch - error returned in array', t => {
+  const [error, value] = subject(1);
+  t.is(error, 1);
+  t.is(value, null);
+});

lib/onThen.js

@@ -0,0 +1,7 @@
+'use strict';
+
+function onThen (value) {
+  return [null, value];
+}
+
+module.exports = onThen;

lib/onThen.test.js

@@ -0,0 +1,10 @@
+'use strict';
+
+const subject = require('./onThen');
+const test = require('ava');
+
+test('onThen - return array with value', t => {
+  const [error, value] = subject(1);
+  t.is(error, null);
+  t.is(value, 1);
+});

limit.js

@@ -0,0 +1,35 @@
+'use strict';
+
+const arrayToObj = require('./lib/arrayToObj');
+const objToArray = require('./lib/objToArray');
+const some = require('./some');
+
+async function limit (iterable, limit = 2, exitOnError = false) {
+  const [keys, items] = objToArray(iterable);
+  const allErrors = [];
+  const allValues = [];
+  const queue = [];
+  for (let value of items) {
+    queue.push(typeof value === 'function' ? value() : value);
+    if (queue.length === limit) {
+      const [errors, values] = await some(queue);
+      allErrors.push(...errors);
+      allValues.push(...values);
+      queue.length = 0;
+      if (exitOnError && errors.filter((err) => err).length > 0) {
+        break;
+      }
+    }
+  }
+  if (queue.length > 0) {
+    const [errors, values] = await some(queue);
+    allErrors.push(...errors);
+    allValues.push(...values);
+  }
+  return [
+    arrayToObj(keys, allErrors),
+    arrayToObj(keys, allValues)
+  ];
+}
+
+module.exports = limit;

race.js

@@ -0,0 +1,12 @@
+'use strict';
+
+const onCatch = require('./lib/onCatch');
+const onThen = require('./lib/onThen');
+
+function race (iterable) {
+  return Promise
+    .race(iterable)
+    .then(onThen, onCatch);
+}
+
+module.exports = race;