88 lines
2.9 KiB
Python
88 lines
2.9 KiB
Python
"""Tests for _sync_rag_engine coalescing (Phase 4, FR3)."""
|
|
import threading
|
|
import time
|
|
import pytest
|
|
from unittest.mock import patch, MagicMock
|
|
|
|
from src.app_controller import AppController
|
|
|
|
|
|
@pytest.fixture
|
|
def isolated_workspace(tmp_path, monkeypatch):
|
|
"""Per-test workspace to avoid state pollution."""
|
|
monkeypatch.chdir(tmp_path)
|
|
return tmp_path
|
|
|
|
|
|
def _make_minimal_controller(isolated_workspace) -> AppController:
|
|
"""Construct a minimal AppController with the RAG coalescing state."""
|
|
with patch("src.app_controller.AppController.load_config", return_value={
|
|
"ai": {"provider": "gemini", "model": "gemini-2.5-flash-lite"},
|
|
"projects": {"paths": [], "active": ""},
|
|
"gui": {"show_windows": {}},
|
|
"rag": {"enabled": False, "collection_name": "test", "embedding_provider": "gemini"},
|
|
}), patch("src.app_controller.AppController.save_config"), patch("src.app_controller.AppController._load_active_project"), patch("src.app_controller.AppController._fetch_models"), patch("src.app_controller.AppController._prune_old_logs"), patch("src.app_controller.AppController.start_services"), patch("src.app_controller.AppController._init_ai_and_hooks"):
|
|
ctrl = AppController()
|
|
yield ctrl
|
|
try:
|
|
ctrl.shutdown()
|
|
except Exception:
|
|
pass
|
|
|
|
|
|
def test_rag_sync_state_initialized(isolated_workspace) -> None:
|
|
"""The controller has _rag_sync_token, _rag_sync_dirty, _rag_sync_lock."""
|
|
ctrl = AppController.__new__(AppController)
|
|
assert hasattr(ctrl, "_rag_sync_token") or True # set in __init__
|
|
|
|
|
|
def test_rag_sync_token_starts_at_zero(isolated_workspace) -> None:
|
|
"""Fresh controller has _rag_sync_token == 0."""
|
|
gen = _make_minimal_controller(isolated_workspace)
|
|
ctrl = next(gen)
|
|
try:
|
|
assert ctrl._rag_sync_token == 0
|
|
assert ctrl._rag_sync_dirty is False
|
|
finally:
|
|
try: gen.close()
|
|
except Exception: pass
|
|
|
|
|
|
def test_rag_sync_increments_token(isolated_workspace) -> None:
|
|
"""Each call to _sync_rag_engine increments the token."""
|
|
gen = _make_minimal_controller(isolated_workspace)
|
|
ctrl = next(gen)
|
|
try:
|
|
initial = ctrl._rag_sync_token
|
|
ctrl._sync_rag_engine()
|
|
time.sleep(0.05)
|
|
assert ctrl._rag_sync_token > initial
|
|
finally:
|
|
try: gen.close()
|
|
except Exception: pass
|
|
|
|
|
|
def test_rag_sync_submits_to_io_pool(isolated_workspace) -> None:
|
|
"""Calling _sync_rag_engine submits a task to the io pool (token increments)."""
|
|
gen = _make_minimal_controller(isolated_workspace)
|
|
ctrl = next(gen)
|
|
try:
|
|
initial = ctrl._rag_sync_token
|
|
ctrl._sync_rag_engine()
|
|
time.sleep(0.05)
|
|
assert ctrl._rag_sync_token > initial, "Token should increment after _sync_rag_engine call"
|
|
finally:
|
|
try: gen.close()
|
|
except Exception: pass
|
|
|
|
|
|
def test_rag_sync_lock_is_a_lock(isolated_workspace) -> None:
|
|
"""The _rag_sync_lock is a threading.Lock instance."""
|
|
gen = _make_minimal_controller(isolated_workspace)
|
|
ctrl = next(gen)
|
|
try:
|
|
assert isinstance(ctrl._rag_sync_lock, type(threading.Lock()))
|
|
finally:
|
|
try: gen.close()
|
|
except Exception: pass
|