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

Fix

Browse Source
This commit is contained in:
Bulat Kurbanov
2024-05-06 23:46:58 +02:00
parent 21ffda8ce4
commit b1143360b4
3 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
Cargo.lock generated
View File

@@ -333,6 +333,7 @@ dependencies = [
"axum-prometheus", "axum-prometheus",
"futures-util", "futures-util",
"sentry", "sentry",
"sentry-tracing",
"tokio", "tokio",
"tokio-cron-scheduler", "tokio-cron-scheduler",
"tokio-util", "tokio-util",

1
Cargo.toml
View File

@@ -15,6 +15,7 @@ axum-prometheus = "0.6.1"
tracing = "0.1.40" tracing = "0.1.40"
tracing-subscriber = { version = "0.3.18", features = ["env-filter"]} tracing-subscriber = { version = "0.3.18", features = ["env-filter"]}
sentry-tracing = "0.32.3"
tower-http = { version = "0.5.2", features = ["trace"] } tower-http = { version = "0.5.2", features = ["trace"] }
async-tempfile = "0.5.0" async-tempfile = "0.5.0"

18
src/main.rs
View File

@@ -11,6 +11,7 @@ use axum::{
use axum_prometheus::PrometheusMetricLayer; use axum_prometheus::PrometheusMetricLayer;
use futures_util::StreamExt; use futures_util::StreamExt;
use sentry::{integrations::debug_images::DebugImagesIntegration, types::Dsn, ClientOptions}; use sentry::{integrations::debug_images::DebugImagesIntegration, types::Dsn, ClientOptions};
use sentry_tracing::EventFilter;
use std::{io::SeekFrom, net::SocketAddr, str::FromStr}; use std::{io::SeekFrom, net::SocketAddr, str::FromStr};
use tokio::{ use tokio::{
fs::{read_dir, remove_dir, remove_file, File}, fs::{read_dir, remove_dir, remove_file, File},
@@ -21,6 +22,7 @@ use tokio_cron_scheduler::{Job, JobScheduler};
use tokio_util::io::ReaderStream; use tokio_util::io::ReaderStream;
use tower_http::trace::{self, TraceLayer}; use tower_http::trace::{self, TraceLayer};
use tracing::{info, log, Level}; use tracing::{info, log, Level};
use tracing_subscriber::{filter, layer::SubscriberExt, util::SubscriberInitExt};
async fn remove_temp_files() -> Result<(), Box<dyn std::error::Error + Send + Sync>> { async fn remove_temp_files() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
let mut dir = read_dir("/tmp/").await?; let mut dir = read_dir("/tmp/").await?;
@@ -205,11 +207,6 @@ async fn start_app() {
#[tokio::main] #[tokio::main]
async fn main() { async fn main() {
tracing_subscriber::fmt()
.with_target(false)
.compact()
.init();
let options = ClientOptions { let options = ClientOptions {
dsn: Some( dsn: Some(
Dsn::from_str( Dsn::from_str(
@@ -225,5 +222,16 @@ async fn main() {
let _guard = sentry::init(options); let _guard = sentry::init(options);
let sentry_layer = sentry_tracing::layer().event_filter(|md| match md.level() {
&tracing::Level::ERROR => EventFilter::Event,
_ => EventFilter::Ignore,
});
tracing_subscriber::registry()
.with(tracing_subscriber::fmt::layer().with_target(false))
.with(filter::LevelFilter::INFO)
.with(sentry_layer)
.init();
tokio::join![cron_jobs(), start_app()]; tokio::join![cron_jobs(), start_app()];
} }