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

Fix stale cursor used on reconnect (#764)

Browse Source
This commit is contained in:
ekzyis 2024-01-20 23:57:52 +01:00 committed by GitHub
parent dc8d35fdcf
commit 30850acd8f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
worker/wallet.js
View File

@ -22,11 +22,16 @@ function subscribeForever (subscribe) {
let sub let sub
try { try {
return await new Promise((resolve, reject) => { return await new Promise((resolve, reject) => {
sub = subscribe(resolve, bail) const sub = subscribe(resolve, bail)
if (!sub) { if (!sub) {
return bail(new Error('function passed to subscribeForever must return a subscription object')) return bail(new Error('function passed to subscribeForever must return a subscription object or promise'))
}
if (sub.then) {
// sub is promise
sub.then(sub => sub.on('error', reject))
} else {
sub.on('error', reject)
} }
sub.on('error', reject)
}) })
} catch (error) { } catch (error) {
console.error(error) console.error(error)
@ -45,13 +50,12 @@ const logEventError = (name, error) => console.error(`error running ${name}`, er
async function subscribeToDeposits (args) { async function subscribeToDeposits (args) {
const { models, lnd } = args const { models, lnd } = args
const [lastConfirmed] = await models.$queryRaw` subscribeForever(async () => {
const [lastConfirmed] = await models.$queryRaw`
SELECT "confirmedIndex" SELECT "confirmedIndex"
FROM "Invoice" FROM "Invoice"
ORDER BY "confirmedIndex" DESC NULLS LAST ORDER BY "confirmedIndex" DESC NULLS LAST
LIMIT 1` LIMIT 1`
subscribeForever(() => {
const sub = subscribeToInvoices({ lnd, confirmed_after: lastConfirmed?.confirmedIndex }) const sub = subscribeToInvoices({ lnd, confirmed_after: lastConfirmed?.confirmedIndex })
sub.on('invoice_updated', async (inv) => { sub.on('invoice_updated', async (inv) => {