feat(repo): Added web-utils crate and added telemetry to all svc (#373)

Cargo.toml

@@ -65,6 +65,7 @@ thiserror = "2.0"
 
 fuel-streams = { version = "0.0.16", path = "crates/fuel-streams" }
 fuel-data-parser = { version = "0.0.16", path = "crates/fuel-data-parser" }
+fuel-web-utils = { version = "0.0.16", path = "crates/fuel-web-utils" }
 fuel-streams-core = { version = "0.0.16", path = "crates/fuel-streams-core" }
 fuel-streams-macros = { version = "0.0.16", path = "crates/fuel-streams-macros" }
 fuel-streams-nats = { version = "0.0.16", path = "crates/fuel-streams-nats" }

Makefile

@@ -230,9 +230,11 @@ run-publisher-testnet-profiling:
 
 run-consumer: NATS_CORE_URL="localhost:4222"
 run-consumer: NATS_PUBLISHER_URL="localhost:4223"
+run-consumer: PORT="9003"
 run-consumer:
 	cargo run --package sv-consumer --profile dev -- \
 		--nats-core-url $(NATS_CORE_URL) \
+		--port $(PORT) \
 		--nats-publisher-url $(NATS_PUBLISHER_URL)
 
 # ------------------------------------------------------------
@@ -241,9 +243,11 @@ run-consumer:
 
 run-consumer: NATS_URL="localhost:4222"
 run-consumer: NATS_PUBLISHER_URL="localhost:4333"
+run-consumer: PORT="9003"
 run-consumer:
 	cargo run --package sv-consumer --profile dev -- \
 		--nats-url $(NATS_URL) \
+		--port $(PORT) \
 		--nats-publisher-url $(NATS_PUBLISHER_URL)
 
 # ------------------------------------------------------------

crates/fuel-web-utils/Cargo.toml

@@ -0,0 +1,55 @@
+[package]
+name = "fuel-web-utils"
+description = "Fuel library for web utils"
+authors = { workspace = true }
+keywords = { workspace = true }
+edition = { workspace = true }
+homepage = { workspace = true }
+license = { workspace = true }
+repository = { workspace = true }
+version = { workspace = true }
+rust-version = { workspace = true }
+
+[dependencies]
+actix-cors = { workspace = true }
+actix-server = { workspace = true }
+actix-service = "2.0.2"
+actix-web = { workspace = true }
+anyhow = { workspace = true }
+async-trait = { workspace = true }
+chrono = { workspace = true }
+derive_more = { version = "1.0", features = ["full"] }
+displaydoc = { workspace = true }
+dotenvy = { workspace = true }
+elasticsearch = "8.15.0-alpha.1"
+fuel-data-parser = { workspace = true }
+fuel-streams-nats = { workspace = true, features = ["test-helpers"] }
+futures = { workspace = true }
+futures-util = { workspace = true }
+jsonwebtoken = "9.3.0"
+num_cpus = { workspace = true }
+parking_lot = { version = "0.12", features = ["serde"] }
+prometheus = { version = "0.13", features = ["process"] }
+rand = { workspace = true }
+rust_decimal = { version = "1.13" }
+serde = { workspace = true }
+serde_json = { workspace = true }
+serde_prometheus = { version = "0.2" }
+sysinfo = { version = "0.29" }
+thiserror = "2.0"
+time = { version = "0.3", features = ["serde"] }
+tokio = { workspace = true }
+tokio-util = "0.7.13"
+tracing = { workspace = true }
+tracing-actix-web = { workspace = true }
+url = "2.5"
+urlencoding = "2.1"
+uuid = { version = "1.11.0", features = ["serde", "v4"] }
+
+# in an individual package Cargo.toml
+[package.metadata.cargo-machete]
+ignored = ["fuel-data-parser"]
+
+[features]
+default = []
+test-helpers = []

crates/fuel-web-utils/src/lib.rs

@@ -0,0 +1,15 @@
+pub mod server;
+pub mod shutdown;
+pub mod telemetry;
+
+use std::sync::LazyLock;
+
+pub static MAX_WORKERS: LazyLock<usize> = LazyLock::new(|| {
+    let available_cpus = num_cpus::get();
+    let default_threads = 2 * available_cpus;
+
+    dotenvy::var("MAX_WORKERS")
+        .ok()
+        .and_then(|val| val.parse().ok())
+        .unwrap_or(default_threads)
+});