feat: receive network via config file

Author: MarcosNicolau

aggregation_mode/batcher/src/config.rs

@@ -8,6 +8,7 @@ pub struct Config {
     pub db_connection_url: String,
     pub eth_rpc_url: String,
     pub payment_service_address: String,
+    pub network: String,
 }
 
 impl Config {

aggregation_mode/batcher/src/server/http.rs

@@ -8,6 +8,7 @@ use actix_web::{
     web::{self, Data},
     App, HttpRequest, HttpResponse, HttpServer, Responder,
 };
+use agg_mode_sdk::types::Network;
 use aligned_sdk::aggregation_layer::AggregationModeProvingSystem;
 use alloy::signers::Signature;
 use sp1_sdk::{SP1ProofWithPublicValues, SP1VerifyingKey};
@@ -29,11 +30,17 @@ use crate::{
 pub struct BatcherServer {
     db: Db,
     config: Config,
+    network: Network,
 }
 
 impl BatcherServer {
     pub fn new(db: Db, config: Config) -> Self {
-        Self { db, config }
+        let network = Network::from_str(&config.network).expect("A valid network in config file");
+        Self {
+            db,
+            config,
+            network,
+        }
     }
 
     pub async fn start(&self) {
@@ -96,6 +103,12 @@ impl BatcherServer {
         req: HttpRequest,
         MultipartForm(data): MultipartForm<SubmitProofRequestSP1>,
     ) -> impl Responder {
+        let Some(state) = req.app_data::<Data<BatcherServer>>() else {
+            return HttpResponse::InternalServerError()
+                .json(AppResponse::new_unsucessfull("Internal server error", 500));
+        };
+
+        let state = state.get_ref();
         let Ok(signature) = Signature::from_str(&data.signature_hex.0) else {
             return HttpResponse::InternalServerError()
                 .json(AppResponse::new_unsucessfull("Invalid signature", 500));
@@ -117,21 +130,14 @@ impl BatcherServer {
             proof_content.clone(),
             vk_content.clone(),
         );
-        let Ok(recovered_address) = signature.recover_address_from_prehash(
-            &msg.eip712_hash(&agg_mode_sdk::types::Network::Devnet)
-                .into(),
-        ) else {
+        let Ok(recovered_address) =
+            signature.recover_address_from_prehash(&msg.eip712_hash(&state.network).into())
+        else {
             return HttpResponse::InternalServerError()
                 .json(AppResponse::new_unsucessfull("Internal server error", 500));
         };
         let recovered_address = recovered_address.to_string().to_lowercase();
 
-        let Some(state) = req.app_data::<Data<BatcherServer>>() else {
-            return HttpResponse::InternalServerError()
-                .json(AppResponse::new_unsucessfull("Internal server error", 500));
-        };
-        let state = state.get_ref();
-
         let Ok(count) = state.db.count_tasks_by_address(&recovered_address).await else {
             return HttpResponse::InternalServerError()
                 .json(AppResponse::new_unsucessfull("Internal server error", 500));

config-files/config-agg-mode-batcher-ethereum-package.yaml

@@ -2,3 +2,4 @@ port: 8089
 db_connection_url: "postgres://postgres:postgres@localhost:5435/"
 eth_rpc_url: "http://localhost:8545"
 payment_service_address: "0x922D6956C99E12DFeB3224DEA977D0939758A1Fe"
+network: "devnet"

config-files/config-agg-mode-batcher.yaml

@@ -2,3 +2,4 @@ port: 8089
 db_connection_url: "postgres://postgres:postgres@localhost:5435/"
 eth_rpc_url: "http://localhost:8545"
 payment_service_address: "0x922D6956C99E12DFeB3224DEA977D0939758A1Fe"
+network: "devnet"