fix: filter bundles on insertion

prestwich · prestwich · commit 978887669832 · 2025-11-25T12:59:28.000-05:00
diff --git a/src/tasks/cache/task.rs b/src/tasks/cache/task.rs
@@ -55,6 +55,12 @@ impl CacheTask {
                     }
                 }
                 Some(bundle) = self.bundles.recv() => {
+                    let block_num = self.envs.borrow().as_ref().map(|e| e.rollup_env().number.to::<u64>()).unwrap_or_default();
+                    if block_num != bundle.bundle.block_number() {
+                        debug!(env.block = block_num, bundle.block = bundle.bundle.block_number(), "skipping bundle insert");
+                        continue;
+                    }
+
                     let res = cache.add_bundle(bundle.bundle, basefee);
                     // Skip bundles that fail to be added to the cache
                     if let Err(e) = res {

Original file line number	Diff line number	Diff line change
`@@ -55,6 +55,12 @@ impl CacheTask {`
`55`	`55`	`}`
`56`	`56`	`}`
`57`	`57`	`Some(bundle) = self.bundles.recv() => {`
	`58`	`+ let block_num = self.envs.borrow().as_ref().map(\|e\| e.rollup_env().number.to::<u64>()).unwrap_or_default();`
	`59`	`+ if block_num != bundle.bundle.block_number() {`
	`60`	`+ debug!(env.block = block_num, bundle.block = bundle.bundle.block_number(), "skipping bundle insert");`
	`61`	`+ continue;`
	`62`	`+ }`
	`63`	`+`
`58`	`64`	`let res = cache.add_bundle(bundle.bundle, basefee);`
`59`	`65`	`// Skip bundles that fail to be added to the cache`
`60`	`66`	`if let Err(e) = res {`