feat: submit proof message in gateway provider

Author: MarcosNicolau

crates/sdk/Cargo.toml

@@ -26,4 +26,5 @@ hex = "0.4.3"
 ciborium = "=0.2.2"
 serde_repr = "0.1.19"
 dialoguer = "0.11.0"
-reqwest = { version = "0.12", features = ["json"] }
+reqwest = { version = "0.12", features = ["json", "multipart"] }
+alloy = { version = "1.1.1", features = ["default", "signer-keystore"] }

crates/sdk/src/aggregation_layer/gateway/provider.rs

@@ -1,15 +1,18 @@
-use reqwest::Client;
+use alloy::network::EthereumWallet;
+use reqwest::{multipart, Client};
 use serde::de::DeserializeOwned;
 
 use crate::{
     aggregation_layer::gateway::types::{
         GatewayResponse, NonceResponse, Receipt, ReceiptsQuery, ReceiptsResponse,
+        SubmitProofResponse, SubmitSP1ProofMessage,
     },
     common::types::Network,
 };
 
 pub struct AggregationModeGatewayProvider {
     gateway_url: String,
+    signer: Option<EthereumWallet>,
     http_client: Client,
 }
 
@@ -18,6 +21,7 @@ pub enum AggregationModeError {
     UnsupportedNetwork,
     Request(String),
     Api { status: u16, message: String },
+    SignerNotConfigured,
 }
 
 impl AggregationModeGatewayProvider {
@@ -31,12 +35,29 @@ impl AggregationModeGatewayProvider {
         Ok(Self {
             gateway_url,
             http_client: Client::new(),
+            signer: None,
         })
     }
 
-    pub fn new_with_signer() {}
+    pub fn new_with_signer(
+        network: Network,
+        signer: EthereumWallet,
+    ) -> Result<Self, AggregationModeError> {
+        let gateway_url = match network {
+            Network::Devnet => "http://127.0.0.1:8089".into(),
+            _ => return Err(AggregationModeError::UnsupportedNetwork),
+        };
+
+        Ok(Self {
+            gateway_url,
+            http_client: Client::new(),
+            signer: Some(signer),
+        })
+    }
 
-    pub fn signer() {}
+    pub fn signer(&self) -> Option<&EthereumWallet> {
+        self.signer.as_ref()
+    }
 }
 
 impl AggregationModeGatewayProvider {
@@ -71,7 +92,37 @@ impl AggregationModeGatewayProvider {
         Ok(response.receipts)
     }
 
-    pub async fn submit_sp1_proof(&self, serialized_proof: Vec<u8>, serialized_vk: Vec<u8>) {}
+    pub async fn submit_sp1_proof(
+        &self,
+        serialized_proof: Vec<u8>,
+        serialized_vk: Vec<u8>,
+    ) -> Result<SubmitProofResponse, AggregationModeError> {
+        let Some(signer) = &self.signer else {
+            return Err(AggregationModeError::SignerNotConfigured);
+        };
+        let signer_address = signer.default_signer().address().to_string();
+
+        let nonce = self.get_nonce_for(signer_address).await?;
+        let message = SubmitSP1ProofMessage::new(nonce, serialized_proof, serialized_vk).sign();
+        let form = multipart::Form::new()
+            .text("nonce", message.nonce.to_string())
+            .part(
+                "proof",
+                multipart::Part::bytes(message.proof).file_name("proof.bin"),
+            )
+            .part(
+                "program_vk",
+                multipart::Part::bytes(message.program_vk).file_name("program_vk.bin"),
+            )
+            .text("signature_hex", hex::encode(message.signature));
+
+        let request = self
+            .http_client
+            .post(format!("{}/proof/sp1", self.gateway_url))
+            .multipart(form);
+
+        self.send_request(request).await
+    }
 
     // TODO: verify proof from receipt merkle path
 

crates/sdk/src/aggregation_layer/gateway/types.rs

@@ -34,10 +34,10 @@ pub(super) struct ReceiptsResponse {
 
 #[derive(Debug, Clone, Deserialize)]
 pub struct SubmitSP1ProofMessage {
-    nonce: u64,
-    proof: Vec<u8>,
-    program_vk: Vec<u8>,
-    signature: Vec<u8>,
+    pub nonce: u64,
+    pub proof: Vec<u8>,
+    pub program_vk: Vec<u8>,
+    pub signature: Vec<u8>,
 }
 
 #[derive(Debug, Clone, Deserialize)]

crates/sdk/src/aggregation_layer/gateway_.rs

@@ -0,0 +1,37 @@
+use crate::common::types::Network;
+use reqwest::Client;
+use serde::{de::DeserializeOwned, Deserialize, Serialize};
+
+#[derive(Debug, Clone, Deserialize)]
+pub struct GatewayReceipt {
+    pub status: String,
+    pub merkle_path: Vec<String>,
+    pub nonce: i64,
+    pub address: String,
+}
+
+pub struct SubmitSP1ProofMessage {
+    nonce: u64,
+    proof: Vec<u8>,
+    program_vk: Vec<u8>,
+    signature: Vec<u8>,
+}
+
+pub struct SubmitProofResponse {
+    pub task_id: String,
+}
+
+impl SubmitSP1ProofMessage {
+    pub fn new(nonce: u64, serialized_proof: Vec<u8>, serialized_vk: Vec<u8>) -> Self {
+        Self {
+            nonce,
+            proof: serialized_proof,
+            program_vk: serialized_vk,
+            signature: vec![],
+        }
+    }
+
+    pub fn sign(self) -> Self {
+        self
+    }
+}