aiolabs/lightning-pub
2
0
Fork 0
Code Issues 9 Pull requests 4 Projects Releases Packages Wiki Activity Actions

clean send payment

Browse source
This commit is contained in:
hatim boufnichel 2020-08-15 20:52:34 +02:00
parent 756d84920d
commit 26f76e4f0e
1 changed files with 10 additions and 36 deletions
Download patch file Download diff file Expand all files Collapse all files

32
src/routes.js
View file

@ -1479,26 +1479,9 @@ module.exports = async (
logger.info('Sending payment', paymentRequest) logger.info('Sending payment', paymentRequest)
const sentPayment = router.sendPaymentV2(paymentRequest) const sentPayment = router.sendPaymentV2(paymentRequest)
let finalEvent = null //Object to send to the socket, depends on final event from the stream
sentPayment.on('data', response => { sentPayment.on('data', response => {
if (res.headersSent) {
//if res was already sent
if (response.status !== 'SUCCEEDED') {
//if the operation failed
logger.error('Sen payment failure', response.details)
} else {
finalEvent = { status: response.status }
}
} else {
if (response.status !== 'SUCCEEDED') {
logger.error('Sen payment failure', response.details)
return res.status(500).json({
errorMessage: sanitizeLNDError(response.details)
})
}
logger.info('SendPayment Data:', response) logger.info('SendPayment Data:', response)
return res.json(response) res.json(response)
}
}) })
sentPayment.on('status', status => { sentPayment.on('status', status => {
@ -1507,26 +1490,17 @@ module.exports = async (
sentPayment.on('error', async err => { sentPayment.on('error', async err => {
logger.error('SendPayment Error:', err) logger.error('SendPayment Error:', err)
if (res.headersSent) {
logger.error('Sen payment failure', err)
} else {
const health = await checkHealth() const health = await checkHealth()
if (health.LNDStatus.success) { if (health.LNDStatus.success) {
res.status(500).json({ res.status(500).json({
errorMessage: sanitizeLNDError(err) errorMessage: sanitizeLNDError(err.details)
}) })
} else { } else {
res.status(500) res.status(500)
res.json({ errorMessage: 'LND is down' }) res.json({ errorMessage: 'LND is down' })
} }
}
})
sentPayment.on('end', () => {
if (finalEvent !== null) {
//send the last event got from the stream
//TO DO send finalEvent on socket
}
}) })
//sentPayment.on('end', () => {})
}) })
app.post('/api/lnd/trackpayment', (req, res) => { app.post('/api/lnd/trackpayment', (req, res) => {