diff --git a/lib/cash-in/cash-in-atomic.js b/lib/cash-in/cash-in-atomic.js index 8a23360c..e3441a76 100644 --- a/lib/cash-in/cash-in-atomic.js +++ b/lib/cash-in/cash-in-atomic.js @@ -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 => { diff --git a/lib/cash-out/cash-out-atomic.js b/lib/cash-out/cash-out-atomic.js index e51710d5..c82f6f65 100644 --- a/lib/cash-out/cash-out-atomic.js +++ b/lib/cash-out/cash-out-atomic.js @@ -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))