diff options
author | Bernd Schoolmann <mail@quexten.com> | 2023-04-17 02:59:23 +0200 |
---|---|---|
committer | Bernd Schoolmann <mail@quexten.com> | 2023-04-17 02:59:23 +0200 |
commit | e49ca91ea1607a39257fc28b58598482eff4338a (patch) | |
tree | d004986a2e63277837c8d4e6d70bf751ce3e66a1 /src | |
parent | 8fbed0f3fbcac726fb73f2cd49cb7e4d36091c47 (diff) | |
download | rbw-e49ca91ea1607a39257fc28b58598482eff4338a.tar.gz rbw-e49ca91ea1607a39257fc28b58598482eff4338a.zip |
Fix panic when websocket endpoint is not available
Diffstat (limited to 'src')
-rw-r--r-- | src/bin/rbw-agent/actions.rs | 4 | ||||
-rw-r--r-- | src/bin/rbw-agent/agent.rs | 2 |
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>), |