merge with ax/crypto-update and fix conflicts

Author: alxiong

.github/workflows/build-and-test.yml

@@ -14,6 +14,9 @@ jobs:
     runs-on: ubuntu-latest
     steps:
     - uses: actions/checkout@v4
+      with:
+        submodules: recursive
+        fetch-depth: 0
     - uses: actions/cache@v4
       with:
         path: |
@@ -44,6 +47,9 @@ jobs:
     runs-on: ubuntu-latest
     steps:
     - uses: actions/checkout@v4
+      with:
+        submodules: recursive
+        fetch-depth: 0
     - uses: taiki-e/install-action@nextest
     - name: Install protobuf compiler
       run: |
@@ -61,6 +67,9 @@ jobs:
     runs-on: ubuntu-latest
     steps:
     - uses: actions/checkout@v4
+      with:
+        submodules: recursive
+        fetch-depth: 0
     - name: Install protobuf compiler
       run: |
         sudo apt-get update
@@ -81,6 +90,9 @@ jobs:
     runs-on: ubuntu-latest
     steps:
     - uses: actions/checkout@v4
+      with:
+        submodules: recursive
+        fetch-depth: 0
     - uses: docker/setup-buildx-action@v3
     - name: Install Just
       run: |
@@ -94,6 +106,9 @@ jobs:
     timeout-minutes: 25
     steps:
     - uses: actions/checkout@v4
+      with:
+        submodules: recursive
+        fetch-depth: 0
     - name: Install protobuf compiler
       run: |
         sudo apt-get update

.github/workflows/push-docker.yml

@@ -13,6 +13,9 @@ jobs:
       tag: ${{ steps.set-tag.outputs.tag }}
     steps:
     - uses: actions/checkout@v4
+      with:
+        submodules: recursive
+        fetch-depth: 0
     - uses: docker/setup-buildx-action@v3
     - name: Login to Github Container Repo
       uses: docker/login-action@v3
@@ -42,6 +45,6 @@ jobs:
       uses: docker/build-push-action@v6
       with:
         push: true
-        platforms: linux/amd64
+        platforms: linux/amd64,linux/arm64
         file: ./docker/timeboost.Dockerfile
         tags: ghcr.io/espressosystems/timeboost:${{ env.TAG }}

.gitmodules

@@ -0,0 +1,3 @@
+[submodule "timeboost-proto/protos"]
+	path = timeboost-proto/protos
+	url = https://github.com/EspressoSystems/timeboost-proto.git

Cargo.toml

@@ -3,18 +3,19 @@ members = [
     "cliquenet",
     "metrics",
     "multisig",
+    "robusta",
     "sailfish",
     "sailfish-consensus",
     "sailfish-rbc",
     "sailfish-types",
     "tests",
     "timeboost",
     "timeboost-builder",
-    "timeboost-sequencer",
     "timeboost-crypto",
+    "timeboost-proto",
+    "timeboost-sequencer",
     "timeboost-types",
     "timeboost-utils",
-    "timeboost-proto",
     "yapper",
 ]
 resolver = "2"
@@ -24,11 +25,6 @@ version = "0.1.0"
 edition = "2024"
 rust-version = "1.85.0"
 
-[profile.test]
-codegen-units = 16
-incremental = false
-opt-level = 3
-
 [workspace.dependencies]
 aes-gcm = { version = "0.10.3" }
 alloy-chains = "0.2.0"
@@ -41,12 +37,12 @@ alloy-signer-local = "1.0.5"
 anyhow = "1.0.89"
 arbitrary = "1.4.1"
 arbtest = "0.3.2"
+ark-bls12-381 = "0.5"
 ark-bn254 = "0.5"
 ark-ec = "0.5"
 ark-ff = "0.5"
 ark-poly = "0.5"
 ark-secp256k1 = "0.5"
-ark-bls12-381 = "0.5"
 ark-serialize = { version = "0.5", features = ["derive"] }
 ark-std = { version = "0.5", default-features = false }
 arrayvec = "0.7.6"
@@ -65,6 +61,7 @@ criterion = "0.6"
 crossbeam-queue = "0.3.11"
 data-encoding = "2.6.0"
 derive_builder = "0.20"
+derive_more = { version = "1.0.0", features = ["full"] }
 digest = "0.10"
 dyn-clone = "1.0.17"
 ed25519-compact = "2.1.1"
@@ -81,29 +78,40 @@ prost = "0.13.5"
 quickcheck = "1.0.3"
 rand = "0.9"
 rayon = "1.10"
