style: fix formatting

Author: farhan-syah

nodedb-sql/src/planner/select.rs

@@ -163,8 +163,9 @@ fn plan_select(
 
     // 6. Check for GROUP BY / aggregation.
     if has_aggregation(select, functions) {
-        let mut plan =
-            super::aggregate::plan_aggregate(select, table, &filters, &scope, functions, &temporal)?;
+        let mut plan = super::aggregate::plan_aggregate(
+            select, table, &filters, &scope, functions, &temporal,
+        )?;
 
         // Semi/anti subquery joins belong below the aggregate so they filter
         // the input rows before grouping. Scalar subqueries remain above the

nodedb-strict/src/decode.rs

@@ -353,11 +353,7 @@ impl TupleDecoder {
 }
 
 /// Extract a fixed Int64 column as a raw i64.
-fn extract_i64(
-    decoder: &TupleDecoder,
-    tuple: &[u8],
-    col_idx: usize,
-) -> Result<i64, StrictError> {
+fn extract_i64(decoder: &TupleDecoder, tuple: &[u8], col_idx: usize) -> Result<i64, StrictError> {
     let raw = decoder
         .extract_fixed_raw(tuple, col_idx)?
         .ok_or(StrictError::TypeMismatch {

nodedb-strict/src/encode.rs

@@ -502,7 +502,10 @@ mod tests {
         let decoder = crate::decode::TupleDecoder::new(&schema);
         let (sys, vf, vu) = decoder.extract_bitemporal_timestamps(&tuple).unwrap();
         assert_eq!((sys, vf, vu), (100, 200, i64::MAX));
-        assert_eq!(decoder.extract_by_name(&tuple, "id").unwrap(), Value::Integer(42));
+        assert_eq!(
+            decoder.extract_by_name(&tuple, "id").unwrap(),
+            Value::Integer(42)
+        );
         assert_eq!(
             decoder.extract_by_name(&tuple, "name").unwrap(),
             Value::String("alice".into())
@@ -530,7 +533,13 @@ mod tests {
         .unwrap();
         let encoder = TupleEncoder::new(&schema);
         let err = encoder.encode_bitemporal(0, 0, 0, &[]).unwrap_err();
-        assert!(matches!(err, StrictError::ValueCountMismatch { expected: 1, got: 0 }));
+        assert!(matches!(
+            err,
+            StrictError::ValueCountMismatch {
+                expected: 1,
+                got: 0
+            }
+        ));
     }
 
     #[test]

nodedb-types/src/collection.rs

@@ -188,7 +188,7 @@ impl std::str::FromStr for CollectionType {
                     columns: vec![],
                     version: 1,
                     dropped_columns: Vec::new(),
-            bitemporal: false,
+                    bitemporal: false,
                 },
             ))),
             "columnar" => Ok(Self::columnar()),
@@ -199,7 +199,7 @@ impl std::str::FromStr for CollectionType {
                     columns: vec![],
                     version: 1,
                     dropped_columns: Vec::new(),
-            bitemporal: false,
+                    bitemporal: false,
                 },
                 ttl: None,
                 capacity_hint: 0,

nodedb-types/src/columnar/schema.rs

@@ -187,7 +187,10 @@ impl StrictSchema {
             BITEMPORAL_SYSTEM_FROM,
             ColumnType::Int64,
         ));
-        columns.push(ColumnDef::required(BITEMPORAL_VALID_FROM, ColumnType::Int64));
+        columns.push(ColumnDef::required(
+            BITEMPORAL_VALID_FROM,
+            ColumnType::Int64,
+        ));
         columns.push(ColumnDef::required(
             BITEMPORAL_VALID_UNTIL,
             ColumnType::Int64,

nodedb/src/bridge/physical_plan/wire.rs

@@ -169,8 +169,8 @@ mod tests {
             gap_fill: "null".into(),
             computed_columns: vec![],
             rls_filters: vec![],
-                system_as_of_ms: None,
-                valid_at_ms: None,
+            system_as_of_ms: None,
+            valid_at_ms: None,
         }));
     }
 

nodedb/src/control/planner/auto_tier.rs

@@ -225,8 +225,8 @@ fn build_scan_task(
             gap_fill: gap_fill.to_string(),
             computed_columns: Vec::new(),
             rls_filters: Vec::new(),
-                system_as_of_ms: None,
-                valid_at_ms: None,
+            system_as_of_ms: None,
+            valid_at_ms: None,
         }),
         post_set_op: PostSetOp::None,
     }

nodedb/src/control/server/native/dispatch/plan_builder/timeseries.rs

@@ -31,8 +31,8 @@ pub(crate) fn build_scan(fields: &TextFields, collection: &str) -> crate::Result
         gap_fill: String::new(),
         computed_columns: Vec::new(),
         rls_filters: Vec::new(),
-                system_as_of_ms: None,
-                valid_at_ms: None,
+        system_as_of_ms: None,
+        valid_at_ms: None,
     }))
 }
 

nodedb/src/control/server/pgwire/ddl/collection/create/handler.rs

@@ -87,9 +87,8 @@ pub fn create_collection(
     let collection_type = if upper.contains("TYPE") && upper.contains("KEY_VALUE") {
         super::super::super::kv::parse_kv_collection(sql, &upper)?
     } else if upper.contains("TYPE") && upper.contains("STRICT") {
-        let schema =
-            super::super::helpers::parse_typed_schema_with_flags(sql, bitemporal_flag)
-                .map_err(|e| sqlstate_error("42601", &e))?;
+        let schema = super::super::helpers::parse_typed_schema_with_flags(sql, bitemporal_flag)
+            .map_err(|e| sqlstate_error("42601", &e))?;
         nodedb_types::CollectionType::strict(schema)
     } else if upper.contains("TYPE") && upper.contains("COLUMNAR") {
         resolve_columnar(sql, &upper, &mut columnar_schema_columns)

nodedb/src/control/server/pgwire/ddl/convert.rs

@@ -93,7 +93,7 @@ pub async fn convert_collection(
                 columns,
                 version: 1,
                 dropped_columns: Vec::new(),
-            bitemporal: false,
+                bitemporal: false,
             };
             if target_type == "kv" {
                 nodedb_types::CollectionType::kv(schema)