fix: run linters

Author: maltesander

rust/operator-binary/src/controller.rs

@@ -67,11 +67,11 @@ use stackable_operator::{
 use strum::{EnumDiscriminants, IntoStaticStr};
 
 use crate::{
+    controller::build::properties::logging::BundleBuilderLogLevel,
     crd::{
         APP_NAME, Container, DEFAULT_SERVER_GRACEFUL_SHUTDOWN_TIMEOUT, OPERATOR_NAME,
         OpaClusterStatus, OpaConfig, OpaRole, user_info_fetcher, v1alpha2,
     },
-    controller::build::properties::logging::BundleBuilderLogLevel,
     operations::graceful_shutdown::add_graceful_shutdown_config,
     service::{
         self, APP_PORT, APP_PORT_NAME, build_rolegroup_headless_service,
@@ -336,7 +336,8 @@ pub async fn reconcile_opa(
 
     // NOTE(@maltesander): There currently is no dereference (client required) step for OPA.
     // validate (no client required)
-    let validated = validate::validate(opa, &ctx.operator_environment).context(ValidateClusterSnafu)?;
+    let validated =
+        validate::validate(opa, &ctx.operator_environment).context(ValidateClusterSnafu)?;
 
     let opa_role = OpaRole::Server;
 

rust/operator-binary/src/controller/build/config_map.rs

@@ -86,11 +86,9 @@ pub fn build_rolegroup_config_map(
         cm_builder.add_data(VECTOR_CONFIG_FILE, vector_config);
     }
 
-    cm_builder
-        .build()
-        .with_context(|_| BuildConfigMapSnafu {
-            rolegroup: rolegroup_ref.clone(),
-        })
+    cm_builder.build().with_context(|_| BuildConfigMapSnafu {
+        rolegroup: rolegroup_ref.clone(),
+    })
 }
 
 #[cfg(test)]
@@ -100,8 +98,9 @@ mod tests {
 
     use super::*;
     use crate::{
-        controller::{build::properties::test_support::validated_cluster_from_spec,
-            build_recommended_labels},
+        controller::{
+            build::properties::test_support::validated_cluster_from_spec, build_recommended_labels,
+        },
         crd::OpaRole,
     };
 

rust/operator-binary/src/controller/build/discovery.rs

@@ -162,6 +162,9 @@ mod tests {
             data.get("OPA").map(String::as_str),
             Some("https://test-opa-server.default.svc.cluster.local:8443/")
         );
-        assert_eq!(data.get("OPA_SECRET_CLASS").map(String::as_str), Some("tls"));
+        assert_eq!(
+            data.get("OPA_SECRET_CLASS").map(String::as_str),
+            Some("tls")
+        );
     }
 }

rust/operator-binary/src/controller/build/properties/config_json.rs

@@ -49,9 +49,10 @@ pub fn build(merged_config: &OpaConfig, config_overrides: &OpaConfigOverrides) -
 
     let config = OpaClusterConfigFile::new(decision_logging);
 
-    let config_value = serde_json::to_value(&config).with_context(|_| SerializeConfigFileSnafu {
-        file: ConfigFileName::ConfigJson.to_string(),
-    })?;
+    let config_value =
+        serde_json::to_value(&config).with_context(|_| SerializeConfigFileSnafu {
+            file: ConfigFileName::ConfigJson.to_string(),
+        })?;
 
     // Apply the merged user `configOverrides`. The merge built a sequence that applies the
     // role-level patch first, then the role-group-level patch on top. `apply` is infallible; an
@@ -139,7 +140,9 @@ mod tests {
     use serde_json::{Value, json};
 
     use super::*;
-    use crate::{controller::build::properties::test_support::validated_cluster_from_spec, crd::OpaRole};
+    use crate::{
+        controller::build::properties::test_support::validated_cluster_from_spec, crd::OpaRole,
+    };
 
     /// Renders `config.json` for the `default` server role group of an `OpaCluster` built from
     /// `spec`, and parses it back into a [`Value`].
@@ -159,8 +162,14 @@ mod tests {
 
         // The bundled stackable service and its default polling values.
         assert_eq!(config["services"][0]["name"], "stackable");
-        assert_eq!(config["bundles"]["stackable"]["polling"]["min_delay_seconds"], 10);
-        assert_eq!(config["bundles"]["stackable"]["polling"]["max_delay_seconds"], 20);
+        assert_eq!(
+            config["bundles"]["stackable"]["polling"]["min_delay_seconds"],
+            10
+        );
+        assert_eq!(
+            config["bundles"]["stackable"]["polling"]["max_delay_seconds"],
+            20
+        );
         // Prometheus status metrics are enabled, decision logs are off by default.
         assert_eq!(config["status"]["prometheus"], true);
         assert!(config.get("decision_logs").is_none_or(Value::is_null));

rust/operator-binary/src/controller/build/properties/mod.rs

@@ -48,8 +48,8 @@ pub(crate) mod test_support {
             image_repository: "oci.stackable.tech/sdp".to_string(),
         };
 
-        let validated =
-            validate(&opa, &operator_environment).expect("validation should succeed for the fixture");
+        let validated = validate(&opa, &operator_environment)
+            .expect("validation should succeed for the fixture");
         (opa, validated)
     }
 }