obsidian-plugin/lllin000_PaperForge
1
0
Fork 0
mirror of https://github.com/lllin000/PaperForge.git synced 2026-07-22 06:50:53 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

test(prune): add SyncService prune integration tests

Browse source
This commit is contained in:
Research Assistant 2026-05-18 21:58:57 +08:00
parent 214453d69c
commit e2068d2172
1 changed files with 108 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

108
tests/unit/services/test_sync_service_prune.py Normal file
View file

@ -0,0 +1,108 @@
"""Tests for SyncService.prune() integration."""
from __future__ import annotations
from contextlib import ExitStack
from pathlib import Path
from unittest.mock import patch
from paperforge.services.sync_service import SyncService
class TestSyncServicePruneMethod:
"""SyncService.prune() — delegates to worker module."""
def test_prune_calls_worker_module(self, tmp_path: Path) -> None:
svc = SyncService(tmp_path)
fresh_index = {"schema_version": "3", "items": []}
with patch("paperforge.worker.prune.prune_orphan_papers") as mock_fn:
mock_fn.return_value = {"preview": [], "deleted": [], "counts": {}}
result = svc.prune({}, fresh_index=fresh_index, dry_run=True)
mock_fn.assert_called_once()
assert result["deleted"] == []
def test_prune_dry_run_passed_through(self, tmp_path: Path) -> None:
svc = SyncService(tmp_path)
fresh_index = {"schema_version": "3", "items": []}
with patch("paperforge.worker.prune.prune_orphan_papers") as mock_fn:
mock_fn.return_value = {"preview": [{"key": "k1"}], "deleted": [], "counts": {}}
result = svc.prune({}, fresh_index=fresh_index, dry_run=True)
mock_fn.assert_called_once()
_, kwargs = mock_fn.call_args
assert kwargs.get("dry_run") is True
def test_prune_auto_reads_index(self, tmp_path: Path) -> None:
svc = SyncService(tmp_path)
fake_index = {"schema_version": "3", "items": []}
with patch("paperforge.worker.asset_index.read_index", return_value=fake_index) as mock_read:
with patch("paperforge.worker.prune.prune_orphan_papers") as mock_fn:
mock_fn.return_value = {"preview": [], "deleted": [], "counts": {}}
svc.prune({}, fresh_index=None, dry_run=True)
mock_read.assert_called_once()
mock_fn.assert_called_once()
class TestSyncServiceRunPrune:
"""SyncService.run() with prune/prune_force flags."""
def _make_svc(self, tmp_path: Path) -> SyncService:
vault = tmp_path
(vault / "paperforge.json").write_text(
'{"system_dir": "System", "resources_dir": "Resources", "literature_dir": "Resources/Literature"}'
)
(vault / "System" / "PaperForge" / "exports").mkdir(parents=True)
(vault / "System" / "PaperForge" / "indexes").mkdir(parents=True)
(vault / "Resources" / "Literature").mkdir(parents=True)
return SyncService(vault)
def test_run_with_prune_calls_prune_method(self, tmp_path: Path) -> None:
svc = self._make_svc(tmp_path)
svc.paths = {
"literature": tmp_path / "Resources" / "Literature",
"exports": tmp_path / "System" / "PaperForge" / "exports",
"index": tmp_path / "System" / "PaperForge" / "indexes",
"system_dir": tmp_path / "System",
}
with patch.object(svc, "prune") as mock_prune:
mock_prune.return_value = {"preview": [], "deleted": [], "counts": {}}
with ExitStack() as stack:
stack.enter_context(patch.object(svc, "resolve_paths", return_value=svc.paths))
stack.enter_context(patch("paperforge.worker.sync.load_export_rows", return_value=[]))
stack.enter_context(patch("paperforge.worker._domain.load_domain_config"))
stack.enter_context(patch("paperforge.worker.base_views.ensure_base_views"))
stack.enter_context(patch("paperforge.config.load_vault_config"))
stack.enter_context(patch("paperforge.worker.sync.migrate_to_workspace"))
stack.enter_context(patch("paperforge.worker.asset_index.build_index", return_value=0))
stack.enter_context(patch("paperforge.worker.asset_index.read_index", return_value={"schema_version": "3", "items": []}))
svc.run(prune=True, prune_force=True)
mock_prune.assert_called_once()
def test_run_without_prune_does_not_call_prune(self, tmp_path: Path) -> None:
svc = self._make_svc(tmp_path)
svc.paths = {
"literature": tmp_path / "Resources" / "Literature",
"exports": tmp_path / "System" / "PaperForge" / "exports",
"index": tmp_path / "System" / "PaperForge" / "indexes",
"system_dir": tmp_path / "System",
}
with patch.object(svc, "prune") as mock_prune:
with ExitStack() as stack:
stack.enter_context(patch.object(svc, "resolve_paths", return_value=svc.paths))
stack.enter_context(patch("paperforge.worker.sync.load_export_rows", return_value=[]))
stack.enter_context(patch("paperforge.worker._domain.load_domain_config"))
stack.enter_context(patch("paperforge.worker.base_views.ensure_base_views"))
stack.enter_context(patch("paperforge.config.load_vault_config"))
stack.enter_context(patch("paperforge.worker.sync.migrate_to_workspace"))
stack.enter_context(patch("paperforge.worker.asset_index.build_index", return_value=0))
stack.enter_context(patch("paperforge.worker.asset_index.read_index", return_value={"schema_version": "3", "items": []}))
svc.run()
mock_prune.assert_not_called()