diff --git a/backend/app/api/import_admin.py b/backend/app/api/import_admin.py index ee074e3..6a16bd3 100644 --- a/backend/app/api/import_admin.py +++ b/backend/app/api/import_admin.py @@ -15,10 +15,17 @@ import_admin_bp = Blueprint("import_admin", __name__, url_prefix="/api/import") async def trigger_scan(): body = await request.get_json(silent=True) or {} mode = body.get("mode", "quick") - if mode not in ("quick", "deep"): - return jsonify({"error": f"mode {mode!r} not supported; use 'quick' or 'deep'"}), 400 + if mode not in ("quick", "deep", "verify"): + return jsonify({"error": f"mode {mode!r} not supported; use 'quick', 'deep', or 'verify'"}), 400 + + # 'verify' is a library task — short-circuit the import_root walk + # (no ImportBatch, no per-file ImportTasks). + if mode == "verify": + from ..tasks.maintenance import verify_integrity + + async_result = verify_integrity.delay() + return jsonify({"celery_task_id": async_result.id, "mode": mode}), 202 - # Enqueue the scan task in Celery. The task creates the batch itself. from ..tasks.scan import scan_directory async_result = scan_directory.delay(triggered_by="manual", mode=mode) diff --git a/tests/test_api_import_admin.py b/tests/test_api_import_admin.py index 9f02861..7e15f4b 100644 --- a/tests/test_api_import_admin.py +++ b/tests/test_api_import_admin.py @@ -114,3 +114,26 @@ async def test_trigger_accepts_deep(client, monkeypatch): async def test_trigger_still_rejects_unknown_mode(client): resp = await client.post("/api/import/trigger", json={"mode": "wat"}) assert resp.status_code == 400 + + +@pytest.mark.asyncio +async def test_trigger_accepts_verify(client, monkeypatch): + # Stub the verify task's dispatch so the API contract is asserted + # without running the real (eager) verify_integrity end-to-end. + from backend.app.tasks import maintenance as m + + seen = {} + + class _Res: + id = "celery-verify" + + def _fake_delay(): + seen["called"] = True + return _Res() + + monkeypatch.setattr(m.verify_integrity, "delay", _fake_delay) + resp = await client.post("/api/import/trigger", json={"mode": "verify"}) + assert resp.status_code == 202 + body = await resp.get_json() + assert body["mode"] == "verify" + assert seen == {"called": True}