style: cargo fmt on smoke test files

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: maxine-at-forecast

crosslink/tests/smoke/concurrency.rs

@@ -25,7 +25,13 @@ use std::time::Duration;
 // ============================================================================
 
 /// Send a raw HTTP/1.1 request and return `(status_code, body_string)`.
-fn http_request(port: u16, method: &str, path: &str, body: Option<&str>, auth_token: Option<&str>) -> (u16, String) {
+fn http_request(
+    port: u16,
+    method: &str,
+    path: &str,
+    body: Option<&str>,
+    auth_token: Option<&str>,
+) -> (u16, String) {
     let mut stream =
         TcpStream::connect(format!("127.0.0.1:{}", port)).expect("Failed to connect to server");
     stream.set_read_timeout(Some(Duration::from_secs(10))).ok();
@@ -145,7 +151,13 @@ fn test_concurrent_api_creates_10() {
                     r#"{{"title": "Concurrent issue {}", "priority": "medium"}}"#,
                     i
                 );
-                http_request(port, "POST", "/api/v1/issues", Some(&payload), token.as_deref())
+                http_request(
+                    port,
+                    "POST",
+                    "/api/v1/issues",
+                    Some(&payload),
+                    token.as_deref(),
+                )
             })
         })
         .collect();

crosslink/tests/smoke/harness.rs

