fix: apply cargo fmt formatting fixes

Generated by Mistral Vibe.
Co-Authored-By: Mistral Vibe <[email protected]>

Author: code-inflation

src/main.rs

@@ -26,31 +26,37 @@ fn main() {
     if options.output_format == OutputFormat::StdOut {
         println!("Starting Cloudflare speed test");
     }
-    
+
     let client = match build_http_client(&options) {
         Ok(client) => client,
         Err(e) => {
             eprintln!("Error: {}", e);
             std::process::exit(1);
         }
     };
-    
+
     speed_test(client, options);
 }
 
 fn build_http_client(options: &SpeedTestCLIOptions) -> Result<reqwest::blocking::Client, String> {
-    let mut builder = reqwest::blocking::Client::builder()
-        .timeout(std::time::Duration::from_secs(30));
-    
+    let mut builder =
+        reqwest::blocking::Client::builder().timeout(std::time::Duration::from_secs(30));
+
     if let Some(ref ip) = options.ipv4 {
-        let ip_addr = ip.parse::<IpAddr>().map_err(|e| format!("Invalid IPv4 address '{}': {}", ip, e))?;
+        let ip_addr = ip
+            .parse::<IpAddr>()
+            .map_err(|e| format!("Invalid IPv4 address '{}': {}", ip, e))?;
         builder = builder.local_address(ip_addr);
     } else if let Some(ref ip) = options.ipv6 {
-        let ip_addr = ip.parse::<IpAddr>().map_err(|e| format!("Invalid IPv6 address '{}': {}", ip, e))?;
+        let ip_addr = ip
+            .parse::<IpAddr>()
+            .map_err(|e| format!("Invalid IPv6 address '{}': {}", ip, e))?;
         builder = builder.local_address(ip_addr);
     }
-    
-    builder.build().map_err(|e| format!("Failed to initialize HTTP client: {}", e))
+
+    builder
+        .build()
+        .map_err(|e| format!("Failed to initialize HTTP client: {}", e))
 }
 
 #[cfg(test)]
@@ -64,7 +70,7 @@ mod tests {
             ipv6: None,
             ..Default::default()
         };
-        
+
         let result = build_http_client(&options);
         assert!(result.is_err());
         let err = result.unwrap_err();
@@ -79,7 +85,7 @@ mod tests {
             ipv6: Some("invalid-ipv6".to_string()),
             ..Default::default()
         };
-        
+
         let result = build_http_client(&options);
         assert!(result.is_err());
         let err = result.unwrap_err();
@@ -94,7 +100,7 @@ mod tests {
             ipv6: None,
             ..Default::default()
         };
-        
+
         let result = build_http_client(&options);
         assert!(result.is_ok());
     }
@@ -106,7 +112,7 @@ mod tests {
             ipv6: Some("::1".to_string()),
             ..Default::default()
         };
-        
+
         let result = build_http_client(&options);
         assert!(result.is_ok());
     }
@@ -118,7 +124,7 @@ mod tests {
             ipv6: None,
             ..Default::default()
         };
-        
+
         let result = build_http_client(&options);
         assert!(result.is_ok());
     }

src/speedtest.rs

@@ -201,7 +201,7 @@ pub fn test_latency(client: &Client) -> f64 {
                         return duration; // Return full duration if we can't parse server timing
                     }
                 };
-                
+
                 match re.captures(header_str) {
                     Some(captures) => match captures.get(1) {
                         Some(dur_match) => match dur_match.as_str().parse::<f64>() {
@@ -232,7 +232,7 @@ pub fn test_latency(client: &Client) -> f64 {
             return duration;
         }
     };
-    
+
     let mut req_latency = duration - cf_req_duration;
     if req_latency < 0.0 {
         log::warn!("Negative latency calculated: {req_latency}ms, using 0.0ms instead");
@@ -294,7 +294,7 @@ pub fn test_upload(client: &Client, payload_size_bytes: usize, output_format: Ou
     let url = &format!("{BASE_URL}/{UPLOAD_URL}");
     let payload: Vec<u8> = vec![1; payload_size_bytes];
     let req_builder = client.post(url).body(payload);
-    
+
     let start = Instant::now();
     let response = match req_builder.send() {
         Ok(res) => res,
@@ -306,7 +306,7 @@ pub fn test_upload(client: &Client, payload_size_bytes: usize, output_format: Ou
     let status_code = response.status();
     let duration = start.elapsed();
     let mbits = (payload_size_bytes as f64 * 8.0 / 1_000_000.0) / duration.as_secs_f64();
-    
+
     if output_format == OutputFormat::StdOut {
         print_current_speed(mbits, duration, status_code, payload_size_bytes);
     }
@@ -320,7 +320,7 @@ pub fn test_download(
 ) -> f64 {
     let url = &format!("{BASE_URL}/{DOWNLOAD_URL}{payload_size_bytes}");
     let req_builder = client.get(url);
-    
+
     let start = Instant::now();
     let response = match req_builder.send() {
         Ok(res) => res,
@@ -333,7 +333,7 @@ pub fn test_download(
     let _res_bytes = response.bytes();
     let duration = start.elapsed();
     let mbits = (payload_size_bytes as f64 * 8.0 / 1_000_000.0) / duration.as_secs_f64();
-    
+
     if output_format == OutputFormat::StdOut {
         print_current_speed(mbits, duration, status_code, payload_size_bytes);
     }