fix: Add message send to avoid the tx db has not submit finish yet.

nervosnetwork · Nov 17, 2023 · 95dedd8 · 95dedd8
1 parent ea04f42
commit 95dedd8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/packages/neuron-wallet/src/block-sync-renderer/sync/light-connector.ts b/packages/neuron-wallet/src/block-sync-renderer/sync/light-connector.ts
@@ -248,14 +248,14 @@ export default class LightConnector extends Connector<CKBComponents.Hash> {
       .createBatchRequest<'getTransaction', string[], TransactionWithStatus[]>(txHashes.map(v => ['getTransaction', v]))
       .exec()
     const previousTxHashes = new Set<string>()
-    transactions.forEach(tx => {
-      tx.transaction.inputs.forEach(input => {
+    transactions
+      .flatMap(tx => tx.transaction.inputs)
+      .forEach(input => {
         const previousTxHash = input.previousOutput!.txHash
         if (previousTxHash !== `0x${'0'.repeat(64)}`) {
           previousTxHashes.add(previousTxHash)
         }
       })
-    })
     await this.lightRpc.createBatchRequest([...previousTxHashes].map(v => ['fetchTransaction' as keyof Base, v])).exec()
   }
 

diff --git a/packages/neuron-wallet/src/block-sync-renderer/sync/queue.ts b/packages/neuron-wallet/src/block-sync-renderer/sync/queue.ts
@@ -90,6 +90,7 @@ export default class Queue {
       while (true) {
         try {
           await this.#checkAndSave(txHashes)
+          process.send?.({ channel: 'tx-db-changed' })
           break
         } catch (error) {
           logger.error('retry saving transactions in 2 seconds due to error:', error)