81 lines
2.4 KiB
JavaScript
81 lines
2.4 KiB
JavaScript
const _ = require('lodash/fp')
|
|
const db = require('./db')
|
|
const BN = require('./bn')
|
|
const CashInTx = require('./cash-in/cash-in-tx')
|
|
const CashOutTx = require('./cash-out/cash-out-tx')
|
|
|
|
function process (tx, pi) {
|
|
const mtx = massage(tx, pi)
|
|
if (mtx.direction === 'cashIn') return CashInTx.post(mtx, pi)
|
|
if (mtx.direction === 'cashOut') return CashOutTx.post(mtx, pi)
|
|
return Promise.reject(new Error('No such tx direction: ' + mtx.direction))
|
|
}
|
|
|
|
function post (tx, pi) {
|
|
return process(tx, pi)
|
|
.then(_.set('dirty', false))
|
|
}
|
|
|
|
function massage (tx, pi) {
|
|
const isDateField = r => r === 'created' || _.endsWith('_time', r)
|
|
const transformDate = (v, k) => isDateField(k) ? new Date(v) : v
|
|
const mapValuesWithKey = _.mapValues.convert({'cap': false})
|
|
const transformDates = r => mapValuesWithKey(transformDate, r)
|
|
|
|
const mapBN = r => {
|
|
const update = r.direction === 'cashIn'
|
|
? {
|
|
cryptoAtoms: BN(r.cryptoAtoms),
|
|
fiat: BN(r.fiat),
|
|
cashInFee: BN(r.cashInFee),
|
|
cashInFeeCrypto: BN(r.cashInFeeCrypto),
|
|
commissionPercentage: BN(r.commissionPercentage),
|
|
rawTickerPrice: r.rawTickerPrice ? BN(r.rawTickerPrice) : null,
|
|
minimumTx: BN(r.minimumTx)
|
|
}
|
|
: {
|
|
cryptoAtoms: BN(r.cryptoAtoms),
|
|
fiat: BN(r.fiat),
|
|
rawTickerPrice: r.rawTickerPrice ? BN(r.rawTickerPrice) : null,
|
|
commissionPercentage: BN(r.commissionPercentage)
|
|
}
|
|
|
|
return _.assign(r, update)
|
|
}
|
|
|
|
const mapper = _.flow(
|
|
transformDates,
|
|
mapBN,
|
|
_.unset('dirty'))
|
|
|
|
return mapper(tx)
|
|
}
|
|
|
|
function cancel (txId) {
|
|
const promises = [
|
|
CashInTx.cancel(txId).then(() => true).catch(() => false),
|
|
CashOutTx.cancel(txId).then(() => true).catch(() => false)
|
|
]
|
|
|
|
return Promise.all(promises)
|
|
.then(r => {
|
|
if (_.some(r)) return
|
|
throw new Error('No such transaction')
|
|
})
|
|
}
|
|
|
|
function customerHistory (customerId, thresholdDays) {
|
|
const sql = ` select txIn.id, txIn.created, txIn.fiat, 'cashIn' as direction from cash_in_txs txIn
|
|
where txIn.customer_id = $1
|
|
and txIn.created > now() - interval $2
|
|
union
|
|
select txOut.id, txOut.created, txOut.fiat, 'cashOut' as direction from cash_out_txs txOut
|
|
where txOut.customer_id = $1
|
|
and txOut.created > now() - interval $2
|
|
order by created;`
|
|
|
|
const days = _.isNil(thresholdDays) ? 0 : thresholdDays
|
|
return db.any(sql, [customerId, `${days} days`])
|
|
}
|
|
|
|
module.exports = {post, cancel, customerHistory}
|