style: cargo fmt --all

Co-Authored-By: Oz <oz-agent@warp.dev>

Author: tbitcs

crates/cpac-crypto/src/pqc.rs

@@ -225,9 +225,9 @@ fn keygen_mldsa65() -> CpacResult<PqcKeyPair> {
 
 fn sign_mldsa65(message: &[u8], secret_key: &[u8]) -> CpacResult<Vec<u8>> {
     use ml_dsa::{MlDsa65, Seed, SigningKey};
-    let seed: Seed = secret_key
-        .try_into()
-        .map_err(|_| CpacError::Encryption("invalid ML-DSA-65 seed length (expected 32 bytes)".into()))?;
+    let seed: Seed = secret_key.try_into().map_err(|_| {
+        CpacError::Encryption("invalid ML-DSA-65 seed length (expected 32 bytes)".into())
+    })?;
     let sk = SigningKey::<MlDsa65>::from_seed(&seed);
     let sig = sk
         .sign_deterministic(message, &[])

crates/cpac-engine/src/lib.rs

@@ -452,8 +452,7 @@ pub fn compress(data: &[u8], config: &CompressConfig) -> CpacResult<CompressResu
     // per-block frame.  The frame stores original_size = residual size so the
     // per-block decompressor returns the residual directly.  The caller
     // (compress_parallel) stores metadata once and applies reconstruction.
-    let msn_applied_externally =
-        config.msn_metadata_external && !msn_metadata.is_empty();
+    let msn_applied_externally = config.msn_metadata_external && !msn_metadata.is_empty();
     if msn_applied_externally {
         cpac_trace!(
             "[TRACE] Phase 2: MSN applied externally — metadata excluded from frame ({}B meta, {}B residual)",
@@ -1022,8 +1021,7 @@ pub(crate) fn decompress_with_dict(
     let (header, payload) = cpac_frame::decode_frame(data)?;
 
     // 2. Entropy decompress with dictionary
-    let decompressed_payload =
-        cpac_entropy::decompress_with_dict(payload, header.backend, dict)?;
+    let decompressed_payload = cpac_entropy::decompress_with_dict(payload, header.backend, dict)?;
 
     // 2.5 MSN inline metadata split
     let (inline_meta_bytes, data_to_unpreprocess) =
@@ -1046,8 +1044,7 @@ pub(crate) fn decompress_with_dict(
     let mut result = if header.dag_descriptor.is_empty() {
         cpac_transforms::unpreprocess(&data_to_unpreprocess, &[])
     } else {
-        let (ids, metas, _consumed) =
-            cpac_dag::deserialize_dag_descriptor(&header.dag_descriptor)?;
+        let (ids, metas, _consumed) = cpac_dag::deserialize_dag_descriptor(&header.dag_descriptor)?;
         let registry = cached_transform_registry();
         let dag = TransformDAG::compile_from_ids(registry, &ids)?;
         let meta_chain: Vec<(u8, Vec<u8>)> = ids.into_iter().zip(metas).collect();

crates/cpac-engine/src/parallel.rs

@@ -189,9 +189,11 @@ pub fn compress_parallel(
         // limit; truncating the probe is safe because we only need enough
         // data to detect the domain and build the field map.
         let probe_len = blocks[0].len().min(cpac_msn::MAX_DOMAIN_EXTRACT_SIZE);
-        if let Ok(probe_result) =
-            cpac_msn::extract(&blocks[0][..probe_len], probe_filename, config.msn_confidence)
-        {
+        if let Ok(probe_result) = cpac_msn::extract(
+            &blocks[0][..probe_len],
+            probe_filename,
+            config.msn_confidence,
+        ) {
             cpac_trace!(
                 "[TRACE] parallel MSN probe: applied={} domain={:?} conf={:.3} fields={}",
                 probe_result.applied,
@@ -216,8 +218,7 @@ pub fn compress_parallel(
                 // transform selection (logged for now; future phases use for projection).
                 let typed_cols = probe_result.typed_columns();
                 if !typed_cols.is_empty() {
-                    let analysis =
-                        cpac_cas::analyze_columns(&typed_cols.int_columns);
+                    let analysis = cpac_cas::analyze_columns(&typed_cols.int_columns);
                     cpac_trace!(
                         "[TRACE] Phase 6: CAS bridge → {} int cols, {} constraints, benefit={:.3}",
                         typed_cols.int_columns.len(),
@@ -230,11 +231,7 @@ pub fn compress_parallel(
                     );
                     for (col_name, constraints) in &analysis.constraints {
                         for c in constraints {
-                            cpac_trace!(
-                                "[TRACE] Phase 6: CAS col '{}': {:?}",
-                                col_name,
-                                c
-                            );
+                            cpac_trace!("[TRACE] Phase 6: CAS col '{}': {:?}", col_name, c);
                         }
                     }
                     // Also analyze string columns for enumeration/length constraints
@@ -275,10 +272,7 @@ pub fn compress_parallel(
         && config.dictionary.is_none()
     {
         let sample_count = block_count.min(DICT_TRAIN_MAX_BLOCKS);
-        let samples: Vec<Vec<u8>> = blocks[..sample_count]
-            .iter()
-            .map(|b| b.to_vec())
-            .collect();
+        let samples: Vec<Vec<u8>> = blocks[..sample_count].iter().map(|b| b.to_vec()).collect();
         match cpac_dict::CpacDictionary::train(&samples, DICT_MAX_SIZE) {
             Ok(dict) => {
                 cpac_trace!(

crates/cpac-engine/tests/phase1_bwt_parallel.rs

@@ -14,12 +14,7 @@ fn roundtrip_block_size_text_with_smart_transforms() {
     let sentence = b"The quick brown fox jumps over the lazy dog. ";
     // 17 MB — the approximate per-block size the parallel path would create
     let block_size = 17 * 1024 * 1024;
-    let data: Vec<u8> = sentence
-        .iter()
-        .copied()
-        .cycle()
-        .take(block_size)
-        .collect();
+    let data: Vec<u8> = sentence.iter().copied().cycle().take(block_size).collect();
 
     let config = CompressConfig {
         backend: Some(Backend::Zstd),
@@ -57,12 +52,7 @@ fn roundtrip_block_size_json_with_smart_transforms() {
     let record = br#"{"name": "Alice", "age": 30, "city": "New York", "active": true}
 "#;
     let block_size = 17 * 1024 * 1024;
-    let data: Vec<u8> = record
-        .iter()
-        .copied()
-        .cycle()
-        .take(block_size)
-        .collect();
+    let data: Vec<u8> = record.iter().copied().cycle().take(block_size).collect();
 
     let config = CompressConfig {
         backend: Some(Backend::Zstd),

crates/cpac-msn/src/lib.rs

@@ -164,19 +164,13 @@ impl MsnResult {
             match value {
                 serde_json::Value::Array(arr) if !arr.is_empty() => {
                     // Try as all-integer
-                    let ints: Vec<i64> = arr
-                        .iter()
-                        .filter_map(|v| v.as_i64())
-                        .collect();
+                    let ints: Vec<i64> = arr.iter().filter_map(|v| v.as_i64()).collect();
                     if ints.len() == arr.len() {
                         cols.int_columns.push((name.clone(), ints));
                         continue;
                     }
                     // Try as all-float (numbers including decimals)
-                    let floats: Vec<f64> = arr
-                        .iter()
-                        .filter_map(|v| v.as_f64())
-                        .collect();
+                    let floats: Vec<f64> = arr.iter().filter_map(|v| v.as_f64()).collect();
                     if floats.len() == arr.len() {
                         cols.float_columns.push((name.clone(), floats));
                         continue;

crates/cpac-transforms/src/conditioned_bwt.rs

@@ -103,8 +103,7 @@ impl TransformNode for ConditionedBwtTransform {
                     if stream.len() >= MIN_STREAM_SIZE && stream.len() <= bwt::BWT_MAX_SIZE {
                         // Try BWT+MTF+RLE on this stream
                         if let Ok((bwt_data, original_idx)) = bwt::bwt_encode(stream) {
-                            let mtf_data = mtf::mtf_encode(&bwt_data)
-                                .unwrap_or(bwt_data);
+                            let mtf_data = mtf::mtf_encode(&bwt_data).unwrap_or(bwt_data);
                             let (rle_data, _) = rle::rle_encode(&mtf_data);
 
                             // Only apply if it actually helps
@@ -220,7 +219,9 @@ mod tests {
         // Mix of text and structured data
         let mut data = Vec::new();
         data.extend_from_slice(
-            b"The quick brown fox jumps over the lazy dog. ".repeat(15).as_slice(),
+            b"The quick brown fox jumps over the lazy dog. "
+                .repeat(15)
+                .as_slice(),
         );
         // Add some numeric/structural bytes
         for i in 0u8..200 {
@@ -229,7 +230,9 @@ mod tests {
             data.push(0xFF);
         }
         data.extend_from_slice(
-            b"Another repeated text segment for testing. ".repeat(10).as_slice(),
+            b"Another repeated text segment for testing. "
+                .repeat(10)
+                .as_slice(),
         );
 
         let ctx = TransformContext {