feat: implement file blockstore

Cargo.toml

@@ -53,6 +53,7 @@ axum = "0.7.5"
 base64 = "0.22.1"
 bitflags = "2.5.0"
 blake2b_simd = { version = "1.0.2", default-features = false }
+blockstore = "0.7.1"
 bls12_381 = "0.8"
 bs58 = "0.5.1"
 byteorder = "1.5.0"

mater/lib/Cargo.toml

@@ -7,6 +7,9 @@ name = "mater"                # name WIP
 repository.workspace = true
 version = "0.1.0"
 
+[features]
+blockstore = ["dep:blockstore"]
+
 [dependencies]
 async-stream.workspace = true
 bitflags.workspace = true
@@ -27,6 +30,9 @@ tokio = { workspace = true, features = ["fs", "macros", "rt-multi-thread"] }
 tokio-stream.workspace = true
 tokio-util = { workspace = true, features = ["io"] }
 
+# Optional dependencies
+blockstore = { workspace = true, optional = true }
+
 [dev-dependencies]
 criterion = { workspace = true, features = ["async_tokio", "html_reports"] }
 rand = { workspace = true, default_features = true }

mater/lib/src/lib.rs

@@ -19,7 +19,7 @@ mod v2;
 
 // We need to re-expose this because `read_block` returns `(Cid, Vec<u8>)`.
 pub use ipld_core::cid::Cid;
-pub use stores::{create_filestore, Blockstore, Config};
+pub use stores::{create_filestore, Blockstore, Config, FileBlockstore};
 pub use v1::{Header as CarV1Header, Reader as CarV1Reader, Writer as CarV1Writer};
 pub use v2::{
     verify_cid, Characteristics, Header as CarV2Header, Index, IndexEntry, IndexSorted,

mater/lib/src/stores/blockstore.rs

@@ -164,7 +164,7 @@ impl Blockstore {
 
     /// Get the [`CarV2Header`] that will be written out.
     fn header_v2(&self) -> CarV2Header {
-        let data_offset = CarV2Header::SIZE as u64;
+        let data_offset = CarV2Header::SIZE;
         let data_size: u64 = self
             .blocks
             .iter()
@@ -298,16 +298,13 @@ mod tests {
         car_reader.read_pragma().await.unwrap();
 
         let car_v2_header = car_reader.read_header().await.unwrap();
-        assert_eq!(car_v2_header.data_offset, CarV2Header::SIZE as u64);
+        assert_eq!(car_v2_header.data_offset, CarV2Header::SIZE);
         // Extracted with go-car and validated with an hex viewer
         // to extract the values, run the following commands:
         // $ car inspect <output of this process>
         // The dump is necessary because go-car does not support parametrization
         assert_eq!(car_v2_header.data_size, 1358);
-        assert_eq!(
-            car_v2_header.index_offset,
-            (CarV2Header::SIZE as u64) + 1358
-        );
+        assert_eq!(car_v2_header.index_offset, CarV2Header::SIZE + 1358);
 
         let car_v1_header = car_reader.read_v1_header().await.unwrap();
         assert_eq!(car_v1_header.roots.len(), 1);