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

refactor: add transaction ID to stale errors

Browse source
This commit is contained in:
André Sá 2022-02-02 14:19:02 +00:00
parent fb48222203
commit 2b4e531367
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
lib/cash-in/cash-in-atomic.js
View file

@ -18,7 +18,7 @@ function atomic (machineTx, pi) {
return t.oneOrNone(sql, [machineTx.id])
.then(row => {
if (row && row.tx_version >= machineTx.txVersion) throw new E.StaleTxError('Stale tx')
if (row && row.tx_version >= machineTx.txVersion) throw new E.StaleTxError({ txId: machineTx.id })
return t.any(sql2, [machineTx.id])
.then(billRows => {

2
lib/cash-out/cash-out-atomic.js
View file

@ -25,7 +25,7 @@ function atomic (tx, pi, fromClient) {
.then(toObj)
.then(oldTx => {
const isStale = fromClient && oldTx && (oldTx.txVersion >= tx.txVersion)
if (isStale) throw new E.StaleTxError('Stale tx')
if (isStale) throw new E.StaleTxError({ txId: tx.id })
return preProcess(t, oldTx, tx, pi)
.then(preProcessedTx => cashOutLow.upsert(t, oldTx, preProcessedTx))