You have the Reddit posts.
Now find out who wants to buy.

{
  "product_id": "YOUR_PRODUCT_ID",
  "include_drafting_context": false,
  "items": [
    {
      "id": "t3_1abc2de",
      "text": "Our CRM contract ends in June and we're not renewing.\n\nWhat did your team move to?",
      "source_hint": "reddit"
    }
  ]
}

import os
import requests

API = "https://api.signalpipe.io"
HEADERS = {"Authorization": f"Bearer {os.environ['SIGNALPIPE_OPERATOR_KEY']}"}
PRODUCT_ID = os.environ["SIGNALPIPE_PRODUCT_ID"]


def score(posts):
    """posts: dicts with 'id', 'title' and 'body', from a source you may use."""
    items = [
        {"id": p["id"], "text": f"{p['title']}\n\n{p.get('body') or ''}".strip(), "source_hint": "reddit"}
        for p in posts
    ]
    results = []
    for i in range(0, len(items), 25):  # the endpoint takes 1-25 items
        r = requests.post(
            f"{API}/signal/score_batch",
            headers=HEADERS,
            json={"product_id": PRODUCT_ID, "items": items[i:i + 25], "include_drafting_context": False},
            timeout=600,  # items are scored one after another; borderline ones convene the panel
        )
        r.raise_for_status()
        results.extend(r.json()["results"])
    return results


results = score(posts)
buyers = [r for r in results if r["ok"] and r["classification"] == "buying_intent"]
look_again = [r for r in results if r["ok"] and (r.get("degraded") or (r.get("swarm") or {}).get("split"))]
failed = [r for r in results if not r["ok"]]

const API = 'https://api.signalpipe.io'
const headers = {
  Authorization: `Bearer ${process.env.SIGNALPIPE_OPERATOR_KEY}`,
  'Content-Type': 'application/json',
}

// posts: [{ id, title, body }] from a source you may use
export async function score(posts, productId) {
  const items = posts.map(p => ({
    id: p.id,
    text: `${p.title}\n\n${p.body ?? ''}`.trim(),
    source_hint: 'reddit',
  }))
  const results = []
  for (let i = 0; i < items.length; i += 25) { // the endpoint takes 1-25 items
    const res = await fetch(`${API}/signal/score_batch`, {
      method: 'POST',
      headers,
      body: JSON.stringify({ product_id: productId, items: items.slice(i, i + 25), include_drafting_context: false }),
    })
    if (!res.ok) throw new Error(`score_batch ${res.status}: ${await res.text()}`)
    results.push(...(await res.json()).results)
  }
  return results
}

# your product ids
curl -s https://api.signalpipe.io/products/list \
  -H "Authorization: Bearer $SIGNALPIPE_OPERATOR_KEY"

# score up to 25 posts
curl -s https://api.signalpipe.io/signal/score_batch \
  -H "Authorization: Bearer $SIGNALPIPE_OPERATOR_KEY" \
  -H "Content-Type: application/json" \
  -d @batch.json

{
  "count": 3,
  "scored": 2,
  "failed": 1,
  "judgements_spent": 1,
  "degraded_count": 0,
  "results": [
    {
      "id": "t3_1abc2de", "index": 0, "ok": true,
      "classification": "buying_intent",
      "swarm_ran": true, "panel_verdict": "kept",
      "swarm": { "judges": { "skeptic": "convinced", "analyst": "convinced", "optimist": "convinced" }, "split": false },
      "degraded": false
    },
    {
      "id": "t3_1fgh3ij", "index": 1, "ok": true,
      "classification": "noise",
      "swarm_ran": false, "swarm_skipped": "not_borderline", "panel_verdict": "not_run",
      "degraded": false
    },
    { "id": "t3_1klm4no", "index": 2, "ok": false, "error": "Missing required field: text" }
  ]
}

claude mcp add --transport http signalpipe https://api.signalpipe.io/mcp \
  --header "Authorization: Bearer YOUR_OPERATOR_KEY"

{
  "mcpServers": {
    "signalpipe": {
      "type": "http",
      "url": "https://api.signalpipe.io/mcp",
      "headers": { "Authorization": "Bearer YOUR_OPERATOR_KEY" }
    }
  }
}

Take the posts you just fetched. For each one, call SignalPipe's
score_signal tool with the title and body as text, product_id YOUR_PRODUCT_ID
and source_hint "reddit". For a comment, pass the post it replies to as context.
Then list the posts classified buying_intent, and separately any where the
judges split or the verdict is degraded.