chore: cargo fmt --all

Pure formatting changes across 6 files. No behavioral changes.

Author: Bnjoroge1

crates/aksh-conformance/src/main.rs

@@ -3,9 +3,9 @@
 use std::path::PathBuf;
 use std::process::Stdio;
 
+use aksh_gha_parser::{expand_jobs, parse_workflow};
 use anyhow::{bail, Context};
 use clap::{Parser, Subcommand};
-use aksh_gha_parser::{expand_jobs, parse_workflow};
 use tokio::process::Command;
 use walkdir::WalkDir;
 
@@ -153,11 +153,7 @@ fn looks_like_workflow(text: &str) -> bool {
     })
 }
 
-async fn compare_command(
-    upstream: String,
-    aksh: String,
-    args: Vec<String>,
-) -> anyhow::Result<()> {
+async fn compare_command(upstream: String, aksh: String, args: Vec<String>) -> anyhow::Result<()> {
     let upstream_output = Command::new(&upstream)
         .args(&args)
         .stdout(Stdio::piped())
@@ -202,7 +198,12 @@ async fn golden_compare(fixtures: PathBuf) -> anyhow::Result<()> {
     for entry in WalkDir::new(&fixtures)
         .into_iter()
         .filter_map(Result::ok)
-        .filter(|e| e.file_type().is_file() && e.path().extension().is_some_and(|ext| ext == "yml" || ext == "yaml"))
+        .filter(|e| {
+            e.file_type().is_file()
+                && e.path()
+                    .extension()
+                    .is_some_and(|ext| ext == "yml" || ext == "yaml")
+        })
     {
         let yaml_path = entry.path();
         let json_path = yaml_path.with_extension("json");
@@ -284,7 +285,10 @@ async fn replay_wire(fixtures: PathBuf) -> anyhow::Result<()> {
     eprintln!();
     eprintln!("To replay wire traffic:");
     eprintln!("  1. Record traffic with 'aksh-conformance record'");
-    eprintln!("  2. Run 'aksh-conformance replay --fixtures {}'", fixtures.display());
+    eprintln!(
+        "  2. Run 'aksh-conformance replay --fixtures {}'",
+        fixtures.display()
+    );
     eprintln!("  3. Each captured request/response is validated against our DTOs");
     Ok(())
 }
@@ -310,9 +314,8 @@ fn fuzz_parser(iterations: usize) -> anyhow::Result<()> {
         let yaml = generate_random_yaml(hash);
 
         // Parse should never panic
-        let result = std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| {
-            parse_workflow(&yaml)
-        }));
+        let result =
+            std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| parse_workflow(&yaml)));
 
         match result {
             Ok(_) => passed += 1,
@@ -334,7 +337,9 @@ fn fuzz_parser(iterations: usize) -> anyhow::Result<()> {
 fn generate_random_yaml(seed: u64) -> String {
     let mut s = seed;
     let mut next = || -> u64 {
-        s = s.wrapping_mul(6364136223846793005).wrapping_add(1442695040888963407);
+        s = s
+            .wrapping_mul(6364136223846793005)
+            .wrapping_add(1442695040888963407);
         s
     };
 
@@ -352,7 +357,8 @@ fn generate_random_yaml(seed: u64) -> String {
     };
     let step_count = (next() % 5) + 1;
 
-    let mut yaml = format!("name: {name}\non: {event}\njobs:\n  build:\n    runs-on: [{label}]\n    steps:\n");
+    let mut yaml =
+        format!("name: {name}\non: {event}\njobs:\n  build:\n    runs-on: [{label}]\n    steps:\n");
     for _ in 0..step_count {
         let cmd = match next() % 3 {
             0 => "echo hello",

crates/aksh-gha-parser/src/eval.rs

@@ -10,8 +10,8 @@
 
 use std::collections::BTreeMap;
 
-use indexmap::IndexMap;
 use aksh_gha_expressions::{eval_expression, Context};
+use indexmap::IndexMap;
 use serde_json::{Map, Value};
 
 /// Resolve all `${{ }}` expressions in a string using the given context.
@@ -148,10 +148,8 @@ pub fn build_context(
         .collect();
     ctx.insert("vars", Value::Object(vars_value));
 
-    let matrix_value: Map<String, Value> = matrix
-        .iter()
-        .map(|(k, v)| (k.clone(), v.clone()))
-        .collect();
+    let matrix_value: Map<String, Value> =
+        matrix.iter().map(|(k, v)| (k.clone(), v.clone())).collect();
     ctx.insert("matrix", Value::Object(matrix_value));
 
     ctx.insert("strategy", strategy.clone());
@@ -184,10 +182,7 @@ mod tests {
         let mut env = Map::new();
         env.insert("MY_VAR".to_owned(), Value::String("hello".to_owned()));
         ctx.insert("env", Value::Object(env));
-        ctx.insert(
-            "matrix",
-            json!({"os": "ubuntu-latest", "node": "18"}),
-        );
+        ctx.insert("matrix", json!({"os": "ubuntu-latest", "node": "18"}));
         ctx
     }
 
@@ -236,10 +231,7 @@ mod tests {
     #[test]
     fn resolve_env_value() {
         let ctx = make_context();
-        assert_eq!(
-            resolve_string("${{ env.MY_VAR }}", &ctx).unwrap(),
-            "hello"
-        );
+        assert_eq!(resolve_string("${{ env.MY_VAR }}", &ctx).unwrap(), "hello");
     }
 
     #[test]

crates/aksh-gha-parser/src/lib.rs

@@ -3,8 +3,8 @@
 use std::collections::BTreeMap;
 use std::path::{Path, PathBuf};
 
-use indexmap::IndexMap;
 use aksh_gha_protocol::{JobId, JobPlan, StepPlan};
+use indexmap::IndexMap;
 
 /// Expression evaluation for workflow fields.
 pub mod eval;
@@ -151,7 +151,9 @@ impl Trigger {
                         }
                         // paths filter
                         if let Some(path_filters) = obj.get("paths") {
-                            if !paths.is_empty() && !paths.iter().any(|p| matches_filter(path_filters, p)) {
+                            if !paths.is_empty()
+                                && !paths.iter().any(|p| matches_filter(path_filters, p))
+                            {
                                 return false;
                             }
                         }
@@ -216,9 +218,7 @@ fn glob_match(pattern: &str, value: &str) -> bool {
             return false;
         }
 
-        vi < value.len()
-            && pattern[pi] == value[vi]
-            && matches(pattern, value, pi + 1, vi + 1)
+        vi < value.len() && pattern[pi] == value[vi] && matches(pattern, value, pi + 1, vi + 1)
     }
 
     let pattern: Vec<char> = pattern.chars().collect();
@@ -773,10 +773,7 @@ fn object_entry_indexed(
             field,
         });
     };
-    Ok(map
-        .iter()
-        .map(|(k, v)| (k.clone(), v.clone()))
-        .collect())
+    Ok(map.iter().map(|(k, v)| (k.clone(), v.clone())).collect())
 }
 
 fn can_merge_include_indexed(
@@ -1006,4 +1003,3 @@ jobs:
         assert!(jobs[0].secrets_inherit);
     }
 }
-

crates/aksh-gha-protocol/src/crypto.rs

@@ -11,13 +11,13 @@
 //! Source: `MessageListener.cs` → `GetMessageDecryptor()`
 //! Source: `AgentSessionController.cs` → session creation
 
+use aes::cipher::{block_padding::Pkcs7, BlockDecryptMut, BlockEncryptMut, KeyIvInit};
 use base64::engine::general_purpose::{STANDARD as BASE64_STANDARD, URL_SAFE_NO_PAD};
 use base64::Engine;
-use aes::cipher::{block_padding::Pkcs7, BlockDecryptMut, BlockEncryptMut, KeyIvInit};
 use rsa::pkcs1::DecodeRsaPublicKey;
 use rsa::pkcs8::DecodePublicKey;
-use rsa::{BigUint, Oaep};
 use rsa::traits::PublicKeyParts;
+use rsa::{BigUint, Oaep};
 use sha1::Sha1;
 
 type Aes256CbcEnc = cbc::Encryptor<aes::Aes256>;
@@ -55,7 +55,9 @@ impl AgentRsaPublicKey {
             rsa::RsaPublicKey::from_pkcs1_pem(trimmed)
                 .map_err(|e| CryptoError::ParseKey(e.to_string()))?
         } else {
-            return Err(CryptoError::ParseKey("unsupported public key format".to_owned()));
+            return Err(CryptoError::ParseKey(
+                "unsupported public key format".to_owned(),
+            ));
         };
 
         Ok(Self { public_key })
@@ -171,7 +173,6 @@ impl AgentRsaKeypair {
     }
 }
 
-
 /// A session encryption context — holds the AES key for encrypting/decrypting
 /// message bodies within a session.
 pub struct SessionEncryption {

crates/aksh-runner-client/src/main.rs

@@ -3,9 +3,9 @@
 use std::collections::BTreeMap;
 use std::path::PathBuf;
 
+use aksh_gha_protocol::RunId;
 use anyhow::Context;
 use clap::{Parser, Subcommand};
-use aksh_gha_protocol::RunId;
 use reqwest::Url;
 use serde_json::Value;
 

crates/aksh-runner-server/src/main.rs

@@ -3,8 +3,8 @@
 use std::net::SocketAddr;
 use std::path::PathBuf;
 
-use clap::{Parser, Subcommand};
 use aksh_runner_server::{serve, ServerConfig};
+use clap::{Parser, Subcommand};
 
 #[derive(Debug, Parser)]
 #[command(name = "aksh-server")]