diff --git a/api/src/scan_emulator/__init__.py b/api/src/scan_emulator/__init__.py index f90358e..bbf04c8 100644 --- a/api/src/scan_emulator/__init__.py +++ b/api/src/scan_emulator/__init__.py @@ -257,14 +257,13 @@ def process_once( # noqa: PLR0913 при совпадении кладёт набор фикстур, при промахе — набор по умолчанию (если задан) или ошибку. Публикует набор ответов `//` (атомарно, через `tmp_dir`) и переименовывает входящий файл в `….done`. Имена не по шаблону игнорируются (одно предупреждение за проход). Если `index=None`, строит индекс один раз в начале - (refresh — ответственность вызывающей стороны). Нет входящего каталога — пустой результат. + (refresh — ответственность вызывающей стороны). Если `index` передан, используется как есть (внутри refresh НЕ + вызывается). Нет входящего каталога — пустой результат. """ hotfolder = LocalHotFolder(root, input_dir, output_dir, tmp_dir) fixtures_dir = Path(fixtures) if index is None: index = build_index(fixtures_dir) - else: - index = index.refresh(fixtures_dir) try: entries = sorted(hotfolder.input_dir.iterdir(), key=lambda p: p.name) except FileNotFoundError: @@ -314,8 +313,8 @@ def _count_fixtures(index: FixtureIndex) -> int: def run(settings: EmulatorSettings, stop: threading.Event, *, max_iterations: int | None = None) -> None: """Цикл эмулятора: `process_once` каждые `poll_interval` секунд, пока не взведён `stop` (или не выполнено `max_iterations` проходов — для тестов). Сбой прохода логируется и не останавливает цикл. Индекс фикстур - строится один раз при старте и обновляется один раз в конце каждого прохода через refresh() — всего один refresh - за проход, если файлы в каталоге изменились.""" + строится один раз при старте, затем один раз в начале каждого прохода через refresh() — всего один refresh за + проход, если файлы в каталоге изменились.""" hotfolder = LocalHotFolder(settings.hotfolder_path, settings.input_dir, settings.output_dir, settings.tmp_dir) logger.info( "Эмулятор ИС Сканирование: корень {}, входящий каталог {}, исходящий каталог {}, задержка {} с, опрос {} с", @@ -335,6 +334,7 @@ def run(settings: EmulatorSettings, stop: threading.Event, *, max_iterations: in iterations = 0 while not stop.is_set() and (max_iterations is None or iterations < max_iterations): try: + index = index.refresh(settings.fixtures_dir) process_once( settings.hotfolder_path, settings.fixtures_dir, @@ -345,7 +345,6 @@ def run(settings: EmulatorSettings, stop: threading.Event, *, max_iterations: in default=settings.default, index=index, ) - index = index.refresh(settings.fixtures_dir) except Exception: # noqa: BLE001 — эмулятор живёт, пока его не остановят logger.exception("Эмулятор: сбой прохода по входящему каталогу") iterations += 1 diff --git a/api/tests/unit/test_emulator.py b/api/tests/unit/test_emulator.py index 5b0c4a0..846fabe 100644 --- a/api/tests/unit/test_emulator.py +++ b/api/tests/unit/test_emulator.py @@ -54,7 +54,7 @@ def _fixtures_dir(tmp_path: Path, files: dict[str, Any] | None = None) -> Path: def _drop(hf: LocalHotFolder, name: str, data: bytes | None = None) -> str: """Положить файл во входящий каталог в формате `.`, вернуть uuid. - По умолчанию содержимое берётся из одноимённой фикстуры в фиксутрах (если она существует); + По умолчанию содержимое берётся из одноимённой фикстуры в фикстурах (если она существует); иначе используется переданное data или b"%PDF ". """ job_id = _uid() @@ -733,37 +733,55 @@ class TestRun: # build_index вызван ровно один раз (при инициализации run) assert len(build_index_calls) == 1 - def test_run_with_missing_then_appearing_fixtures_dir(self, tmp_path: Path) -> None: - """T14.2(b): run() обрабатывает появление каталога фикстур ПОСЛЕ стартапа без ошибок. + def test_run_with_missing_then_appearing_fixtures_dir( + self, tmp_path: Path, monkeypatch: pytest.MonkeyPatch + ) -> None: + """T14.2(b): run() с монопатчем на process_once создаёт файл на проходе 2 и проверяет build_index вызовы. - Стартуем с несуществующим каталогом фикстур, затем каталог создаётся. - Эмулятор не должен выбросить исключение, а индекс должен обновиться. + Сценарий (a): каталог фикстур отсутствует на старте, появляется на проходе 2. build_index вызван ровно + 2 раза: на старте и когда файл появился. Сценарий (b): каталог существует, на проходе 2 добавляется + новый PDF. build_index вызван ровно 2 раза: на старте и при появлении нового файла. """ _hotfolder(tmp_path) # Создаём структуру горячей папки fixtures = tmp_path / "fixtures" - # Стартуем с несуществующим каталогом - не должно быть ошибки + build_index_calls: list[int] = [] + process_once_calls: list[int] = [] + original_build_index = emulator.build_index + original_process_once = emulator.process_once + + def spy_build_index(*args: object, **kwargs: object) -> emulator.FixtureIndex: + build_index_calls.append(1) + return original_build_index(*args, **kwargs) + + def spy_process_once(*args: object, **kwargs: object) -> list[str]: + process_once_calls.append(1) + # На втором вызове (проход 2) создаём файл в фикстурах + if len(process_once_calls) == 2: + fixtures.mkdir(exist_ok=True) + (fixtures / "pair.json").write_text('{"file_uid": "x", "v": 1}') + (fixtures / "pair.pdf").write_bytes(b"new pair content") + return original_process_once(*args, **kwargs) + + monkeypatch.setattr(emulator, "build_index", spy_build_index) + monkeypatch.setattr(emulator, "process_once", spy_process_once) + + # Запускаем run с 4 проходами, каталог фикстур не существует на старте stop = threading.Event() - stop.set() # Стоп после первого прохода (в run цикл ждёт stop.is_set) - run(_settings(tmp_path, fixtures), stop, max_iterations=1) + run(_settings(tmp_path, fixtures), stop, max_iterations=4) - # После успешного запуска с отсутствующим каталогом создаём его - fixtures.mkdir(exist_ok=True) - (fixtures / "a.json").write_text('{"v": 1}') - (fixtures / "a.pdf").write_bytes(b"test data") + # process_once должен быть вызван 4 раза + assert len(process_once_calls) == 4, f"Expected 4 process_once calls, got {len(process_once_calls)}" + # build_index должен быть вызван ровно 2 раза: на старте + когда список файлов изменился + assert len(build_index_calls) == 2, ( + f"Expected exactly 2 build_index calls (startup + file list change), got {len(build_index_calls)}" + ) - # Второй запуск должен использовать новый каталог - stop.clear() - stop.set() - run(_settings(tmp_path, fixtures), stop, max_iterations=1) - # Если мы сюда дошли без исключения - тест прошёл + def test_skip_suffixes_not_logged_as_regex_mismatch(self, tmp_path: Path, log_messages: list[str]) -> None: + """T14.2(c): Файлы в _SKIP_SUFFIXES + dot-файлы пропускаются молча (не логируются как не совпадающие). - def test_skip_suffixes_not_logged_as_regex_mismatch( - self, tmp_path: Path, log_messages: list[str], monkeypatch: pytest.MonkeyPatch - ) -> None: - """T14.2(c): Файлы в _SKIP_SUFFIXES пропускаются молча, не логируются как не совпадающие с шаблоном. - - Мутационный тест: если убрать проверку _SKIP_SUFFIXES, тест сломается (файлы будут залогированы). + Мутационный тест: если убрать проверку `entry.name.startswith(".")`, dot-файл не будет проигнорирован + и может быть залогирован как ошибка или другим способом отличаться в поведении. """ hf = _hotfolder(tmp_path) fixtures = _fixtures_dir(tmp_path, {"a.json": {"v": 1}}) @@ -776,6 +794,8 @@ class TestRun: (hf.input_dir / f"{job_id}.pdf.done").write_bytes(b"skip") (hf.input_dir / f"{job_id}.pdf.tmp").write_bytes(b"skip") (hf.input_dir / f"{job_id}.pdf.part").write_bytes(b"skip") + # Добавляем dot-файл (должен быть пропущен как и _SKIP_SUFFIXES) + (hf.input_dir / f".{job_id}.pdf.part").write_bytes(b"skip dot") # Кладём нормальный файл для проверки, что обработка работает job_id2 = _drop(hf, "a.pdf", data=b"a data") @@ -783,7 +803,7 @@ class TestRun: result = process_once(hf.root, fixtures, 0) assert job_id2 in result - # Логи НЕ должны содержать сообщения о "не по шаблону" для файлов с _SKIP_SUFFIXES + # Логи НЕ должны содержать сообщения о "не по шаблону" для файлов с _SKIP_SUFFIXES или dot-файлов foreign_warnings = [m for m in log_messages if m.startswith("WARNING|") and "не по шаблону" in m] assert len(foreign_warnings) == 0 # Ни одного предупреждения про "не по шаблону"