fix some lints

crates/exex/exex/src/wal/cache.rs

@@ -12,7 +12,7 @@ use reth_primitives::BlockNumHash;
 /// This cache is needed to avoid walking the WAL directory every time we want to find a
 /// notification corresponding to a block.
 #[derive(Debug)]
-pub(super) struct BlockCache(BTreeMap<u64, VecDeque<CachedBlock>>);
+pub struct BlockCache(BTreeMap<u64, VecDeque<CachedBlock>>);
 
 impl BlockCache {
     /// Creates a new instance of [`BlockCache`].

crates/exex/exex/src/wal/entry.rs

@@ -1,8 +1,9 @@
 use reth_exex_types::ExExNotification;
 use serde::{Deserialize, Serialize};
 
+/// A single entry in the WAL.
 #[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
-pub(crate) struct WalEntry {
+pub struct WalEntry {
     pub(crate) target: NotificationCommitTarget,
     pub(crate) notification: ExExNotification,
 }

crates/exex/exex/src/wal/mod.rs

@@ -1,14 +1,13 @@
 #![allow(dead_code)]
 
 mod cache;
-use cache::BlockCache;
+pub use cache::*;
 
 mod entry;
-pub(crate) use entry::NotificationCommitTarget;
-use entry::WalEntry;
+pub use entry::*;
 
 mod storage;
-use storage::Storage;
+pub use storage::*;
 
 use std::path::Path;
 
@@ -170,7 +169,7 @@ impl Wal {
         // Remove notifications from the storage.
         let removed_notifications = self
             .storage
-            .take_notifications(remove_from_file_id..=remove_to_file_id)?
+            .take_entries(remove_from_file_id..=remove_to_file_id)?
             .into_iter()
             .map(|entry| entry.notification)
             .collect::<Vec<_>>();

crates/exex/exex/src/wal/storage.rs

@@ -14,9 +14,9 @@ use super::entry::WalEntry;
 /// The underlying WAL storage backed by a directory of files.
 ///
 /// Each notification is represented by a single file that contains a MessagePack-encoded
-/// notification.
+/// [`WalEntry`] struct.
 #[derive(Debug)]
-pub(super) struct Storage {
+pub struct Storage {
     /// The path to the WAL file.
     path: PathBuf,
 }
@@ -90,10 +90,7 @@ impl Storage {
     /// # Returns
     ///
     /// Entries that were removed.
-    pub(super) fn take_notifications(
-        &self,
-        range: RangeInclusive<u64>,
-    ) -> eyre::Result<Vec<WalEntry>> {
+    pub(super) fn take_entries(&self, range: RangeInclusive<u64>) -> eyre::Result<Vec<WalEntry>> {
         let entries = self.entries(range).collect::<eyre::Result<Vec<_>>>()?;
 
         for (id, _) in &entries {
@@ -183,8 +180,8 @@ mod tests {
         // Do a round trip serialization and deserialization
         let file_id = 0;
         storage.write_entry(file_id, entry.clone())?;
-        let deserialized_notification = storage.read_entry(file_id)?;
-        assert_eq!(deserialized_notification, entry);
+        let deserialized_entry = storage.read_entry(file_id)?;
+        assert_eq!(deserialized_entry, entry);
 
         Ok(())
     }