apollo_storage: add transaction_events table for event storage (#13461)

* apollo_storage: add transaction_events table for event storage

Events are now written to a dedicated transaction_events table in addition
to the events index table. Event iterators read from the new table instead
of deserializing transaction outputs from mmap files. This eliminates
redundant file I/O during event iteration and prepares for separating
events from TransactionOutput in a follow-up change.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

* apollo_storage: store events in mmap file instead of MDBX

The transaction_events table now stores LocationInFile pointers into a
dedicated events.dat mmap file, rather than serializing Vec<Event>
directly into MDBX. This matches the pattern used for transaction outputs
and avoids MDBX size overhead for large event payloads.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

---------

Co-authored-by: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: MohammadNassar1

crates/apollo_reverts/src/lib.rs

@@ -127,6 +127,8 @@ pub fn revert_block(storage_writer: &mut StorageWriter, target_block_marker: Blo
         .revert_header(target_block_marker)
         .unwrap()
         .0
+        .revert_events(target_block_marker)
+        .unwrap()
         .revert_body(target_block_marker)
         .unwrap()
         .0

crates/apollo_storage/src/body/body_test.rs

@@ -215,7 +215,16 @@ async fn revert_body_state_only(storage_scope: StorageScope) {
         .unwrap()
         .commit()
         .unwrap();
-    writer.begin_rw_txn().unwrap().revert_body(BlockNumber(0)).unwrap().0.commit().unwrap();
+    writer
+        .begin_rw_txn()
+        .unwrap()
+        .revert_events(BlockNumber(0))
+        .unwrap()
+        .revert_body(BlockNumber(0))
+        .unwrap()
+        .0
+        .commit()
+        .unwrap();
 }
 
 #[tokio::test]
@@ -236,7 +245,16 @@ async fn revert_body_updates_marker(storage_scope: StorageScope) {
     // Verify that the body marker before revert is 2.
     assert_eq!(reader.begin_ro_txn().unwrap().get_body_marker().unwrap(), BlockNumber(2));
 
-    writer.begin_rw_txn().unwrap().revert_body(BlockNumber(1)).unwrap().0.commit().unwrap();
+    writer
+        .begin_rw_txn()
+        .unwrap()
+        .revert_events(BlockNumber(1))
+        .unwrap()
+        .revert_body(BlockNumber(1))
+        .unwrap()
+        .0
+        .commit()
+        .unwrap();
     assert_eq!(reader.begin_ro_txn().unwrap().get_body_marker().unwrap(), BlockNumber(1));
 }
 
@@ -266,7 +284,16 @@ async fn get_reverted_body_returns_none() {
             .is_some()
     );
 
-    writer.begin_rw_txn().unwrap().revert_body(BlockNumber(1)).unwrap().0.commit().unwrap();
+    writer
+        .begin_rw_txn()
+        .unwrap()
+        .revert_events(BlockNumber(1))
+        .unwrap()
+        .revert_body(BlockNumber(1))
+        .unwrap()
+        .0
+        .commit()
+        .unwrap();
     assert!(
         reader.begin_ro_txn().unwrap().get_block_transactions(BlockNumber(1)).unwrap().is_none()
     );
@@ -335,7 +362,16 @@ async fn revert_transactions() {
             .is_some()
     );
 
-    writer.begin_rw_txn().unwrap().revert_body(BlockNumber(0)).unwrap().0.commit().unwrap();
+    writer
+        .begin_rw_txn()
+        .unwrap()
+        .revert_events(BlockNumber(0))
+        .unwrap()
+        .revert_body(BlockNumber(0))
+        .unwrap()
+        .0
+        .commit()
+        .unwrap();
 
     // Check that all the transactions were deleted.
     for (offset, tx_hash) in body.transaction_hashes.into_iter().enumerate() {