stop trying to reconnect to notifications so aggressively1.8.0

it adds a bunch of latency to every command otherwise

1 files changed, 13 insertions, 18 deletions

diff --git a/src/bin/rbw-agent/agent.rs b/src/bin/rbw-agent/agent.rs
index fe46e3b..131bab2 100644
--- a/src/bin/rbw-agent/agent.rs
+++ b/src/bin/rbw-agent/agent.rs
@@ -156,26 +156,21 @@ impl Agent {
                     self.state.lock().await.clear();
                 }
                 Event::Sync(()) => {
-                    // this could fail if we aren't logged in, but we don't
-                    // care about that
                     let state = self.state.clone();
                     tokio::spawn(async move {
-                        let result = crate::actions::sync(None).await;
-                        if let Err(e) = result {
-                            eprintln!("failed to sync: {e:#}");
-                        } else if !state
-                            .lock()
-                            .await
-                            .notifications_handler
-                            .is_connected()
-                        {
-                            let err =
-                                crate::actions::subscribe_to_notifications(
-                                    state,
-                                )
-                                .await;
-                            if let Err(e) = err {
-                                eprintln!("failed to subscribe to notifications: {e:#}");
+                        // this could fail if we aren't logged in, but we
+                        // don't care about that
+                        match crate::actions::sync(None).await {
+                            Ok(()) => {
+                                if let Err(e) = crate::actions::subscribe_to_notifications(
+                                        state,
+                                    )
+                                    .await {
+                                    eprintln!("failed to subscribe to notifications: {e:#}");
+                                }
+                            }
+                            Err(e) => {
+                                eprintln!("failed to sync: {e:#}");
                             }
                         }
                     });