fbi_vault_live.py

import httpx
from ingest.generic_public_foia import GenericFOIAAdapter

class FBIAdapter(GenericFOIAAdapter):
    name = "FBI Vault"
    rate_limit = 1
    robots_respected = True
    base_url = "https://vault.fbi.gov/search"

    async def search(self, query: str):
        async with httpx.AsyncClient(timeout=10) as client:
            r = await client.get(self.base_url, params={"q": query})
            if r.status_code != 200:
                return []
            return [{
                "source": "FBI Vault",
                "query": query,
                "url": str(r.url),
                "snippet": "Public FBI Vault search results"
            }]