feat: L1 providers

.github/workflows/lint.yaml

@@ -128,11 +128,11 @@ jobs:
           - type: wasm
             target: wasm32-unknown-unknown
             exclude: |
-              scroll-engine,scroll-wire,rollup-node,scroll-network,rollup-node-manager,rollup-node-watcher,scroll-db,scroll-migration,rollup-node-indexer,scroll-derivation-pipeline
+              scroll-engine,scroll-wire,rollup-node,scroll-network,rollup-node-manager,rollup-node-watcher,scroll-db,scroll-migration,rollup-node-indexer,scroll-derivation-pipeline,rollup-node-providers
           - type: riscv
             target: riscv32imac-unknown-none-elf
             exclude: |
-              scroll-engine,scroll-wire,rollup-node,scroll-network,rollup-node-manager,rollup-node-watcher,scroll-db,scroll-migration,rollup-node-indexer,scroll-codec,scroll-derivation-pipeline
+              scroll-engine,scroll-wire,rollup-node,scroll-network,rollup-node-manager,rollup-node-watcher,scroll-db,scroll-migration,rollup-node-indexer,scroll-codec,scroll-derivation-pipeline,rollup-node-providers
     steps:
       - uses: actions/checkout@v4
       - uses: rui314/setup-mold@v1

Cargo.toml

@@ -18,6 +18,7 @@ members = [
     "crates/node",
     "crates/network",
     "crates/primitives",
+    "crates/providers",
     "crates/scroll-wire",
     "crates/watcher",
 ]
@@ -152,6 +153,7 @@ reth-scroll-primitives = { git = "https://github.com/scroll-tech/reth.git", defa
 rollup-node-indexer = { path = "crates/indexer" }
 rollup-node-manager = { path = "crates/node" }
 rollup-node-primitives = { path = "crates/primitives" }
+rollup-node-providers = { path = "crates/providers" }
 rollup-node-watcher = { path = "crates/watcher" }
 scroll-codec = { path = "crates/codec" }
 scroll-db = { path = "crates/database/db" }

crates/database/db/src/models/batch_commit.rs

@@ -11,6 +11,7 @@ pub struct Model {
     index: i64,
     hash: Vec<u8>,
     block_number: i64,
+    block_timestamp: i64,
     calldata: Vec<u8>,
     blob_hash: Option<Vec<u8>>,
     finalized_block_number: Option<i64>,
@@ -33,6 +34,9 @@ impl From<BatchCommitData> for ActiveModel {
             block_number: ActiveValue::Set(
                 batch_commit.block_number.try_into().expect("block number should fit in i64"),
             ),
+            block_timestamp: ActiveValue::Set(
+                batch_commit.block_timestamp.try_into().expect("block timestamp should fit in i64"),
+            ),
             calldata: ActiveValue::Set(batch_commit.calldata.0.to_vec()),
             blob_hash: ActiveValue::Set(batch_commit.blob_versioned_hash.map(|b| b.to_vec())),
             finalized_block_number: ActiveValue::Unchanged(None),
@@ -46,6 +50,7 @@ impl From<Model> for BatchCommitData {
             hash: value.hash.as_slice().try_into().expect("data persisted in database is valid"),
             index: value.index as u64,
             block_number: value.block_number as u64,
+            block_timestamp: value.block_timestamp as u64,
             calldata: Arc::new(value.calldata.into()),
             blob_versioned_hash: value
                 .blob_hash

crates/database/migration/src/m20220101_000001_create_batch_commit_table.rs

@@ -17,6 +17,7 @@ impl MigrationTrait for Migration {
                     .col(pk_auto(BatchCommit::Index))
                     .col(binary_len(BatchCommit::Hash, HASH_LENGTH))
                     .col(big_unsigned(BatchCommit::BlockNumber))
+                    .col(big_unsigned(BatchCommit::BlockTimestamp))
                     .col(binary(BatchCommit::Calldata))
                     .col(binary_len_null(BatchCommit::BlobHash, HASH_LENGTH))
                     .col(boolean_null(BatchCommit::FinalizedBlockNumber))
@@ -36,6 +37,7 @@ enum BatchCommit {
     Index,
     Hash,
     BlockNumber,
+    BlockTimestamp,
     Calldata,
     BlobHash,
     FinalizedBlockNumber,

crates/derivation-pipeline/Cargo.toml

@@ -22,14 +22,17 @@ scroll-alloy-rpc-types-engine.workspace = true
 
 # rollup node
 rollup-node-primitives.workspace = true
+rollup-node-providers.workspace = true
 scroll-codec.workspace = true
 
 # misc
 thiserror.workspace = true
 
 [dev-dependencies]
+async-trait.workspace = true
 eyre.workspace = true
 scroll-codec = { workspace = true, features = ["test-utils"] }
+tokio = { workspace = true, features = ["macros"] }
 
 [features]
 default = ["std"]

crates/derivation-pipeline/src/error.rs

@@ -1,3 +1,4 @@
+use rollup_node_providers::L1ProviderError;
 use scroll_codec::CodecError;
 
 /// An error occurred during the derivation process.
@@ -9,4 +10,10 @@ pub enum DerivationPipelineError {
     /// Missing L1 messages cursor.
     #[error("missing l1 message queue cursor")]
     MissingL1MessageQueueCursor,
+    /// Missing L1 message.
+    #[error("missing l1 message")]
+    MissingL1Message,
+    /// An error at the L1 provider.
+    #[error(transparent)]
+    L1Provider(#[from] L1ProviderError),
 }