Ghost spam filter.

// Generic Ghost webhook receiver. Adapt the field mapping to your event.
export default {
  async fetch(req, env) {
    if (req.method !== "POST") return new Response("method", { status: 405 });
    const event = await req.json();

    const text = [
      event.member?.name,
      event.member?.email,
      event.comment?.html,
      event.message,
    ].filter(Boolean).join("\n");

    let probability = 0;
    let ceiling = null;
    const resp = await fetch("https://api.siftfy.io/v1/predict", {
      method: "POST",
      headers: {
        "Content-Type": "application/json",
        "X-API-Key": env.SIFTFY_KEY,
      },
      body: JSON.stringify({ text }),
    });
    if (resp.ok) {
      const data = await resp.json();
      probability = data.spam_probability;
      ceiling = data.max_confidence ?? null;
    }

    // Drop only ABOVE the ceiling the response reports. At the ceiling the score
    // is censored, so a fixed constant never fires on the model's own opinion.
    if (ceiling !== null && probability > ceiling) return new Response("ok", { status: 200 });
    await env.CLEAN_QUEUE.send({ event, probability });
    return new Response("ok", { status: 200 });
  },
};