fix: mock crate.

Author: l-monninger

Cargo.lock

@@ -3,6 +3,8 @@
 resolver = "2"
 
 members = [
+  "protocol-units/mcr/util/*",
+  "protocol-units/mcr/clients/*",
   "protocol-units/mcr/client",
   "protocol-units/mcr/manager",
   "protocol-units/post-confirmations/*",
@@ -64,6 +66,9 @@ tokio = { version = "1.35.1", features = ["full", "tracing"] }
 tokio-stream = "0.1.15"
 
 # internal
+## mcr
+mcr-types = { path = "protocol-units/mcr/util/types" }
+mcr-client-util = { path = "protocol-units/mcr/clients/util" }
 mcr-settlement-client = { path = "protocol-units/mcr/client" }
 
 [workspace.lints.clippy]

Cargo.toml

@@ -0,0 +1,60 @@
+[package]
+name = "mcr-client-eth"
+version = { workspace = true }
+edition = { workspace = true }
+license = { workspace = true }
+authors = { workspace = true }
+homepage = { workspace = true }
+publish = { workspace = true }
+rust-version = { workspace = true }
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+# [[bin]]
+# name = "test-mcr-settlement-client"
+# path = "src/bin/e2e/test_client_settlement.rs"
+
+
+[dependencies]
+alloy = { workspace = true, features = [
+    "node-bindings",
+    "rpc-types-trace",
+    "json-rpc",
+    "rpc-client",
+    "signers",
+    "signer-yubihsm",
+    "pubsub",
+    "providers",
+] }
+alloy-contract = { workspace = true }
+alloy-network = { workspace = true }
+alloy-primitives = { workspace = true }
+alloy-provider = { workspace = true, features = [] }
+alloy-signer = { workspace = true }
+alloy-sol-types = { workspace = true }
+alloy-transport = { workspace = true }
+alloy-transport-ws = { workspace = true }
+
+anyhow = { workspace = true }
+async-stream = { workspace = true }
+async-trait = { workspace = true }
+serde_json = { workspace = true }
+thiserror = { workspace = true }
+tokio = { workspace = true }
+tokio-stream = { workspace = true }
+tracing = { workspace = true }
+serde = { workspace = true }
+
+
+alloy-rpc-types = { workspace = true }
+futures = { workspace = true }
+tracing-subscriber = { workspace = true }
+mcr-types = { workspace = true }
+
+[features]
+default = ["eth"]
+e2e = ["eth"]
+eth = []
+mock = []
+
+[lints]
+workspace = true

protocol-units/mcr/clients/eth/Cargo.toml

@@ -0,0 +1,60 @@
+use mcr_types::block_commitment::Commitment as BlockCommitment;
+use tokio_stream::Stream;
+
+/// Errors thrown by the McrClient.
+#[derive(Debug, thiserror::Error)]
+pub enum McrClientError {
+	#[error("failed to post block commitment: {0}")]
+	PostBlockCommitment(#[source] Box<dyn std::error::Error + Send + Sync>),
+	#[error("failed to invoke admin function: {0}")]
+	AdminFunction(#[source] Box<dyn std::error::Error + Send + Sync>),
+	#[error("failed to stream block commitments: {0}")]
+	StreamBlockCommitments(#[source] Box<dyn std::error::Error + Send + Sync>),
+	#[error("failed to get commitment: {0}")]
+	GetCommitment(#[source] Box<dyn std::error::Error + Send + Sync>),
+	#[error("internal error: {0}")]
+	Internal(#[source] Box<dyn std::error::Error + Send + Sync>),
+}
+
+type CommitmentStream =
+	std::pin::Pin<Box<dyn Stream<Item = Result<BlockCommitment, anyhow::Error>> + Send>>;
+
+#[async_trait::async_trait]
+pub trait McrClientOperations {
+	/// Posts a block commitment to the settlement client.
+	async fn post_block_commitment(
+		&self,
+		block_commitment: BlockCommitment,
+	) -> Result<(), McrClientError>;
+
+	/// Posts a batch of block commitments to the settlement client.
+	async fn post_block_commitment_batch(
+		&self,
+		block_commitment: Vec<BlockCommitment>,
+	) -> Result<(), McrClientError>;
+
+	/// Forces a block commitment
+	/// This will only work in admin mode
+	async fn force_block_commitment(
+		&self,
+		block_commitment: BlockCommitment,
+	) -> Result<(), McrClientError>;
+
+	/// Streams block commitments from the settlement client.
+	async fn stream_block_commitments(&self) -> Result<CommitmentStream, McrClientError>;
+
+	/// Gets the accepted commitment at the given height.
+	async fn get_commitment_at_height(
+		&self,
+		height: u64,
+	) -> Result<Option<BlockCommitment>, McrClientError>;
+
+	/// Gets the commitment this validator has made at a given height
+	async fn get_posted_commitment_at_height(
+		&self,
+		height: u64,
+	) -> Result<Option<BlockCommitment>, McrClientError>;
+
+	/// Gets the max tolerable block height.
+	async fn get_max_tolerable_block_height(&self) -> Result<u64, McrClientError>;
+}

protocol-units/mcr/clients/eth/src/lib.rs

@@ -0,0 +1,35 @@
+[package]
+name = "mcr-client-mock"
+version = { workspace = true }
+edition = { workspace = true }
+license = { workspace = true }
+authors = { workspace = true }
+homepage = { workspace = true }
+publish = { workspace = true }
+rust-version = { workspace = true }
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+# [[bin]]
+# name = "test-mcr-settlement-client"
+# path = "src/bin/e2e/test_client_settlement.rs"
+
+
+[dependencies]
+thiserror = { workspace = true }
+tokio = { workspace = true }
+tokio-stream = { workspace = true }
+tracing = { workspace = true }
+serde = { workspace = true, features = ["derive"] }
+mcr-types = { workspace = true }
+mcr-client-util = { workspace = true }
+anyhow = { workspace = true }
+futures = { workspace = true}
+
+[features]
+default = ["eth"]
+e2e = ["eth"]
+eth = []
+mock = []
+
+[lints]
+workspace = true