feat: support local prover && multiple task types

.gitignore

@@ -27,3 +27,5 @@ db/
 *.lock
 *.tgz
 .vscode/
+
+.DS_Store

Cargo.toml

@@ -16,34 +16,24 @@ bls12_381 = { git = "https://github.com/scroll-tech/bls12_381", branch = "feat/i
 [dependencies]
 anyhow = "1.0"
 log = "0.4"
-env_logger = "0.11.3"
 serde = { version = "1.0.198", features = ["derive"] }
 serde_json = "1.0.116"
-futures = "0.3.30"
 ethers-core = { git = "https://github.com/scroll-tech/ethers-rs.git", branch = "v2.0.7" }
 ethers-providers = { git = "https://github.com/scroll-tech/ethers-rs.git", branch = "v2.0.7" }
-halo2_proofs = { git = "https://github.com/scroll-tech/halo2.git", branch = "v1.1" }
-snark-verifier-sdk = { git = "https://github.com/scroll-tech/snark-verifier", branch = "develop", default-features = false, features = ["loader_halo2", "loader_evm", "halo2-pse"] }
-# prover_darwin = { git = "https://github.com/scroll-tech/zkevm-circuits.git", tag = "v0.12.2", package = "prover", default-features = false, features = ["parallel_syn", "scroll"] }
 prover_darwin_v2 = { git = "https://github.com/scroll-tech/zkevm-circuits.git", tag = "v0.13.1", package = "prover", default-features = false, features = ["parallel_syn", "scroll"] }
-base64 = "0.13.1"
 reqwest = { version = "0.12.4", features = ["gzip"] }
 reqwest-middleware = "0.3"
 reqwest-retry = "0.5"
-once_cell = "1.19.0"
 hex = "0.4.3"
 tiny-keccak = { version = "2.0.0", features = ["sha3", "keccak"] }
 rand = "0.8.5"
-eth-keystore = "0.5.0"
 rlp = "0.5.2"
 tokio = { version = "1.37.0", features = ["full"] }
 async-trait = "0.1"
-sled = "0.34.7"
 http = "1.1.0"
 clap = { version = "4.5", features = ["derive"] }
-ctor = "0.2.8"
 tracing = "0.1.40"
 tracing-subscriber = { version = "0.3.18", features = ["env-filter"] }
 axum = "0.6.0"
 dotenv = "0.15"
-rocksdb = "0.20"
+rocksdb = "0.23.0"

conf/config.json

@@ -1,26 +1,38 @@
 {
-  "prover_name_prefix": "cloud_prover_",
-  "keys_dir": "keys",
-  "coordinator": {
-    "base_url": "https://coordinator-api.scrollsdk",
-    "retry_count": 3,
-    "retry_wait_time_sec": 5,
-    "connection_timeout_sec": 60
-  },
-  "l2geth": {
-    "endpoint": "https://l2-rpc.scrollsdk"
-  },
-  "prover": {
-    "circuit_type": 3,
-    "circuit_version": "v0.13.1",
-    "n_workers": 1,
-    "cloud": {
-      "base_url": "<CLOUD_PROVING_SERVICE_BASE_URL>",
-      "api_key": "<API_KEY>",
+    "prover_name_prefix": "prover_name",
+    "keys_dir": "keys",
+    "coordinator": {
+      "base_url": "https://coordinator-api.scrollsdk",
       "retry_count": 3,
       "retry_wait_time_sec": 5,
       "connection_timeout_sec": 60
-    }
-  },
-  "db_path": "db"
-}
+    },
+    "l2geth": {
+      "endpoint": "https://l2-rpc.scrollsdk"
+    },
+    "prover": {
+      "circuit_type": [1,2,3],
+      "circuit_version": "v0.13.1",
+      "cloud": {
+        "base_url": "<CLOUD_PROVING_SERVICE_BASE_URL>",
+        "api_key": "<API_KEY>",
+        "retry_count": 3,
+        "retry_wait_time_sec": 5,
+        "connection_timeout_sec": 60
+      },
+      "local": {
+        "low_version_circuit": {
+          "hard_fork_name": "bernoulli",
+          "params_path": "params",
+          "assets_path": "assets"
+        },
+        "high_version_circuit": {
+          "hard_fork_name": "curie",
+          "params_path": "params",
+          "assets_path": "assets"
+        }
+      }
+    },
+    "db_path": "db"
+  }
+

examples/cloud.rs

@@ -32,7 +32,7 @@ impl ProvingService for CloudProver {
     fn is_local(&self) -> bool {
         false
     }
-    async fn get_vk(&self, req: GetVkRequest) -> GetVkResponse {
+    async fn get_vks(&self, req: GetVkRequest) -> GetVkResponse {
         todo!()
     }
     async fn prove(&self, req: ProveRequest) -> ProveResponse {

examples/local.rs

@@ -28,7 +28,7 @@ impl ProvingService for LocalProver {
     fn is_local(&self) -> bool {
         true
     }
-    async fn get_vk(&self, req: GetVkRequest) -> GetVkResponse {
+    async fn get_vks(&self, req: GetVkRequest) -> GetVkResponse {
         todo!()
     }
     async fn prove(&self, req: ProveRequest) -> ProveResponse {
@@ -50,7 +50,7 @@ async fn main() -> anyhow::Result<()> {
     init_tracing();
 
     let args = Args::parse();
-    let cfg: Config = Config::from_file(args.config_file)?;
+    let cfg: Config = Config::from_file_and_env(args.config_file)?;
     let local_prover = LocalProver::new(cfg.prover.local.clone().unwrap());
     let prover = ProverBuilder::new(cfg)
         .with_proving_service(Box::new(local_prover))