Wait for 'synced' event

Author: ekzyis

wallets/client/protocols/breezSpark.js

@@ -1,8 +1,11 @@
 import init, { defaultConfig, connect } from '@breeztech/breez-sdk-spark'
+import { withTimeout } from '@/lib/time'
 import { getUsername } from '@/wallets/lib/protocols/breezSpark'
 
 export const name = 'BREEZ_SPARK'
 
+const SDK_SYNC_TIMEOUT = 30_000
+
 async function withSdk (mnemonic, cb) {
   await init()
 
@@ -18,11 +21,38 @@ async function withSdk (mnemonic, cb) {
     storageDir: 'breez-sdk-spark'
   })
 
-  const result = await cb(sdk)
+  try {
+    await waitForSync(sdk)
+    return await cb(sdk)
+  } finally {
+    sdk.disconnect()
+  }
+}
+
+async function waitForSync (sdk) {
+  const syncPromise = new Promise(
+    resolve => sdk.addEventListener(new SyncEventListener(resolve))
+  )
+  await withTimeout(syncPromise, SDK_SYNC_TIMEOUT)
+}
+
+class SdkEventListener {
+  constructor (event, resolve) {
+    this.event = event
+    this.resolve = resolve
+  }
 
-  sdk.disconnect()
+  onEvent (event) {
+    if (event.type === this.event) {
+      this.resolve()
+    }
+  }
+}
 
-  return result
+class SyncEventListener extends SdkEventListener {
+  constructor (resolve) {
+    super('synced', resolve)
+  }
 }
 
 export async function sendPayment (bolt11, { mnemonic }, { signal }) {