fmt fix

Author: nikhilsinhaparseable

src/alerts/alert_enums.rs

@@ -266,8 +266,8 @@ mod tests {
 
     #[test]
     fn alert_request_deserializes_promql_query_type() {
-        let request: crate::alerts::alert_structs::AlertRequest = serde_json::from_value(
-            serde_json::json!({
+        let request: crate::alerts::alert_structs::AlertRequest =
+            serde_json::from_value(serde_json::json!({
                 "severity": "high",
                 "title": "Test alert",
                 "alertType": "threshold",
@@ -284,9 +284,8 @@ mod tests {
                 "targets": [],
                 "notificationConfig": {"interval": 1},
                 "datasets": ["azure-prod-cluster-metrics"]
-            }),
-        )
-        .unwrap();
+            }))
+            .unwrap();
 
         assert_eq!(request.query_type, AlertQueryType::Promql);
         assert_eq!(request.datasets, vec!["azure-prod-cluster-metrics"]);

src/alerts/alert_structs.rs

@@ -346,7 +346,9 @@ impl AlertRequest {
             )));
         }
         if self.query_type == AlertQueryType::Promql
-            && !PARSEABLE.check_or_load_stream(&datasets[0], &tenant_id).await
+            && !PARSEABLE
+                .check_or_load_stream(&datasets[0], &tenant_id)
+                .await
         {
             return Err(AlertError::ValidationFailure(format!(
                 "Invalid PromQL metrics stream: {}",

src/alerts/mod.rs

@@ -108,7 +108,9 @@ pub async fn user_auth_for_alert_config(
     alert: &AlertConfig,
 ) -> Result<(), actix_web::Error> {
     match alert.query_type {
-        AlertQueryType::Builder | AlertQueryType::Code => user_auth_for_query(session, &alert.query).await,
+        AlertQueryType::Builder | AlertQueryType::Code => {
+            user_auth_for_query(session, &alert.query).await
+        }
         AlertQueryType::Promql => {
             let [dataset] = alert.datasets.as_slice() else {
                 return Err(actix_web::error::ErrorUnauthorized(

src/handlers/http/alerts.rs

@@ -20,12 +20,13 @@ use std::{collections::HashMap, str::FromStr};
 
 use crate::{
     alerts::{
-        ALERTS, AlertError, AlertState, Severity, user_auth_for_alert_config,
+        ALERTS, AlertError, AlertState, Severity,
         alert_enums::{AlertType, NotificationState},
         alert_structs::{AlertConfig, AlertRequest, AlertStateEntry, NotificationStateRequest},
         alert_traits::AlertTrait,
         alert_types::ThresholdAlert,
         target::Retry,
+        user_auth_for_alert_config,
     },
     metastore::metastore_traits::MetastoreObject,
     parseable::PARSEABLE,

src/lib.rs

@@ -68,8 +68,8 @@ use once_cell::sync::Lazy;
 pub use openid;
 use parseable::PARSEABLE;
 use reqwest::{Client, ClientBuilder};
+pub use {clap, tracing_actix_web, tracing_opentelemetry, tracing_subscriber};
 pub use {opentelemetry, opentelemetry_otlp, opentelemetry_proto, opentelemetry_sdk};
-pub use {tracing_actix_web, tracing_opentelemetry, tracing_subscriber, clap};
 
 // It is very unlikely that panic will occur when dealing with locks.
 pub const LOCK_EXPECT: &str = "Thread shouldn't panic while holding a lock";

src/metastore/metastore_traits.rs

@@ -229,7 +229,7 @@ pub trait Metastore: std::fmt::Debug + Send + Sync {
         stream_name: &str,
         get_base: bool,
         tenant_id: &Option<String>,
-        is_migration: bool
+        is_migration: bool,
     ) -> Result<Bytes, MetastoreError>;
     async fn put_stream_json(
         &self,