chore: rustfmt (#53)

Author: freeman94

examples/read_sbf.rs

@@ -1,4 +1,4 @@
-use libsbf::{Messages, reader::SbfReader};
+use libsbf::{reader::SbfReader, Messages};
 
 use clap::Parser;
 use std::collections::HashMap;
@@ -12,7 +12,7 @@ use tracing_subscriber::EnvFilter;
 #[command(author, version, about, long_about = None)]
 struct Args {
     /// Input source: file path or TCP address (host:port)
-    /// 
+    ///
     /// Examples:
     ///   - /path/to/file.sbf (read from file)
     ///   - 192.168.1.100:5555 (connect to TCP)
@@ -30,9 +30,9 @@ fn main() -> anyhow::Result<()> {
         .with_env_filter(EnvFilter::from_default_env())
         .with_writer(std::io::stderr)
         .init();
-    
+
     let args = Args::parse();
-    
+
     // Check if argument looks like a file path or TCP address
     let reader: Box<dyn Read> = if args.input.contains(':') {
         eprintln!("Connecting to TCP: {}", args.input);
@@ -41,7 +41,7 @@ fn main() -> anyhow::Result<()> {
         eprintln!("Reading from file: {}", args.input);
         Box::new(File::open(args.input)?)
     };
-    
+
     let sbf_reader = SbfReader::new(reader);
     let mut stats: HashMap<&str, usize> = HashMap::new();
     let mut unsupported_blocks: HashMap<u16, usize> = HashMap::new();
@@ -87,19 +87,31 @@ fn main() -> anyhow::Result<()> {
             }
             Messages::Meas3Ranges(msg) => {
                 if args.verbose {
-                    println!("Meas3Ranges: TOW={:?}, raw_bytes={}", msg.tow, msg.raw_data.len());
+                    println!(
+                        "Meas3Ranges: TOW={:?}, raw_bytes={}",
+                        msg.tow,
+                        msg.raw_data.len()
+                    );
                 }
                 *stats.entry("Meas3Ranges").or_insert(0) += 1;
             }
             Messages::Meas3Doppler(msg) => {
                 if args.verbose {
-                    println!("Meas3Doppler: TOW={:?}, raw_bytes={}", msg.tow, msg.raw_data.len());
+                    println!(
+                        "Meas3Doppler: TOW={:?}, raw_bytes={}",
+                        msg.tow,
+                        msg.raw_data.len()
+                    );
                 }
                 *stats.entry("Meas3Doppler").or_insert(0) += 1;
             }
             Messages::INSSupport(msg) => {
                 if args.verbose {
-                    println!("INSSupport: TOW={:?}, raw_bytes={}", msg.tow, msg.raw_data.len());
+                    println!(
+                        "INSSupport: TOW={:?}, raw_bytes={}",
+                        msg.tow,
+                        msg.raw_data.len()
+                    );
                 }
                 *stats.entry("INSSupport").or_insert(0) += 1;
             }
@@ -242,15 +254,15 @@ fn main() -> anyhow::Result<()> {
             }
         }
     }
-    
+
     // Print statistics
     eprintln!("\n=== Message Statistics ===");
     let total: usize = stats.values().sum();
     for (msg_type, count) in stats.iter() {
         eprintln!("{}: {}", msg_type, count);
     }
     eprintln!("Total messages: {}", total);
-    
+
     // Print unsupported blocks
     if !unsupported_blocks.is_empty() {
         eprintln!("\n=== Unsupported Block IDs ===");
@@ -260,14 +272,14 @@ fn main() -> anyhow::Result<()> {
             eprintln!("  0x{:04X} ({}): {} occurrences", block_id, block_id, count);
         }
     }
-    
+
     // Print AttCovEuler error distribution
     if !att_cov_errors.is_empty() {
         eprintln!("\n=== AttCovEuler Error Distribution ===");
         for (error_code, count) in att_cov_errors.iter() {
             eprintln!("  Error {}: {} occurrences", error_code, count);
         }
     }
-    
+
     Ok(())
 }

sbf-parser-fuzz/src/main.rs

@@ -3,7 +3,7 @@ use afl::*;
 use libsbf::parser::SbfParser;
 
 fn main() {
-    fuzz!(|data: &[u8]|{
+    fuzz!(|data: &[u8]| {
         let mut parser = SbfParser::new();
 
         match parser.consume(data) {
@@ -17,4 +17,3 @@ fn main() {
         }
     })
 }
-

sbf-parser-fuzz/src/reader-fuzz.rs

@@ -7,7 +7,7 @@ fn main() {
     fuzz!(|data: &[u8]| {
         // Test with the original fuzz data
         test_sbf_reader(data);
-        
+
         // Also test with larger data to catch buffer-related bugs
         if (0..20000).contains(&data.len()) {
             // Create a larger test case by repeating the data
@@ -24,16 +24,16 @@ fn test_sbf_reader(data: &[u8]) {
     // Create a simple reader from the fuzz data
     let mut reader = FuzzReader::new(data);
     let total_bytes = reader.len();
-    
+
     // Skip empty data
     if total_bytes == 0 {
         return;
     }
-    
+
     // Process all messages from the SbfReader
     let sbf_reader = SbfReader::new(&mut reader);
     let mut message_count = 0;
-    
+
     for result in sbf_reader {
         match result {
             Ok(_msg) => {
@@ -44,12 +44,14 @@ fn test_sbf_reader(data: &[u8]) {
             }
         }
     }
-    
+
     // The reader should have consumed all the data
     let bytes_consumed = reader.bytes_read();
-    assert_eq!(bytes_consumed, total_bytes, 
-        "SbfReader did not consume all {} bytes of fuzz data, only consumed {}", 
-        total_bytes, bytes_consumed);
+    assert_eq!(
+        bytes_consumed, total_bytes,
+        "SbfReader did not consume all {} bytes of fuzz data, only consumed {}",
+        total_bytes, bytes_consumed
+    );
 }
 
 // A simple reader that provides all fuzz data at once
@@ -65,11 +67,11 @@ impl FuzzReader {
             position: 0,
         }
     }
-    
+
     fn len(&self) -> usize {
         self.data.len()
     }
-    
+
     fn bytes_read(&self) -> usize {
         self.position
     }
@@ -79,12 +81,12 @@ impl Read for FuzzReader {
     fn read(&mut self, buf: &mut [u8]) -> std::io::Result<usize> {
         let remaining = self.data.len() - self.position;
         let to_read = buf.len().min(remaining);
-        
+
         if to_read > 0 {
             buf[..to_read].copy_from_slice(&self.data[self.position..self.position + to_read]);
             self.position += to_read;
         }
-        
+
         Ok(to_read)
     }
 }

src/lib.rs

@@ -12,8 +12,8 @@ use binrw::binrw;
 
 extern crate alloc;
 
-pub mod parser;
 pub mod messages;
+pub mod parser;
 
 #[cfg(feature = "std")]
 #[cfg_attr(docsrs, doc(cfg(feature = "std")))]
@@ -24,46 +24,23 @@ mod mega_test;
 
 // Constants for DO_NOT_USE values
 const DO_NOT_USE_I2: i16 = -32768;
-const DO_NOT_USE_U1: u8  = 255;
+const DO_NOT_USE_U1: u8 = 255;
 const DO_NOT_USE_U2: u16 = 65535;
 const DO_NOT_USE_U4: u32 = 4294967295;
 const DO_NOT_USE_F4: f32 = -2e10;
 const DO_NOT_USE_F8: f64 = -2e10;
 
 // Re-export all message types at crate level
 pub use messages::{
-    MeasEpoch, MeasEpochChannelType1, MeasEpochChannelType2,
-    MeasExtra, MeasExtraChannelSub,
-    Meas3Ranges, Meas3Doppler,
-    DiffCorrIn,
-    INSSupport,
-    INSNavGeod, INSNavGeodPosStdDev, INSNavGeodAtt, INSNavGeodAttStdDev,
-    INSNavGeodVel, INSNavGeodVelStdDev, INSNavGeodPosCov, INSNavGeodVelCov,
-    INSNavGeodAttCov,
-    AttEuler, AttCovEuler,
-    ExtSensorMeas, ExtSensorMeasSet, ExtSensorMeasAcceleration,
-    ExtSensorMeasAngularRate, ExtSensorMeasVelocity, ExtSensorMeasInfo,
-    ExtSensorMeasZeroVelocityFlag, ExtSensorMeasSetType,
-    QualityInd,
-    ImuSetup,
-    ReceiverSetup,
-    GEORawL1, GEONav,
-    PosCovGeodetic,
-    PVTGeodetic,
-    ReceiverStatus, AGCState,
-    ExtSensorStatus,
-    GALIon,
-    GALUtc,
-    GPSIon,
-    GPSUtc,
-    VelSensorSetup,
-    ExtSensorInfo,
-    GALNav,
-    GALGstGps,
-    GPSNav,
-    Commands,
-    BDSIon,
-    GPSCNav,
+    AGCState, AttCovEuler, AttEuler, BDSIon, Commands, DiffCorrIn, ExtSensorInfo, ExtSensorMeas,
+    ExtSensorMeasAcceleration, ExtSensorMeasAngularRate, ExtSensorMeasInfo, ExtSensorMeasSet,
+    ExtSensorMeasSetType, ExtSensorMeasVelocity, ExtSensorMeasZeroVelocityFlag, ExtSensorStatus,
+    GALGstGps, GALIon, GALNav, GALUtc, GEONav, GEORawL1, GPSCNav, GPSIon, GPSNav, GPSUtc,
+    INSNavGeod, INSNavGeodAtt, INSNavGeodAttCov, INSNavGeodAttStdDev, INSNavGeodPosCov,
+    INSNavGeodPosStdDev, INSNavGeodVel, INSNavGeodVelCov, INSNavGeodVelStdDev, INSSupport,
+    ImuSetup, Meas3Doppler, Meas3Ranges, MeasEpoch, MeasEpochChannelType1, MeasEpochChannelType2,
+    MeasExtra, MeasExtraChannelSub, PVTGeodetic, PosCovGeodetic, QualityInd, ReceiverSetup,
+    ReceiverStatus, VelSensorSetup,
 };
 
 #[binrw]
@@ -162,4 +139,4 @@ define_messages!(
 
 pub fn is_sync(bytes: &[u8; 2]) -> bool {
     bytes == b"$@"
-}
+}