flibusta-apps/book_bot
1
0
Fork 0
mirror of https://github.com/flibusta-apps/book_bot.git synced 2026-03-03 07:00:53 +01:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
Bulat Kurbanov
2024-01-08 02:04:05 +01:00
parent 0c6d30eff6
commit 4f61f94579
1 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/bots_manager/axum_server.rs
View File

@@ -4,7 +4,6 @@ use axum::{extract::Path, routing::get};
use axum_prometheus::PrometheusMetricLayer; use axum_prometheus::PrometheusMetricLayer;
use reqwest::StatusCode; use reqwest::StatusCode;
use tokio::sync::Mutex;
use std::{ use std::{
net::SocketAddr, net::SocketAddr,
@@ -45,9 +44,7 @@ pub async fn start_axum_server(stop_signal: Arc<AtomicBool>) {
break 'creator; break 'creator;
} }
let start_result = start_bot(&bot_data.unwrap(), SERVER_PORT).await; if !start_bot(&bot_data.unwrap(), SERVER_PORT).await {
if !start_result {
return StatusCode::SERVICE_UNAVAILABLE; return StatusCode::SERVICE_UNAVAILABLE;
} }
} }
@@ -92,12 +89,11 @@ pub async fn start_axum_server(stop_signal: Arc<AtomicBool>) {
let (prometheus_layer, metric_handle) = PrometheusMetricLayer::pair(); let (prometheus_layer, metric_handle) = PrometheusMetricLayer::pair();
let start_bot_mutex = Arc::new(Mutex::new(())); // let start_bot_mutex = Arc::new(Mutex::new(()));
let app_router = axum::Router::new() let app_router = axum::Router::new()
.route("/:token/", post(telegram_request)) .route("/:token/", post(telegram_request))
.layer(prometheus_layer) .layer(prometheus_layer);
.with_state(start_bot_mutex);
let metric_router = let metric_router =
axum::Router::new().route("/metrics", get(|| async move { metric_handle.render() })); axum::Router::new().route("/metrics", get(|| async move { metric_handle.render() }));