diff --git a/src/server/api/ws.rs b/src/server/api/ws.rs index 5501079..3909956 100644 --- a/src/server/api/ws.rs +++ b/src/server/api/ws.rs @@ -34,7 +34,7 @@ pub async fn ws( if let Err(e) = tx.send(BroadcastMessage::StartSyncTaskForUser( auth.user.user_id.clone(), )) { - log::error!("Failed to send StartSyncTaskForUser: {}", e); + log::error!("Failed to send StartSyncTaskForUser: {e}"); } let rx = tx.subscribe(); @@ -96,7 +96,7 @@ pub async fn ws_handler( // Send the message to the websocket if let Ok(msg) = serde_json::to_string(&WsMessage::Sync(*event)) { if let Err(e) = session.text(msg).await { - log::error!("Failed to send SyncEvent: {}", e); + log::error!("Failed to send SyncEvent: {e}"); } } } diff --git a/src/server/web_ui.rs b/src/server/web_ui.rs index 4693334..e8f68b1 100644 --- a/src/server/web_ui.rs +++ b/src/server/web_ui.rs @@ -105,12 +105,12 @@ pub async fn home( // Close sync task if let Err(e) = tx.send(BroadcastMessage::StopSyncTaskForUser(user.id.clone())) { - log::error!("Failed to send StopSyncClientForUser: {}", e); + log::error!("Failed to send StopSyncClientForUser: {e}"); } // Invalidate all Ws connections if let Err(e) = tx.send(BroadcastMessage::CloseAllUserSessions(user.id.clone())) { - log::error!("Failed to send CloseAllUserSessions: {}", e); + log::error!("Failed to send CloseAllUserSessions: {e}"); } } } @@ -145,7 +145,7 @@ pub async fn home( success_message = Some("The client was successfully deleted!".to_string()); if let Err(e) = tx.send(BroadcastMessage::CloseClientSession(delete_client_id)) { - log::error!("Failed to send CloseClientSession: {}", e); + log::error!("Failed to send CloseClientSession: {e}"); } } } @@ -215,7 +215,7 @@ pub async fn oidc_cb(session: Session, query: web::Query) -> name: user.name.unwrap_or("no_name".to_string()), email: user.email.unwrap_or("no@mail.com".to_string()), }; - log::info!("Successful authentication as {:?}", user); + log::info!("Successful authentication as {user:?}"); session.insert(USER_SESSION_KEY, user)?; Ok(HttpResponse::Found() diff --git a/src/sync_client.rs b/src/sync_client.rs index c8303b3..a2b9fb2 100644 --- a/src/sync_client.rs +++ b/src/sync_client.rs @@ -28,7 +28,7 @@ pub async fn sync_client_manager(tx: broadcast::Sender) -> ! { continue; } - log::info!("Start sync task for user {:?}", user_id); + log::info!("Start sync task for user {user_id:?}"); let task_id = SyncClientID(uuid::Uuid::new_v4()); running_tasks.insert(user_id.clone(), task_id.clone()); @@ -41,7 +41,7 @@ pub async fn sync_client_manager(tx: broadcast::Sender) -> ! { BroadcastMessage::StopSyncTaskForUser(user_id) => { // Check if a task is running for this user if let Some(task_id) = running_tasks.remove(&user_id) { - log::info!("Stop sync task for user {:?}", user_id); + log::info!("Stop sync task for user {user_id:?}"); tx.send(BroadcastMessage::StopSyncClient(task_id)).unwrap(); } else { log::info!("Not stopping sync task for user {user_id:?}: not running"); diff --git a/src/user.rs b/src/user.rs index 129fac5..c7397f0 100644 --- a/src/user.rs +++ b/src/user.rs @@ -147,7 +147,7 @@ impl UserConfig { log::warn!("The bucket does not seem to exists, trying to create it!") } Err(e) => { - log::error!("Got unexpected error when querying bucket info: {}", e); + log::error!("Got unexpected error when querying bucket info: {e}"); return Err(e.into()); } }