fmt

Author: tac0turtle

client/crates/types/build.rs

@@ -57,7 +57,7 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
         .btree_map(".")
         // Generate to our output directory
         .out_dir(&proto_dir)
-        .compile_protos(&proto_files, &[proto_root.clone()])?;
+        .compile_protos(&proto_files, std::slice::from_ref(&proto_root.clone()))?;
 
     println!("cargo:rerun-if-changed={}", proto_root.display());
     Ok(())

client/crates/types/src/compression.rs

@@ -87,8 +87,7 @@ pub fn decompress_blob(compressed_blob: &[u8]) -> Result<Bytes> {
         // This could be either a legacy blob or a corrupted header
         // Use heuristics to determine which
 
-        let original_size =
-            u64::from_le_bytes(compressed_blob[1..9].try_into().unwrap_or([0; 8]));
+        let original_size = u64::from_le_bytes(compressed_blob[1..9].try_into().unwrap_or([0; 8]));
 
         // If flag is in printable ASCII range (32-126) and size is unreasonable,
         // it's likely a legacy text blob
@@ -115,7 +114,7 @@ pub fn decompress_blob(compressed_blob: &[u8]) -> Result<Bytes> {
             // Decompress with ruzstd
             let mut decoder = StreamingDecoder::new(payload)
                 .map_err(|e| CompressionError::DecompressionFailed(e.to_string()))?;
-            
+
             let mut decompressed = Vec::new();
             decoder
                 .read_to_end(&mut decompressed)
@@ -229,16 +228,16 @@ mod tests {
         // Create a blob with uncompressed header
         let original_data = b"test data";
         let mut blob = Vec::with_capacity(COMPRESSION_HEADER_SIZE + original_data.len());
-        
+
         // Add header
         blob.push(FLAG_UNCOMPRESSED);
         blob.extend_from_slice(&(original_data.len() as u64).to_le_bytes());
         blob.extend_from_slice(original_data);
-        
+
         // Decompress
         let decompressed = decompress_blob(&blob).unwrap();
         assert_eq!(original_data, decompressed.as_ref());
-        
+
         // Check info
         let info = get_compression_info(&blob);
         assert!(!info.is_compressed);
@@ -252,11 +251,11 @@ mod tests {
         let mut blob = Vec::new();
         blob.push(FLAG_UNCOMPRESSED);
         blob.extend_from_slice(&100u64.to_le_bytes());
-        blob.extend_from_slice(&vec![0u8; 100]);
+        blob.extend_from_slice(&[0u8; 100]);
 
         let info = get_compression_info(&blob);
         assert!(!info.is_compressed);
         assert_eq!(info.algorithm, "none");
         assert_eq!(info.original_size, 100);
     }
-}
+}

client/crates/types/src/lib.rs

@@ -15,6 +15,4 @@ pub mod v1 {
 
 // Re-export compression types for convenience when compression is enabled
 #[cfg(feature = "compression")]
-pub use compression::{
-    decompress_blob, get_compression_info, CompressionError, CompressionInfo,
-};
+pub use compression::{decompress_blob, get_compression_info, CompressionError, CompressionInfo};

client/crates/types/tests/compression_test.rs

@@ -35,12 +35,12 @@ fn test_uncompressed_with_header() {
     // Create a blob with uncompressed header
     let original_data = b"test data";
     let mut blob = Vec::with_capacity(9 + original_data.len());
-    
+
     // Add header (flag + 8 bytes for size)
     blob.push(0x00); // FLAG_UNCOMPRESSED
     blob.extend_from_slice(&(original_data.len() as u64).to_le_bytes());
     blob.extend_from_slice(original_data);
-    
+
     // Decompress
     let decompressed = decompress_blob(&blob).unwrap();
     assert_eq!(original_data, decompressed.as_ref());
@@ -64,7 +64,7 @@ fn test_compression_info() {
 #[test]
 fn test_empty_blob() {
     let empty = vec![];
-    
+
     // Should handle empty blob gracefully
     let decompressed = decompress_blob(&empty).unwrap();
     assert_eq!(empty, decompressed.as_ref());
@@ -96,11 +96,11 @@ fn test_corrupted_blob_detection() {
     // Create a blob that looks like it has a header but is corrupted
     let mut corrupted = vec![0u8; 20];
     corrupted[0] = 0xAB; // Invalid flag that's not ASCII
-    // Set a reasonable size that suggests this was meant to be compressed
+                         // Set a reasonable size that suggests this was meant to be compressed
     let size_bytes = 1000u64.to_le_bytes();
     corrupted[1..9].copy_from_slice(&size_bytes);
 
     // Should detect as corrupted
     let result = decompress_blob(&corrupted);
     assert!(result.is_err());
-}
+}