fmt

Author: cen1

daemon/src/api/v1/package.rs

@@ -438,8 +438,10 @@ pub async fn get_source_packages(
             let status_values: Vec<String> = statuses.iter().map(|s| s.to_uppercase()).collect();
             query = query.filter(
                 r1.field(rebuilds::status).is_not_null().and(
-                    r1.field(rebuilds::status).assume_not_null().eq_any(status_values)
-                )
+                    r1.field(rebuilds::status)
+                        .assume_not_null()
+                        .eq_any(status_values),
+                ),
             );
         }
     }
@@ -471,8 +473,10 @@ pub async fn get_source_packages(
             let status_values: Vec<String> = statuses.iter().map(|s| s.to_uppercase()).collect();
             count_query = count_query.filter(
                 r1.field(rebuilds::status).is_not_null().and(
-                    r1.field(rebuilds::status).assume_not_null().eq_any(status_values)
-                )
+                    r1.field(rebuilds::status)
+                        .assume_not_null()
+                        .eq_any(status_values),
+                ),
             );
         }
     }
@@ -537,8 +541,10 @@ pub async fn get_binary_packages(
             let status_values: Vec<String> = statuses.iter().map(|s| s.to_uppercase()).collect();
             query = query.filter(
                 rebuild_artifacts::status.is_not_null().and(
-                    rebuild_artifacts::status.assume_not_null().eq_any(status_values)
-                )
+                    rebuild_artifacts::status
+                        .assume_not_null()
+                        .eq_any(status_values),
+                ),
             );
         }
     }
@@ -570,8 +576,10 @@ pub async fn get_binary_packages(
             let status_values: Vec<String> = statuses.iter().map(|s| s.to_uppercase()).collect();
             count_query = count_query.filter(
                 rebuild_artifacts::status.is_not_null().and(
-                    rebuild_artifacts::status.assume_not_null().eq_any(status_values)
-                )
+                    rebuild_artifacts::status
+                        .assume_not_null()
+                        .eq_any(status_values),
+                ),
             );
         }
     }

daemon/src/api/v1/util/auth.rs

@@ -25,7 +25,6 @@ pub fn worker(
     req: &HttpRequest,
     connection: &mut SqliteConnection,
 ) -> rebuilderd_common::errors::Result<Worker> {
-
     // Check if auth is required BEFORE trying to extract the header
     if cfg.worker.authorized_workers.is_empty() && cfg.worker.signup_secret.is_none() {
         // When no auth is configured, try to get the worker key if provided, otherwise use a default key

daemon/src/api/v1/util/filters.rs

@@ -70,12 +70,12 @@ impl<T: 'static> IntoIdentityFilter<T, Sqlite> for IdentityFilter {
             (Some(name), _) => {
                 // Exact match for name
                 Box::new(name_column.is(name))
-            },
+            }
             (None, Some(prefix)) => {
                 // LIKE pattern for name_starts_with - append % to the prefix
                 let pattern = format!("{}%", prefix);
                 Box::new(name_column.like(pattern))
-            },
+            }
             (None, None) => Box::new(AsExpression::<Bool>::as_expression(true)),
         };
 
@@ -146,7 +146,9 @@ where
         };
 
         let component_is: Self::Output = match self.component {
-            Some(component) if !component.is_empty() => Box::new(source_packages::component.is(component)),
+            Some(component) if !component.is_empty() => {
+                Box::new(source_packages::component.is(component))
+            }
             Some(_) => Box::new(source_packages::component.is_null()), // Empty string means NULL
             None => Box::new(AsExpression::<Bool>::as_expression(true)),
         };