fmt

Author: jaronoff97

src/transforms/policy/adapter.rs

@@ -960,9 +960,7 @@ mod tests {
             Some(TypedValue::String(s)) if s == "42",
         ));
         assert!(matches!(
-            adapter.get_typed_value(&LogFieldSelector::LogAttribute(
-                vec!["flagged".to_string()],
-            )),
+            adapter.get_typed_value(&LogFieldSelector::LogAttribute(vec!["flagged".to_string()],)),
             Some(TypedValue::Bool(true)),
         ));
         assert!(matches!(
@@ -972,8 +970,10 @@ mod tests {
             Some(TypedValue::Double(d)) if (d - 1.5).abs() < 1e-9,
         ));
         // Absent attribute → None.
-        assert!(adapter
-            .get_typed_value(&LogFieldSelector::LogAttribute(vec!["missing".to_string()]))
-            .is_none());
+        assert!(
+            adapter
+                .get_typed_value(&LogFieldSelector::LogAttribute(vec!["missing".to_string()]))
+                .is_none()
+        );
     }
 }

src/transforms/policy/config.rs

@@ -453,7 +453,10 @@ path = "/dev/null"
     }
 
     fn map(pairs: &[(&str, &str)]) -> HashMap<String, String> {
-        pairs.iter().map(|(k, v)| ((*k).into(), (*v).into())).collect()
+        pairs
+            .iter()
+            .map(|(k, v)| ((*k).into(), (*v).into()))
+            .collect()
     }
 
     fn policy_config_with_metadata(client_metadata: ClientMetadata) -> PolicyConfig {

src/transforms/policy/otlp_common.rs

@@ -348,7 +348,11 @@ mod tests {
     // -- typed-value coercion -------------------------------------------
 
     fn typed_str<'a>(t: TypedValue<'a>) -> Option<Cow<'a, str>> {
-        if let TypedValue::String(s) = t { Some(s) } else { None }
+        if let TypedValue::String(s) = t {
+            Some(s)
+        } else {
+            None
+        }
     }
 
     #[test]
@@ -377,14 +381,20 @@ mod tests {
     fn any_value_typed_int_from_json_string() {
         // OTLP/JSON encodes int64 as a JSON string for JS safety.
         let av = v(json!({"intValue": "42"}));
-        assert!(matches!(any_value_typed(Some(&av)), Some(TypedValue::Int(42))));
+        assert!(matches!(
+            any_value_typed(Some(&av)),
+            Some(TypedValue::Int(42))
+        ));
     }
 
     #[test]
     fn any_value_typed_int_from_native_integer() {
         // Protobuf decoding may yield a native integer rather than a string.
         let av = v(json!({"intValue": 42}));
-        assert!(matches!(any_value_typed(Some(&av)), Some(TypedValue::Int(42))));
+        assert!(matches!(
+            any_value_typed(Some(&av)),
+            Some(TypedValue::Int(42))
+        ));
     }
 
     #[test]
@@ -442,10 +452,7 @@ mod tests {
             Some(TypedValue::Bool(true)),
         ));
         assert!(matches!(
-            find_attribute_typed_path(
-                Some(&attrs),
-                &["http".to_string(), "status".to_string()],
-            ),
+            find_attribute_typed_path(Some(&attrs), &["http".to_string(), "status".to_string()],),
             Some(TypedValue::Int(500)),
         ));
         // Missing keys still resolve to None.

src/transforms/policy/otlp_log_adapter.rs

@@ -262,7 +262,9 @@ impl Matchable for OtlpLogAdapter<'_> {
 
     fn get_typed_value(&self, field: &LogFieldSelector) -> Option<TypedValue<'_>> {
         match field {
-            LogFieldSelector::Simple(LogField::Body) => any_value_typed(self.log_record.get("body")),
+            LogFieldSelector::Simple(LogField::Body) => {
+                any_value_typed(self.log_record.get("body"))
+            }
             LogFieldSelector::Simple(LogField::Unspecified) => None,
             LogFieldSelector::Simple(_) => self.get_field(field).map(TypedValue::String),
             LogFieldSelector::LogAttribute(path)

src/transforms/policy/otlp_trace_adapter.rs

@@ -561,9 +561,8 @@ mod tests {
 
     #[test]
     fn typed_value_surfaces_int_span_attribute() {
-        let mut span = val(
-            json!({"attributes": [{"key": "http.status_code", "value": {"intValue": "500"}}]}),
-        );
+        let mut span =
+            val(json!({"attributes": [{"key": "http.status_code", "value": {"intValue": "500"}}]}));
         let adapter = TraceAdapter {
             span: &mut span,
             resource: None,