diff options
| author | DanConwayDev <DanConwayDev@protonmail.com> | 2025-11-19 17:01:36 +0000 |
|---|---|---|
| committer | DanConwayDev <DanConwayDev@protonmail.com> | 2025-11-19 17:01:36 +0000 |
| commit | bf7f4d5381203d5c27b2811d62c5b1781533aa2b (patch) | |
| tree | 26903bbf535d83abd7242370d8b6932eb80e3389 /src/http/websocket.rs | |
| parent | fa065ad128882755f2a988d6203b59a2ab5e38ff (diff) | |
fix some clippy fmt warnings
Diffstat (limited to 'src/http/websocket.rs')
| -rw-r--r-- | src/http/websocket.rs | 24 |
1 files changed, 12 insertions, 12 deletions
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 @@ | |||
| 1 | /// WebSocket Handler | 1 | /// WebSocket Handler |
| 2 | /// | 2 | /// |
| 3 | /// Handles WebSocket upgrade requests and passes connections to the Nostr relay. | 3 | /// Handles WebSocket upgrade requests and passes connections to the Nostr relay. |
| 4 | 4 | use actix_web::{web, Error, HttpRequest, HttpResponse, Result}; | |
| 5 | use actix_web::{web, HttpRequest, HttpResponse, Result, Error}; | ||
| 6 | use actix_ws::Message; | 5 | use actix_ws::Message; |
| 7 | use futures_util::StreamExt; | 6 | use futures_util::StreamExt; |
| 8 | use nostr_relay_builder::LocalRelay; | 7 | use nostr_relay_builder::LocalRelay; |
| @@ -14,19 +13,20 @@ pub async fn handle( | |||
| 14 | relay: web::Data<LocalRelay>, | 13 | relay: web::Data<LocalRelay>, |
| 15 | ) -> Result<HttpResponse, Error> { | 14 | ) -> Result<HttpResponse, Error> { |
| 16 | let (response, mut session, mut msg_stream) = actix_ws::handle(&req, stream)?; | 15 | let (response, mut session, mut msg_stream) = actix_ws::handle(&req, stream)?; |
| 17 | 16 | ||
| 18 | let peer_addr = req.peer_addr() | 17 | let peer_addr = req |
| 18 | .peer_addr() | ||
| 19 | .unwrap_or_else(|| "0.0.0.0:0".parse().unwrap()); | 19 | .unwrap_or_else(|| "0.0.0.0:0".parse().unwrap()); |
| 20 | 20 | ||
| 21 | tracing::debug!("WebSocket connection from {}", peer_addr); | 21 | tracing::debug!("WebSocket connection from {}", peer_addr); |
| 22 | 22 | ||
| 23 | // Spawn task to handle the WebSocket connection | 23 | // Spawn task to handle the WebSocket connection |
| 24 | // TODO: Will use relay.take_connection() for full Nostr relay integration | 24 | // TODO: Will use relay.take_connection() for full Nostr relay integration |
| 25 | let _relay = relay.get_ref().clone(); | 25 | let _relay = relay.get_ref().clone(); |
| 26 | actix_web::rt::spawn(async move { | 26 | actix_web::rt::spawn(async move { |
| 27 | // Create a channel to communicate between actix-ws and relay | 27 | // Create a channel to communicate between actix-ws and relay |
| 28 | let (tx, mut rx) = tokio::sync::mpsc::unbounded_channel(); | 28 | let (tx, mut rx) = tokio::sync::mpsc::unbounded_channel(); |
| 29 | 29 | ||
| 30 | // Spawn task to send messages from relay to client | 30 | // Spawn task to send messages from relay to client |
| 31 | let mut session_clone = session.clone(); | 31 | let mut session_clone = session.clone(); |
| 32 | actix_web::rt::spawn(async move { | 32 | actix_web::rt::spawn(async move { |
| @@ -36,7 +36,7 @@ pub async fn handle( | |||
| 36 | } | 36 | } |
| 37 | } | 37 | } |
| 38 | }); | 38 | }); |
| 39 | 39 | ||
| 40 | // Handle incoming messages from client | 40 | // Handle incoming messages from client |
| 41 | while let Some(Ok(msg)) = msg_stream.next().await { | 41 | while let Some(Ok(msg)) = msg_stream.next().await { |
| 42 | match msg { | 42 | match msg { |
| @@ -65,9 +65,9 @@ pub async fn handle( | |||
| 65 | Message::Nop => {} | 65 | Message::Nop => {} |
| 66 | } | 66 | } |
| 67 | } | 67 | } |
| 68 | 68 | ||
| 69 | tracing::debug!("WebSocket connection closed for {}", peer_addr); | 69 | tracing::debug!("WebSocket connection closed for {}", peer_addr); |
| 70 | }); | 70 | }); |
| 71 | 71 | ||
| 72 | Ok(response) | 72 | Ok(response) |
| 73 | } \ No newline at end of file | 73 | } |