The real-time intent feed for AI agents.

# 1. a key (live + sandbox)
curl -s https://leadfeed.dev/v1/signup -d '{"email":"you@agency.com"}' -H 'content-type: application/json'

# 2. natural language → filter JSON
curl -s https://leadfeed.dev/v1/subscriptions/compile -H "authorization: Bearer $LF_KEY" \
  -d '{"prompt":"emergency plumbing in Phoenix with a budget signal"}'

# 3. subscribe (webhook, HMAC-signed, retried)
curl -s https://leadfeed.dev/v1/subscriptions -H "authorization: Bearer $LF_KEY" -d '{
  "name": "phx-plumbing-emergency",
  "filter": {"services":["plumbing"], "geo":{"center":[33.45,-112.07],"radius_km":40},
             "min_scores":{"composite":70,"urgency":0.6}, "max_age_seconds":1800},
  "delivery": {"type":"webhook","url":"https://agent.example.com/leads","secret":"whsec_…"}}'

# or just stream it
curl -N https://leadfeed.dev/v1/stream?subscription=sub_01JB… -H "authorization: Bearer $LF_KEY"

# pip install leadfeed  (sdk/python in the repo)
from leadfeed import LeadFeed

lf = LeadFeed(api_key="lf_live_…")
flt = lf.compile("emergency HVAC in Phoenix with budget")
sub = lf.subscribe("phx-hvac", filter=flt, delivery={"type": "stream"})

for lead in lf.stream(sub["id"]):            # SSE, resumes with Last-Event-ID
    if lead["scores"]["composite"] >= 80 and lead["age_seconds"] < 600:
        lf.claim(lead["id"])
        my_voice_agent.call(lead)            # your outreach, your rules
        lf.outcome(lead["id"], "contacted")  # feeds calibration + refunds

// npm i @leadfeed/sdk  (sdk/typescript in the repo)
import { LeadFeed } from "@leadfeed/sdk";

const lf = new LeadFeed({ apiKey: process.env.LF_KEY! });
const { filter } = await lf.compile("same-day movers in Denver, budget present");
const sub = await lf.subscribe({ name: "den-movers", filter, delivery: { type: "poll" } });

let cursor: string | undefined;
setInterval(async () => {
  const page = await lf.poll(sub.id, { cursor });        // cursor pagination
  for (const { lead } of page.data) await agent.handle(lead);
  cursor = page.next_cursor ?? cursor;
}, 15_000);

// Claude Desktop / Claude Code / any MCP client — hosted remote server
{
  "mcpServers": {
    "leadfeed": {
      "type": "http",
      "url": "https://leadfeed.dev/mcp",
      "headers": { "Authorization": "Bearer lf_live_…" }
    }
  }
}

// tools: search_leads · compile_filter · subscribe · poll_leads · get_lead
//        claim_lead · research_lead · mark_outcome · signals · taxonomy · sandbox_replay
> "Find urgent roofing leads within 50 km of Phoenix posted in the last hour,
   claim the top two, and research the authors."

POST https://agent.example.com/leads
X-LeadFeed-Event: lead.created
X-LeadFeed-Idempotency-Key: ld_01JB…
X-LeadFeed-Signature: t=1761141791,v1=5f1c…   # hmac_sha256(secret, "<t>.<body>")

{ "event": "lead.created",
  "subscription": "phx-plumbing-emergency",
  "lead": { "id": "ld_01JB…", "age_seconds": 91, "scores": { "composite": 86, … }, … },
  "next_actions": [ {"action":"claim", …}, {"action":"research", …}, {"action":"reply", …} ] }

# later, pushed to the same endpoint so your agent stops chasing a solved lead:
{ "event": "lead.status", "lead_id": "ld_01JB…", "status": "resolved" }