pip install filing-firehose

from filing_firehose import FilingFirehose

ff = FilingFirehose()

# Recent 8-Ks where the body language flags items the filer didn't report
buried = ff.recent_8k(suspected_buried_only=True, limit=10)
for f in buried:
    print(f"{f.company_name}: filer reported {f.filer_reported_items}, "
          f"body suggests {f.suspected_buried_events}")

# Recent activist 13D / 13G filings
for f in ff.recent_13d(activist="Saba"):
    print(f"{f.company_name} — {f.percent_of_class}% by {f.activist_filers}")

# Recent ATM offerings with shelf size > $50M
for f in ff.recent_atm(min_shelf_million_usd=50):
    print(f"{f.company_name}: ${f.shelf_size_million_usd:.1f}M via {f.sales_agents}")

ff = FilingFirehose(api_key="ff_live_...")

# Search the entire archive for cyber events
for f in ff.search_8k(items="1.05", since="2026-01-01"):
    print(f.company_name, f.filed_at)

import asyncio
from filing_firehose import AsyncFilingFirehose

async def main():
    async with AsyncFilingFirehose() as ff:
        filings = await ff.recent_8k(items="1.05,5.02")
        for f in filings:
            print(f.company_name, f.detected_items)

asyncio.run(main())