style: run cargo fmt and fix manual_div_ceil clippy warnings

Author: Tuntii

crates/rustapi-core/src/app.rs

@@ -995,15 +995,31 @@ impl RustApi {
         fn base64_encode(input: &[u8]) -> String {
             const ALPHA: &[u8; 64] =
                 b"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";
-            let mut out = String::with_capacity((input.len() + 2) / 3 * 4);
+            let mut out = String::with_capacity(input.len().div_ceil(3) * 4);
             for chunk in input.chunks(3) {
                 let b0 = chunk[0] as usize;
-                let b1 = if chunk.len() > 1 { chunk[1] as usize } else { 0 };
-                let b2 = if chunk.len() > 2 { chunk[2] as usize } else { 0 };
+                let b1 = if chunk.len() > 1 {
+                    chunk[1] as usize
+                } else {
+                    0
+                };
+                let b2 = if chunk.len() > 2 {
+                    chunk[2] as usize
+                } else {
+                    0
+                };
                 out.push(ALPHA[b0 >> 2] as char);
                 out.push(ALPHA[((b0 & 3) << 4) | (b1 >> 4)] as char);
-                out.push(if chunk.len() > 1 { ALPHA[((b1 & 0xf) << 2) | (b2 >> 6)] as char } else { '=' });
-                out.push(if chunk.len() > 2 { ALPHA[b2 & 63] as char } else { '=' });
+                out.push(if chunk.len() > 1 {
+                    ALPHA[((b1 & 0xf) << 2) | (b2 >> 6)] as char
+                } else {
+                    '='
+                });
+                out.push(if chunk.len() > 2 {
+                    ALPHA[b2 & 63] as char
+                } else {
+                    '='
+                });
             }
             out
         }

crates/rustapi-extras/src/diesel/mod.rs

@@ -24,9 +24,9 @@
 //! ```
 
 use rustapi_core::health::{HealthCheck, HealthCheckBuilder, HealthStatus};
+use std::fmt;
 use std::sync::Arc;
 use std::time::Duration;
-use std::fmt;
 
 /// Error type for Diesel pool operations
 #[derive(Debug)]

crates/rustapi-extras/src/insight/export.rs

@@ -44,11 +44,15 @@ impl std::error::Error for ExportError {
 }
 
 impl From<std::io::Error> for ExportError {
-    fn from(e: std::io::Error) -> Self { Self::Io(e) }
+    fn from(e: std::io::Error) -> Self {
+        Self::Io(e)
+    }
 }
 
 impl From<serde_json::Error> for ExportError {
-    fn from(e: serde_json::Error) -> Self { Self::Serialization(e) }
+    fn from(e: serde_json::Error) -> Self {
+        Self::Serialization(e)
+    }
 }
 
 /// Result type for export operations.

crates/rustapi-extras/src/replay/client.rs

@@ -32,7 +32,9 @@ impl std::error::Error for ReplayClientError {
 }
 
 impl From<reqwest::Error> for ReplayClientError {
-    fn from(e: reqwest::Error) -> Self { Self::Http(e) }
+    fn from(e: reqwest::Error) -> Self {
+        Self::Http(e)
+    }
 }
 
 /// HTTP client for replaying recorded requests against a target server.

crates/rustapi-extras/src/sqlx/mod.rs

@@ -93,7 +93,9 @@ impl std::error::Error for PoolError {
 }
 
 impl From<sqlx::Error> for PoolError {
-    fn from(e: sqlx::Error) -> Self { Self::Sqlx(e) }
+    fn from(e: sqlx::Error) -> Self {
+        Self::Sqlx(e)
+    }
 }
 
 /// Configuration for SQLx connection pool

crates/rustapi-jobs/src/backend.rs

@@ -28,16 +28,12 @@ pub struct JobRequest {
 /// Backend storage for jobs (dyn-compatible via boxed futures)
 pub trait JobBackend: Send + Sync {
     /// Push a new job to the queue
-    fn push<'a>(
-        &'a self,
-        job: JobRequest,
-    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'a>>;
+    fn push<'a>(&'a self, job: JobRequest)
+        -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'a>>;
 
     /// Pop the next available job
     /// Should return None if no job is available or ready
-    fn pop<'a>(
-        &'a self,
-    ) -> Pin<Box<dyn Future<Output = Result<Option<JobRequest>>> + Send + 'a>>;
+    fn pop<'a>(&'a self) -> Pin<Box<dyn Future<Output = Result<Option<JobRequest>>> + Send + 'a>>;
 
     /// Mark a job as completed successfully
     fn complete<'a>(

crates/rustapi-jobs/src/backend/memory.rs

@@ -33,9 +33,7 @@ impl JobBackend for InMemoryBackend {
         })
     }
 
-    fn pop<'a>(
-        &'a self,
-    ) -> Pin<Box<dyn Future<Output = Result<Option<JobRequest>>> + Send + 'a>> {
+    fn pop<'a>(&'a self) -> Pin<Box<dyn Future<Output = Result<Option<JobRequest>>> + Send + 'a>> {
         Box::pin(async move {
             let mut q = self
                 .queue

crates/rustapi-jobs/src/backend/postgres.rs

@@ -78,9 +78,7 @@ impl JobBackend for PostgresBackend {
         })
     }
 
-    fn pop<'a>(
-        &'a self,
-    ) -> Pin<Box<dyn Future<Output = Result<Option<JobRequest>>> + Send + 'a>> {
+    fn pop<'a>(&'a self) -> Pin<Box<dyn Future<Output = Result<Option<JobRequest>>> + Send + 'a>> {
         Box::pin(async move {
             // Atomic pop using DELETE ... RETURNING with locking
             let query = format!(

crates/rustapi-jobs/src/backend/redis.rs

@@ -62,9 +62,7 @@ impl JobBackend for RedisBackend {
         })
     }
 
-    fn pop<'a>(
-        &'a self,
-    ) -> Pin<Box<dyn Future<Output = Result<Option<JobRequest>>> + Send + 'a>> {
+    fn pop<'a>(&'a self) -> Pin<Box<dyn Future<Output = Result<Option<JobRequest>>> + Send + 'a>> {
         Box::pin(async move {
             let mut conn = self
                 .client

crates/rustapi-jobs/src/error.rs

@@ -33,7 +33,9 @@ impl std::error::Error for JobError {
 }
 
 impl From<serde_json::Error> for JobError {
-    fn from(e: serde_json::Error) -> Self { Self::SerializationError(e) }
+    fn from(e: serde_json::Error) -> Self {
+        Self::SerializationError(e)
+    }
 }
 
 pub type Result<T> = std::result::Result<T, JobError>;