feat: build server app and define routes

Author: MarcosNicolau

Makefile

@@ -303,9 +303,11 @@ proof_aggregator_write_program_ids: ## Write proof aggregator zkvm programs ids
 	@cd aggregation_mode/proof_aggregator && ./scripts/build_programs.sh
 
 agg_mode_batcher_start_local:
+	@cd aggregation_mode && docker-compose up -d
 	cargo run --manifest-path ./aggregation_mode/Cargo.toml --release --bin agg_mode_batcher -- config-files/config-agg-mode-batcher.yaml
 
 agg_mode_batcher_start_ethereum_package:
+	@cd aggregation_mode && docker-compose up -d
 	cargo run --manifest-path ./aggregation_mode/Cargo.toml --release --bin agg_mode_batcher -- config-files/config-agg-mode-batcher-ethereum-package.yaml
 
 __AGGREGATOR__: ## ____

aggregation_mode/batcher/src/config.rs

@@ -2,7 +2,7 @@ use std::{fs::File, io::Read};
 
 use serde::{Deserialize, Serialize};
 
-#[derive(Debug, Deserialize, Serialize)]
+#[derive(Clone, Debug, Deserialize, Serialize)]
 pub struct Config {
     pub port: u16,
     pub db_connection_url: String,

aggregation_mode/batcher/src/server.rs

@@ -1,7 +1,14 @@
-use actix_web::{web, App, HttpResponse, HttpServer};
+use actix_web::{
+    web::{self, Data},
+    App, HttpRequest, HttpResponse, HttpServer, Responder,
+};
 
 use crate::{config::Config, db::Db};
 
+/// Starts the http server to receive proofs
+///
+/// It is also thread safe to share and it is used as the shared state between endpoints
+#[derive(Clone, Debug)]
 pub struct BatcherServer {
     db: Db,
     config: Config,
@@ -20,14 +27,36 @@ impl BatcherServer {
     }
 
     pub async fn start(&self) -> Result<(), std::io::Error> {
-        HttpServer::new(|| {
-            App::new().route(
-                "/",
-                web::get().to(async || HttpResponse::Ok().body("Hey there!")),
+        // Note: BatcherServer is thread safe so we can just clone it (no need to add mutexes)
+        let port = self.config.port;
+        let state = self.clone();
+
+        HttpServer::new(move || Self::build_app(state.clone()))
+            .bind(("127.0.0.1", port))?
+            .run()
+            .await
+    }
+
+    fn build_app(state: BatcherServer) -> App {
+        App::new()
+            .app_data(Data::new(state))
+            .route("/nonce/:address", web::get().to(Self::get_nonce))
+            .route(
+                "/proof/merkle/:receipt",
+                web::get().to(Self::get_proof_merkle_path),
             )
-        })
-        .bind(("127.0.0.1", self.config.port))?
-        .run()
-        .await
+            .route("/proof", web::post().to(Self::post_proof))
+    }
+
+    async fn get_nonce(req: HttpRequest) -> impl Responder {
+        HttpResponse::Ok()
+    }
+
+    async fn post_proof(req: HttpRequest) -> impl Responder {
+        HttpResponse::Ok()
+    }
+
+    async fn get_proof_merkle_path(req: HttpRequest) -> impl Responder {
+        HttpResponse::Ok()
     }
 }