upleb.uk

Public git repos — served from a NIP-34 GRASP relay at git.upleb.uk

summaryrefslogtreecommitdiff
path: root/src/http/websocket.rs
diff options
context:
space:
mode:
authorDanConwayDev <DanConwayDev@protonmail.com>2025-11-19 17:01:36 +0000
committerDanConwayDev <DanConwayDev@protonmail.com>2025-11-19 17:01:36 +0000
commitbf7f4d5381203d5c27b2811d62c5b1781533aa2b (patch)
tree26903bbf535d83abd7242370d8b6932eb80e3389 /src/http/websocket.rs
parentfa065ad128882755f2a988d6203b59a2ab5e38ff (diff)
fix some clippy fmt warnings
Diffstat (limited to 'src/http/websocket.rs')
-rw-r--r--src/http/websocket.rs24
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 4use actix_web::{web, Error, HttpRequest, HttpResponse, Result};
5use actix_web::{web, HttpRequest, HttpResponse, Result, Error};
6use actix_ws::Message; 5use actix_ws::Message;
7use futures_util::StreamExt; 6use futures_util::StreamExt;
8use nostr_relay_builder::LocalRelay; 7use 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}