From 7becf4f3369fbaf5945939403d756a09b6baa4f3 Mon Sep 17 00:00:00 2001
From: Petar Radovic <petar.radovic@gmail.com>
Date: Tue, 22 Apr 2025 16:57:37 +0200
Subject: [PATCH] simple loop pooling

---
 sz-poc-offsite-2025/evm/prover/src/main.rs | 85 +++++++++++++++++++++-
 1 file changed, 81 insertions(+), 4 deletions(-)

diff --git a/sz-poc-offsite-2025/evm/prover/src/main.rs b/sz-poc-offsite-2025/evm/prover/src/main.rs
index b3f0c92..77d3729 100644
--- a/sz-poc-offsite-2025/evm/prover/src/main.rs
+++ b/sz-poc-offsite-2025/evm/prover/src/main.rs
@@ -1,5 +1,5 @@
 use clap::Parser;
-use std::process::Command;
+use std::{process::Command, thread, time::Duration};
 
 #[derive(Parser, Debug)]
 #[clap(author, version, about = "Ethereum Proof Generation Tool")]
@@ -8,10 +8,13 @@ struct Args {
     rpc: String,
 
     #[clap(long, default_value = "5")]
-    block_number: u64,
+    start_block: u64,
 
     #[clap(long, default_value = "10")]
     batch_size: u64,
+
+    #[clap(long, default_value = "5")]
+    interval: u64,
 }
 
 fn run_ethereum_prove(rpc: &str, block_number: u64, batch_size: u64) -> Result<(), String> {
@@ -44,11 +47,85 @@ fn run_ethereum_prove(rpc: &str, block_number: u64, batch_size: u64) -> Result<(
     Ok(())
 }
 
+fn get_latest_block(rpc: &str) -> Result<u64, String> {
+    println!("Checking latest block height...");
+
+    let output = Command::new("curl")
+        .args([
+            "-s",
+            "-X",
+            "POST",
+            "-H",
+            "Content-Type: application/json",
+            rpc,
+            "-d",
+            r#"{"jsonrpc":"2.0","method":"eth_blockNumber","params":[],"id":1}"#,
+        ])
+        .output()
+        .map_err(|e| format!("Failed to execute curl: {}", e))?;
+
+    if !output.status.success() {
+        return Err(format!(
+            "curl command failed with status: {}",
+            output.status
+        ));
+    }
+
+    let response = String::from_utf8_lossy(&output.stdout);
+
+    let block_hex = response
+        .split("\"result\":\"")
+        .nth(1)
+        .ok_or("Failed to parse response")?
+        .split("\"")
+        .next()
+        .ok_or("Failed to parse block number")?
+        .trim_start_matches("0x");
+
+    let block_number = u64::from_str_radix(block_hex, 16)
+        .map_err(|e| format!("Failed to parse hex block number: {}", e))?;
+
+    println!("Latest block: {}", block_number);
+    Ok(block_number)
+}
+
 fn main() -> Result<(), Box<dyn std::error::Error>> {
     let args = Args::parse();
 
     println!("Starting Ethereum prover...");
-    run_ethereum_prove(&args.rpc, args.block_number, args.batch_size)?;
+    // todo: read current block from state maybe
+    let mut current_block = args.start_block;
+    loop {
+        match get_latest_block(&args.rpc) {
+            Ok(latest_block) => {
+                if latest_block >= current_block + args.batch_size {
+                    println!(
+                        "New blocks available. Current: {}, Latest: {}",
+                        current_block, latest_block
+                    );
 
-    Ok(())
+                    match run_ethereum_prove(&args.rpc, current_block, args.batch_size) {
+                        Ok(_) => {
+                            current_block += args.batch_size;
+                            println!("Updated current block to {}", current_block);
+                        }
+                        Err(e) => {
+                            eprintln!("Error running prover: {}", e);
+                        }
+                    }
+                } else {
+                    println!(
+                        "No new blocks to process. Current: {}, Latest: {}",
+                        current_block, latest_block
+                    );
+                }
+            }
+            Err(e) => {
+                eprintln!("Error getting latest block: {}", e);
+            }
+        }
+
+        println!("Sleeping for {} seconds...", args.interval);
+        thread::sleep(Duration::from_secs(args.interval));
+    }
 }