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

refactor: inline one step

Browse source
This commit is contained in:
siiky 2023-10-23 10:35:28 +01:00
parent 347844610c
commit d47101215f
1 changed files with 7 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

16
lib/plugins.js
View file

@ -161,20 +161,18 @@ function plugins (settings, deviceId) {
return _.map(([acc, bill]) => acc + bill.provisioned, _.zip(sum, bills)) return _.map(([acc, bill]) => acc + bill.provisioned, _.zip(sum, bills))
} }
const counts = _.flow( recyclers = _.flow(
// Sum "used" bills per recycler
_.reduce(sumTxs, _.map(_.constant(0), recyclers)), _.reduce(sumTxs, _.map(_.constant(0), recyclers)),
_.zip(_.map('count', recyclers)), _.zip(recyclers),
_.map(([count, provisioned]) => count - provisioned), // Remove used bills from recycler counts
_.map(([recycler, provisioned]) => _.set('count', recycler.count - provisioned, recycler)),
)(redeemableTxs) )(redeemableTxs)
if (_.some(_.lt(_, 0), counts)) { if (_.some(({ count }) => count < 0, recyclers))
throw new Error('Negative note count: %j', counts) throw new Error('Negative note count: %j', counts)
}
return _.map( return recyclers
recycler => _.set('count', counts[recycler.number], recycler),
recyclers
)
} }
function buildAvailableCassettes (excludeTxId) { function buildAvailableCassettes (excludeTxId) {