fix: rustfmt lint

Author: NickLarsenNZ

rust/bundle-builder/src/main.rs

@@ -4,12 +4,13 @@ use std::{
     sync::{Arc, Mutex},
 };
 
-use axum::{extract::State, http, response::IntoResponse, routing::get, Router};
+use axum::{Router, extract::State, http, response::IntoResponse, routing::get};
 use clap::Parser;
 use flate2::write::GzEncoder;
 use futures::{
+    FutureExt, StreamExt, TryFutureExt,
     future::{self, BoxFuture},
-    pin_mut, FutureExt, StreamExt, TryFutureExt,
+    pin_mut,
 };
 use snafu::{ResultExt, Snafu};
 use stackable_operator::{

rust/operator-binary/src/controller.rs

@@ -6,24 +6,24 @@ use std::{
 
 use const_format::concatcp;
 use indoc::formatdoc;
-use product_config::{types::PropertyNameKind, ProductConfigManager};
+use product_config::{ProductConfigManager, types::PropertyNameKind};
 use serde::{Deserialize, Serialize};
 use serde_json::json;
 use snafu::{OptionExt, ResultExt, Snafu};
 use stackable_opa_operator::crd::{
-    user_info_fetcher, v1alpha1, APP_NAME, DEFAULT_SERVER_GRACEFUL_SHUTDOWN_TIMEOUT, OPERATOR_NAME,
+    APP_NAME, DEFAULT_SERVER_GRACEFUL_SHUTDOWN_TIMEOUT, OPERATOR_NAME, user_info_fetcher, v1alpha1,
 };
 use stackable_operator::{
     builder::{
         self,
         configmap::ConfigMapBuilder,
         meta::ObjectMetaBuilder,
         pod::{
+            PodBuilder,
             container::{ContainerBuilder, FieldPathEnvVar},
             resources::ResourceRequirementsBuilder,
             security::PodSecurityContextBuilder,
             volume::VolumeBuilder,
-            PodBuilder,
         },
     },
     cluster_resources::{ClusterResourceApplyStrategy, ClusterResources},
@@ -34,6 +34,7 @@ use stackable_operator::{
         tls_verification::TlsClientDetailsError,
     },
     k8s_openapi::{
+        DeepMerge,
         api::{
             apps::v1::{DaemonSet, DaemonSetSpec},
             core::v1::{
@@ -42,12 +43,11 @@ use stackable_operator::{
             },
         },
         apimachinery::pkg::{apis::meta::v1::LabelSelector, util::intstr::IntOrString},
-        DeepMerge,
     },
     kube::{
-        core::{error_boundary, DeserializeGuard},
-        runtime::{controller::Action, reflector::ObjectRef},
         Resource as KubeResource, ResourceExt,
+        core::{DeserializeGuard, error_boundary},
+        runtime::{controller::Action, reflector::ObjectRef},
     },
     kvp::{Label, LabelError, Labels, ObjectLabels},
     logging::controller::ReconcilerError,
@@ -56,7 +56,7 @@ use stackable_operator::{
     product_logging::{
         self,
         framework::{
-            create_vector_shutdown_file_command, remove_vector_shutdown_file_command, LoggingError,
+            LoggingError, create_vector_shutdown_file_command, remove_vector_shutdown_file_command,
         },
         spec::{
             AppenderConfig, AutomaticContainerLogConfig, ContainerLogConfig,
@@ -77,7 +77,7 @@ use crate::{
     discovery::{self, build_discovery_configmaps},
     operations::graceful_shutdown::add_graceful_shutdown_config,
     product_logging::{
-        extend_role_group_config_map, resolve_vector_aggregator_address, BundleBuilderLogLevel,
+        BundleBuilderLogLevel, extend_role_group_config_map, resolve_vector_aggregator_address,
     },
 };
 
@@ -787,11 +787,9 @@ fn build_server_rolegroup_daemonset(
             "pipefail".to_string(),
             "-c".to_string(),
         ])
-        .args(vec![build_prepare_start_command(
-            merged_config,
-            &prepare_container_name,
-        )
-        .join(" && ")])
+        .args(vec![
+            build_prepare_start_command(merged_config, &prepare_container_name).join(" && "),
+        ])
         .add_volume_mount(BUNDLES_VOLUME_NAME, BUNDLES_DIR)
         .context(AddVolumeMountSnafu)?
         .add_volume_mount(LOG_VOLUME_NAME, STACKABLE_LOG_DIR)

rust/operator-binary/src/discovery.rs

@@ -4,11 +4,11 @@ use stackable_operator::{
     builder::{configmap::ConfigMapBuilder, meta::ObjectMetaBuilder},
     commons::product_image_selection::ResolvedProductImage,
     k8s_openapi::api::core::v1::{ConfigMap, Service},
-    kube::{runtime::reflector::ObjectRef, Resource, ResourceExt},
+    kube::{Resource, ResourceExt, runtime::reflector::ObjectRef},
     utils::cluster_info::KubernetesClusterInfo,
 };
 
-use crate::controller::{build_recommended_labels, APP_PORT};
+use crate::controller::{APP_PORT, build_recommended_labels};
 
 #[derive(Snafu, Debug)]
 pub enum Error {

rust/operator-binary/src/main.rs

@@ -1,28 +1,29 @@
 use std::sync::Arc;
 
-use clap::{crate_description, crate_version, Parser};
+use clap::{Parser, crate_description, crate_version};
 use futures::StreamExt;
 use product_config::ProductConfigManager;
-use stackable_opa_operator::crd::{v1alpha1, OpaCluster, APP_NAME, OPERATOR_NAME};
+use stackable_opa_operator::crd::{APP_NAME, OPERATOR_NAME, OpaCluster, v1alpha1};
 use stackable_operator::{
+    YamlSchema,
     cli::{Command, ProductOperatorRun},
     client::{self, Client},
     k8s_openapi::api::{
         apps::v1::DaemonSet,
         core::v1::{ConfigMap, Service},
     },
     kube::{
+        Api,
         core::DeserializeGuard,
         runtime::{
+            Controller,
             events::{Recorder, Reporter},
-            watcher, Controller,
+            watcher,
         },
-        Api,
     },
     logging::controller::report_controller_reconciled,
     namespace::WatchNamespace,
     shared::yaml::SerializeOptions,
-    YamlSchema,
 };
 
 use crate::controller::OPA_FULL_CONTROLLER_NAME;
@@ -127,13 +128,10 @@ async fn create_controller(
         .owns(configmaps_api, watcher::Config::default())
         .owns(services_api, watcher::Config::default());
 
-    let event_recorder = Arc::new(Recorder::new(
-        client.as_kube_client(),
-        Reporter {
-            controller: OPA_FULL_CONTROLLER_NAME.to_string(),
-            instance: None,
-        },
-    ));
+    let event_recorder = Arc::new(Recorder::new(client.as_kube_client(), Reporter {
+        controller: OPA_FULL_CONTROLLER_NAME.to_string(),
+        instance: None,
+    }));
     controller
         .run(
             controller::reconcile_opa,

rust/operator-binary/src/operations/graceful_shutdown.rs

@@ -1,5 +1,5 @@
 use snafu::{ResultExt, Snafu};
-use stackable_opa_operator::crd::{v1alpha1, SERVER_GRACEFUL_SHUTDOWN_SAFETY_OVERHEAD};
+use stackable_opa_operator::crd::{SERVER_GRACEFUL_SHUTDOWN_SAFETY_OVERHEAD, v1alpha1};
 use stackable_operator::builder::pod::PodBuilder;
 
 #[derive(Debug, Snafu)]

rust/user-info-fetcher/src/backend/active_directory.rs

@@ -8,12 +8,12 @@ use std::{
 
 use byteorder::{BigEndian, LittleEndian, ReadBytesExt};
 use hyper::StatusCode;
-use ldap3::{ldap_escape, Ldap, LdapConnAsync, LdapConnSettings, LdapError, Scope, SearchEntry};
+use ldap3::{Ldap, LdapConnAsync, LdapConnSettings, LdapError, Scope, SearchEntry, ldap_escape};
 use snafu::{OptionExt, ResultExt, Snafu};
 use stackable_operator::commons::tls_verification::TlsClientDetails;
 use uuid::Uuid;
 
-use crate::{http_error, utils, ErrorRenderUserInfoRequest, UserInfo, UserInfoRequest};
+use crate::{ErrorRenderUserInfoRequest, UserInfo, UserInfoRequest, http_error, utils};
 
 #[derive(Snafu, Debug)]
 pub enum Error {

rust/user-info-fetcher/src/backend/keycloak.rs

@@ -6,7 +6,7 @@ use snafu::{OptionExt, ResultExt, Snafu};
 use stackable_opa_operator::crd::user_info_fetcher::v1alpha1;
 use stackable_operator::commons::authentication::oidc;
 
-use crate::{http_error, utils::http::send_json_request, Credentials, UserInfo, UserInfoRequest};
+use crate::{Credentials, UserInfo, UserInfoRequest, http_error, utils::http::send_json_request};
 
 #[derive(Snafu, Debug)]
 pub enum Error {

rust/user-info-fetcher/src/backend/xfsc_aas.rs

@@ -18,7 +18,7 @@ use snafu::{ResultExt, Snafu};
 use stackable_opa_operator::crd::user_info_fetcher::v1alpha1;
 use url::Url;
 
-use crate::{http_error, utils::http::send_json_request, UserInfo, UserInfoRequest};
+use crate::{UserInfo, UserInfoRequest, http_error, utils::http::send_json_request};
 
 static API_PATH: &str = "/cip/claims";
 static SUB_CLAIM: &str = "sub";

rust/user-info-fetcher/src/http_error.rs

@@ -1,6 +1,6 @@
 use std::sync::Arc;
 
-use axum::{response::IntoResponse, Json};
+use axum::{Json, response::IntoResponse};
 use hyper::StatusCode;
 use serde::Serialize;
 

rust/user-info-fetcher/src/main.rs

@@ -5,9 +5,9 @@ use std::{
     sync::Arc,
 };
 
-use axum::{extract::State, routing::post, Json, Router};
+use axum::{Json, Router, extract::State, routing::post};
 use clap::Parser;
-use futures::{future, pin_mut, FutureExt};
+use futures::{FutureExt, future, pin_mut};
 use moka::future::Cache;
 use reqwest::ClientBuilder;
 use serde::{Deserialize, Serialize};