From 9e9fa4f77f47ecec4b322444d5be73adc0fbb7cf Mon Sep 17 00:00:00 2001 From: euzu Date: Wed, 11 Jun 2025 10:11:23 +0200 Subject: [PATCH] sanitize log added --- src/api/main_api.rs | 2 +- src/api/model/active_user_manager.rs | 7 ++++--- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/src/api/main_api.rs b/src/api/main_api.rs index ac3389417..00324a898 100644 --- a/src/api/main_api.rs +++ b/src/api/main_api.rs @@ -73,7 +73,7 @@ async fn create_shared_data(cfg: &Arc) -> AppState { let active_users = Arc::new(ActiveUserManager::new(cfg)); let active_provider = Arc::new(ActiveProviderManager::new(cfg).await); - let mut builder = create_client(cfg).http1_only(); + let mut builder = create_client(cfg).http1_only(); // because of RAII connection dropping if cfg.connect_timeout_secs > 0 { builder = builder.connect_timeout(Duration::from_secs(u64::from(cfg.connect_timeout_secs))); } diff --git a/src/api/model/active_user_manager.rs b/src/api/model/active_user_manager.rs index 362dbf88c..5b4598b32 100644 --- a/src/api/model/active_user_manager.rs +++ b/src/api/model/active_user_manager.rs @@ -7,6 +7,7 @@ use std::collections::HashMap; use std::sync::atomic::{AtomicU64, Ordering}; use std::sync::Arc; use tokio::sync::RwLock; +use crate::utils::request::sanitize_sensitive_info; const USER_CON_TTL: u64 = 10_800; // 3 hours const USER_SESSION_LIMIT: usize = 50; @@ -237,19 +238,19 @@ impl ActiveUserManager { session.provider = provider.to_string(); } session.permission = connection_permission; - debug!("Using session for user {} with token {session_token} {stream_url}", user.username); + debug!("Using session for user {} with token {session_token} {}", user.username, sanitize_sensitive_info(stream_url)); return Some(session.token.to_string()); } } // no session create new one - debug!("Creating session for user {} with token {session_token} {stream_url}", user.username); + debug!("Creating session for user {} with token {session_token} {}", user.username, sanitize_sensitive_info(stream_url)); let session = Self::new_user_session(session_token, virtual_id, provider, stream_url, connection_permission); let token = session.token.clone(); connection_data.add_session(session); Some(token) } else { - debug!("Creating session for user {} with token {session_token} {stream_url}", user.username); + debug!("Creating session for user {} with token {session_token} {}", user.username, sanitize_sensitive_info(stream_url)); let mut connection_data = UserConnectionData::new(0, user.max_connections); let session = Self::new_user_session(session_token, virtual_id, provider, stream_url, connection_permission); let token = session.token.clone();