Create tests/test_adapters.py

tests/test_adapters.py

@@ -1,29 +1,31 @@
+import inspect
 import asyncio
 import pytest
+from ingest.generic_public_foia import GenericFOIAAdapter
+from ingest.registry import get_all_adapters
 
-from ingest.cia_reading_room import CIAAdapter
-from ingest.fbi_vault import FBIAdapter
 
+@pytest.mark.asyncio
+async def test_all_adapters_compliant():
+    adapters = get_all_adapters()
 
-REQUIRED_KEYS = {"source", "title", "url", "snippet", "live"}
+    assert adapters, "No adapters registered"
 
+    for name, adapter in adapters.items():
+        # Must subclass base
+        assert isinstance(adapter, GenericFOIAAdapter)
 
-@pytest.mark.asyncio
-@pytest.mark.parametrize(
-    "adapter_cls",
-    [CIAAdapter, FBIAdapter]
-)
-async def test_adapter_contract(adapter_cls):
-    adapter = adapter_cls()
-    results = await adapter.search("test")
+        # Must define metadata
+        assert adapter.source_name != "UNKNOWN"
+        assert adapter.base_url.startswith("http")
 
-    assert isinstance(results, list)
+        # Must implement search
+        assert "search" in dir(adapter)
+        assert inspect.iscoroutinefunction(adapter.search)
 
-    for r in results:
-        assert isinstance(r, dict)
-        assert REQUIRED_KEYS.issubset(r.keys())
-        assert isinstance(r["source"], str)
-        assert isinstance(r["title"], str)
-        assert isinstance(r["url"], str)
-        assert isinstance(r["snippet"], str)
-        assert isinstance(r["live"], bool)
+        # Must not raise on empty query
+        try:
+            results = await adapter.search("test")
+            assert isinstance(results, list)
+        except Exception as e:
+            pytest.fail(f"{name} adapter failed search(): {e}")