apollo_batcher: perform commitment tasks

Author: yoavGrs

crates/apollo_batcher/src/commitment_manager/state_committer.rs

@@ -1,6 +1,10 @@
 #![allow(dead_code, unused_variables, unused_mut)]
 
-use apollo_committer_types::communication::SharedCommitterClient;
+use apollo_committer_types::communication::{
+    CommitterClientResponse,
+    CommitterRequest,
+    SharedCommitterClient,
+};
 use tokio::sync::mpsc::{Receiver, Sender};
 use tokio::task::JoinHandle;
 
@@ -44,8 +48,20 @@ impl StateCommitter {
         mut results_sender: Sender<CommitmentTaskOutput>,
         committer_client: SharedCommitterClient,
     ) {
-        // Placeholder: simply drain the receiver and do nothing.
-        // TODO(Amos): Implement the actual commitment tasks logic.
-        while let Some(_task) = tasks_receiver.recv().await {}
+        while let Some(CommitmentTaskInput(request)) = tasks_receiver.recv().await {
+            let (committer_response, height) = match request {
+                CommitterRequest::CommitBlock(commit_block_request) => {
+                    let height = commit_block_request.height;
+                    let response = committer_client.commit_block(commit_block_request).await;
+                    (CommitterClientResponse::CommitBlock(response), height)
+                }
+                CommitterRequest::RevertBlock(revert_block_request) => {
+                    let height = revert_block_request.height;
+                    let response = committer_client.revert_block(revert_block_request).await;
+                    (CommitterClientResponse::RevertBlock(response), height)
+                }
+            };
+            results_sender.send(CommitmentTaskOutput { committer_response, height }).await.unwrap()
+        }
     }
 }