✅ test(cli): integration tests for search + system

Author: chaizhenhua

crates/oversight-cli/tests/search_system_cli.rs

@@ -0,0 +1,182 @@
+use assert_cmd::Command;
+use serde_json::json;
+use std::fs;
+use tempfile::TempDir;
+use wiremock::matchers::{method, path};
+use wiremock::{Mock, MockServer, ResponseTemplate};
+
+fn write_config(cfg_dir: &std::path::Path, server_url: &str) {
+    let cfg_path = cfg_dir.join("config.toml");
+    fs::write(
+        &cfg_path,
+        format!(
+            "[current]\nprofile = \"default\"\n\n\
+             [profiles.default]\nserver = \"{server_url}\"\ntoken = \"plain-token\"\n"
+        ),
+    )
+    .unwrap();
+}
+
+#[tokio::test]
+async fn search_renders_results() {
+    let server = MockServer::start().await;
+    Mock::given(method("GET"))
+        .and(path("/api/search"))
+        .respond_with(ResponseTemplate::new(200).set_body_json(json!({
+            "mode_used": "lexical",
+            "results": [
+                {
+                    "type": "document",
+                    "id": "doc-1",
+                    "title": "Auth Endpoints",
+                    "snippet": "POST /auth/login authenticates a user",
+                    "score": 0.85
+                },
+                {
+                    "type": "task",
+                    "id": "task-1",
+                    "title": "Add login validation",
+                    "snippet": "implement password rules",
+                    "score": 0.42
+                }
+            ]
+        })))
+        .mount(&server)
+        .await;
+
+    let cfg_dir = TempDir::new().unwrap();
+    write_config(cfg_dir.path(), &server.uri());
+
+    Command::cargo_bin("oversight")
+        .unwrap()
+        .env("OVERSIGHT_CONFIG_HOME", cfg_dir.path())
+        .args(["--format", "table", "search", "auth"])
+        .assert()
+        .success()
+        .stdout(predicates::str::contains("Auth Endpoints"))
+        .stdout(predicates::str::contains("Add login validation"));
+}
+
+#[tokio::test]
+async fn search_prints_degraded_reason_to_stderr() {
+    let server = MockServer::start().await;
+    Mock::given(method("GET"))
+        .and(path("/api/search"))
+        .respond_with(ResponseTemplate::new(200).set_body_json(json!({
+            "mode_used": "lexical",
+            "results": [],
+            "degraded_reason": "hybrid mode degrades to lexical in Phase 1"
+        })))
+        .mount(&server)
+        .await;
+
+    let cfg_dir = TempDir::new().unwrap();
+    write_config(cfg_dir.path(), &server.uri());
+
+    Command::cargo_bin("oversight")
+        .unwrap()
+        .env("OVERSIGHT_CONFIG_HOME", cfg_dir.path())
+        .args(["--format", "table", "search", "needle", "--mode", "hybrid"])
+        .assert()
+        .success()
+        .stderr(predicates::str::contains("note: hybrid mode degrades"));
+}
+
+#[tokio::test]
+async fn system_status_returns_health() {
+    let server = MockServer::start().await;
+    Mock::given(method("GET"))
+        .and(path("/health"))
+        .respond_with(ResponseTemplate::new(200).set_body_json(json!({
+            "status": "healthy",
+            "version": "0.2.0",
+            "uptime_seconds": 1234.5,
+            "components": {"runtime": "ok", "store": "ok"}
+        })))
+        .mount(&server)
+        .await;
+
+    let cfg_dir = TempDir::new().unwrap();
+    write_config(cfg_dir.path(), &server.uri());
+
+    Command::cargo_bin("oversight")
+        .unwrap()
+        .env("OVERSIGHT_CONFIG_HOME", cfg_dir.path())
+        .args(["--format", "json", "system", "status"])
+        .assert()
+        .success()
+        .stdout(predicates::str::contains("\"status\": \"healthy\""))
+        .stdout(predicates::str::contains("\"version\": \"0.2.0\""));
+}
+
+#[tokio::test]
+async fn system_stats_renders() {
+    let server = MockServer::start().await;
+    Mock::given(method("GET"))
+        .and(path("/api/stats"))
+        .respond_with(ResponseTemplate::new(200).set_body_json(json!({
+            "total_documents": 42,
+            "total_edges": 17,
+            "top_labels": [{"label": "design", "count": 5}, {"label": "wip", "count": 3}]
+        })))
+        .mount(&server)
+        .await;
+
+    let cfg_dir = TempDir::new().unwrap();
+    write_config(cfg_dir.path(), &server.uri());
+
+    Command::cargo_bin("oversight")
+        .unwrap()
+        .env("OVERSIGHT_CONFIG_HOME", cfg_dir.path())
+        .args(["--format", "json", "system", "stats"])
+        .assert()
+        .success()
+        .stdout(predicates::str::contains("\"total_documents\": 42"));
+}
+
+#[tokio::test]
+async fn system_activities_renders_table() {
+    let server = MockServer::start().await;
+    Mock::given(method("GET"))
+        .and(path("/api/activities"))
+        .respond_with(ResponseTemplate::new(200).set_body_json(json!([
+            {
+                "id": "act-1",
+                "agent_id": "coder",
+                "activity_type": "run",
+                "thread_id": null,
+                "task_id": "task-1234abcd",
+                "source_id": null,
+                "status": "completed",
+                "cost_usd": 0.0123,
+                "token_input": 1000,
+                "token_output": 500,
+                "summary": null,
+                "model": "sonnet",
+                "workspace_id": null,
+                "created_at": "2026-04-18T12:00:00Z"
+            }
+        ])))
+        .mount(&server)
+        .await;
+
+    let cfg_dir = TempDir::new().unwrap();
+    write_config(cfg_dir.path(), &server.uri());
+
+    Command::cargo_bin("oversight")
+        .unwrap()
+        .env("OVERSIGHT_CONFIG_HOME", cfg_dir.path())
+        .args([
+            "--format",
+            "table",
+            "system",
+            "activities",
+            "--agent",
+            "coder",
+        ])
+        .assert()
+        .success()
+        .stdout(predicates::str::contains("coder"))
+        .stdout(predicates::str::contains("run"))
+        .stdout(predicates::str::contains("completed"));
+}