feat: improve error handling for channel watching and drop retrieval

Author: this-is-really

src/main.rs

@@ -401,7 +401,14 @@ async fn watch_sync (clients: Vec<Arc<TwitchClient>>, rx: Receiver<Channel>, not
             let mut old_stream_name = String::new();
             let mut now_watching_stream: Option<(String, String, String)> = None;
 
-            let mut watching = rx.recv().await.unwrap();
+            let mut watching = match rx.recv().await {
+                Ok(w) => w,
+                Err(e) => {
+                    tracing::debug!("{e}");
+                    tracing::error!("Failed to receive initial channel to watch. Watch synchronization will not start for this client");
+                    return ;
+                }  
+            };
             loop {
                 match rx.try_recv() {
                     Ok(channel) => watching = channel,
@@ -478,7 +485,10 @@ async fn drop_sync(clients: Vec<Arc<TwitchClient>>, tx: Sender<String>, cache_pa
             bar.set_message("Initialization...");
             bar.enable_steady_tick(Duration::from_millis(500));
 
-            let mut watching = rx_watch.recv().await.unwrap();
+            let mut watching = match rx_watch.recv().await {
+                Ok(channel) => channel,
+                Err(_) => return,
+            };
             let mut last_drop_id = String::new();
 
             loop {

src/stream.rs

@@ -42,7 +42,13 @@ pub async fn filter_streams (client: Arc<TwitchClient>, campaigns_arc: Arc<Mutex
                         if count >= MAX_TOPICS {
                             break;
                         }
-                        let avaiable_drops = retry!(client.get_available_drops_for_channel(&channel.id));
+                        let avaiable_drops = match retry_backup(|| client.get_available_drops_for_channel(&channel.id)).await {
+                            Ok(drops) => drops,
+                            Err(e) => {
+                                tracing::error!("{e}");
+                                continue;
+                            }
+                        };
                         if avaiable_drops.viewerDropCampaigns.is_some() {
                             video_vec.insert(Channel { channel_id: channel.id, channel_login: channel.name });
                             count += 1
@@ -65,7 +71,13 @@ pub async fn filter_streams (client: Arc<TwitchClient>, campaigns_arc: Arc<Mutex
                         break;
                     }
                     if stream_info.stream.is_some() {
-                        let available_drops = retry!(client.get_available_drops_for_channel(&channel.broadcaster.id));
+                        let available_drops = match retry_backup(|| client.get_available_drops_for_channel(&channel.broadcaster.id)).await {
+                            Ok(drops) => drops,
+                            Err(e) => {
+                                tracing::error!("{e}");
+                                continue;
+                            }
+                        };
                         if available_drops.viewerDropCampaigns.is_some() {
                             video_vec.insert(Channel { channel_id: channel.broadcaster.id, channel_login: channel.broadcaster.login });
                             count += 1