feat(testing): Task Sender / Stress Tester

Makefile

@@ -250,6 +250,19 @@ batcher/target/release/aligned:
 RPC_URL=http://localhost:8545
 NETWORK=devnet # devnet | holesky-stage | holesky
 
+# Infinite stream of burst of 10 proofs
+batcher_send_infinite_burst:
+	@cd batcher/aligned-task-sender && cargo run --release 
+
+# Infinite stream of one proof
+batcher_send_infinite_stream:
+	@cd batcher/aligned-task-sender && cargo run --release -- --burst-size 1
+
+# Infinite connections
+# To test: `make batcher_test_connection NUM_SENDERS=10000`, with 0 proofs sent returns `Error 101` when tested locally
+batcher_test_connections:
+	@cd batcher/aligned-task-sender && cargo run --release -- --num-senders $(NUM_SENDERS) --burst-size 1
+
 batcher_send_sp1_task:
 	@echo "Sending SP1 fibonacci task to Batcher..."
 	@cd batcher/aligned/ && cargo run --release -- submit \

batcher/Cargo.toml

@@ -1,7 +1,3 @@
 [workspace]
-members = [
-    "aligned-batcher",
-    "aligned-sdk",
-    "aligned"
-]
+members = ["aligned-batcher", "aligned-sdk", "aligned", "aligned-task-sender"]
 resolver = "2"

batcher/aligned-task-sender/Cargo.toml

@@ -0,0 +1,35 @@
+
+[package]
+name = "task-sender"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+serde = { version = "1.0.201", features = ["derive"] }
+serde_json = "1.0.117"
+futures-util = "0.3.30"
+tokio = { version = "1.40.0", features = [
+    "io-std",
+    "time",
+    "macros",
+    "rt",
+    "rt-multi-thread",
+    "sync",
+    "process",
+    "fs",
+] }
+tokio-tungstenite = { version = "0.24.0", features = [
+    "rustls-tls-webpki-roots",
+    "native-tls",
+] }
+url = "2.5.0"
+log = "0.4.21"
+env_logger = "0.11.3"
+clap = { version = "4.5.4", features = ["derive"] }
+ethers = { tag = "v2.0.15-fix-reconnections", features = [
+    "ws",
+    "rustls",
+], git = "https://github.com/yetanotherco/ethers-rs.git" }
+aligned-sdk = { path = "../aligned-sdk" }
+rpassword = "7.3.1"
+sha3 = { version = "0.10.8" }

batcher/aligned-task-sender/rust-toolchain

@@ -0,0 +1,3 @@
+[toolchain]
+channel = "nightly-2024-04-17"
+components = ["llvm-tools", "rustc-dev"]