From dc0510070e65e124187f7b81b45801a7fa3a3274 Mon Sep 17 00:00:00 2001 From: Bulat Kurbanov Date: Thu, 8 Aug 2024 20:09:32 +0200 Subject: [PATCH] Fix --- src/twitch_handler/mod.rs | 22 ++++++++++------------ 1 file changed, 10 insertions(+), 12 deletions(-) diff --git a/src/twitch_handler/mod.rs b/src/twitch_handler/mod.rs index 4fa657a..33f2ca1 100644 --- a/src/twitch_handler/mod.rs +++ b/src/twitch_handler/mod.rs @@ -100,23 +100,21 @@ impl TwitchBot { } }; - let mut eventsub_client = client.connect_eventsub( - vec![ - ("stream.online".to_string(), "1".to_string()), - ("stream.offline".to_string(), "1".to_string()), - ("channel.update".to_string(), "2".to_string()) - ], - config::CONFIG.twitch_channel_id.clone() - ).await.unwrap(); - println!("Connected to Twitch EventSub..."); - - // let (_chat_client, mut chat_stream) = client.connect_chat(vec!["hafmc".to_string()]).await.unwrap(); - // println!("Connected to Twitch Chat..."); client.validate_token().await.unwrap(); loop { println!("Checking Twitch events..."); + let mut eventsub_client = client.connect_eventsub( + vec![ + ("stream.online".to_string(), "1".to_string()), + ("stream.offline".to_string(), "1".to_string()), + ("channel.update".to_string(), "2".to_string()) + ], + config::CONFIG.twitch_channel_id.clone() + ).await.unwrap(); + + if let Some(event) = eventsub_client.next().await { match event { eventsub::NotificationType::CustomRewardRedemptionAdd(_) => todo!(),