Add tokio sync, replay cfg and code formatting

Enable the `sync` feature for tokio in cargo-rustapi and gate the Replay CLI subcommand/tests behind cfg(feature = "replay"). Additionally apply a series of small refactors and formatting fixes across the workspace: reflowed long expressions, added/removed trailing commas, normalized imports and multi-line signatures, and cleaned up test invocations and assertions. Changes touch cargo-rustapi, rustapi-core, rustapi-extras, rustapi-rs and related examples/tests; they are primarily stylistic and readability improvements (with the notable functional addition of the tokio `sync` feature and conditional replay wiring).

Author: Tuntii

crates/cargo-rustapi/Cargo.toml

@@ -30,7 +30,7 @@ notify = "7.0"
 notify-debouncer-mini = "0.5"
 
 # Async
-tokio = { workspace = true, features = ["process", "fs", "macros", "rt-multi-thread", "time", "signal"] }
+tokio = { workspace = true, features = ["process", "fs", "macros", "rt-multi-thread", "time", "signal", "sync"] }
 
 # Serialization
 serde = { workspace = true }

crates/cargo-rustapi/src/cli.rs

@@ -1,11 +1,11 @@
 //! CLI argument parsing
 
+#[cfg(feature = "replay")]
+use crate::commands::ReplayArgs;
 use crate::commands::{
     self, AddArgs, BenchArgs, ClientArgs, DeployArgs, DoctorArgs, GenerateArgs, MigrateArgs,
     NewArgs, ObservabilityArgs, RunArgs, WatchArgs,
 };
-#[cfg(feature = "replay")]
-use crate::commands::ReplayArgs;
 use clap::{Parser, Subcommand};
 
 /// The official CLI tool for the RustAPI framework. Scaffold new projects, run development servers, and manage database migrations.
@@ -67,6 +67,7 @@ enum Commands {
     Deploy(DeployArgs),
 
     /// Replay debugging commands (time-travel debugging)
+    #[cfg(feature = "replay")]
     #[command(subcommand)]
     Replay(ReplayArgs),
 }
@@ -87,6 +88,7 @@ impl Cli {
             Commands::Docs { port } => commands::open_docs(port).await,
             Commands::Client(args) => commands::client(args).await,
             Commands::Deploy(args) => commands::deploy(args).await,
+            #[cfg(feature = "replay")]
             Commands::Replay(args) => commands::replay(args).await,
         }
     }

crates/cargo-rustapi/src/commands/bench.rs

@@ -56,7 +56,10 @@ pub async fn bench(args: BenchArgs) -> Result<()> {
         command.env("RUSTAPI_PERF_ITERS", iterations.to_string());
     }
 
-    let status = command.status().await.context("Failed to launch benchmark workflow")?;
+    let status = command
+        .status()
+        .await
+        .context("Failed to launch benchmark workflow")?;
     if !status.success() {
         bail!("Benchmark workflow exited with status {}", status);
     }

crates/cargo-rustapi/src/commands/doctor.rs

