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

Fix

Browse Source
This commit is contained in:
Bulat Kurbanov
2023-07-21 01:32:43 +02:00
parent 5d0d8b8b1c
commit 4b171e5670
1 changed files with 3 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
src/bots_manager/mod.rs
View File

@@ -1,6 +1,6 @@
pub mod bot_manager_client; pub mod bot_manager_client;
use axum::extract::State; use axum::extract::{State, Path};
use axum::response::IntoResponse; use axum::response::IntoResponse;
use axum::routing::post; use axum::routing::post;
use reqwest::StatusCode; use reqwest::StatusCode;
@@ -178,38 +178,10 @@ impl BotsManager {
} }
} }
// async fn start_axum_server(&mut self) {
// loop {
// let routers = match self.check(true).await {
// Some(v) => v,
// None => continue,
// };
// let mut app = Router::new();
// for router in routers {
// app = app.merge(router);
// }
// let addr = SocketAddr::from(([0, 0, 0, 0], self.next_port));
// self.next_port += 1;
// tokio::spawn(async move {
// log::info!("Start webserver...");
// axum::Server::bind(&addr)
// .serve(app.into_make_service())
// .await
// .unwrap();
// log::info!("Webserver shutdown...")
// });
// return;
// }
// }
async fn start_axum_server(&mut self) { async fn start_axum_server(&mut self) {
async fn telegram_request( async fn telegram_request(
State(ServerState { routers }): State<ServerState>, State(ServerState { routers }): State<ServerState>,
Path(token): Path<String>,
// secret_header: XTelegramBotApiSecretToken, // secret_header: XTelegramBotApiSecretToken,
input: String, input: String,
) -> impl IntoResponse { ) -> impl IntoResponse {
@@ -219,7 +191,7 @@ impl BotsManager {
// } // }
let t1 = routers.read().unwrap(); let t1 = routers.read().unwrap();
let tx = t1.get("t"); let tx = t1.get(&token);
let tx = match tx { let tx = match tx {
Some(tx) => { Some(tx) => {