"Understanding Server-Sent Events (SSE)" matching MCP tools:

• stream_taskA

  TunnelMind Data APIB

  Opens a persistent SSE connection that emits events as the task progresses. The stream closes automatically when the task reaches a terminal state or after ~90 seconds (timeout). Heartbeat comments are sent every ~15 seconds to keep the connection alive through proxies. Event types: - `status` — emitted when status changes (pending → running → complete/failed) - `result` — emitted on `complete` with the full result payload - `error` — emitted on `failed`, `cancelled`, or `expired` with error info - SSE comment (`: heartbeat`) — keepalive, no data Use this tool when: - You want real-time progress without polling. - You are in an environment that supports SSE (EventSource API). Do NOT use this tool when: - You want a simple one-shot status check — use `get_task` instead. - Your HTTP client doesn't support streaming responses. Inputs: - `task_id` (path, required): 26-char ULID. Returns: - SSE stream (`text/event-stream`). Each event is `event: <type>\\ndata: <json>\\n\\n`. Cost: - Free. Counts as one request against rate limits when the stream opens. Latency: - First event: <200ms. Stream duration: up to 90s.

  ConnectorNo auth

• find_my_phoneA

  ReflectoA

  Ring the user's phone at full volume for up to 60 seconds, even if it's on silent or Do Not Disturb. Use this when the user asks to locate or ring their phone. Fire-and-forget: the server can't confirm the phone actually rang, only that the ring request was sent.

  ConnectorOAuth

• findagent_create_remote_mcpA

  FindAgentA

  List an EXTERNAL remote MCP server you run as a marketplace LISTING — for an MCP server hosted on YOUR OWN infrastructure that buyers connect their client straight to (FindAgent never proxies or runs it). Pass the listing basics (title/slug/tagline/description/category_slug + example_prompts: 1–5 required) and the remote endpoint as `server_url` (https) OR a parsed `server.json` object in `server_json`. The server's tools are auto-detected (a sandbox-gated live scan when available) — you can override with `tools` (name+description), `transport` (streamable-http|sse), and `auth_note` (what credential the server needs — NEVER a secret value). Creates a status=draft agent you own; then call findagent_submit_for_review IN THIS MCP CLIENT to submit it. The server URL is stored + displayed only; nothing executes on FindAgent. Before calling: findagent_check_slug + findagent_list_categories.

  ConnectorOAuth

• post_scholar_search_explainA

  AIsa Web Search & ResearchA

  Explain a result set you already fetched. Unlike the three search endpoints this one takes a **JSON body**: `search_id` (required — the `id` returned by `post_scholar_search_web`, `post_scholar_search_scholar` or `post_scholar_search_mixed`), plus `detail_level` (BRIEF / MODERATE / DETAILED), `language`, and `response_mode`. ⚠️ Use `response_mode: NON_STREAMING`. It returns `{"message": "…"}` as JSON, measured at about 2 KB. The COMPLETE and INCREMENTAL modes emit server-sent events in which **each event repeats the whole answer so far** — the identical explanation measured 177 KB that way, roughly 90 times larger, and a tool call cannot consume a stream incrementally anyway. It only ever explains an existing search; it cannot run one.

  ConnectorOAuth

• setWebhookA

  AgoreanA

  Push side of your event stream (needs your API key): we POST every event for your profile to `url` as it happens — body is the event row's JSON byte for byte, signed with the `webhook_secret` this call returns (`Agorean-Signature: t=<unix>,v1=<hex HMAC-SHA256(secret, t + "." + body)>`, plus `Agorean-Event-Id`), retried at 1 m, 5 m, 30 m, 2 h and 12 h, then dead-lettered; anything undelivered still waits in events(). Every call mints a new secret (keep it: it is shown once, the old one stops verifying, and a retry with the same idempotency_key is refused with `conflict` rather than replayed). A `webhook.test` event is sent right away so you can see the loop close. `url: null` stops pushing. Refused (invalid_input, `details.reason`), on the literal host and nothing resolved: `malformed` (not a URL, or one carrying credentials), `not_https`, `our_infrastructure` (agorean.com, a netlify.app host or this deploy's own), `localhost`, `private_address` (private, loopback, carrier-grade NAT or link-local IPs). No server? docs('receive-events') runs one from a laptop through a tunnel — or just poll events().

  ConnectorNo auth

