lamassu/lamassu-server
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Splitting up daily volume queries

Browse source
This commit is contained in:
Rafael Taranto 2019-05-31 11:43:28 -03:00 • committed by Josh Harvey
parent 18bbfc6def
commit abf4dd5c32
1 changed files with 26 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

36
lib/customers.js
View file

@ -117,22 +117,38 @@ function getById (id, userToken) {
* @returns {Bignumber} Customer's daily volume * @returns {Bignumber} Customer's daily volume
*/ */
function getDailyVolume (id, txId) { function getDailyVolume (id, txId) {
return Promise.all([ const queries = txId ? getDailyVolumeMinusCurrentTxQueries(id, txId) : getDailyVolumeQueries(id)
db.one(`select coalesce(sum(fiat), 0) as total, max(created) as maxdate from cash_in_txs return Promise.all(queries).then(([cashIn, cashOut]) => {
where customer_id=$1
${txId ? 'and id!=$2' : ''}
and created > now() - interval '1 day'`, [id, txId]),
db.one(`select coalesce(sum(fiat), 0) as total, max(created) as maxdate from cash_out_txs
where customer_id=$1
${txId ? 'and id!=$2' : ''}
and created > now() - interval '1 day'`, [id, txId])
]).then(([cashIn, cashOut]) => {
const dailyVolume = BN(cashIn.total).add(cashOut.total) const dailyVolume = BN(cashIn.total).add(cashOut.total)
const hoursTillLimitClear = getHoursTillLimitClear(cashIn.maxdate, cashOut.maxdate) const hoursTillLimitClear = getHoursTillLimitClear(cashIn.maxdate, cashOut.maxdate)
return { dailyVolume, hoursTillLimitClear } return { dailyVolume, hoursTillLimitClear }
}) })
} }
function getDailyVolumeQueries (id) {
return [
db.one(`select coalesce(sum(fiat), 0) as total, max(created) as maxdate from cash_in_txs
where customer_id=$1
and created > now() - interval '1 day'`, [id]),
db.one(`select coalesce(sum(fiat), 0) as total, max(created) as maxdate from cash_out_txs
where customer_id=$1
and created > now() - interval '1 day'`, [id])
]
}
function getDailyVolumeMinusCurrentTxQueries (id, txId) {
return [
db.one(`select coalesce(sum(fiat), 0) as total, max(created) as maxdate from cash_in_txs
where customer_id=$1
and id!=$2
and created > now() - interval '1 day'`, [id, txId]),
db.one(`select coalesce(sum(fiat), 0) as total, max(created) as maxdate from cash_out_txs
where customer_id=$1
and id!=$2
and created > now() - interval '1 day'`, [id, txId])
]
}
function getHoursTillLimitClear (cashInDate, cashOutDate) { function getHoursTillLimitClear (cashInDate, cashOutDate) {
let startDate = moment() let startDate = moment()
startDate = startDate.subtract(1, 'days') startDate = startDate.subtract(1, 'days')