+reqwest = { version = "0.12", features = ["json"] }
 secp256k1 = { version = "0.31.0", features = ["global-context", "hashes", "rand", "serde"] }
-reqwest = { version = "0.12" }
 serde = { version = "1", features = ["derive", "rc"] }
 serde_bytes = "0.11.15"
 serde_json = { version = "1.0" }
 serde_with = "3.12.0"
 sha2 = { version = "0.10", default-features = false }
 sha3 = "0.10.8"
+smallvec = "1.15.1"
 snow = "0.9.6"
 spongefish = { git = "https://github.com/arkworks-rs/spongefish.git", rev = "e9f7031", features = [
     "arkworks-algebra",
 ] }
 thiserror = "2.0"
 tide-disco = "0.9.3"
-smallvec = "1.15.1"
 tokio = { version = "1", default-features = false, features = ["full"] }
 tokio-stream = "0.1.17"
+tokio-tungstenite = { version = "0.27.0", features = ["rustls-tls-webpki-roots", "url"] }
 tokio-util = "0.7.15"
 toml = "0.8.19"
 tonic = "0.13.1"
 tonic-build = { version = "0.13.1", features = ["prost"] }
 tracing = "0.1"
 tracing-subscriber = { version = "0.3.18", features = ["env-filter", "json"] }
 turmoil = "0.6.4"
+url = "2.5.4"
 vbs = "0.1"
 zeroize = { version = "1.8", features = ["zeroize_derive"] }
+
+espresso-types = { git = "https://github.com/EspressoSystems/espresso-network.git" }
+hotshot-query-service = { git = "https://github.com/EspressoSystems/espresso-network.git" }
+hotshot-types = { git = "https://github.com/EspressoSystems/espresso-network.git" }
+
+[profile.test]
+codegen-units = 16
+incremental = false
+opt-level = 3

docker/timeboost.Dockerfile

@@ -12,6 +12,8 @@ FROM debian:bullseye-slim
 
 WORKDIR /app
 
+RUN apt update && apt-get install -y libcurl4
+
 # Create non-root user and group
 RUN groupadd -r appgroup && useradd -r -g appgroup timeboostuser
 

robusta/Cargo.toml

@@ -0,0 +1,27 @@
+[package]
+name = "robusta"
+description = "espresso client"
+version.workspace = true
+edition.workspace = true
+rust-version.workspace = true
+
+[dependencies]
+bincode = { workspace = true }
+bon = { workspace = true }
+data-encoding = { workspace = true }
+espresso-types = { workspace = true }
+futures = { workspace = true }
+hotshot-query-service = { workspace = true }
+hotshot-types = { workspace = true }
+reqwest = { workspace = true }
+serde = { workspace = true }
+serde_json = { workspace = true }
+thiserror = { workspace = true }
+timeboost-types = { path = "../timeboost-types" }
+tokio = { workspace = true }
+tokio-tungstenite = { workspace = true }
+tracing = { workspace = true }
+url = { workspace = true }
+
+[dev-dependencies]
+tracing-subscriber = { workspace = true }

robusta/src/config.rs

@@ -0,0 +1,35 @@
+use std::{iter::repeat, time::Duration};
+
+use bon::Builder;
+use url::{ParseError, Url};
+
+const NUM_DELAYS: usize = 5;
+
+#[derive(Debug, Clone, Builder)]
+pub struct Config {
+    /// Espresso network base URL.
+    #[builder(with = |s: &str| -> Result<_, ParseError> { Url::parse(s) })]
+    pub(crate) base_url: Url,
+
+    /// Espresso network websocket base URL.
+    #[builder(with = |s: &str| -> Result<_, ParseError> { Url::parse(s) })]
+    pub(crate) wss_base_url: Url,
+
+    #[builder(default = 3)]
+    pub(crate) max_redirects: usize,
+
+    /// The sequence of delays between successive requests.
+    ///
+    /// The last value is repeated forever.
+    #[builder(default = [1, 3, 5, 10, 15])]
+    pub(crate) delays: [u8; NUM_DELAYS],
+}
+
+impl Config {
+    pub fn delay_iter(&self) -> impl Iterator<Item = Duration> + use<> {
+        self.delays
+            .into_iter()
+            .chain(repeat(self.delays[NUM_DELAYS - 1]))
+            .map(|n| Duration::from_secs(n.into()))
+    }
+}