| from pathlib import Path |
| import sqlite3 |
|
|
| from codex_dashboard.codex_data import list_logs, list_logs_result |
|
|
|
|
| def _make_logs_db(path: Path) -> None: |
| conn = sqlite3.connect(path) |
| conn.execute( |
| """ |
| CREATE TABLE logs ( |
| id INTEGER PRIMARY KEY, |
| ts INTEGER NOT NULL, |
| ts_nanos INTEGER NOT NULL DEFAULT 0, |
| level TEXT NOT NULL DEFAULT '', |
| target TEXT NOT NULL DEFAULT '', |
| thread_id TEXT NOT NULL DEFAULT '', |
| module_path TEXT NOT NULL DEFAULT '', |
| feedback_log_body TEXT |
| ) |
| """ |
| ) |
| conn.executemany( |
| """ |
| INSERT INTO logs (id, ts, ts_nanos, level, target, thread_id, module_path, feedback_log_body) |
| VALUES (?, ?, ?, ?, ?, ?, ?, ?) |
| """, |
| [ |
| (1, 100, 123_000_000, "INFO", "codex_core", "thread-a", "core", "first message"), |
| (2, 101, 500_000_000, "WARN", "codex_ui", "thread-b", "ui", "needle message"), |
| ], |
| ) |
| conn.commit() |
| conn.close() |
|
|
|
|
| def test_list_logs_reads_codex_logs_fixture_and_searches(tmp_path): |
| db = tmp_path / "logs_2.sqlite" |
| _make_logs_db(db) |
|
|
| logs = list_logs(db_path=db, query="needle") |
|
|
| assert [entry.id for entry in logs] == [2] |
| assert logs[0].ts_ms == 101_500 |
| assert logs[0].level == "WARN" |
| assert logs[0].thread_id == "thread-b" |
| assert logs[0].message == "needle message" |
|
|
|
|
| def test_list_logs_schema_drift_missing_expected_columns_reports_data_error(tmp_path): |
| db = tmp_path / "logs_2.sqlite" |
| conn = sqlite3.connect(db) |
| conn.execute( |
| """ |
| CREATE TABLE logs ( |
| id INTEGER PRIMARY KEY, |
| ts INTEGER NOT NULL, |
| level TEXT, |
| target TEXT, |
| thread_id TEXT |
| ) |
| """ |
| ) |
| conn.execute("INSERT INTO logs (id, ts, level, target, thread_id) VALUES (1, 100, 'INFO', 'target', 't')") |
| conn.commit() |
| conn.close() |
|
|
| result = list_logs_result(db_path=db) |
|
|
| assert result.data == [] |
| assert result.error is not None |
| assert "ts_nanos" in result.error.message or "feedback_log_body" in result.error.message |
|
|
