From cce34571f19934e9a0c494c5152cd1a70a7f5d9b Mon Sep 17 00:00:00 2001 From: Nulo Date: Thu, 25 Jan 2024 16:56:27 -0300 Subject: [PATCH] no requerir telegram para auto --- scraper-rs/src/main.rs | 48 ++++++++++++++++++++++++++---------------- 1 file changed, 30 insertions(+), 18 deletions(-) diff --git a/scraper-rs/src/main.rs b/scraper-rs/src/main.rs index 6cc3d98..0e46c11 100644 --- a/scraper-rs/src/main.rs +++ b/scraper-rs/src/main.rs @@ -296,11 +296,16 @@ async fn scrap_url( } } +#[derive(Clone)] +struct AutoTelegram { + token: String, + chat_id: String, +} + #[derive(Clone)] struct Auto { pool: Pool, - telegram_token: String, - telegram_chat_id: String, + telegram: Option, } impl Auto { async fn download_supermercado(self: Self, supermercado: Supermercado) -> anyhow::Result<()> { @@ -383,28 +388,35 @@ impl Auto { async fn inform(self: &Self, msg: &str) { println!("{}", msg); - let u = Url::parse_with_params( - &format!( - "https://api.telegram.org/bot{}/sendMessage", - self.telegram_token - ), - &[ - ("chat_id", self.telegram_chat_id.clone()), - ("text", msg.to_string()), - ], - ) - .unwrap(); - reqwest::get(u).await.unwrap(); + if let Some(telegram) = &self.telegram { + let u = Url::parse_with_params( + &format!("https://api.telegram.org/bot{}/sendMessage", telegram.token), + &[ + ("chat_id", telegram.chat_id.clone()), + ("text", msg.to_string()), + ], + ) + .unwrap(); + reqwest::get(u).await.unwrap(); + } } } async fn auto_cli() -> anyhow::Result<()> { let db = connect_db(); - let auto = Auto { - pool: db, - telegram_token: env::var("TELEGRAM_BOT_TOKEN")?, - telegram_chat_id: env::var("TELEGRAM_BOT_CHAT_ID")?, + let telegram = { + match ( + env::var("TELEGRAM_BOT_TOKEN"), + env::var("TELEGRAM_BOT_CHAT_ID"), + ) { + (Ok(token), Ok(chat_id)) => Some(AutoTelegram { token, chat_id }), + _ => { + tracing::warn!("No token or chat_id for telegram"); + None + } + } }; + let auto = Auto { pool: db, telegram }; auto.inform("[auto] Empezando scrap").await; let handles: Vec<_> = Supermercado::value_variants() .iter()