feat: update torii client

crates/torii/client/src/client/mod.rs

@@ -101,9 +101,9 @@ impl Client {
         })
     }
 
-    /// Waits for the relay connection to be established.
-    pub async fn wait_for_connection(&mut self) -> Result<(), Error> {
-        self.relay_client.command_sender.wait_for_connection().await.map_err(Error::RelayClient)
+    /// Waits for the relay to be ready and listening for messages.
+    pub async fn wait_for_relay(&mut self) -> Result<(), Error> {
+        self.relay_client.command_sender.wait_for_relay().await.map_err(Error::RelayClient)
     }
 
     /// Subscribes to a topic.

crates/torii/libp2p/src/client/mod.rs

@@ -4,7 +4,7 @@ use std::time::Duration;
 use futures::channel::mpsc::{UnboundedReceiver, UnboundedSender};
 use futures::channel::oneshot;
 use futures::lock::Mutex;
-use futures::{select, FutureExt, StreamExt};
+use futures::{select, StreamExt};
 use libp2p::gossipsub::{self, IdentTopic, MessageId, TopicHash};
 use libp2p::swarm::{NetworkBehaviour, Swarm, SwarmEvent};
 use libp2p::{identify, identity, ping, Multiaddr, PeerId};

crates/torii/libp2p/src/server/mod.rs

@@ -190,7 +190,10 @@ impl Relay {
                                 "Subscribed to topic"
                             );
                         }
-                        ServerEvent::Gossipsub(gossipsub::Event::Unsubscribed { peer_id, topic }) => {
+                        ServerEvent::Gossipsub(gossipsub::Event::Unsubscribed {
+                            peer_id,
+                            topic,
+                        }) => {
                             info!(
                                 target: "torii::relay::server::gossipsub",
                                 peer_id = %peer_id,

crates/torii/libp2p/src/tests.rs

@@ -73,7 +73,7 @@ mod test {
         // Make sure the cert hash is correct - corresponding to the cert in the relay server
         let mut client = RelayClient::new(
             "/ip4/127.0.0.1/udp/9091/webrtc-direct/certhash/\
-            uEiCAoeHQh49fCHDolECesXO0CPR7fpz0sv0PWVaIahzT4g"
+             uEiCAoeHQh49fCHDolECesXO0CPR7fpz0sv0PWVaIahzT4g"
                 .to_string(),
         )?;