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

fix: check for invoice fulfillment

Browse source
This commit is contained in:
Rafael Taranto 2024-02-09 19:05:25 +00:00
parent 17701ecd3c
commit 3465173e1a
1 changed files with 26 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

32
lib/plugins/wallet/galoy/galoy.js
View file

@ -152,7 +152,6 @@ function sendProbeRequest (walletId, invoice, cryptoAtoms, token, endpoint) {
function sendCoins (account, tx, settings, operatorId) { function sendCoins (account, tx, settings, operatorId) {
const { toAddress, cryptoAtoms, cryptoCode } = tx const { toAddress, cryptoAtoms, cryptoCode } = tx
const externalCryptoCode = coinUtils.getEquivalentCode(cryptoCode)
return checkCryptoCode(cryptoCode) return checkCryptoCode(cryptoCode)
.then(() => getGaloyWallet(account.apiSecret, account.endpoint, account.walletId)) .then(() => getGaloyWallet(account.apiSecret, account.endpoint, account.walletId))
.then(wallet => { .then(wallet => {
@ -166,7 +165,7 @@ function sendCoins (account, tx, settings, operatorId) {
case 'ALREADY_PAID': case 'ALREADY_PAID':
throw new Error('Transaction already exists!') throw new Error('Transaction already exists!')
case 'FAILURE': case 'FAILURE':
throw new Error('Transaction failed!') throw new Error('Transaction failed!', JSON.stringify(result.errors))
case 'SUCCESS': case 'SUCCESS':
return '<galoy transaction>' return '<galoy transaction>'
case 'PENDING': case 'PENDING':
@ -253,6 +252,25 @@ function newAddress (account, info, tx, settings, operatorId) {
}) })
} }
function getInvoiceStatus (token, endpoint, address) {
const query = {
'operationName': 'lnInvoicePaymentStatus',
'query': `query lnInvoicePaymentStatus($input: LnInvoicePaymentStatusInput!) {
lnInvoicePaymentStatus(input: $input) {
status
}
}`,
'variables': {"input": {"paymentRequest": address}}
}
return request(query, token, endpoint)
.then(r => {
return r?.data?.lnInvoicePaymentStatus?.status
})
.catch(err => {
throw new Error(err)
})
}
function getStatus (account, tx, requested, settings, operatorId) { function getStatus (account, tx, requested, settings, operatorId) {
const { toAddress, cryptoAtoms, cryptoCode } = tx const { toAddress, cryptoAtoms, cryptoCode } = tx
const getBalance = _.reduce((acc, value) => { const getBalance = _.reduce((acc, value) => {
@ -260,13 +278,16 @@ function getStatus (account, tx, requested, settings, operatorId) {
return acc return acc
}, { SUCCESS: new BN(0), PENDING: new BN(0), FAILURE: new BN(0) }) }, { SUCCESS: new BN(0), PENDING: new BN(0), FAILURE: new BN(0) })
const externalCryptoCode = coinUtils.getEquivalentCode(cryptoCode)
return checkCryptoCode(cryptoCode) return checkCryptoCode(cryptoCode)
.then(() => { .then(() => {
const address = coinUtils.parseUrl(cryptoCode, account.environment, toAddress, false) const address = coinUtils.parseUrl(cryptoCode, account.environment, toAddress, false)
// Consider all LN transactions successful
if (isLightning(address)) { if (isLightning(address)) {
return { receivedCryptoAtoms: cryptoAtoms, status: 'confirmed' } return getInvoiceStatus(account.apiSecret, account.endpoint, address)
.then(it => {
const isPaid = it === 'PAID'
if (isPaid) return { receivedCryptoAtoms: cryptoAtoms, status: 'confirmed' }
return { receivedCryptoAtoms: BN(0), status: 'notSeen' }
})
} }
// On-chain and intra-ledger transactions // On-chain and intra-ledger transactions
return getTransactionsByAddress(account.apiSecret, account.endpoint, account.walletId, address) return getTransactionsByAddress(account.apiSecret, account.endpoint, account.walletId, address)
@ -282,7 +303,6 @@ function getStatus (account, tx, requested, settings, operatorId) {
} }
function newFunding (account, cryptoCode, settings, operatorId) { function newFunding (account, cryptoCode, settings, operatorId) {
const externalCryptoCode = coinUtils.getEquivalentCode(cryptoCode)
// Regular BTC address // Regular BTC address
return checkCryptoCode(cryptoCode) return checkCryptoCode(cryptoCode)
.then(() => getGaloyWallet(account.apiSecret, account.endpoint, account.walletId)) .then(() => getGaloyWallet(account.apiSecret, account.endpoint, account.walletId))