chore: re-add feature missing from merge

lib/db.js

@@ -20,7 +20,8 @@ const stripDefaultDbFuncs = dbCtx => {
     manyOrNone: dbCtx.$manyOrNone,
     tx: dbCtx.$tx,
     task: dbCtx.$task,
-    batch: dbCtx.batch
+    batch: dbCtx.batch,
+    multi: dbCtx.$multi
   }
 }
 
@@ -67,6 +68,7 @@ const pgp = Pgp({
     obj.$one = (query, variables) => obj.__taskEx(t => t.one(query, variables))
     obj.$none = (query, variables) => obj.__taskEx(t => t.none(query, variables))
     obj.$any = (query, variables) => obj.__taskEx(t => t.any(query, variables))
+    obj.$multi = (query, variables) => obj.__taskEx(t => t.multi(query, variables))
     // when opts is not defined "cb" occupies the "opts" spot of the arguments
     obj.$tx = (opts, cb) => typeof opts === 'function' ? _tx(obj, {}, opts) : _tx(obj, opts, cb)
     obj.$task = (opts, cb) => typeof opts === 'function' ? _task(obj, {}, opts) : _task(obj, opts, cb)

lib/new-admin/graphql/resolvers/transaction.resolver.js

@@ -31,8 +31,8 @@ const resolvers = {
   Query: {
     transactions: (...[, { from, until, limit, offset, deviceId, txClass, machineName, customerName, fiatCode, cryptoCode, toAddress, status }]) =>
       transactions.batch(from, until, limit, offset, deviceId, txClass, machineName, customerName, fiatCode, cryptoCode, toAddress, status),
-    transactionsCsv: (...[, { from, until, limit, offset, txClass, machineName, customerName, fiatCode, cryptoCode, toAddress, status, timezone }]) =>
-      transactions.batch(from, until, limit, offset, txClass, machineName, customerName, fiatCode, cryptoCode, toAddress, status)
+    transactionsCsv: (...[, { from, until, limit, offset, txClass, machineName, customerName, fiatCode, cryptoCode, toAddress, status, timezone, simplified }]) =>
+      transactions.batch(from, until, limit, offset, txClass, machineName, customerName, fiatCode, cryptoCode, toAddress, status, simplified)
         .then(data => parseAsync(logDateFormat(timezone, data, ['created', 'sendTime']), { fields: txLogFields })),
     transactionCsv: (...[, { id, txClass, timezone }]) =>
       transactions.getTx(id, txClass).then(data => 

lib/new-admin/graphql/types/transaction.type.js

@@ -52,7 +52,7 @@ const typeDef = gql`
 
   type Query {
     transactions(from: Date, until: Date, limit: Int, offset: Int, deviceId: ID, txClass: String, machineName: String, customerName: String, fiatCode: String, cryptoCode: String, toAddress: String, status: String): [Transaction] @auth
-    transactionsCsv(from: Date, until: Date, limit: Int, offset: Int, txClass: String, machineName: String, customerName: String, fiatCode: String, cryptoCode: String, toAddress: String, status: String, timezone: String): String @auth
+    transactionsCsv(from: Date, until: Date, limit: Int, offset: Int, txClass: String, machineName: String, customerName: String, fiatCode: String, cryptoCode: String, toAddress: String, status: String, timezone: String, simplified: Boolean): String @auth
     transactionCsv(id: ID, txClass: String, timezone: String): String @auth
     txAssociatedDataCsv(id: ID, txClass: String, timezone: String): String @auth
     transactionFilters: [Filter] @auth

lib/new-admin/services/transactions.js

@@ -36,7 +36,8 @@ function batch (
   fiatCode = null,
   cryptoCode = null,
   toAddress = null,
-  status = null
+  status = null,
+  simplified = false
 ) {
   const packager = _.flow(_.flatten, _.orderBy(_.property('created'), ['desc']), _.map(camelize), addNames)
 
@@ -99,6 +100,55 @@ function batch (
     db.any(cashOutSql, [REDEEMABLE_AGE, from, until, limit, offset, id, txClass, machineName, customerName, fiatCode, cryptoCode, toAddress, status])
   ])
     .then(packager)
+    .then(res => {
+      if (simplified) return simplifiedBatch(res)
+      else return res
+    })
+}
+
+function simplifiedBatch (data) {
+  const fields = ['txClass', 'id', 'created', 'machineName',
+    'cryptoCode', 'fiat', 'fiatCode', 'phone', 'toAddress',
+    'txHash', 'dispense', 'error', 'status', 'fiatProfit', 'cryptoAmount']
+
+  const addSimplifiedFields = _.map(it => ({
+    ...it,
+    status: getStatus(it),
+    fiatProfit: getProfit(it).toString(),
+    cryptoAmount: getCryptoAmount(it)
+  }))
+
+  return _.compose(_.map(_.pick(fields)), addSimplifiedFields)(data)
+}
+
+const getCryptoAmount = it => coinUtils.toUnit(BN(it.cryptoAtoms), it.cryptoCode).toString()
+
+const getProfit = it => {
+  const getCommissionFee = it => BN(it.commissionPercentage).mul(BN(it.fiat))
+  if (!it.cashInFee) return getCommissionFee(it)
+  return getCommissionFee(it).add(BN(it.cashInFee))
+}
+
+const getCashOutStatus = it => {
+  if (it.hasError) return 'Error'
+  if (it.dispense) return 'Success'
+  if (it.expired) return 'Expired'
+  return 'Pending'
+}
+
+const getCashInStatus = it => {
+  if (it.operatorCompleted) return 'Cancelled'
+  if (it.hasError) return 'Error'
+  if (it.sendConfirmed) return 'Sent'
+  if (it.expired) return 'Expired'
+  return 'Pending'
+}
+
+const getStatus = it => {
+  if (it.txClass === 'cashOut') {
+    return getCashOutStatus(it)
+  }
+  return getCashInStatus(it)
 }
 
 function getCustomerTransactionsBatch (ids) {