feat(storage): add receipts_for_block getter

crates/storage/src/connection.rs

@@ -186,6 +186,13 @@ impl<'inner> Transaction<'inner> {
         transaction::transactions_for_block(self, block)
     }
 
+    pub fn receipts_for_block(
+        &self,
+        block: BlockId,
+    ) -> anyhow::Result<Option<Vec<gateway::Receipt>>> {
+        transaction::receipts_for_block(self, block)
+    }
+
     pub fn transaction_hashes_for_block(
         &self,
         block: BlockId,

crates/storage/src/connection/event.rs

@@ -11,7 +11,7 @@ use pathfinder_common::{
 
 pub const PAGE_SIZE_LIMIT: usize = 1_024;
 pub const KEY_FILTER_LIMIT: usize = 16;
-const MAX_BLOCKS_TO_SCAN: usize = 200;
+const MAX_BLOCKS_TO_SCAN: usize = 300;
 
 #[derive(Debug)]
 pub struct EventFilter {
@@ -148,10 +148,10 @@ pub(super) fn get_events(
             return Err(EventFilterError::TooManyMatches);
         }
 
-        let transaction_data = tx.transaction_data_for_block(crate::BlockId::Number(
-            BlockNumber::new_or_panic(block_number),
-        ))?;
-        let Some(transaction_data) = transaction_data else {
+        let receipts = tx.receipts_for_block(crate::BlockId::Number(BlockNumber::new_or_panic(
+            block_number,
+        )))?;
+        let Some(receipts) = receipts else {
             break;
         };
 
@@ -161,9 +161,9 @@ pub(super) fn get_events(
             .map(|keys| keys.iter().collect())
             .collect();
 
-        let events = transaction_data
+        let events = receipts
             .into_iter()
-            .flat_map(|(_, receipt)| {
+            .flat_map(|receipt| {
                 receipt
                     .events
                     .into_iter()

crates/storage/src/connection/transaction.rs

@@ -259,6 +259,38 @@ pub(super) fn transactions_for_block(
     Ok(Some(data))
 }
 
+pub(super) fn receipts_for_block(
+    tx: &Transaction<'_>,
+    block: BlockId,
+) -> anyhow::Result<Option<Vec<gateway::Receipt>>> {
+    let Some((_, block_hash)) = tx.block_id(block)? else {
+        return Ok(None);
+    };
+
+    let mut stmt = tx
+        .inner()
+        .prepare("SELECT receipt FROM starknet_transactions WHERE block_hash = ? ORDER BY idx ASC")
+        .context("Preparing statement")?;
+
+    let mut rows = stmt
+        .query(params![&block_hash])
+        .context("Executing query")?;
+
+    let mut data = Vec::new();
+    while let Some(row) = rows.next()? {
+        let receipt = row
+            .get_ref_unwrap("receipt")
+            .as_blob_or_null()?
+            .context("Transaction data missing")?;
+        let receipt = zstd::decode_all(receipt).context("Decompressing receipt")?;
+        let receipt = serde_json::from_slice(&receipt).context("Deserializing receipt")?;
+
+        data.push(receipt);
+    }
+
+    Ok(Some(data))
+}
+
 pub(super) fn transaction_hashes_for_block(
     tx: &Transaction<'_>,
     block: BlockId,