feat: add batcher and com prep

crates/batcher/Cargo.toml

@@ -5,7 +5,12 @@ edition.workspace = true
 license.workspace = true
 repository.workspace = true
 
-[dependencies]
 
 [lints]
 workspace = true
+
+[dependencies]
+async-trait.workspace = true
+starknet_batcher_types = { path = "../batcher_types", version = "0.0" }
+starknet_mempool_infra = { path = "../mempool_infra", version = "0.0" }
+tokio.workspace = true

crates/batcher/src/batcher.rs

@@ -0,0 +1,2 @@
+// TODO(Tsabary/Yael/Dafna): Replace with actual batcher code.
+pub struct Batcher {}

crates/batcher/src/communication.rs

@@ -0,0 +1,55 @@
+use std::net::IpAddr;
+
+use async_trait::async_trait;
+use starknet_batcher_types::communication::{
+    BatcherRequest,
+    BatcherRequestAndResponseSender,
+    BatcherResponse,
+};
+use starknet_mempool_infra::component_definitions::ComponentRequestHandler;
+use starknet_mempool_infra::component_runner::ComponentStarter;
+use starknet_mempool_infra::component_server::{LocalComponentServer, RemoteComponentServer};
+use tokio::sync::mpsc::Receiver;
+
+use crate::batcher::Batcher;
+
+pub type LocalBatcherServer = LocalComponentServer<Batcher, BatcherRequest, BatcherResponse>;
+pub type RemoteBatcherServer = RemoteComponentServer<Batcher, BatcherRequest, BatcherResponse>;
+
+pub fn create_local_batcher_server(
+    batcher: Batcher,
+    rx_batcher: Receiver<BatcherRequestAndResponseSender>,
+) -> LocalBatcherServer {
+    LocalComponentServer::new(batcher, rx_batcher)
+}
+
+pub fn create_remote_batcher_server(
+    batcher: Batcher,
+    ip_address: IpAddr,
+    port: u16,
+) -> RemoteBatcherServer {
+    RemoteComponentServer::new(batcher, ip_address, port)
+}
+
+#[async_trait]
+impl ComponentRequestHandler<BatcherRequest, BatcherResponse> for Batcher {
+    async fn handle_request(&mut self, request: BatcherRequest) -> BatcherResponse {
+        match request {
+            BatcherRequest::BatcherFnOne(_batcher_input) => {
+                // TODO(Tsabary/Yael/Dafna): Invoke a function that returns a
+                // BatcherResult<BatcherFnOneReturnValue>, and return
+                // the BatcherResponse::BatcherFnOneInput accordingly.
+                unimplemented!()
+            }
+            BatcherRequest::BatcherFnTwo(_batcher_input) => {
+                // TODO(Tsabary/Yael/Dafna): Invoke a function that returns a
+                // BatcherResult<BatcherFnTwoReturnValue>, and return
+                // the BatcherResponse::BatcherFnTwoInput accordingly.
+                unimplemented!()
+            }
+        }
+    }
+}
+
+#[async_trait]
+impl ComponentStarter for Batcher {}

crates/batcher/src/lib.rs

@@ -1 +1,2 @@
-
+pub mod batcher;
+pub mod communication;