From df62075040ff18859d9821c706a285818276c1ea Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?H=C3=A9ctor=20Ram=C3=B3n=20Jim=C3=A9nez?= <hector@hecrj.dev>
Date: Wed, 28 Feb 2024 17:16:37 +0100
Subject: [PATCH] Reconnect `Client` after disconnect in `iced_sentinel`

---
 sentinel/src/client.rs | 12 +++++++-----
 sentinel/src/lib.rs    |  2 +-
 2 files changed, 8 insertions(+), 6 deletions(-)

diff --git a/sentinel/src/client.rs b/sentinel/src/client.rs
index 8f7bfd65..3a7b38c8 100644
--- a/sentinel/src/client.rs
+++ b/sentinel/src/client.rs
@@ -46,18 +46,20 @@ async fn run(mut receiver: mpsc::Receiver<Input>) {
                     &mut stream,
                     Input::Connected {
                         at: SystemTime::now(),
-                        version,
+                        version: version.clone(),
                     },
                 )
                 .await;
 
                 while let Some(input) = receiver.recv().await {
-                    if send(&mut stream, input).await.is_err() {
-                        break;
+                    match send(&mut stream, input).await {
+                        Ok(()) => {}
+                        Err(error) => {
+                            log::warn!("Error sending message to sentinel server: {error}");
+                            break;
+                        }
                     }
                 }
-
-                break;
             }
             Err(_) => {
                 time::sleep(time::Duration::from_secs(2)).await;
diff --git a/sentinel/src/lib.rs b/sentinel/src/lib.rs
index 24fdc3c0..49b2f1b9 100644
--- a/sentinel/src/lib.rs
+++ b/sentinel/src/lib.rs
@@ -75,7 +75,7 @@ pub fn run() -> impl Stream<Item = Event> {
             },
             State::Connected(stream) => match receive(stream).await {
                 Ok((stream, input)) => {
-                    let event = match dbg!(input) {
+                    let event = match input {
                         Input::Connected { at, version } => {
                             Event::Connected { at, version }
                         }