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

expire attempted trades

Browse source
This commit is contained in:
Josh Harvey 2016-06-03 12:23:41 +03:00
parent 19ebf9d2a2
commit 1fe57e7cf1
1 changed files with 9 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

13
lib/plugins.js
View file

@ -26,6 +26,7 @@ var TRANSACTION_EXPIRATION = 48 * 60 * 60 * 1000
var SWEEP_LIVE_HD_INTERVAL = 60 * 1000 var SWEEP_LIVE_HD_INTERVAL = 60 * 1000
var SWEEP_OLD_HD_INTERVAL = 2 * 60 * 1000 var SWEEP_OLD_HD_INTERVAL = 2 * 60 * 1000
var TRADE_INTERVAL = 60 * 1000 var TRADE_INTERVAL = 60 * 1000
var TRADE_TTL = 5 * 60 * 1000
var cryptoCodes = null var cryptoCodes = null
@ -317,7 +318,8 @@ exports.trade = function trade (session, rawTrade) {
tradesQueues[cryptoCode].push({ tradesQueues[cryptoCode].push({
currency: rawTrade.currency, currency: rawTrade.currency,
cryptoAtoms: rawTrade.cryptoAtoms, cryptoAtoms: rawTrade.cryptoAtoms,
cryptoCode: cryptoCode cryptoCode: cryptoCode,
timestamp: Date.now()
}) })
} }
@ -581,9 +583,12 @@ function consolidateTrades (cryptoCode) {
logger.debug('tradesQueues size: %d', tradesQueues[cryptoCode].length) logger.debug('tradesQueues size: %d', tradesQueues[cryptoCode].length)
logger.debug('tradesQueues head: %j', tradesQueues[cryptoCode][0]) logger.debug('tradesQueues head: %j', tradesQueues[cryptoCode][0])
var cryptoAtoms = tradesQueues[cryptoCode].reduce(function (prev, current) {
return prev.plus(current.cryptoAtoms) const t0 = Date.now()
}, new BigNumber(0))
const cryptoAtoms = tradesQueues[cryptoCode]
.filter(trade => t0 - trade.timestamp < TRADE_TTL)
.reduce((prev, current) => prev.plus(current.cryptoAtoms), new BigNumber(0))
var consolidatedTrade = { var consolidatedTrade = {
currency: deviceCurrency, currency: deviceCurrency,