feat: Add new main.rs, derived from bin/server.rs.

Cargo.toml

@@ -63,8 +63,6 @@ ark-groth16 = "0.5.0"
 ark-serialize = "0.5.0"
 ark-bn254 = { version = "0.5.0", features = ["curve", "scalar_field"], default-features = false }
 
-
-
 [patch.crates-io]
 bitcoincore-rpc = { version = "0.18.0", git = "https://github.com/chainwayxyz/rust-bitcoincore-rpc.git", rev = "44f9bba" }
 secp256k1 = { git = "https://github.com/jlest01/rust-secp256k1", rev = "1cc7410df436b73d06db3c8ff7cbb29a78916b06" }

core/Cargo.toml

@@ -52,9 +52,5 @@ serial_test = { workspace = true }
 bitcoin-script = { workspace = true }
 citrea-e2e = { workspace = true }
 
-[[bin]]
-name = "server"
-path = "src/bin/server.rs"
-
 [lints.clippy]
 unwrap_used = { level = "deny" }

core/src/cli.rs

@@ -29,6 +29,9 @@ pub struct Args {
     /// Enable aggregator server.
     #[clap(long)]
     pub aggregator_server: bool,
+    /// Enable watchtower server.
+    #[clap(long)]
+    pub watchtower_server: bool,
 }
 
 /// Parse all the command line arguments and generate a `BridgeConfig`.

core/src/main.rs

@@ -0,0 +1,81 @@
+use clementine_core::database::Database;
+use clementine_core::servers::{
+    create_aggregator_grpc_server, create_operator_grpc_server, create_verifier_grpc_server,
+    create_watchtower_grpc_server,
+};
+use clementine_core::utils::get_configuration_for_binaries;
+use std::process::exit;
+
+#[tokio::main]
+async fn main() {
+    eprintln!("\nBEWARE: Current behavior of this binary might be incorrect! It is in active development.\n");
+
+    let (mut config, args) = get_configuration_for_binaries();
+
+    if !args.verifier_server
+        && !args.operator_server
+        && !args.aggregator_server
+        && !args.watchtower_server
+    {
+        eprintln!("No servers are specified. Please specify one.");
+        exit(1);
+    }
+
+    Database::run_schema_script(&config)
+        .await
+        .expect("Can't run schema script");
+
+    let mut handles = vec![];
+
+    if args.verifier_server {
+        handles.push(
+            create_verifier_grpc_server(config.clone())
+                .await
+                .expect("Can't create verifier server")
+                .1,
+        );
+        config.port += 1;
+
+        println!("Verifier server is started.");
+    }
+
+    if args.operator_server {
+        handles.push(
+            create_operator_grpc_server(config.clone())
+                .await
+                .expect("Can't create operator server")
+                .1,
+        );
+        config.port += 1;
+
+        println!("Operator server is started.");
+    }
+
+    if args.aggregator_server {
+        handles.push(
+            create_aggregator_grpc_server(config.clone())
+                .await
+                .expect("Can't create aggregator server")
+                .1,
+        );
+        config.port += 1;
+
+        println!("Aggregator server is started.");
+    }
+
+    if args.watchtower_server {
+        handles.push(
+            create_watchtower_grpc_server(config)
+                .await
+                .expect("Can't create watchtower server")
+                .1,
+        );
+
+        println!("Watchtower server is started.");
+    }
+
+    // Wait for servers to close, A.K.A. run forever.
+    for mut handle in handles {
+        handle.closed().await;
+    }
+}