ekzyis
/
stacker.news
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix settleHodlInvoice timing out paid action transition

This commit is contained in:
keyan 2024-07-06 11:37:32 -05:00
parent bcdbf9cede
commit 9213e3ad1a
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
worker/paidAction.js
View File

@ -45,7 +45,12 @@ async function transitionInvoice (jobName, { invoiceId, fromState, toState, toDa
} }
await onTransition({ lndInvoice, dbInvoice, tx }) await onTransition({ lndInvoice, dbInvoice, tx })
}, { isolationLevel: Prisma.TransactionIsolationLevel.ReadCommitted }) }, {
isolationLevel: Prisma.TransactionIsolationLevel.ReadCommitted,
// we only need to do this because we settleHodlInvoice inside the transaction
// ... and it's prone to timing out
timeout: 60000
})
console.log('transition succeeded') console.log('transition succeeded')
} catch (e) { } catch (e) {
@ -98,7 +103,10 @@ export async function holdAction ({ data: { invoiceId }, models, lnd, boss }) {
fromState: 'PENDING_HELD', fromState: 'PENDING_HELD',
toState: 'HELD', toState: 'HELD',
toData: invoice => { toData: invoice => {
if (!invoice.is_held) { // XXX allow both held and confirmed invoices to do this transition
// because it's possible for a prior settleHodlInvoice to have succeeded but
// timeout and rollback the transaction, leaving the invoice in a pending_held state
if (!(invoice.is_held || invoice.is_confirmed)) {
throw new Error('invoice is not held') throw new Error('invoice is not held')
} }
return { return {
@ -122,7 +130,8 @@ export async function holdAction ({ data: { invoiceId }, models, lnd, boss }) {
await tx.invoice.update({ await tx.invoice.update({
where: { id: dbInvoice.id }, where: { id: dbInvoice.id },
data: { data: {
actionResult: result actionResult: result,
actionError: null
} }
}) })
} catch (e) { } catch (e) {