style: apply cargo fmt across all sources

Run `cargo fmt --all` to satisfy the `cargo fmt --check` step in CI.
Reflows long function signatures, struct literals, and macro arguments
to fit rustfmt's default column width, and expands single-line
if/else and let-else bindings into block form. No behavioral changes.

Author: NullSablex

src/https.rs

@@ -68,13 +68,7 @@ static JOB_TX: LazyLock<Sender<Job>> = LazyLock::new(|| {
 });
 
 /// Submits a request. Falls back to a one-off thread if the worker pool is saturated.
-pub fn start_request(
-    index: i32,
-    method: String,
-    url: String,
-    body: BodyPayload,
-    callback: String,
-) {
+pub fn start_request(index: i32, method: String, url: String, body: BodyPayload, callback: String) {
     let headers: Vec<(String, String)> = state::snapshot_headers().into_iter().collect();
     let job = Job {
         index,
@@ -222,7 +216,13 @@ fn run_job(job: Job) {
 
         if method == "HEAD" {
             let resp_headers = extract_response_headers(&resp);
-            finish_ok(index, &callback, String::new(), status.as_u16() as i32, resp_headers);
+            finish_ok(
+                index,
+                &callback,
+                String::new(),
+                status.as_u16() as i32,
+                resp_headers,
+            );
             return;
         }
 

src/lib.rs

@@ -18,7 +18,9 @@ pub struct Plugin {
 
 impl Plugin {
     fn new() -> Self {
-        Self { amx_list: Vec::new() }
+        Self {
+            amx_list: Vec::new(),
+        }
     }
 }
 

src/natives.rs

@@ -206,7 +206,10 @@ impl Plugin {
         key: &AmxString,
         value: &AmxString,
     ) -> AmxResult<bool> {
-        Ok(state::add_multipart_text(key.to_string(), value.to_string()))
+        Ok(state::add_multipart_text(
+            key.to_string(),
+            value.to_string(),
+        ))
     }
 
     /// Appends a file field to the multipart/form-data builder. The file is

src/state.rs

@@ -98,7 +98,14 @@ pub fn enqueue_response(
         if q.len() >= MAX_QUEUE {
             q.pop_front();
         }
-        q.push_back(HttpsResponse { index, callback, response, status, error, headers });
+        q.push_back(HttpsResponse {
+            index,
+            callback,
+            response,
+            status,
+            error,
+            headers,
+        });
     }
 }
 
@@ -155,7 +162,11 @@ pub fn set_timeout_once(total_ms: u64) {
 
 pub fn take_timeout_once() -> Option<Duration> {
     let ms = PENDING_TIMEOUT_MS.swap(0, Ordering::AcqRel);
-    if ms == 0 { None } else { Some(Duration::from_millis(ms)) }
+    if ms == 0 {
+        None
+    } else {
+        Some(Duration::from_millis(ms))
+    }
 }
 
 // ============================================================================
@@ -330,7 +341,10 @@ static COOKIE_JAR: LazyLock<Mutex<Arc<Jar>>> =
     LazyLock::new(|| Mutex::new(Arc::new(Jar::default())));
 
 fn cookie_jar() -> Arc<Jar> {
-    COOKIE_JAR.lock().map(|j| j.clone()).unwrap_or_else(|_| Arc::new(Jar::default()))
+    COOKIE_JAR
+        .lock()
+        .map(|j| j.clone())
+        .unwrap_or_else(|_| Arc::new(Jar::default()))
 }
 
 pub fn set_cookies_enabled(enabled: bool) {
@@ -386,9 +400,10 @@ fn rebuild_active_client() {
 }
 
 pub fn active_client() -> Arc<Client> {
-    ACTIVE_CLIENT.lock().map(|c| c.clone()).unwrap_or_else(|_| {
-        Arc::new(build_client(None, false).expect("fallback default client"))
-    })
+    ACTIVE_CLIENT
+        .lock()
+        .map(|c| c.clone())
+        .unwrap_or_else(|_| Arc::new(build_client(None, false).expect("fallback default client")))
 }
 
 pub fn set_mtls_identity_pem(pem: &[u8]) -> bool {

src/util.rs

@@ -24,7 +24,10 @@ pub fn print_banner() {
     samp::log::info!("");
     samp::log::info!("  | {} {} | {}", name, version, build_year);
     samp::log::info!("  |-------------------------------");
-    samp::log::info!("  | Author and maintainer: {}", value_or(authors, "Unknown"));
+    samp::log::info!(
+        "  | Author and maintainer: {}",
+        value_or(authors, "Unknown")
+    );
     samp::log::info!("");
     samp::log::info!("  | Compiled: {} at {}", build_date, build_time);
     samp::log::info!("  |-------------------------------");
@@ -65,10 +68,14 @@ fn dispatch_one(amx_list: &[AmxIdent], item: HttpsResponse) {
     let mut delivered = false;
     for ident in amx_list {
         let Some(amx) = get_amx(*ident) else { continue };
-        let Ok(func) = amx.find_public(&item.callback) else { continue };
+        let Ok(func) = amx.find_public(&item.callback) else {
+            continue;
+        };
 
         let allocator = amx.allocator();
-        let Ok(amx_str) = allocator.allot_string(&item.response) else { continue };
+        let Ok(amx_str) = allocator.allot_string(&item.response) else {
+            continue;
+        };
 
         if amx.push(item.error).is_err()
             || amx.push(item.status).is_err()