cfs-synapse 0.2.3

use std::fs;
use std::path::PathBuf;
use std::process::Command;
use std::time::{SystemTime, UNIX_EPOCH};

fn test_dir(name: &str) -> PathBuf {
    let stamp = SystemTime::now()
        .duration_since(UNIX_EPOCH)
        .unwrap()
        .as_nanos();
    let dir =
        std::env::temp_dir().join(format!("synapse-cli-{name}-{}-{stamp}", std::process::id()));
    fs::create_dir_all(&dir).unwrap();
    dir
}

fn write_import_fixture(dir: &std::path::Path) -> PathBuf {
    fs::write(
        dir.join("frame_descriptor.syn"),
        r#"namespace frame_descriptor
struct FrameDescriptor { gain: f32 }
"#,
    )
    .unwrap();
    let root = dir.join("postcard.syn");
    fs::write(
        &root,
        r#"namespace camera
import "frame_descriptor.syn"
struct Postcard { fd: frame_descriptor::FrameDescriptor }
"#,
    )
    .unwrap();
    root
}

#[test]
fn out_dir_generates_import_closure_by_default() {
    let dir = test_dir("closure");
    let root = write_import_fixture(&dir);
    let out_dir = dir.join("generated");

    let output = Command::new(env!("CARGO_BIN_EXE_synapse"))
        .arg("--lang")
        .arg("c")
        .arg("-o")
        .arg(&out_dir)
        .arg(&root)
        .output()
        .expect("run synapse");

    assert!(
        output.status.success(),
        "synapse failed\nstdout:\n{}\nstderr:\n{}",
        String::from_utf8_lossy(&output.stdout),
        String::from_utf8_lossy(&output.stderr)
    );
    assert!(out_dir.join("frame_descriptor.h").exists());
    assert!(out_dir.join("postcard.h").exists());
}

#[test]
fn single_file_writes_only_root_file() {
    let dir = test_dir("single-file");
    let root = write_import_fixture(&dir);
    let out_dir = dir.join("generated");

    let output = Command::new(env!("CARGO_BIN_EXE_synapse"))
        .arg("--lang")
        .arg("c")
        .arg("-o")
        .arg(&out_dir)
        .arg("--single-file")
        .arg(&root)
        .output()
        .expect("run synapse");

    assert!(
        output.status.success(),
        "synapse failed\nstdout:\n{}\nstderr:\n{}",
        String::from_utf8_lossy(&output.stdout),
        String::from_utf8_lossy(&output.stderr)
    );
    assert!(!out_dir.join("frame_descriptor.h").exists());
    assert!(out_dir.join("postcard.h").exists());
}

#[test]
fn check_validates_import_closure_without_output() {
    let dir = test_dir("check");
    let root = write_import_fixture(&dir);

    let output = Command::new(env!("CARGO_BIN_EXE_synapse"))
        .arg("check")
        .arg(&root)
        .output()
        .expect("run synapse");

    assert!(
        output.status.success(),
        "synapse failed\nstdout:\n{}\nstderr:\n{}",
        String::from_utf8_lossy(&output.stdout),
        String::from_utf8_lossy(&output.stderr)
    );
    assert!(String::from_utf8_lossy(&output.stderr).contains("checked"));
    assert!(!dir.join("postcard.h").exists());
    assert!(!dir.join("frame_descriptor.h").exists());
}

#[test]
fn check_rejects_unsupported_imported_file() {
    let dir = test_dir("check-import-error");
    fs::write(
        dir.join("bad.syn"),
        "namespace bad\nstruct Unsupported { count?: u32 }",
    )
    .unwrap();
    let root = dir.join("root.syn");
    fs::write(
        &root,
        r#"namespace root
import "bad.syn"
struct Root { unsupported: bad::Unsupported }
"#,
    )
    .unwrap();

    let output = Command::new(env!("CARGO_BIN_EXE_synapse"))
        .arg("check")
        .arg(&root)
        .output()
        .expect("run synapse");

    assert!(
        !output.status.success(),
        "synapse unexpectedly succeeded\nstdout:\n{}\nstderr:\n{}",
        String::from_utf8_lossy(&output.stdout),
        String::from_utf8_lossy(&output.stderr)
    );
    assert!(String::from_utf8_lossy(&output.stderr).contains("optional field"));
}

