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:
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"))?;