feat: explicitly handle 'UtxoDoesNotExistError' from sync

GaloyMoney · Dec 15, 2024 · 283aa71 · 283aa71
1 parent 9ddfe63
commit 283aa71
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/src/job/sync_wallet.rs b/src/job/sync_wallet.rs
@@ -507,10 +507,18 @@ pub async fn execute(
                 bdk_txs
                     .delete_transaction_if_no_more_utxos_exist(&mut tx, outpoint)
                     .await?;
-                let detected_txn_id = deps
+                let detected_txn_id = match deps
                     .bria_utxos
                     .delete_utxo(&mut tx, outpoint, keychain_id)
-                    .await?;
+                    .await
+                {
+                    Ok(txn_id) => txn_id,
+                    Err(UtxoError::UtxoDoesNotExistError) => {
+                        tx.commit().await?;
+                        continue;
+                    }
+                    Err(err) => Err(err)?,
+                };
                 match deps
                     .ledger
                     .utxo_dropped(tx, LedgerTransactionId::new(), detected_txn_id)