• get_statusA

  TracklutionA

  Connectivity check only — does NOT return any analytics data. Pings every connected Tracklution server and reports reachable / unreachable. USE WHEN: - The user reports the integration "isn't working" and you need to isolate network vs. data issues. - You want to confirm a freshly-added server is online before running real queries. For any data question (counts, events, sessions), skip this and go straight to get_summary or get_report.

  ConnectorOAuth

• hash_textA

  DoichainA

  Compute the SHA-256 digest of a short text (UTF-8) on the server, for example to anchor a statement or a message with anchor_proof. The text is sent to the server but not stored or logged. For files and for confidential texts compute the hash locally instead (sha256sum file, or Get-FileHash -Algorithm SHA256).

  ConnectorNo auth

• tflogsA

  InsideOut (Riley)A

  MONITORING: Fetch Terraform deployment logs with pagination Fetches logs from a running or completed Terraform deployment job. For **completed jobs**: uses REST endpoint for instant retrieval (supports `tail` for server-side filtering). For **running jobs**: streams via SSE with timeout-based pagination. **PAGINATION** (running jobs only): Use `last_event_id` from the response to fetch more: 1. First call: `tflogs(session_id='...')` → get logs + `last_event_id` 2. Next call: `tflogs(session_id='...', last_event_id='...')` → get NEW logs only 3. Repeat until `complete: true` in response **RESPONSE FIELDS**: - `logs`: Array of log messages collected - `last_event_id`: Pass this back to get more logs (pagination cursor, SSE only) - `complete`: true if job finished, false if more logs may be available - `total_logs`: total log entries before tail truncation REQUIRES: session_id from convoopen response (format: sess_v2_...). OPTIONAL: job_id to target a specific deployment (use tfruns to discover IDs), timeout (default 50s, max 55s), last_event_id (for pagination), tail (return only last N entries) ⚠️ CONTEXT WARNING: Deploy logs can be hundreds of lines. Use tail: 50 for completed jobs to avoid blowing up the context window.

  ConnectorNo auth

• tflogsA

  InsideOut (Riley)A

  MONITORING: Fetch Terraform deployment logs with pagination Fetches logs from a running or completed Terraform deployment job. For **completed jobs**: uses REST endpoint for instant retrieval (supports `tail` for server-side filtering). For **running jobs**: streams via SSE with timeout-based pagination. **PAGINATION** (running jobs only): Use `last_event_id` from the response to fetch more: 1. First call: `tflogs(session_id='...')` → get logs + `last_event_id` 2. Next call: `tflogs(session_id='...', last_event_id='...')` → get NEW logs only 3. Repeat until `complete: true` in response **RESPONSE FIELDS**: - `logs`: Array of log messages collected - `last_event_id`: Pass this back to get more logs (pagination cursor, SSE only) - `complete`: true if job finished, false if more logs may be available - `total_logs`: total log entries before tail truncation REQUIRES: session_id from convoopen response (format: sess_v2_...). OPTIONAL: job_id to target a specific deployment (use tfruns to discover IDs), timeout (default 50s, max 55s), last_event_id (for pagination), tail (return only last N entries) ⚠️ CONTEXT WARNING: Deploy logs can be hundreds of lines. Use tail: 50 for completed jobs to avoid blowing up the context window.

  ConnectorNo auth

• subscribe_threatsA

  Nullcone Threat IntelligenceA

  Open a named, stateful subscription to live threat push delivery. Returns a subscription_id. Pass it to drain_subscription() to collect the IOCs that have arrived since your last drain — zero polling, each caller gets their own isolated stream. Multiple subscribers receive independent copies of every matching IOC. Subscriptions expire after 1 hour of inactivity (no drain calls). Composition filters let you narrow the stream: - ioc_types: only deliver these IOC types (empty = all) - families: only deliver IOCs from these malware families (empty = all) - tags: only deliver IOCs with at least one of these tags (empty = all) Requires the MCP server to be running in SSE mode (MCP_TRANSPORT=sse) with a live SpacetimeDB push subscription active. Args: min_severity: Minimum severity to deliver (0-10). Default 5 (medium+). ioc_types: List of IOC types to include. E.g. ["skill","prompt","ip"]. Valid: hash_md5, hash_sha1, hash_sha256, ip, ip_port, domain, url, yara, email, mutex, filepath, asn, ja3, imphash, cve, prompt, skill. Empty = all types. families: List of malware family names to include. Empty = all. tags: List of tags — IOC must match at least one. Empty = all. Returns: subscription_id: Opaque ID — pass to drain_subscription() / unsubscribe() push_active: Whether the background push subscription is running filters: Echo of the composition filters applied

  ConnectorNo auth

