Fixing duplicate transactions on mainnet sync (#672)

ethui · May 14, 2024 · 5bef4d3 · 5bef4d3
1 parent a36b61e
commit 5bef4d3
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/crates/sync/alchemy/src/lib.rs b/crates/sync/alchemy/src/lib.rs
@@ -59,6 +59,8 @@ impl Alchemy {
             .get_asset_transfers(Direction::To(address), from_block, latest)
             .await?;
 
+        tracing::trace!("inc {}, out {}", inc.0.len(), out.0.len());
+
         let tip = out
             .0
             .iter()
@@ -72,7 +74,7 @@ impl Alchemy {
         self.db.save_erc20_metadatas(self.chain_id, out.1).await?;
 
         if tip > std::u64::MIN {
-            self.db.kv_set(&(self.chain_id, address), &tip).await?;
+            self.db.kv_set(&key, &tip).await?;
         }
 
         Ok(())

diff --git a/migrations/21_clear_transactions.sql b/migrations/21_clear_transactions.sql
@@ -0,0 +1,2 @@
+-- clean up transactions table, we need to re-sync after a bugfix
+DELETE * from transactions;