@@ -89,34 +89,34 @@ pub async fn doctor(args: DoctorArgs) -> Result<()> {
 
     println!("{}", style("Toolchain").bold());
     checks.push(check_tool("rustc", &["--version"], "Rust compiler", true).await);
-    checks.push(check_tool(
-        "cargo",
-        &["--version"],
-        "Cargo package manager",
-        true,
-    )
-    .await);
-    checks.push(check_tool(
-        "cargo",
-        &["watch", "--version"],
-        "cargo-watch (for hot reload)",
-        false,
-    )
-    .await);
-    checks.push(check_tool(
-        "docker",
-        &["--version"],
-        "Docker (for containerization)",
-        false,
-    )
-    .await);
-    checks.push(check_tool(
-        "sqlx",
-        &["--version"],
-        "sqlx-cli (for database migrations)",
-        false,
-    )
-    .await);
+    checks.push(check_tool("cargo", &["--version"], "Cargo package manager", true).await);
+    checks.push(
+        check_tool(
+            "cargo",
+            &["watch", "--version"],
+            "cargo-watch (for hot reload)",
+            false,
+        )
+        .await,
+    );
+    checks.push(
+        check_tool(
+            "docker",
+            &["--version"],
+            "Docker (for containerization)",
+            false,
+        )
+        .await,
+    );
+    checks.push(
+        check_tool(
+            "sqlx",
+            &["--version"],
+            "sqlx-cli (for database migrations)",
+            false,
+        )
+        .await,
+    );
 
     for check in &checks {
         print_check(check);
@@ -280,10 +280,7 @@ fn build_project_checks(workspace_root: &Path) -> Result<Vec<DoctorCheck>> {
     }
 
     checks.push(if signals.production_defaults {
-        DoctorCheck::pass(
-            "Application baseline",
-            "production_defaults usage detected",
-        )
+        DoctorCheck::pass("Application baseline", "production_defaults usage detected")
     } else {
         DoctorCheck::warn(
             "Application baseline",
@@ -327,17 +324,21 @@ fn build_project_checks(workspace_root: &Path) -> Result<Vec<DoctorCheck>> {
         )
     });
 
-    checks.push(if (signals.production_defaults || signals.request_id) && (signals.production_defaults || signals.tracing) {
-        DoctorCheck::pass(
-            "Request IDs and tracing",
-            "Request ID and tracing signals detected",
-        )
-    } else {
-        DoctorCheck::warn(
-            "Request IDs and tracing",
-            "RequestIdLayer/tracing signals were not clearly detected",
-        )
-    });
+    checks.push(
+        if (signals.production_defaults || signals.request_id)
+            && (signals.production_defaults || signals.tracing)
+        {
+            DoctorCheck::pass(
+                "Request IDs and tracing",
+                "Request ID and tracing signals detected",
+            )
+        } else {
+            DoctorCheck::warn(
+                "Request IDs and tracing",
+                "RequestIdLayer/tracing signals were not clearly detected",
+            )
+        },
+    );
 
     checks.push(if signals.structured_logging || signals.otel {
         DoctorCheck::pass(
@@ -351,17 +352,19 @@ fn build_project_checks(workspace_root: &Path) -> Result<Vec<DoctorCheck>> {
         )
     });
 
-    checks.push(if signals.rate_limit || signals.security_headers || signals.timeout || signals.cors {
-        DoctorCheck::pass(
-            "Edge protections",
-            "Detected timeout, rate limit, CORS, or security header configuration",
-        )
-    } else {
-        DoctorCheck::warn(
-            "Edge protections",
-            "No timeout, rate limit, CORS, or security header configuration was detected",
-        )
-    });
+    checks.push(
+        if signals.rate_limit || signals.security_headers || signals.timeout || signals.cors {
+            DoctorCheck::pass(
+                "Edge protections",
+                "Detected timeout, rate limit, CORS, or security header configuration",
+            )
+        } else {
+            DoctorCheck::warn(
+                "Edge protections",
+                "No timeout, rate limit, CORS, or security header configuration was detected",
+            )
+        },
+    );
 
     checks.push(if signals.body_limit {
         DoctorCheck::pass(
@@ -401,7 +404,11 @@ fn scan_workspace_signals(workspace_root: &Path) -> Result<WorkspaceSignals> {
         );
         signals.health_endpoints |= contains_any(
             &contents,
-            &[".health_endpoints(", ".health_endpoint_config(", "HealthEndpointConfig"],
+            &[
+                ".health_endpoints(",
+                ".health_endpoint_config(",
+                "HealthEndpointConfig",
+            ],
         );
         signals.health_checks |= contents.contains(".with_health_check(");
         signals.request_id |= contents.contains("RequestIdLayer");
@@ -414,10 +421,8 @@ fn scan_workspace_signals(workspace_root: &Path) -> Result<WorkspaceSignals> {
         );
         signals.otel |= contains_any(&contents, &["OtelLayer", "otel("]);
         signals.rate_limit |= contains_any(&contents, &["RateLimitLayer", "rate_limit("]);
-        signals.security_headers |= contains_any(
-            &contents,
-            &["SecurityHeadersLayer", "security_headers("],
-        );
+        signals.security_headers |=
+            contains_any(&contents, &["SecurityHeadersLayer", "security_headers("]);
         signals.timeout |= contains_any(&contents, &["TimeoutLayer", "timeout("]);
         signals.cors |= contains_any(&contents, &["CorsLayer", "cors("]);
         signals.body_limit |= contains_any(&contents, &["BodyLimitLayer", ".body_limit("]);
@@ -463,7 +468,10 @@ fn should_scan(path: &Path) -> bool {
         return true;
     };
 
-    !matches!(name, ".git" | "target" | "node_modules" | ".next" | "dist" | "build")
+    !matches!(
+        name,
+        ".git" | "target" | "node_modules" | ".next" | "dist" | "build"
+    )
 }
 
 fn is_scannable_file(path: &Path) -> bool {
@@ -500,7 +508,11 @@ mod tests {
     #[test]
     fn scan_workspace_signals_detects_production_patterns() {
         let dir = tempdir().unwrap();
-        fs::write(dir.path().join("Cargo.toml"), "[package]\nname='demo'\nversion='0.1.0'\n").unwrap();
+        fs::write(
+            dir.path().join("Cargo.toml"),
+            "[package]\nname='demo'\nversion='0.1.0'\n",
+        )
+        .unwrap();
         fs::write(dir.path().join(".env"), "RUSTAPI_ENV=production\n").unwrap();
 
         let src_dir = dir.path().join("src");
@@ -536,12 +548,20 @@ mod tests {
     #[test]
     fn build_project_checks_warns_when_signals_are_missing() {
         let dir = tempdir().unwrap();
-        fs::write(dir.path().join("Cargo.toml"), "[package]\nname='demo'\nversion='0.1.0'\n").unwrap();
+        fs::write(
+            dir.path().join("Cargo.toml"),
+            "[package]\nname='demo'\nversion='0.1.0'\n",
+        )
+        .unwrap();
         fs::create_dir_all(dir.path().join("src")).unwrap();
         fs::write(dir.path().join("src").join("main.rs"), "fn main() {}\n").unwrap();
 
         let checks = build_project_checks(dir.path()).unwrap();
-        assert!(checks.iter().any(|check| check.status == DoctorStatus::Warn));
-        assert!(checks.iter().any(|check| check.name == "Application baseline"));
+        assert!(checks
+            .iter()
+            .any(|check| check.status == DoctorStatus::Warn));
+        assert!(checks
+            .iter()
+            .any(|check| check.name == "Application baseline"));
     }
 }

crates/cargo-rustapi/src/commands/new.rs

@@ -118,7 +118,12 @@ pub async fn new_project(mut args: NewArgs) -> Result<()> {
 
     // Get features
     let features = if let Some(features) = args.features {
-        merge_unique_features(preset.map(ProjectPreset::recommended_features).unwrap_or_default(), features)
+        merge_unique_features(
+            preset
+                .map(ProjectPreset::recommended_features)
+                .unwrap_or_default(),
+            features,
+        )
     } else if args.yes {
         preset
             .map(ProjectPreset::recommended_features)
@@ -153,7 +158,12 @@ pub async fn new_project(mut args: NewArgs) -> Result<()> {
         let defaults = defaults
             .into_iter()
             .enumerate()
-            .map(|(index, default)| default || preset_features.iter().any(|feature| feature == available[index]))
+            .map(|(index, default)| {
+                default
+                    || preset_features
+                        .iter()
+                        .any(|feature| feature == available[index])
+            })
             .collect::<Vec<_>>();
 
         let selections = dialoguer::MultiSelect::with_theme(&theme)

crates/cargo-rustapi/tests/cli_tests.rs

@@ -112,13 +112,7 @@ mod new_command {
 
         cargo_rustapi()
             .current_dir(dir.path())
-            .args([
-                "new",
-                project_name,
-                "--preset",
-                "prod-api",
-                "--yes",
-            ])
+            .args(["new", project_name, "--preset", "prod-api", "--yes"])
             .assert()
             .success();
 
@@ -140,13 +134,7 @@ mod new_command {
 
         cargo_rustapi()
             .current_dir(dir.path())
-            .args([
-                "new",
-                project_name,
-                "--preset",
-                "ai-api",
-                "--yes",
-            ])
+            .args(["new", project_name, "--preset", "ai-api", "--yes"])
             .assert()
             .success();
 
@@ -166,13 +154,7 @@ mod new_command {
 
         cargo_rustapi()
             .current_dir(dir.path())
-            .args([
-                "new",
-                project_name,
-                "--preset",
-                "realtime-api",
-                "--yes",
-            ])
+            .args(["new", project_name, "--preset", "realtime-api", "--yes"])
             .assert()
             .success();
 
@@ -282,6 +264,7 @@ mod observability_command {
     }
 }
 
+#[cfg(feature = "replay")]
 mod replay_command {
     use super::*;