feat: add append_receipts function

crates/stages/stages/src/test_utils/test_db.rs

@@ -349,9 +349,8 @@ impl TestStageDB {
                 let mut writer = provider.latest_writer(StaticFileSegment::Receipts)?;
                 let res = receipts.into_iter().try_for_each(|(block_num, receipts)| {
                     writer.increment_block(StaticFileSegment::Receipts, block_num)?;
-                    for (tx_num, receipt) in receipts {
-                        writer.append_receipt(tx_num, receipt)?;
-                    }
+                    let receipts = receipts.into_iter();
+                    writer.append_receipts(receipts)?;
                     Ok(())
                 });
                 writer.commit_without_sync_all()?;

crates/static-file/static-file/src/segments/receipts.rs

@@ -42,11 +42,8 @@ impl<DB: Database> Segment<DB> for Receipts {
             let mut receipts_cursor = provider.tx_ref().cursor_read::<tables::Receipts>()?;
             let receipts_walker = receipts_cursor.walk_range(block_body_indices.tx_num_range())?;
 
-            for entry in receipts_walker {
-                let (tx_number, receipt) = entry?;
-
-                static_file_writer.append_receipt(tx_number, receipt)?;
-            }
+            let receipts = receipts_walker.collect::<Result<Vec<_>, _>>()?;
+            static_file_writer.append_receipts(receipts)?;
         }
 
         Ok(())

crates/storage/provider/src/bundle_state/bundle_state_with_receipts.rs

@@ -42,12 +42,19 @@ impl StateWriter for BundleStateWithReceipts {
             if let Some(static_file_producer) = &mut static_file_producer {
                 // Increment block on static file header.
                 static_file_producer.increment_block(StaticFileSegment::Receipts, block_number)?;
-
-                for (tx_idx, receipt) in receipts.into_iter().enumerate() {
-                    let receipt = receipt
-                        .expect("receipt should not be filtered when saving to static files.");
-                    static_file_producer.append_receipt(first_tx_index + tx_idx as u64, receipt)?;
-                }
+                let receipts = receipts
+                    .into_iter()
+                    .enumerate()
+                    .map(|(tx_idx, receipt)| {
+                        (
+                            first_tx_index + tx_idx as u64,
+                            receipt.expect(
+                                "receipt should not be filtered when saving to static files.",
+                            ),
+                        )
+                    })
+                    .collect::<Vec<_>>();
+                static_file_producer.append_receipts(receipts)?;
             } else if !receipts.is_empty() {
                 for (tx_idx, receipt) in receipts.into_iter().enumerate() {
                     if let Some(receipt) = receipt {

crates/storage/provider/src/providers/static_file/writer.rs

@@ -547,6 +547,33 @@ impl StaticFileProviderRW {
         Ok(result)
     }
 
+    /// Appends multiple receipts to the static file.
+    ///
+    /// Returns the current [`TxNumber`] as seen in the static file.
+    pub fn append_receipts<I>(&mut self, receipts: I) -> ProviderResult<TxNumber>
+    where
+        I: IntoIterator<Item = (TxNumber, Receipt)>,
+    {
+        let start = Instant::now();
+        self.ensure_no_queued_prune()?;
+        let mut last_tx_number = None;
+
+        for (tx_num, receipt) in receipts {
+            self.append_with_tx_number(StaticFileSegment::Receipts, tx_num, receipt)?;
+            last_tx_number = Some(tx_num);
+        }
+
+        if let Some(metrics) = &self.metrics {
+            metrics.record_segment_operation(
+                StaticFileSegment::Receipts,
+                StaticFileProviderOperation::Append,
+                Some(start.elapsed()),
+            );
+        }
+
+        Ok(last_tx_number.expect("receipts can't be empty"))
+    }
+
     /// Adds an instruction to prune `to_delete`transactions during commit.
     ///
     /// Note: `last_block` refers to the block the unwinds ends at.