From 6f34a0a4faf8d931af573a800a5468d720ab8df1 Mon Sep 17 00:00:00 2001 From: Nils Schneider Date: Tue, 11 Nov 2025 15:50:51 +0100 Subject: [PATCH] fmt --- backend/src/auth/mod.rs | 5 +++-- backend/src/services/documents.rs | 17 +++++------------ backend/src/workers/mod.rs | 7 ++----- 3 files changed, 10 insertions(+), 19 deletions(-) diff --git a/backend/src/auth/mod.rs b/backend/src/auth/mod.rs index 8b6e990..abcf34f 100644 --- a/backend/src/auth/mod.rs +++ b/backend/src/auth/mod.rs @@ -11,9 +11,9 @@ use axum::{ extract::FromRequestParts, http::{request::Parts, StatusCode}, }; -use diesel::{pg::PgConnection, prelude::*}; use axum_extra::headers::{authorization::Bearer, Authorization}; use axum_extra::TypedHeader; +use diesel::{pg::PgConnection, prelude::*}; use serde::{Deserialize, Serialize}; use utoipa::ToSchema; @@ -138,7 +138,8 @@ impl FromRequestParts for TenantScopedConn { async move { let user = AuthenticatedUser::from_request_parts(parts, &state).await?; let tenant_id = user.tenant_id; - let mut conn = if let Some(holder) = parts.extensions.remove::() { + let mut conn = if let Some(holder) = parts.extensions.remove::() + { holder .into_conn() .ok_or_else(|| AppError::internal("tenant connection unavailable"))? diff --git a/backend/src/services/documents.rs b/backend/src/services/documents.rs index 07fb964..312ee5b 100644 --- a/backend/src/services/documents.rs +++ b/backend/src/services/documents.rs @@ -1427,14 +1427,9 @@ impl<'a> DocumentsService<'a> { }); if let Some(deleted_at) = document.deleted_at { - message.push_str( - ". Note: the existing document is currently in the trash.", - ); + message.push_str(". Note: the existing document is currently in the trash."); if let Some(obj) = details.as_object_mut() { - obj.insert( - "conflict_document_in_trash".to_string(), - Value::Bool(true), - ); + obj.insert("conflict_document_in_trash".to_string(), Value::Bool(true)); obj.insert( "conflict_document_deleted_at".to_string(), Value::String(to_iso(deleted_at)), @@ -1442,11 +1437,9 @@ impl<'a> DocumentsService<'a> { } } - return Err( - AppError::conflict(message) - .with_code("duplicate_document") - .with_details(details), - ); + return Err(AppError::conflict(message) + .with_code("duplicate_document") + .with_details(details)); } if let Some(issued_at) = issued_at_override { diff --git a/backend/src/workers/mod.rs b/backend/src/workers/mod.rs index e6c7447..7ab5910 100644 --- a/backend/src/workers/mod.rs +++ b/backend/src/workers/mod.rs @@ -98,11 +98,8 @@ impl Worker { None => { warn!(job_id = %job.id, job_type = %job.job_type, "job detached from tenant; marking failed"); if let Ok(mut conn) = self.state.db_unscoped() { - let _ = mark_job_failed( - &mut conn, - job.id, - "job detached from tenant context", - ); + let _ = + mark_job_failed(&mut conn, job.id, "job detached from tenant context"); } return Ok(true); }