kurbezz/discord-bot
1
0
Fork 0
mirror of https://github.com/kurbezz/discord-bot.git synced 2025-12-06 07:05:36 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
Bulat Kurbanov
2024-08-06 02:16:39 +02:00
parent 0d6b60acb2
commit 428b1b501a
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/twitch_handler/mod.rs
View File

@@ -2,12 +2,12 @@ pub mod eventsub;
pub mod helix; pub mod helix;
pub mod auth; pub mod auth;
use chrono::{format, DateTime, Utc}; use chrono::{DateTime, Utc};
use futures::StreamExt; use futures::StreamExt;
use async_trait::async_trait; use async_trait::async_trait;
use auth::Token; use auth::Token;
use crate::{config, notifiers::{discord::send_to_discord, telegram::send_to_telegram}}; use crate::{config, notifiers::discord::send_to_discord};
pub struct TokenStorage { pub struct TokenStorage {
@@ -48,7 +48,7 @@ pub struct TwitchBot {}
pub async fn notify_game_change(title: String, _old_game: String, new_game: String) { pub async fn notify_game_change(title: String, _old_game: String, new_game: String) {
let msg = format!("HafMC сменил игру на {} ({})!", new_game, title); let msg = format!("HafMC сменил игру на {} ({})! \nПрисоединяйся: https://twitch.tv/hafmc", new_game, title);
send_to_discord(&msg).await; send_to_discord(&msg).await;
// send_to_telegram(&msg).await; // send_to_telegram(&msg).await;
@@ -115,7 +115,7 @@ impl TwitchBot {
eventsub::NotificationType::StreamOffline(_) => {}, eventsub::NotificationType::StreamOffline(_) => {},
eventsub::NotificationType::ChannelUpdate(data) => { eventsub::NotificationType::ChannelUpdate(data) => {
if let Some(state) = current_state { if let Some(state) = current_state {
if state.game.to_lowercase().trim() != data.category_name.to_lowercase().trim() { if state.game != data.category_name {
notify_game_change( notify_game_change(
data.title.clone(), data.title.clone(),
state.game.clone(), state.game.clone(),
@@ -130,7 +130,7 @@ impl TwitchBot {
updated_at: chrono::offset::Utc::now() updated_at: chrono::offset::Utc::now()
}); });
}, },
eventsub::NotificationType::StreamOnline(data) => { eventsub::NotificationType::StreamOnline(_) => {
if (chrono::offset::Utc::now() - current_state.as_ref().unwrap().updated_at).num_seconds() > 15 * 60 || current_state.is_none() { if (chrono::offset::Utc::now() - current_state.as_ref().unwrap().updated_at).num_seconds() > 15 * 60 || current_state.is_none() {
let new_state: Option<State> = { let new_state: Option<State> = {
let stream = client.get_stream(config::CONFIG.twitch_channel_id.clone()).await; let stream = client.get_stream(config::CONFIG.twitch_channel_id.clone()).await;