From bf7f4d5381203d5c27b2811d62c5b1781533aa2b Mon Sep 17 00:00:00 2001 From: DanConwayDev Date: Wed, 19 Nov 2025 17:01:36 +0000 Subject: fix some clippy fmt warnings --- src/http/websocket.rs | 24 ++++++++++++------------ 1 file changed, 12 insertions(+), 12 deletions(-) (limited to 'src/http/websocket.rs') diff --git a/src/http/websocket.rs b/src/http/websocket.rs index 7af847a..0171013 100644 --- a/src/http/websocket.rs +++ b/src/http/websocket.rs @@ -1,8 +1,7 @@ /// WebSocket Handler -/// +/// /// Handles WebSocket upgrade requests and passes connections to the Nostr relay. - -use actix_web::{web, HttpRequest, HttpResponse, Result, Error}; +use actix_web::{web, Error, HttpRequest, HttpResponse, Result}; use actix_ws::Message; use futures_util::StreamExt; use nostr_relay_builder::LocalRelay; @@ -14,19 +13,20 @@ pub async fn handle( relay: web::Data, ) -> Result { let (response, mut session, mut msg_stream) = actix_ws::handle(&req, stream)?; - - let peer_addr = req.peer_addr() + + let peer_addr = req + .peer_addr() .unwrap_or_else(|| "0.0.0.0:0".parse().unwrap()); - + tracing::debug!("WebSocket connection from {}", peer_addr); - + // Spawn task to handle the WebSocket connection // TODO: Will use relay.take_connection() for full Nostr relay integration let _relay = relay.get_ref().clone(); actix_web::rt::spawn(async move { // Create a channel to communicate between actix-ws and relay let (tx, mut rx) = tokio::sync::mpsc::unbounded_channel(); - + // Spawn task to send messages from relay to client let mut session_clone = session.clone(); actix_web::rt::spawn(async move { @@ -36,7 +36,7 @@ pub async fn handle( } } }); - + // Handle incoming messages from client while let Some(Ok(msg)) = msg_stream.next().await { match msg { @@ -65,9 +65,9 @@ pub async fn handle( Message::Nop => {} } } - + tracing::debug!("WebSocket connection closed for {}", peer_addr); }); - + Ok(response) -} \ No newline at end of file +} -- cgit v1.2.3