flibusta-apps/book_bot
1
0
Fork 0
mirror of https://github.com/flibusta-apps/book_bot.git synced 2025-12-06 15:35:35 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add start bot mutex

Browse Source
This commit is contained in:
Bulat Kurbanov
2024-01-08 01:25:27 +01:00
parent 16489b4f1b
commit 6a2f34b878
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/bots_manager/internal.rs
View File

@@ -1,3 +1,5 @@
use once_cell::sync::Lazy;
use teloxide::adaptors::throttle::Limits; use teloxide::adaptors::throttle::Limits;
use teloxide::dispatching::Dispatcher; use teloxide::dispatching::Dispatcher;
use teloxide::error_handlers::LoggingErrorHandler; use teloxide::error_handlers::LoggingErrorHandler;
@@ -9,12 +11,14 @@ use teloxide::update_listeners::{StatefulListener, UpdateListener};
use teloxide::{dptree, Bot}; use teloxide::{dptree, Bot};
use tokio::sync::mpsc::{self, UnboundedSender}; use tokio::sync::mpsc::{self, UnboundedSender};
use tokio::sync::Mutex;
use tokio_stream::wrappers::UnboundedReceiverStream; use tokio_stream::wrappers::UnboundedReceiverStream;
use tracing::log; use tracing::log;
use url::Url; use url::Url;
use std::convert::Infallible; use std::convert::Infallible;
use std::sync::Arc;
use crate::bots_manager::BOTS_ROUTES; use crate::bots_manager::BOTS_ROUTES;
use crate::config; use crate::config;
@@ -46,7 +50,11 @@ pub fn get_listener() -> (
(stop_token, stop_flag, tx, listener) (stop_token, stop_flag, tx, listener)
} }
pub static START_BOT_LOCK: Lazy<Arc<Mutex<()>>> = Lazy::new(|| Arc::new(Mutex::new(())));
pub async fn start_bot(bot_data: &BotData, port: u16) -> bool { pub async fn start_bot(bot_data: &BotData, port: u16) -> bool {
let _mutex_guard = START_BOT_LOCK.lock().await;
let bot = Bot::new(bot_data.token.clone()) let bot = Bot::new(bot_data.token.clone())
.set_api_url(config::CONFIG.telegram_bot_api.clone()) .set_api_url(config::CONFIG.telegram_bot_api.clone())
.throttle(Limits::default()) .throttle(Limits::default())