Fix panic when websocket endpoint is not available

2 files changed, 3 insertions, 3 deletions

diff --git a/src/bin/rbw-agent/actions.rs b/src/bin/rbw-agent/actions.rs
index cc363dd..5ee23d9 100644
--- a/src/bin/rbw-agent/actions.rs
+++ b/src/bin/rbw-agent/actions.rs
@@ -205,7 +205,7 @@ pub async fn login(
         }
     }
 
-    subscribe_to_notifications(state.clone()).await.expect("could not subscribe");
+    let _ = subscribe_to_notifications(state.clone()).await;
 
     respond_ack(sock).await?;
 
@@ -669,7 +669,7 @@ pub async fn subscribe_to_notifications(state: std::sync::Arc<tokio::sync::RwLoc
 
     let mut websocket_url = config.base_url.clone().expect("config is missing base url").replace("https://", "wss://") + "/notifications/hub?access_token=";
     websocket_url = websocket_url + &access_token;
-    
+
     let mut state = state.write().await;
     let err = state.notifications_handler.connect(websocket_url).await.err();
     
diff --git a/src/bin/rbw-agent/agent.rs b/src/bin/rbw-agent/agent.rs
index c025880..0d672ee 100644
--- a/src/bin/rbw-agent/agent.rs
+++ b/src/bin/rbw-agent/agent.rs
@@ -78,7 +78,7 @@ impl Agent {
         self,
         listener: tokio::net::UnixListener,
     ) -> anyhow::Result<()> {
-        crate::actions::subscribe_to_notifications(self.state.clone()).await.expect("could not subscribe");
+        let _ = crate::actions::subscribe_to_notifications(self.state.clone()).await;
 
         enum Event {
             Request(std::io::Result<tokio::net::UnixStream>),