#[test]
fn check_accepts_multiple_roots_and_rejects_mission_mid_conflicts() {
    let dir = test_dir("check-multiple-roots");
    let nav = dir.join("nav.syn");
    fs::write(
        &nav,
        "namespace nav_app\n@mid(0x0801)\ntelemetry NavState { x: f64 }",
    )
    .unwrap();
    let payload = dir.join("payload.syn");
    fs::write(
        &payload,
        "namespace payload_app\n@mid(0x0801)\ntelemetry PayloadStatus { temp: f32 }",
    )
    .unwrap();

    let output = Command::new(env!("CARGO_BIN_EXE_synapse"))
        .arg("check")
        .arg(&nav)
        .arg(&payload)
        .output()
        .expect("run synapse");

    assert!(
        !output.status.success(),
        "synapse unexpectedly succeeded\nstdout:\n{}\nstderr:\n{}",
        String::from_utf8_lossy(&output.stdout),
        String::from_utf8_lossy(&output.stderr)
    );
    let stderr = String::from_utf8_lossy(&output.stderr);
    assert!(stderr.contains("duplicate telemetry MID `0x0801`"));
    assert!(stderr.contains("nav_app::NavState"));
    assert!(stderr.contains("payload_app::PayloadStatus"));
}

#[test]
fn mission_demo_validates_multiple_roots() {
    let repo = PathBuf::from(env!("CARGO_MANIFEST_DIR"))
        .parent()
        .unwrap()
        .to_path_buf();

    let output = Command::new(env!("CARGO_BIN_EXE_synapse"))
        .arg("check")
        .arg(repo.join("examples/mission-demo/syn/nav_app.syn"))
        .arg(repo.join("examples/mission-demo/syn/camera_app.syn"))
        .arg(repo.join("examples/mission-demo/syn/payload_app.syn"))
        .output()
        .expect("run synapse");

    assert!(
        output.status.success(),
        "synapse failed\nstdout:\n{}\nstderr:\n{}",
        String::from_utf8_lossy(&output.stdout),
        String::from_utf8_lossy(&output.stderr)
    );
}

#[test]
fn doc_writes_static_html() {
    let dir = test_dir("doc-html");
    let input = dir.join("status.syn");
    fs::write(
        &input,
        r#"namespace status_app
/// Status packet.
@mid(0x0801)
telemetry Status {
    /// Counter value.
    count: u32
}
"#,
    )
    .unwrap();
    let out_dir = dir.join("site");

    let output = Command::new(env!("CARGO_BIN_EXE_synapse"))
        .arg("doc")
        .arg("-o")
        .arg(&out_dir)
        .arg(&input)
        .output()
        .expect("run synapse");

    assert!(
        output.status.success(),
        "synapse failed\nstdout:\n{}\nstderr:\n{}",
        String::from_utf8_lossy(&output.stdout),
        String::from_utf8_lossy(&output.stderr)
    );

    let html = fs::read_to_string(out_dir.join("index.html")).unwrap();
    assert!(html.contains("Synapse Message Documentation"));
    assert!(html.contains("status_app"));
    assert!(html.contains("Status packet."));
    assert!(html.contains("0x0801"));
}

#[test]
fn registry_writes_json_and_csv() {
    let dir = test_dir("registry-output");
    let input = dir.join("status.syn");
    fs::write(
        &input,
        "namespace status_app\n@mid(0x0801)\ntelemetry Status { count: u32 }",
    )
    .unwrap();
    let json_path = dir.join("registry.json");
    let csv_path = dir.join("registry.csv");

    let json_output = Command::new(env!("CARGO_BIN_EXE_synapse"))
        .arg("registry")
        .arg("--format")
        .arg("json")
        .arg("-o")
        .arg(&json_path)
        .arg(&input)
        .output()
        .expect("run synapse");

    assert!(
        json_output.status.success(),
        "synapse failed\nstdout:\n{}\nstderr:\n{}",
        String::from_utf8_lossy(&json_output.stdout),
        String::from_utf8_lossy(&json_output.stderr)
    );

    let csv_output = Command::new(env!("CARGO_BIN_EXE_synapse"))
        .arg("registry")
        .arg("--format")
        .arg("csv")
        .arg("-o")
        .arg(&csv_path)
        .arg(&input)
        .output()
        .expect("run synapse");

    assert!(
        csv_output.status.success(),
        "synapse failed\nstdout:\n{}\nstderr:\n{}",
        String::from_utf8_lossy(&csv_output.stdout),
        String::from_utf8_lossy(&csv_output.stderr)
    );

    assert!(
        fs::read_to_string(json_path)
            .unwrap()
            .contains("\"mid_hex\": \"0x0801\"")
    );
    assert!(
        fs::read_to_string(csv_path)
            .unwrap()
            .contains("\"status_app::Status\"")
    );
}