Fix formatting

Author: CodingAnarchy

cargo-hammerwork/src/commands/workflow.rs

@@ -563,7 +563,13 @@ impl WorkflowCommand {
             .filter_map(|dep_id| {
                 if let Some(dep_job) = job_map.get(dep_id) {
                     if !visited.contains(dep_id) {
-                        Self::calculate_job_level(dep_job, job_map, levels, visited, _current_level);
+                        Self::calculate_job_level(
+                            dep_job,
+                            job_map,
+                            levels,
+                            visited,
+                            _current_level,
+                        );
                     }
                     levels.get(dep_id).copied()
                 } else {

cargo-hammerwork/src/config/mod.rs

@@ -118,16 +118,16 @@ use std::path::PathBuf;
 pub struct Config {
     /// Database connection URL (e.g., "postgresql://localhost/hammerwork")
     pub database_url: Option<String>,
-    
+
     /// Default queue name for operations
     pub default_queue: Option<String>,
-    
+
     /// Default limit for list operations
     pub default_limit: Option<u32>,
-    
+
     /// Log level (error, warn, info, debug, trace)
     pub log_level: Option<String>,
-    
+
     /// Database connection pool size
     pub connection_pool_size: Option<u32>,
 }

cargo-hammerwork/src/utils/database.rs

@@ -21,7 +21,7 @@
 //!
 //! // Connect to MySQL
 //! let mysql_pool = DatabasePool::connect(
-//!     "mysql://localhost/hammerwork", 
+//!     "mysql://localhost/hammerwork",
 //!     5
 //! ).await?;
 //! # Ok(())

cargo-hammerwork/src/utils/display.rs

@@ -70,7 +70,7 @@ use std::fmt;
 /// use cargo_hammerwork::utils::display::JobTable;
 ///
 /// let mut table = JobTable::new();
-/// 
+///
 /// // Add multiple jobs
 /// table.add_job_row(
 ///     "job-id-1", "email", "pending", "normal", 0,
@@ -80,7 +80,7 @@ use std::fmt;
 ///     "job-id-2", "data-processing", "running", "high", 1,
 ///     "2024-01-01 09:55:00", "2024-01-01 10:00:00"
 /// );
-/// 
+///
 /// // The table will display with color-coded status and priority
 /// ```
 pub struct JobTable {
@@ -189,7 +189,7 @@ impl fmt::Display for JobTable {
 /// stats.add_stats_row("pending", "normal", 100);
 /// stats.add_stats_row("running", "high", 10);
 /// stats.add_stats_row("failed", "critical", 2);
-/// 
+///
 /// // Display shows icons: 🟡 pending, 🔵 running, 🔴 failed
 /// ```
 pub struct StatsTable {

hammerwork-web/src/api/jobs.rs

@@ -79,8 +79,8 @@
 //! ```
 
 use super::{
-    with_filters, with_pagination, with_sort, ApiResponse, FilterParams,
-    PaginatedResponse, PaginationMeta, PaginationParams, SortParams,
+    ApiResponse, FilterParams, PaginatedResponse, PaginationMeta, PaginationParams, SortParams,
+    with_filters, with_pagination, with_sort,
 };
 use hammerwork::queue::DatabaseQueue;
 use serde::{Deserialize, Serialize};
@@ -226,29 +226,27 @@ where
     // For now, return a placeholder response
     // In a real implementation, this would query the database with filters and pagination
     let _ = (queue, filters, sort);
-    
-    let mock_jobs = vec![
-        JobInfo {
-            id: "job-1".to_string(),
-            queue_name: "default".to_string(),
-            status: "pending".to_string(),
-            priority: "normal".to_string(),
-            attempts: 0,
-            max_attempts: 3,
-            payload: serde_json::json!({"task": "send_email", "to": "[email protected]"}),
-            created_at: chrono::Utc::now(),
-            scheduled_at: chrono::Utc::now(),
-            started_at: None,
-            completed_at: None,
-            failed_at: None,
-            error_message: None,
-            processing_time_ms: None,
-            cron_schedule: None,
-            is_recurring: false,
-            trace_id: None,
-            correlation_id: None,
-        },
-    ];
+
+    let mock_jobs = vec![JobInfo {
+        id: "job-1".to_string(),
+        queue_name: "default".to_string(),
+        status: "pending".to_string(),
+        priority: "normal".to_string(),
+        attempts: 0,
+        max_attempts: 3,
+        payload: serde_json::json!({"task": "send_email", "to": "[email protected]"}),
+        created_at: chrono::Utc::now(),
+        scheduled_at: chrono::Utc::now(),
+        started_at: None,
+        completed_at: None,
+        failed_at: None,
+        error_message: None,
+        processing_time_ms: None,
+        cron_schedule: None,
+        is_recurring: false,
+        trace_id: None,
+        correlation_id: None,
+    }];
 
     let response = PaginatedResponse {
         items: mock_jobs,
@@ -277,8 +275,7 @@ where
         _ => JobPriority::Normal,
     };
 
-    let mut job = Job::new(request.queue_name, request.payload)
-        .with_priority(priority);
+    let mut job = Job::new(request.queue_name, request.payload).with_priority(priority);
 
     if let Some(scheduled_at) = request.scheduled_at {
         job.scheduled_at = scheduled_at;
@@ -312,10 +309,7 @@ where
 }
 
 /// Handler for getting a specific job
-async fn get_job_handler<T>(
-    job_id: String,
-    queue: Arc<T>,
-) -> Result<impl Reply, warp::Rejection>
+async fn get_job_handler<T>(job_id: String, queue: Arc<T>) -> Result<impl Reply, warp::Rejection>
 where
     T: DatabaseQueue + Send + Sync,
 {
@@ -343,10 +337,12 @@ where
                 completed_at: job.completed_at,
                 failed_at: job.failed_at,
                 error_message: job.error_message.clone(),
-                processing_time_ms: job.started_at.and_then(|start| 
-                    job.completed_at.or(job.failed_at).or(job.timed_out_at)
+                processing_time_ms: job.started_at.and_then(|start| {
+                    job.completed_at
+                        .or(job.failed_at)
+                        .or(job.timed_out_at)
                         .map(|end| (end - start).num_milliseconds())
-                ),
+                }),
                 cron_schedule: job.cron_schedule.clone(),
                 is_recurring: job.is_recurring(),
                 trace_id: job.trace_id.clone(),
@@ -384,36 +380,33 @@ where
     };
 
     match action_request.action.as_str() {
-        "retry" => {
-            match queue.retry_job(job_uuid, chrono::Utc::now()).await {
-                Ok(()) => {
-                    let response = ApiResponse::success(serde_json::json!({
-                        "message": format!("Job '{}' scheduled for retry", job_id)
-                    }));
-                    Ok(warp::reply::json(&response))
-                }
-                Err(e) => {
-                    let response = ApiResponse::<()>::error(format!("Failed to retry job: {}", e));
-                    Ok(warp::reply::json(&response))
-                }
+        "retry" => match queue.retry_job(job_uuid, chrono::Utc::now()).await {
+            Ok(()) => {
+                let response = ApiResponse::success(serde_json::json!({
+                    "message": format!("Job '{}' scheduled for retry", job_id)
+                }));
+                Ok(warp::reply::json(&response))
             }
-        }
-        "cancel" | "delete" => {
-            match queue.delete_job(job_uuid).await {
-                Ok(()) => {
-                    let response = ApiResponse::success(serde_json::json!({
-                        "message": format!("Job '{}' deleted", job_id)
-                    }));
-                    Ok(warp::reply::json(&response))
-                }
-                Err(e) => {
-                    let response = ApiResponse::<()>::error(format!("Failed to delete job: {}", e));
-                    Ok(warp::reply::json(&response))
-                }
+            Err(e) => {
+                let response = ApiResponse::<()>::error(format!("Failed to retry job: {}", e));
+                Ok(warp::reply::json(&response))
             }
-        }
+        },
+        "cancel" | "delete" => match queue.delete_job(job_uuid).await {
+            Ok(()) => {
+                let response = ApiResponse::success(serde_json::json!({
+                    "message": format!("Job '{}' deleted", job_id)
+                }));
+                Ok(warp::reply::json(&response))
+            }
+            Err(e) => {
+                let response = ApiResponse::<()>::error(format!("Failed to delete job: {}", e));
+                Ok(warp::reply::json(&response))
+            }
+        },
         _ => {
-            let response = ApiResponse::<()>::error(format!("Unknown action: {}", action_request.action));
+            let response =
+                ApiResponse::<()>::error(format!("Unknown action: {}", action_request.action));
             Ok(warp::reply::json(&response))
         }
     }
@@ -503,7 +496,7 @@ mod tests {
             "priority": "high",
             "max_attempts": 5
         }"#;
-        
+
         let request: CreateJobRequest = serde_json::from_str(json).unwrap();
         assert_eq!(request.queue_name, "email");
         assert_eq!(request.priority, Some("high".to_string()));
@@ -525,9 +518,9 @@ mod tests {
             "action": "delete",
             "reason": "Cleanup old jobs"
         }"#;
-        
+
         let request: BulkJobActionRequest = serde_json::from_str(json).unwrap();
         assert_eq!(request.job_ids.len(), 3);
         assert_eq!(request.action, "delete");
     }
-}
+}

hammerwork-web/src/api/mod.rs

@@ -186,10 +186,15 @@ impl SortParams {
 }
 
 /// Common error handling for API endpoints
-pub async fn handle_api_error(err: warp::Rejection) -> Result<impl warp::Reply, std::convert::Infallible> {
+pub async fn handle_api_error(
+    err: warp::Rejection,
+) -> Result<impl warp::Reply, std::convert::Infallible> {
     let response = if err.is_not_found() {
         ApiResponse::<()>::error("Resource not found".to_string())
-    } else if err.find::<warp::filters::body::BodyDeserializeError>().is_some() {
+    } else if err
+        .find::<warp::filters::body::BodyDeserializeError>()
+        .is_some()
+    {
         ApiResponse::<()>::error("Invalid request body".to_string())
     } else if err.find::<warp::reject::InvalidQuery>().is_some() {
         ApiResponse::<()>::error("Invalid query parameters".to_string())
@@ -199,8 +204,11 @@ pub async fn handle_api_error(err: warp::Rejection) -> Result<impl warp::Reply,
 
     let status = if err.is_not_found() {
         warp::http::StatusCode::NOT_FOUND
-    } else if err.find::<warp::filters::body::BodyDeserializeError>().is_some() 
-        || err.find::<warp::reject::InvalidQuery>().is_some() {
+    } else if err
+        .find::<warp::filters::body::BodyDeserializeError>()
+        .is_some()
+        || err.find::<warp::reject::InvalidQuery>().is_some()
+    {
         warp::http::StatusCode::BAD_REQUEST
     } else {
         warp::http::StatusCode::INTERNAL_SERVER_ERROR
@@ -213,12 +221,14 @@ pub async fn handle_api_error(err: warp::Rejection) -> Result<impl warp::Reply,
 }
 
 /// Extract pagination parameters from query string
-pub fn with_pagination() -> impl warp::Filter<Extract = (PaginationParams,), Error = warp::Rejection> + Clone {
+pub fn with_pagination()
+-> impl warp::Filter<Extract = (PaginationParams,), Error = warp::Rejection> + Clone {
     warp::query::<PaginationParams>()
 }
 
 /// Extract filter parameters from query string  
-pub fn with_filters() -> impl warp::Filter<Extract = (FilterParams,), Error = warp::Rejection> + Clone {
+pub fn with_filters()
+-> impl warp::Filter<Extract = (FilterParams,), Error = warp::Rejection> + Clone {
     warp::query::<FilterParams>()
 }
 
@@ -273,7 +283,7 @@ mod tests {
             offset: None,
         };
         let meta = PaginationMeta::new(&params, 45);
-        
+
         assert_eq!(meta.page, 2);
         assert_eq!(meta.limit, 10);
         assert_eq!(meta.total, 45);
@@ -303,4 +313,4 @@ mod tests {
         assert_eq!(field, "name");
         assert_eq!(direction, "ASC");
     }
-}
+}