feat: remove pipeP usage

flybondi · Oct 20, 2022 · 010863e · 010863e
1 parent c81a0a4
commit 010863e
Show file tree

Hide file tree

Showing 5 changed files with 12 additions and 20 deletions.
diff --git a/src/count.js b/src/count.js
@@ -4,14 +4,13 @@
  * @see https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_Scan.html
  * @module Count
  */
-const { curry, compose, andThen, bind, prop, pipeWith } = require('ramda');
-const pipeP = pipeWith(andThen);
+const { curry, compose, bind, prop } = require('ramda');
 const addTableName = require('./table-name');
 
 /**
  * @private
  */
-const createCount = scan => pipeP([scan, prop('Count')]);
+const createCount = scan => params => scan(params).then(prop('Count'));
 
 /**
  * @private

diff --git a/src/get-all.js b/src/get-all.js
@@ -4,15 +4,14 @@
  * @see https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_Scan.html
  * @module Scan
  */
-const { curry, bind, pipeWith, andThen, compose } = require('ramda');
+const { curry, bind, compose } = require('ramda');
 const { unwrapAll } = require('./wrapper');
 const addTableName = require('./table-name');
-const pipeP = pipeWith(andThen);
 
 /**
  * @private
  */
-const createGetAll = scan => pipeP([scan, unwrapAll('Items')]);
+const createGetAll = scan => params => scan(params).then(unwrapAll('Items'));
 
 /**
  * @private

diff --git a/src/get.js b/src/get.js
@@ -4,17 +4,16 @@
  * @see https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_GetItem.html
  * @module GetItem
  */
-const { curry, bind, pipeWith, andThen, compose, apply } = require('ramda');
+const { curry, bind, compose } = require('ramda');
 const { unwrapProp } = require('./wrapper');
 const { mapMergeFirstPairOfArgs } = require('./map-merge-args');
 const generateKey = require('./generate-key');
 const addTableName = require('./table-name');
-const pipeP = pipeWith(andThen);
 
 /**
  * @private
  */
-const getUnwrappedItem = getItem => pipeP([apply(getItem), unwrapProp('Item')]);
+const getUnwrappedItem = getItem => params => getItem(...params).then(unwrapProp('Item'));
 
 /**
  * @private

diff --git a/src/remove.js b/src/remove.js
@@ -7,19 +7,18 @@
  * @module DeleteItem
  * @see https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_DeleteItem.html
  */
-const { apply, bind, compose, curry, pipeWith, andThen } = require('ramda');
+const { bind, compose, curry } = require('ramda');
 const { unwrapProp } = require('./wrapper');
 const addTableName = require('./table-name');
 const { mapMergeFirstPairOfArgs } = require('./map-merge-args');
 const generateKey = require('./generate-key');
 const addReturnValues = require('./return-values');
-const pipeP = pipeWith(andThen);
 
 /**
  * @private
  */
-const removeAndUnwrapAttributes = deleteItem =>
-  pipeP([apply(deleteItem), unwrapProp('Attributes')]);
+const removeAndUnwrapAttributes = deleteItem => params =>
+  deleteItem(...params).then(unwrapProp('Attributes'));
 
 /**
  * @private

diff --git a/src/update.js b/src/update.js
@@ -7,7 +7,6 @@
  */
 const {
   adjust,
-  apply,
   applyTo,
   bind,
   compose,
@@ -20,13 +19,11 @@ const {
   is,
   keys,
   map,
-  pipeWith,
   toPairs,
   unless,
   zipObj,
   reject,
-  equals,
-  andThen
+  equals
 } = require('ramda');
 const { getUpdateExpression } = require('dynamodb-update-expression');
 const { unwrapProp, wrapOver } = require('./wrapper');
@@ -35,13 +32,12 @@ const addTableName = require('./table-name');
 const addReturnValues = require('./return-values');
 const generateKey = require('./generate-key');
 const camelCase = require('lodash.camelcase');
-const pipeP = pipeWith(andThen);
 
 /**
  * @private
  */
-const updateAndUnwrapAttributes = updateItem =>
-  pipeP([apply(updateItem), unwrapProp('Attributes')]);
+const updateAndUnwrapAttributes = updateItem => params =>
+  updateItem(...params).then(unwrapProp('Attributes'));
 
 /**
  * @private