• get_live_scoreA

  Lumify Sports IntelligenceA

  Get a lightweight live score snapshot for an event: status, period, clock, per-participant score and period-by-period scores, and last-updated time. Cheaper and faster than get_event when you only need the score, not participants or venue. Capped at 20 calls/min per key (shared with GET /v1/events/{id}/score and list_events include_scores=true). For live updates prefer the SSE stream. Raises a not-found error if event_id doesn't exist.

  ConnectorAPI key

• dp_check_password_pwnedA

  Default PrivacyA

  Check whether a password has appeared in known breaches using HIBP k-anonymity. The password is SHA-1 hashed locally and only the first 5 hash characters are sent to HIBP — the password itself never leaves the server and is never stored or logged. Returns whether it was found and how many times.

  ConnectorNo auth

• reportA

  kansei-mcp-serverA

  Record what happened after using a service: success/failure outcome, feedback, API change events, or qualitative experience. Data is saved to this installation's LOCAL database only (improves local recovery hints and stats) — nothing is sent to KanseiLink unless you separately opt in to sharing. PII is auto-masked before storage. This is step 4 of the standard flow: search_services → lookup → (execute) → report.

  ConnectorNo auth

• get_recent_signalsA

  PredMCPA

  Server-detected events from the last hour: funding outliers (≥3x 7d baseline), whale trades (≥$100k), OI caps reached. Cursor-based — pass next_cursor back as since_id to receive only new events. The polling equivalent of the /sse/signals stream. Pro tool get_signal_history covers 7 days with forward-return outcomes.

  ConnectorNo auth

• test_ruleA

  Valuein — SEC EDGAR Fundamentals & Smart-Money DataA

  Dry-run a rule's condition_expr against a SYNTHETIC trigger payload — reports whether it WOULD have fired, but NEVER dispatches the action (no report generated, no team run, no message sent, no inbox write). Use this immediately after create_rule to sanity-check the condition before it starts evaluating against real events. Pass `sample_payload_override` to test against specific field values (e.g. `{price_change_pct: 12}`).

  ConnectorNo auth

• ui_keystrokeA

  Local MCPB

  Sends a key combination, e.g. "cmd+shift+5", "return", "cmd+,", "escape". Modifiers: cmd, shift, alt/option, ctrl, fn. The last token is the key. Returns {sent, delivery:"posted_not_confirmed"} — `sent` means the key events were POSTED, NOT that the app acted on them: CGEvent carries no delivery confirmation, and a keystroke's effect is arbitrary so nothing can be read back to prove it. Confirm the effect with ui_get_element / ui_read_tree rather than trusting `sent`. Modifiers are released after the combo, so a following ui_type is not swallowed. unknown_key if the key isn't recognized. Requires Accessibility permission.

  ConnectorOAuth

• get_apollo_emailer_messages_id_activitiesA

  AIsa SalesB

  Engagement events for one sent email: opens, clicks, replies and bounces, with timestamps. Get the message id from `get_apollo_emailer_messages_search`. Use this rather than inferring engagement from the message record itself, which carries delivery state but not recipient behaviour.

  ConnectorOAuth

• get_apollo_emailer_messages_id_activitiesA

  AIsa ApolloA

  Engagement events for one sent email: opens, clicks, replies and bounces, with timestamps. Get the message id from `get_apollo_emailer_messages_search`. Use this rather than inferring engagement from the message record itself, which carries delivery state but not recipient behaviour.

  ConnectorOAuth

• tascan_cancel_scheduled_smsA

  TaScanB

  Cancel a scheduled text that has not been sent yet (status pending). A row already sending, sent, failed or cancelled is refused (409) — a sent text cannot be recalled.

  Connector

  Destructive

  No auth

• create_submissionA

  FaldaroA

  Create a submission for a form. `data` maps field slugs to values — send only what the user provided; computed fields are derived server-side and anything sent for them is ignored. Use draft:true to save partially-filled work (skips required-field validation). Check the form’s field slugs via get_form_draft or evaluate_submission first. Requires submission:write.

  ConnectorAPI key

• revoke_family_invitationA

  financeA

  Revoke (cancel) a pending invitation YOU sent, before it's accepted. Use list_family_invitations to find the id in the "sent" list — e.g. to withdraw an invitation sent to the wrong address. Only group owners/admins can revoke. (2026-07-19: closes the QA-sweep gap where a sent invitation was unremovable from the agent surface.) Args: invitation_id: ID of the sent invitation to revoke. Returns: {"success": True, "email": ...} or an error when not found / not pending / not yours to revoke.

  ConnectorAPI key