@@ -254,7 +254,10 @@ impl SmokeHarness {
 
         // Read stdout in a background thread to capture the auth token.
         // The server prints "Auth:      Bearer <token>" on startup.
-        let stdout = child.stdout.take().expect("failed to capture server stdout");
+        let stdout = child
+            .stdout
+            .take()
+            .expect("failed to capture server stdout");
         let (token_tx, token_rx) = std::sync::mpsc::channel();
         std::thread::spawn(move || {
             use std::io::{BufRead, BufReader};

crosslink/tests/smoke/server_api.rs

@@ -23,12 +23,7 @@ fn http_request(port: u16, method: &str, path: &str, body: Option<&str>) -> (u16
     http_request_with_auth(port, method, path, body, None)
 }
 
-fn authed_request(
-    h: &SmokeHarness,
-    method: &str,
-    path: &str,
-    body: Option<&str>,
-) -> (u16, String) {
+fn authed_request(h: &SmokeHarness, method: &str, path: &str, body: Option<&str>) -> (u16, String) {
     http_request_with_auth(
         h.server_port.expect("server not started"),
         method,
@@ -234,7 +229,7 @@ fn test_api_get_issue() {
 
     let _port = h.start_server();
 
-    let (status, body) = authed_request(&h,"GET", "/api/v1/issues/1", None);
+    let (status, body) = authed_request(&h, "GET", "/api/v1/issues/1", None);
     assert_eq!(status, 200, "GET issue should return 200");
 
     let json = parse_json(&body);
@@ -258,7 +253,7 @@ fn test_api_list_issues() {
 
     let _port = h.start_server();
 
-    let (status, body) = authed_request(&h,"GET", "/api/v1/issues", None);
+    let (status, body) = authed_request(&h, "GET", "/api/v1/issues", None);
     assert_eq!(status, 200);
 
     let json = parse_json(&body);
@@ -281,15 +276,15 @@ fn test_api_update_issue() {
     let _port = h.start_server();
 
     let payload = r#"{"title": "Updated title", "priority": "high"}"#;
-    let (status, body) = authed_request(&h,"PATCH", "/api/v1/issues/1", Some(payload));
+    let (status, body) = authed_request(&h, "PATCH", "/api/v1/issues/1", Some(payload));
     assert_eq!(status, 200, "PATCH should return 200");
 
     let json = parse_json(&body);
     assert_eq!(json["title"], "Updated title");
     assert_eq!(json["priority"], "high");
 
     // Verify the update persisted by fetching the issue again.
-    let (status2, body2) = authed_request(&h,"GET", "/api/v1/issues/1", None);
+    let (status2, body2) = authed_request(&h, "GET", "/api/v1/issues/1", None);
     assert_eq!(status2, 200);
     let json2 = parse_json(&body2);
     assert_eq!(json2["title"], "Updated title");
@@ -304,17 +299,17 @@ fn test_api_delete_issue() {
     let _port = h.start_server();
 
     // Verify it exists first.
-    let (status, _) = authed_request(&h,"GET", "/api/v1/issues/1", None);
+    let (status, _) = authed_request(&h, "GET", "/api/v1/issues/1", None);
     assert_eq!(status, 200);
 
     // Delete it.
-    let (status, body) = authed_request(&h,"DELETE", "/api/v1/issues/1", None);
+    let (status, body) = authed_request(&h, "DELETE", "/api/v1/issues/1", None);
     assert_eq!(status, 200, "DELETE should return 200");
     let json = parse_json(&body);
     assert_eq!(json["ok"], true);
 
     // Verify it's gone.
-    let (status, _) = authed_request(&h,"GET", "/api/v1/issues/1", None);
+    let (status, _) = authed_request(&h, "GET", "/api/v1/issues/1", None);
     assert_eq!(status, 404, "Deleted issue should return 404");
 }
 
@@ -326,24 +321,24 @@ fn test_api_close_reopen() {
     let _port = h.start_server();
 
     // Close the issue.
-    let (status, body) = authed_request(&h,"POST", "/api/v1/issues/1/close", None);
+    let (status, body) = authed_request(&h, "POST", "/api/v1/issues/1/close", None);
     assert_eq!(status, 200, "Close should return 200");
     let json = parse_json(&body);
     assert_eq!(json["status"], "closed");
 
     // Verify via GET.
-    let (_, body) = authed_request(&h,"GET", "/api/v1/issues/1", None);
+    let (_, body) = authed_request(&h, "GET", "/api/v1/issues/1", None);
     let json = parse_json(&body);
     assert_eq!(json["status"], "closed");
 
     // Reopen.
-    let (status, body) = authed_request(&h,"POST", "/api/v1/issues/1/reopen", None);
+    let (status, body) = authed_request(&h, "POST", "/api/v1/issues/1/reopen", None);
     assert_eq!(status, 200, "Reopen should return 200");
     let json = parse_json(&body);
     assert_eq!(json["status"], "open");
 
     // Verify via GET again.
-    let (_, body) = authed_request(&h,"GET", "/api/v1/issues/1", None);
+    let (_, body) = authed_request(&h, "GET", "/api/v1/issues/1", None);
     let json = parse_json(&body);
     assert_eq!(json["status"], "open");
 }
@@ -357,7 +352,7 @@ fn test_api_404_unknown() {
     let mut h = SmokeHarness::new();
     let _port = h.start_server();
 
-    let (status, _) = authed_request(&h,"GET", "/api/v1/nonexistent", None);
+    let (status, _) = authed_request(&h, "GET", "/api/v1/nonexistent", None);
     assert_eq!(
         status, 404,
         "Unknown API path should return 404, got {}",
@@ -370,7 +365,7 @@ fn test_api_issue_not_found() {
     let mut h = SmokeHarness::new();
     let _port = h.start_server();
 
-    let (status, body) = authed_request(&h,"GET", "/api/v1/issues/99999", None);
+    let (status, body) = authed_request(&h, "GET", "/api/v1/issues/99999", None);
     assert_eq!(status, 404, "Non-existent issue should return 404");
 
     let json = parse_json(&body);
@@ -406,15 +401,15 @@ fn test_api_sessions() {
     let _port = h.start_server();
 
     // Before starting a session, current session should be 404.
-    let (status, _) = authed_request(&h,"GET", "/api/v1/sessions/current", None);
+    let (status, _) = authed_request(&h, "GET", "/api/v1/sessions/current", None);
     assert_eq!(
         status, 404,
         "No session should exist initially, got {}",
         status
     );
 
     // Start a session.
-    let (status, body) = authed_request(&h,"POST", "/api/v1/sessions/start", Some("{}"));
+    let (status, body) = authed_request(&h, "POST", "/api/v1/sessions/start", Some("{}"));
     assert_eq!(status, 200, "Start session should return 200");
     let json = parse_json(&body);
     assert!(json["id"].as_i64().is_some(), "Session should have an id");
@@ -424,7 +419,7 @@ fn test_api_sessions() {
     );
 
     // Get current session.
-    let (status, body) = authed_request(&h,"GET", "/api/v1/sessions/current", None);
+    let (status, body) = authed_request(&h, "GET", "/api/v1/sessions/current", None);
     assert_eq!(status, 200, "Current session should now exist");
     let json = parse_json(&body);
     assert!(json["id"].as_i64().is_some());
@@ -441,7 +436,7 @@ fn test_api_sessions() {
     assert_eq!(json["ok"], true);
 
     // After ending, current session should be 404 again.
-    let (status, _) = authed_request(&h,"GET", "/api/v1/sessions/current", None);
+    let (status, _) = authed_request(&h, "GET", "/api/v1/sessions/current", None);
     assert_eq!(
         status, 404,
         "After ending session, current should be 404, got {}",
@@ -459,28 +454,28 @@ fn test_api_milestones() {
     let _port = h.start_server();
 
     // List milestones (should be empty initially).
-    let (status, body) = authed_request(&h,"GET", "/api/v1/milestones", None);
+    let (status, body) = authed_request(&h, "GET", "/api/v1/milestones", None);
     assert_eq!(status, 200);
     let json = parse_json(&body);
     assert_eq!(json["total"], 0);
 
     // Create a milestone.
     let payload = r#"{"name": "v1.0", "description": "First release"}"#;
-    let (status, body) = authed_request(&h,"POST", "/api/v1/milestones", Some(payload));
+    let (status, body) = authed_request(&h, "POST", "/api/v1/milestones", Some(payload));
     assert_eq!(status, 200, "Create milestone should return 200");
     let created = parse_json(&body);
     assert_eq!(created["name"], "v1.0");
     assert_eq!(created["status"], "open");
     let ms_id = created["id"].as_i64().expect("Milestone should have id");
 
     // List milestones (should have 1).
-    let (status, body) = authed_request(&h,"GET", "/api/v1/milestones", None);
+    let (status, body) = authed_request(&h, "GET", "/api/v1/milestones", None);
     assert_eq!(status, 200);
     let json = parse_json(&body);
     assert_eq!(json["total"], 1);
 
     // Get by ID.
-    let (status, body) = authed_request(&h,"GET", &format!("/api/v1/milestones/{}", ms_id), None);
+    let (status, body) = authed_request(&h, "GET", &format!("/api/v1/milestones/{}", ms_id), None);
     assert_eq!(status, 200);
     let json = parse_json(&body);
     assert_eq!(json["name"], "v1.0");
@@ -504,7 +499,7 @@ fn test_api_search() {
     let _port = h.start_server();
 
     // Search for "authentication" — should find 2 issues.
-    let (status, body) = authed_request(&h,"GET", "/api/v1/search?q=authentication", None);
+    let (status, body) = authed_request(&h, "GET", "/api/v1/search?q=authentication", None);
     assert_eq!(status, 200);
     let json = parse_json(&body);
     let total = json["total"].as_u64().unwrap_or(0);
@@ -537,7 +532,7 @@ fn test_api_config() {
     let mut h = SmokeHarness::new();
     let _port = h.start_server();
 
-    let (status, body) = authed_request(&h,"GET", "/api/v1/config", None);
+    let (status, body) = authed_request(&h, "GET", "/api/v1/config", None);
     assert_eq!(status, 200, "GET config should return 200");
 
     let json = parse_json(&body);
@@ -574,7 +569,7 @@ fn test_api_sync_status() {
     let mut h = SmokeHarness::new();
     let _port = h.start_server();
 
-    let (status, body) = authed_request(&h,"GET", "/api/v1/sync/status", None);
+    let (status, body) = authed_request(&h, "GET", "/api/v1/sync/status", None);
     assert_eq!(status, 200, "GET sync/status should return 200");
 
     let json = parse_json(&body);
@@ -657,7 +652,7 @@ fn test_api_create_issue_with_description() {
 
     let payload =
         r#"{"title": "Described issue", "description": "This is the details", "priority": "low"}"#;
-    let (status, body) = authed_request(&h,"POST", "/api/v1/issues", Some(payload));
+    let (status, body) = authed_request(&h, "POST", "/api/v1/issues", Some(payload));
     assert!(status == 200 || status == 201);
 
     let json = parse_json(&body);
@@ -672,7 +667,7 @@ fn test_api_create_issue_default_priority() {
     let _port = h.start_server();
 
     let payload = r#"{"title": "Default priority issue"}"#;
-    let (status, body) = authed_request(&h,"POST", "/api/v1/issues", Some(payload));
+    let (status, body) = authed_request(&h, "POST", "/api/v1/issues", Some(payload));
     assert!(status == 200 || status == 201);
 
     let json = parse_json(&body);
@@ -688,7 +683,7 @@ fn test_api_update_nonexistent_issue() {
     let _port = h.start_server();
 
     let payload = r#"{"title": "New title"}"#;
-    let (status, _) = authed_request(&h,"PATCH", "/api/v1/issues/99999", Some(payload));
+    let (status, _) = authed_request(&h, "PATCH", "/api/v1/issues/99999", Some(payload));
     assert_eq!(status, 404, "Updating non-existent issue should return 404");
 }
 
@@ -697,7 +692,7 @@ fn test_api_delete_nonexistent_issue() {
     let mut h = SmokeHarness::new();
     let _port = h.start_server();
 
-    let (status, _) = authed_request(&h,"DELETE", "/api/v1/issues/99999", None);
+    let (status, _) = authed_request(&h, "DELETE", "/api/v1/issues/99999", None);
     assert_eq!(status, 404, "Deleting non-existent issue should return 404");
 }
 
@@ -706,7 +701,7 @@ fn test_api_close_nonexistent_issue() {
     let mut h = SmokeHarness::new();
     let _port = h.start_server();
 
-    let (status, _) = authed_request(&h,"POST", "/api/v1/issues/99999/close", None);
+    let (status, _) = authed_request(&h, "POST", "/api/v1/issues/99999/close", None);
     assert_eq!(status, 404, "Closing non-existent issue should return 404");
 }
 
@@ -715,7 +710,7 @@ fn test_api_list_issues_empty() {
     let mut h = SmokeHarness::new();
     let _port = h.start_server();
 
-    let (status, body) = authed_request(&h,"GET", "/api/v1/issues", None);
+    let (status, body) = authed_request(&h, "GET", "/api/v1/issues", None);
     assert_eq!(status, 200);
 
     let json = parse_json(&body);
@@ -734,7 +729,7 @@ fn test_api_issues_blocked_and_ready() {
     let _port = h.start_server();
 
     // Both should appear in the "ready" list (no blockers).
-    let (status, body) = authed_request(&h,"GET", "/api/v1/issues/ready", None);
+    let (status, body) = authed_request(&h, "GET", "/api/v1/issues/ready", None);
     assert_eq!(status, 200);
     let json = parse_json(&body);
     let total = json["total"].as_u64().unwrap_or(0);
@@ -745,7 +740,7 @@ fn test_api_issues_blocked_and_ready() {
     );
 
     // Blocked list should be empty (no dependencies set).
-    let (status, body) = authed_request(&h,"GET", "/api/v1/issues/blocked", None);
+    let (status, body) = authed_request(&h, "GET", "/api/v1/issues/blocked", None);
     assert_eq!(status, 200);
     let json = parse_json(&body);
     assert_eq!(json["total"], 0, "No issues should be blocked initially");
@@ -756,7 +751,7 @@ fn test_api_milestone_not_found() {
     let mut h = SmokeHarness::new();
     let _port = h.start_server();
 
-    let (status, body) = authed_request(&h,"GET", "/api/v1/milestones/99999", None);
+    let (status, body) = authed_request(&h, "GET", "/api/v1/milestones/99999", None);
     assert_eq!(status, 404);
 
     let json = parse_json(&body);
@@ -769,7 +764,7 @@ fn test_api_search_empty_query() {
     let _port = h.start_server();
 
     // Empty query should return 400.
-    let (status, _) = authed_request(&h,"GET", "/api/v1/search?q=", None);
+    let (status, _) = authed_request(&h, "GET", "/api/v1/search?q=", None);
     assert_eq!(
         status, 400,
         "Empty search query should return 400, got {}",
@@ -782,7 +777,7 @@ fn test_api_search_no_results() {
     let mut h = SmokeHarness::new();
     let _port = h.start_server();
 
-    let (status, body) = authed_request(&h,"GET", "/api/v1/search?q=xyznonexistent", None);
+    let (status, body) = authed_request(&h, "GET", "/api/v1/search?q=xyznonexistent", None);
     assert_eq!(status, 200);
     let json = parse_json(&body);
     assert_eq!(json["total"], 0);