use predicates::prelude::*;
use serial_test::serial;
#[macro_use]
mod common;
use common::{ensure_test_project, DaemonTestHarness};
const TEST_PROJECT: &str = "ci-test";
const TEST_PROGRAM: &str = "sample_binary";
fn try_start_daemon() -> Option<DaemonTestHarness> {
match DaemonTestHarness::new(TEST_PROJECT, TEST_PROGRAM) {
Ok(h) => Some(h),
Err(e) => {
let msg = format!("{}", e);
if msg.contains("program file(s) not found") {
eprintln!(
"Skipping test: bridge can't find program (known macOS issue): {}",
msg
);
None
} else {
panic!("Failed to start daemon: {}", e);
}
}
}
}
#[test]
#[serial]
fn test_daemon_start() {
require_ghidra!();
ensure_test_project(TEST_PROJECT, TEST_PROGRAM);
let Some(harness) = try_start_daemon() else {
return;
};
assert_cmd::cargo::cargo_bin_cmd!("ghidra")
.arg("status")
.arg("--project")
.arg(TEST_PROJECT)
.assert()
.success();
drop(harness);
}
#[test]
#[serial]
fn test_daemon_status() {
require_ghidra!();
ensure_test_project(TEST_PROJECT, TEST_PROGRAM);
let Some(harness) = try_start_daemon() else {
return;
};
assert_cmd::cargo::cargo_bin_cmd!("ghidra")
.arg("status")
.arg("--project")
.arg(TEST_PROJECT)
.assert()
.success()
.stdout(predicate::str::contains("running"));
drop(harness);
}
#[test]
#[serial]
fn test_daemon_ping() {
require_ghidra!();
ensure_test_project(TEST_PROJECT, TEST_PROGRAM);
let Some(harness) = try_start_daemon() else {
return;
};
assert_cmd::cargo::cargo_bin_cmd!("ghidra")
.arg("ping")
.arg("--project")
.arg(TEST_PROJECT)
.assert()
.success();
drop(harness);
}
#[test]
#[serial]
fn test_daemon_lifecycle() {
require_ghidra!();
ensure_test_project(TEST_PROJECT, TEST_PROGRAM);
let Some(_harness) = try_start_daemon() else {
return;
};
assert_cmd::cargo::cargo_bin_cmd!("ghidra")
.arg("status")
.arg("--project")
.arg(TEST_PROJECT)
.assert()
.success()
.stdout(predicate::str::contains("running"));
assert_cmd::cargo::cargo_bin_cmd!("ghidra")
.arg("ping")
.arg("--project")
.arg(TEST_PROJECT)
.assert()
.success();
assert_cmd::cargo::cargo_bin_cmd!("ghidra")
.arg("stop")
.arg("--project")
.arg(TEST_PROJECT)
.assert()
.success();
}
#[test]
#[serial]
fn test_daemon_stop() {
require_ghidra!();
ensure_test_project(TEST_PROJECT, TEST_PROGRAM);
let Some(harness) = try_start_daemon() else {
return;
};
assert_cmd::cargo::cargo_bin_cmd!("ghidra")
.arg("stop")
.arg("--project")
.arg(TEST_PROJECT)
.assert()
.success();
assert_cmd::cargo::cargo_bin_cmd!("ghidra")
.arg("status")
.arg("--project")
.arg(TEST_PROJECT)
.assert()
.success()
.stdout(predicate::str::contains("No bridge running"));
drop(harness);
}
#[test]
#[serial]
fn test_daemon_restart() {
require_ghidra!();
ensure_test_project(TEST_PROJECT, TEST_PROGRAM);
let Some(harness) = try_start_daemon() else {
return;
};
let ghidra_bin = assert_cmd::cargo::cargo_bin!("ghidra");
let status = common::run_cli_with_timeout(
ghidra_bin,
&[
"restart",
"--project",
TEST_PROJECT,
"--program",
TEST_PROGRAM,
],
std::time::Duration::from_secs(300),
)
.expect("Failed to run restart");
if !status.success() {
eprintln!("Restart failed with status: {}", status);
drop(harness);
return;
}
assert_cmd::cargo::cargo_bin_cmd!("ghidra")
.arg("stop")
.arg("--project")
.arg(TEST_PROJECT)
.assert()
.success();
drop(harness);
}
#[test]
#[serial]
fn test_daemon_start_when_running() {
require_ghidra!();
ensure_test_project(TEST_PROJECT, TEST_PROGRAM);
let Some(harness) = try_start_daemon() else {
return;
};
assert_cmd::cargo::cargo_bin_cmd!("ghidra")
.arg("start")
.arg("--project")
.arg(TEST_PROJECT)
.arg("--program")
.arg(TEST_PROGRAM)
.assert()
.success()
.stdout(predicate::str::contains("already running"));
drop(harness);
}