upleb.uk

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

summaryrefslogtreecommitdiff
path: root/test_utils/src/relay.rs
diff options
context:
space:
mode:
authorDanConwayDev <DanConwayDev@protonmail.com>2025-07-16 11:01:44 +0100
committerDanConwayDev <DanConwayDev@protonmail.com>2025-07-16 11:01:44 +0100
commit7704178c618f8ac455cd6b0582edb511a9e644c3 (patch)
tree775e425f0af2543eb12e4a4b1d4feb022611368f /test_utils/src/relay.rs
parent8cea674f58e806c22d2887cff5e6f76bc4dba0db (diff)
parentac53bca7e315848864ff9e51703720b5b466bc42 (diff)
Merge branch 'upgrade-dependancies'
Diffstat (limited to 'test_utils/src/relay.rs')
-rw-r--r--test_utils/src/relay.rs10
1 files changed, 6 insertions, 4 deletions
diff --git a/test_utils/src/relay.rs b/test_utils/src/relay.rs
index e820651..b14f532 100644
--- a/test_utils/src/relay.rs
+++ b/test_utils/src/relay.rs
@@ -161,9 +161,11 @@ impl<'a> Relay<'a> {
161 if let Some(listner) = self.req_listener { 161 if let Some(listner) = self.req_listener {
162 listner(self, client_id, subscription_id, vec![filter.clone()])?; 162 listner(self, client_id, subscription_id, vec![filter.clone()])?;
163 } else { 163 } else {
164 self.respond_standard_req(client_id, &subscription_id, &[ 164 self.respond_standard_req(
165 filter.clone() 165 client_id,
166 ])?; 166 &subscription_id,
167 &[filter.clone()],
168 )?;
167 // self.respond_eose(client_id, subscription_id)?; 169 // self.respond_eose(client_id, subscription_id)?;
168 } 170 }
169 // respond with events 171 // respond with events
@@ -186,7 +188,7 @@ impl<'a> Relay<'a> {
186 188
187pub fn shutdown_relay(port: u64) -> Result<()> { 189pub fn shutdown_relay(port: u64) -> Result<()> {
188 let mut counter = 0; 190 let mut counter = 0;
189 while let Ok((mut socket, _)) = tungstenite::connect(format!("ws://localhost:{}", port)) { 191 while let Ok((mut socket, _)) = tungstenite::connect(format!("ws://localhost:{port}")) {
190 counter += 1; 192 counter += 1;
191 if counter == 1 { 193 if counter == 1 {
192 socket.write(tungstenite::Message::text("shut me down"))?; 194 socket.write(tungstenite::Message::text("shut me down"))?;