Fix WebSocket benchmark compilation errors and remove unused function

- Fix tungstenite v0.27 API compatibility by adding .into() for Message::Text
- Remove unused ws_connection_timeout function to eliminate dead code warning
- All 6 compilation errors in websocket_bench.rs resolved
- All benchmarks now compile successfully

Co-authored-by: 0xrinegade <[email protected]>

Author: Copilot

benches/websocket_bench.rs

@@ -78,7 +78,7 @@ fn bench_websocket_subscriptions(c: &mut Criterion) {
                 let (mut ws_stream, _) = connect_websocket(port).await.expect("Failed to connect");
 
                 // Send subscription request
-                let message = Message::Text(req.to_string());
+                let message = Message::Text(req.to_string().into());
                 ws_stream.send(message).await.expect("Failed to send message");
 
                 // Wait for response
@@ -129,7 +129,7 @@ fn bench_websocket_unsubscribe(c: &mut Criterion) {
                 let (mut ws_stream, _) = connect_websocket(port).await.expect("Failed to connect");
 
                 // Send unsubscribe request
-                let message = Message::Text(req.to_string());
+                let message = Message::Text(req.to_string().into());
                 ws_stream.send(message).await.expect("Failed to send message");
 
                 // Wait for response
@@ -170,7 +170,7 @@ fn bench_websocket_throughput(c: &mut Criterion) {
                 for i in 0..count {
                     let mut req = request.clone();
                     req["id"] = json!(i + 1);
-                    let message = Message::Text(req.to_string());
+                    let message = Message::Text(req.to_string().into());
                     ws_stream.send(message).await.expect("Failed to send message");
                 }
 
@@ -215,7 +215,7 @@ fn bench_concurrent_connections(c: &mut Criterion) {
                                 "params": {}
                             });
 
-                            let message = Message::Text(request.to_string());
+                            let message = Message::Text(request.to_string().into());
                             ws_stream.send(message).await.expect("Failed to send message");
 
                             // Wait for response
@@ -259,7 +259,7 @@ fn bench_websocket_error_handling(c: &mut Criterion) {
         b.to_async(&rt).iter(|| async {
             let (mut ws_stream, _) = connect_websocket(port).await.expect("Failed to connect");
 
-            let message = Message::Text(invalid_method_request.to_string());
+            let message = Message::Text(invalid_method_request.to_string().into());
             ws_stream.send(message).await.expect("Failed to send message");
 
             // Wait for error response
@@ -276,7 +276,7 @@ fn bench_websocket_error_handling(c: &mut Criterion) {
         b.to_async(&rt).iter(|| async {
             let (mut ws_stream, _) = connect_websocket(port).await.expect("Failed to connect");
 
-            let message = Message::Text("{invalid json".to_string());
+            let message = Message::Text("{invalid json".to_string().into());
             ws_stream.send(message).await.expect("Failed to send message");
 
             // Wait for error response

src/websocket_server.rs

@@ -41,11 +41,6 @@ type SubscriptionManager = Arc<DashMap<u64, Subscription>>;
 /// Global subscription counter
 static SUBSCRIPTION_COUNTER: std::sync::atomic::AtomicU64 = std::sync::atomic::AtomicU64::new(1);
 
-/// WebSocket connection timeout
-fn ws_connection_timeout(config: &crate::config::Config) -> Duration {
-    Duration::from_secs(config.timeouts.websocket_connection_seconds)
-}
-
 /// WebSocket message timeout
 fn ws_message_timeout(config: &crate::config::Config) -> Duration {
     Duration::from_secs(config.timeouts.websocket_message_seconds)