FastAPI spam filter.

# pip install fastapi uvicorn siftfy
import os
from fastapi import FastAPI
from pydantic import BaseModel, EmailStr
from siftfy import AsyncSiftfy

app = FastAPI()
client = AsyncSiftfy(api_key=os.environ["SIFTFY_KEY"], timeout=2.0)

class ContactSubmission(BaseModel):
    email: EmailStr
    message: str

@app.post("/contact")
async def contact(payload: ContactSubmission) -> dict[str, bool]:
    probability = 0.0
    try:
        result = await client.predict(payload.message)
        probability = result.spam_probability
    except Exception:
        # Fail open so a provider outage does not lose a real lead.
        probability = 0.0

    if probability >= 0.85:
        return {"ok": True}
    if probability >= 0.50:
        await queue_for_review(payload.email, payload.message, probability)
    else:
        await deliver_to_inbox(payload.email, payload.message)
    return {"ok": True}