signalpipe

# SignalPipe

**Agentic sales pipeline — buying-intent detection, swarm-scored lead qualification, and prospect nurturing for OpenClaw agents.**

SignalPipe judges whether the author of a post, email or ticket wants to buy. Your agent brings the text from anywhere it reads, including X through your own X API access, and an optional scout reads the RSS or Atom feeds you choose. Three independent judges rule on every borderline signal, each kept lead gets a drafted reply that answers what the person actually asked, and only real leads reach you for approval. Works with any OpenClaw-compatible agent — or connect directly via MCP from Claude Code, Cursor, or Windsurf.

[signalpipe.io](https://signalpipe.io)

---

## What It Does

**Top of funnel — Signal Acquisition (Mantidae):**
Your agent brings text from anywhere it reads, and the optional scout reads the RSS or Atom feeds you choose every cycle. Clear-cut posts are decided on content alone; borderline ones go to three independent judges (Skeptic, Analyst, Optimist), and when they split you see it. Only real leads reach your queue, each with a drafted reply that answers what the person asked and mentions your product only when they asked for a tool.

Competitor-switch posts are hard-floored and always reach your queue regardless of score.

**Mid/bottom of funnel — Nurture Engine:**
Tracks every prospect's temperature (0–100) across 14 signal types. Automatically selects the right persona (Educator → Consultant → Closer → Re-engager). Remembers objections permanently — if someone said the price is too high, that angle is never repeated. Never spams. One-directional mode transitions.

**Execution — Sender (v2.0):**
The brain scores, drafts, and approves; the plugin can now also **send**. An optional background sender holds a live stream open to the brain, receives the missions you've already approved, and posts `reddit_comment` / `reddit_dm` on Reddit with **your own** credentials. *The math runs on us, the sending runs on you* — your Reddit credentials and LLM keys never reach SignalPipe. `twitter_reply` is handled by the standalone [`signalpipe-daemon`](https://github.com/AbYousef739/signalpipe-daemon). The sender is opt-in: set the `REDDIT_*` env vars to enable it, or ignore it entirely and stay MCP-only. Private messages go only to someone who asked for one: Reddit and X both require the recipient's consent before an app sends one. SignalPipe never auto-sends a DM or an X reply; each waits for your approval.

---

## Tools (29 total)

### Signal Acquisition

| Tool | What it does |
|---|---|
| `signalpipe_get_missions` | List pending leads awaiting review — score, role, channel, snippet, draft. Lean by default; opt into `include_context=true` only when drafting. |
| `signalpipe_draft_mission` | Get the drafting payload for a single mission so the host LLM can write the reply itself (BYOK path) |
| `signalpipe_upload_draft` | Upload a host-LLM-written draft to a mission |
| `signalpipe_approve_mission` | Approve a lead and queue it for outreach |
| `signalpipe_reject_mission` | Reject a lead with a reason — teaches the per-station RL loop (penalty size adapts to the reason; demotes one noisy feed without dragging the rest of the product down). **Don't** use this when the post is just gone — use `signalpipe_delete_mission` instead. |
| `signalpipe_delete_mission` | Hard-delete a mission row — silent cleanup, no learning signal. Companion to reject. **Canonical case:** the post was deleted / 404'd / removed before you could reply. |
| `signalpipe_mark_sent` | Record that you replied by hand, so follow-ups know what was said and the source feed gets the credit |
| `signalpipe_scout_now` | Trigger an on-demand scouting run across your active products |
| `signalpipe_get_products` | List all configured products |
| `signalpipe_suggest_anchors` | Draft buyer-voice anchor sentences for a product, for you to edit before adding it |
| `signalpipe_add_product` | Register a new product to monitor — describe it in buyer language |
| `signalpipe_update_product` | Edit a product's anchors or description, or pause and resume it |
| `signalpipe_add_station` | Add an RSS feed, subreddit, or HN keyword feed for a product |
| `signalpipe_list_stations` | Your feeds with a health readout: posts captured, posts that reached your queue, and what to change |
| `signalpipe_update_station` | Pause, resume, rename or re-point a feed |
| `signalpipe_remove_station` | Remove a feed (one with history is switched off instead, to keep it) |
| `signalpipe_reload_products` | Hot-reload product cache after changes — no redeploy needed |

### Nurture Engine

| Tool | What it does |
|---|---|
| `signalpipe_track_prospect` | Log a signal from a prospect, update their temperature |
| `signalpipe_record_reply` | Send a prospect's reply to the brain, which reads it: intent, objections, do-not-contact, and whether they invited a private message |
| `signalpipe_get_message` | Generate the next outreach message via the backend LLM |
| `signalpipe_get_message_prompt` | Get the full prompt + context so the host LLM writes the message (BYOK path) |
| `signalpipe_record_message` | Record a host-LLM-written message as sent |
| `signalpipe_get_pipeline` | View the full prospect pipeline sorted by temperature |
| `signalpipe_score_signal` | Universal scorer — paste any text (Gmail, Slack, Discord, Telegram, LinkedIn, transcripts) and get back the same score + classification + drafting context the scout produces for Reddit/HN posts. For a reply or comment, pass the post it answers as `context`. `panel_verdict` says what the judges decided. SignalPipe never touches the source channel; your host agent does. |

### Sender

Reddit-only; requires the optional `REDDIT_*` env vars. Contains no scoring or drafting — it only posts pre-approved missions with your credentials.

| Tool | What it does |
|---|---|
| `signalpipe_start_sender` | Start the background sender — streams approved missions and posts `reddit_comment` / `reddit_dm` with your own Reddit creds. Supports `dry_run`. |
| `signalpipe_stop_sender` | Stop the background sender; unsent approved missions stay queued on the brain |
| `signalpipe_sender_status` | Report sender state — running / connected, sent / failed / skipped counts this session, plus brain-side queue depth |

### Reader

Reads feeds from this machine. No credentials and no extra dependencies.

| Tool | What it does |
|---|---|
| `signalpipe_read_feeds` | Read the client-marked stations from this machine and send each feed page to the brain for judging. One pass in the background by default (a minute per feed); `every_minutes` keeps reading on an interval, `stop` ends it. |
| `signalpipe_preview_station` | Check a feed for buyers before adding it: read here, judged by the brain, nothing saved. Answers VIABLE, MARGINAL, ON-TOPIC NOT IN-MARKET, NO BUYERS or NO DATA. |

---

## MCP Support

SignalPipe exposes all tools as an MCP server — no OpenClaw plugin install needed.

Connect from Claude Code, Cursor, or Windsurf — add this URL to your MCP config:
```
https://api.signalpipe.io/mcp
```
Auth: `Authorization: Bearer YOUR_OPERATOR_KEY`

Once connected, ask your agent:
- *"Show me my leads"*
- *"Reject the first one — it's a founder promoting their own tool"*
- *"Who should I follow up with today?"*

---

## Live Session Example

A typical morning lead review inside your OpenClaw agent or Claude.ai via MCP.

---

**You:** Show me today's leads.

```
→ signalpipe_get_missions
```

```
3 missions pending review

MISSION 1 · score: 91 · role: CLOSER · competitor_flag: true
Product : AcmeTool
Channel : reddit_dm
Handle  : u/frustrated_dev99
Snippet : "Their pricing just doubled again. Done. Need a replacement ASAP."
Draft   : "Saw your post — we built AcmeTool for exactly the gap you're
           describing. Teams typically switch in under a week. Worth a
           quick look? Happy to show you how it compares."

MISSION 2 · score: 68 · role: ADVISOR · competitor_flag: false
Product : AcmeTool
Channel : reddit_dm
Handle  : u/ops_lead_rachel
Snippet : "Looking for a tool to automate repetitive ops workflows.
           Budget is flexible, need something the team actually uses."
Draft   : "The part about 'something the team actually uses' is the real
           problem to solve — most tools fail there, not on features.
           AcmeTool is built around that constraint. Happy to walk through
           a real team setup if useful."

MISSION 3 · score: 24 · role: EDUCATOR · competitor_flag: false
Product : AcmeTool
Channel : reddit_dm
Handle  : u/just_browsing_thx
Snippet : "Saw an ad for workflow tools. Not really something I need right now"
Draft   : [Swarm low-confidence — auto-rejected]
```

**Agent:** 2 leads ready. Lead 1 is a competitor-switch signal, score 91 — Closer draft, proposes a direct next step. Lead 2 is a genuine need with flexible budget, score 68 — Advisor draft, leads with their real problem. Lead 3 was auto-rejected by the swarm. Approve 1 and 2, or edit first?

---

**You:** Lead 1 is good, approve it. For lead 2 change the draft to: "Hey Rachel — we solve exactly this. Most ops teams are running automations within a day. Want me to show you how a team like yours uses it?"

```
→ signalpipe_approve_mission (msn_8f3a — swarm draft unchanged)
→ signalpipe_approve_mission (msn_2b91 — user-edited draft)
```

```
✓ msn_8f3a queued for outreach
✓ msn_2b91 queued for outreach (your version)
```

---

**You:** Rachel just replied — she's interested. Log it.

```
→ signalpipe_track_prospect
  handle    : u/ops_lead_rachel
  channel   : reddit_dm
  signal    : replied
  mission_id: msn_2b91
```

```json
{
  "prospect_id": "pro_7f2c",
  "handle": "u/ops_lead_rachel",
  "temperature": 45,
  "mode": "sales",
  "persona": "Consultant",
  "follow_up_in": "2–3 days"
}
```

**Agent:** Rachel is in Sales mode, temperature 45. Consultant persona active — qualify and show fit, no hard sell yet.