feat(acp-nats-ws): add WebSocket-to-NATS bridge binary crate

Introduce `acp-nats-ws`, a WebSocket endpoint that bridges ACP
JSON-RPC messages to NATS for browser-based and remote clients.

- Multiple concurrent WebSocket connections, each with its own ACP
  session on a dedicated single-threaded LocalSet
- Duplex-pipe adapter: WS text frames ↔ newline-delimited JSON-RPC
  byte stream consumed by AgentSideConnection
- Inbound frame sanitization: strip trailing CR/LF, validate UTF-8
  on binary frames
- Graceful shutdown: SIGINT/SIGTERM → broadcast → per-connection
  drain → join connection thread before telemetry teardown
- Extract shared `acp-telemetry` crate from duplicated
  telemetry/signal modules in acp-nats-stdio and acp-nats-ws,
  parameterized by service name

Signed-off-by: Yordis Prieto <yordis.prieto@gmail.com>

Author: yordis

rsworkspace/Cargo.lock

@@ -5,19 +5,16 @@ edition = "2024"
 
 [dependencies]
 acp-nats = { path = "../acp-nats" }
+acp-telemetry = { path = "../acp-telemetry" }
 agent-client-protocol = "0.9.4"
 async-compat = "0.2.5"
 async-nats = "0.45.0"
 clap = { version = "4.5", features = ["derive", "env"] }
 opentelemetry = "0.31.0"
-opentelemetry-appender-tracing = "0.31.0"
-opentelemetry-otlp = { version = "0.31.0", features = ["http-json", "logs", "metrics", "reqwest-rustls"] }
-opentelemetry_sdk = { version = "0.31.0", features = ["rt-tokio", "logs", "metrics"] }
 trogon-std = { path = "../trogon-std" }
 tokio = { version = "1.49.0", features = ["rt-multi-thread", "macros", "signal", "io-std"] }
 tracing = "0.1.44"
-tracing-opentelemetry = "0.32.1"
-tracing-subscriber = { version = "0.3.22", features = ["env-filter", "fmt", "json"] }
 
 [dev-dependencies]
+tracing-subscriber = { version = "0.3.22", features = ["fmt"] }
 trogon-std = { path = "../trogon-std", features = ["test-support"] }

rsworkspace/crates/acp-nats-stdio/Cargo.toml

@@ -1,6 +1,4 @@
 mod config;
-mod signal;
-mod telemetry;
 
 use acp_nats::{StdJsonSerialize, agent::Bridge, client, nats};
 use agent_client_protocol::AgentSideConnection;
@@ -11,10 +9,12 @@ use trogon_std::env::SystemEnv;
 use trogon_std::fs::SystemFs;
 use trogon_std::time::SystemClock;
 
+const SERVICE_NAME: &str = "acp-nats-stdio";
+
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let config = config::base_config(&SystemEnv)?;
-    telemetry::init_logger(config.acp_prefix(), &SystemEnv, &SystemFs);
+    acp_telemetry::init_logger(SERVICE_NAME, config.acp_prefix(), &SystemEnv, &SystemFs);
     let config = config::apply_timeout_overrides(config, &SystemEnv);
 
     info!("ACP bridge starting");
@@ -32,7 +32,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         info!("ACP bridge stopped");
     }
 
-    telemetry::shutdown_otel();
+    acp_telemetry::shutdown_otel();
 
     result
 }
@@ -100,7 +100,7 @@ async fn run_bridge(
                 }
             }
         }
-        _ = signal::shutdown_signal() => {
+        _ = acp_telemetry::signal::shutdown_signal() => {
             info!("ACP bridge shutting down (signal received)");
             Ok(())
         }

rsworkspace/crates/acp-nats-stdio/src/main.rs

@@ -0,0 +1,23 @@
+[package]
+name = "acp-nats-ws"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+acp-nats = { path = "../acp-nats" }
+acp-telemetry = { path = "../acp-telemetry" }
+agent-client-protocol = "0.9.4"
+async-compat = "0.2.5"
+async-nats = "0.45.0"
+axum = { version = "0.8.8", features = ["ws"] }
+clap = { version = "4.5", features = ["derive", "env"] }
+futures-util = { version = "0.3", features = ["sink"] }
+opentelemetry = "0.31.0"
+tokio = { version = "1.49.0", features = ["rt-multi-thread", "macros", "signal", "net", "sync", "io-util"] }
+tower-http = { version = "0.6.8", features = ["trace"] }
+tracing = "0.1.44"
+trogon-std = { path = "../trogon-std" }
+
+[dev-dependencies]
+tracing-subscriber = { version = "0.3.22", features = ["fmt"] }
+trogon-std = { path = "../trogon-std", features = ["test-support"] }