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

onNewInvoice/onNewTransaction stack overflow exception fix

Browse source
This commit is contained in:
emad-salah 2020-07-10 13:37:42 +01:00
parent b5a1db76ee
commit 331a6e0919
1 changed files with 6 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

10
src/sockets.js
View file

@ -121,7 +121,8 @@ module.exports = (
}) })
stream.on('end', () => { stream.on('end', () => {
logger.info('New invoice stream ended, starting a new one...') logger.info('New invoice stream ended, starting a new one...')
onNewInvoice(socket) // Prevents call stack overflow exceptions
process.nextTick(() => onNewInvoice(socket))
}) })
stream.on('error', err => { stream.on('error', err => {
logger.error('New invoice stream error:', err) logger.error('New invoice stream error:', err)
@ -129,7 +130,8 @@ module.exports = (
stream.on('status', status => { stream.on('status', status => {
logger.warn('New invoice stream status:', status) logger.warn('New invoice stream status:', status)
if (status.code === 14) { if (status.code === 14) {
onNewInvoice(socket) // Prevents call stack overflow exceptions
process.nextTick(() => onNewInvoice(socket))
} }
}) })
} }
@ -144,7 +146,7 @@ module.exports = (
}) })
stream.on('end', () => { stream.on('end', () => {
logger.info('New invoice stream ended, starting a new one...') logger.info('New invoice stream ended, starting a new one...')
onNewTransaction(socket) process.nextTick(() => onNewTransaction(socket))
}) })
stream.on('error', err => { stream.on('error', err => {
logger.error('New invoice stream error:', err) logger.error('New invoice stream error:', err)
@ -152,7 +154,7 @@ module.exports = (
stream.on('status', status => { stream.on('status', status => {
logger.error('New invoice stream status:', status) logger.error('New invoice stream status:', status)
if (status.code === 14) { if (status.code === 14) {
onNewTransaction(socket) process.nextTick(() => onNewTransaction(socket))
} }
}) })
} }