arm_confluence_trap

Programmatically arm or disarm a route's stateful signal gate: entity scope field, required confluence tags, sliding window and per-entity cooldown. Requires the Neural Frame tier. Use it to wait for N independent confirmations on the same entity before the route fires.

Argument	Type	Description
enabled	boolean	Set false to disarm the trap without clearing the rest of the route
route_id*	string	Target route ID (e.g. rt_1)
tag_field	string	Field identifying the leg (default timeframe)
window_sec	number	Confluence sliding window in seconds (30-86400, default 900)
cooldown_sec	number	Mute repeat signals for the same entity for N seconds after firing (0 = off)
entity_field	string	Dot-notation payload field that scopes the trap (default ticker)
required_tags	array	Signal legs that must ALL arrive inside the window, e.g. ["15m","1h"]

Input schema (JSON)

{
  "type": "object",
  "required": [
    "route_id"
  ],
  "properties": {
    "enabled": {
      "type": "boolean",
      "description": "Set false to disarm the trap without clearing the rest of the route"
    },
    "route_id": {
      "type": "string",
      "description": "Target route ID (e.g. rt_1)"
    },
    "tag_field": {
      "type": "string",
      "description": "Field identifying the leg (default timeframe)"
    },
    "window_sec": {
      "type": "number",
      "description": "Confluence sliding window in seconds (30-86400, default 900)"
    },
    "cooldown_sec": {
      "type": "number",
      "description": "Mute repeat signals for the same entity for N seconds after firing (0 = off)"
    },
    "entity_field": {
      "type": "string",
      "description": "Dot-notation payload field that scopes the trap (default ticker)"
    },
    "required_tags": {
      "type": "array",
      "items": {
        "type": "string"
      },
      "description": "Signal legs that must ALL arrive inside the window, e.g. [\"15m\",\"1h\"]"
    }
  }
}

claim_subscription

Exchange the claim_token from subscribe_plan for the provisioned Master Passkey. Poll until status is "completed"; returns api_key, tier, quota_limit and expiry.

Argument	Type	Description
order_id*	string	order_id returned by subscribe_plan
claim_token*	string	claim_token returned by subscribe_plan

Input schema (JSON)

{
  "type": "object",
  "required": [
    "order_id",
    "claim_token"
  ],
  "properties": {
    "order_id": {
      "type": "string",
      "description": "order_id returned by subscribe_plan"
    },
    "claim_token": {
      "type": "string",
      "description": "claim_token returned by subscribe_plan"
    }
  }
}

create_or_update_route

Programmatically deploy or update a 1-to-4 fan-out route on the global edge (requires Neural Frame tier for write operations via MCP).

Argument	Type	Description
id	string	Route ID (e.g. rt_1) or 'new' to create a new route
name*	string	Human-readable route label
filters	array
ai_enrich	boolean	Inject {{ai_summary}} and {{ai_sentiment}} into payload
filter_logic	string
template_body	string
template_title	string
dedup_window_sec	number
telegram_bot_url	string
telegram_chat_id	string
slack_webhook_url	string

extract_schema_tokens

The Intelligent Schema Extractor as an agent call: walks every retained inbound payload for a route and returns the {{dot.paths}} you can reference in a template — nested objects as data.object.amount, array projections as commits[].message — each with its inferred type, sample values, how many webhooks carried it and its presence ratio. Pass template_body to also see which of its tokens the traffic actually fills and how the cleaned alert renders: a token the payload lacks is dropped together with its label, so one ingest URL can serve several sources without leaking "RSI:" into the message.

read-only

Argument	Type	Description
route_id	string	Route to extract from (defaults to every retained webhook on the passkey)
template_body	string	Optional draft body: adds resolved_tokens, omitted_tokens and rendered_preview

Input schema (JSON)

{
  "type": "object",
  "properties": {
    "route_id": {
      "type": "string",
      "description": "Route to extract from (defaults to every retained webhook on the passkey)"
    },
    "template_body": {
      "type": "string",
      "description": "Optional draft body: adds resolved_tokens, omitted_tokens and rendered_preview"
    }
  }
}

get_subscription_status

Return the authenticated passkey's tier, plan, quota usage, expiry, routes, registered agent identity and callback delivery history.

read-only

No arguments.

Input schema (JSON)

{
  "type": "object",
  "properties": {},
  "additionalProperties": false
}

inspect_inbound_payload

Read the bytes a sender actually POSTed to an ingest URL, before any parsing, enrichment or filtering — one execution by event_id, or the newest few for a route. Telemetry reports what the edge decided; this reports what arrived, which is what a template has to be written against. Read-only and never charges quota.

read-only

Argument	Type	Description
limit	number	Max events to return when listing (1-25, default 5)
event_id	string	Inspect one retained execution in full (from inspect_live_telemetry or query_signal_memory)
route_id	string	Optional route_id to list the newest retained inbounds for (e.g. rt_1). Omit to cover every route on the passkey.

Input schema (JSON)

{
  "type": "object",
  "properties": {
    "limit": {
      "type": "number",
      "description": "Max events to return when listing (1-25, default 5)"
    },
    "event_id": {
      "type": "string",
      "description": "Inspect one retained execution in full (from inspect_live_telemetry or query_signal_memory)"
    },
    "route_id": {
      "type": "string",
      "description": "Optional route_id to list the newest retained inbounds for (e.g. rt_1). Omit to cover every route on the passkey."
    }
  }
}

inspect_live_telemetry

Fetch the latest 25 webhook execution logs (delivered and dropped signals, inbound edge location, per-target delivery latency in ms, and rescued JSON fields) from Edge Isolate RAM.

read-only

Argument	Type	Description
limit	number	Max log items to return (1-25)
route_id	string	Optional route_id filter (e.g. rt_1)

Input schema (JSON)

{
  "type": "object",
  "properties": {
    "limit": {
      "type": "number",
      "description": "Max log items to return (1-25)"
    },
    "route_id": {
      "type": "string",
      "description": "Optional route_id filter (e.g. rt_1)"
    }
  }
}

list_plans

Return every subscription and credit top-up an AI agent can buy programmatically, with prices, quotas, accepted crypto currencies, and the checkout/claim endpoints. No authentication required.

read-only

No arguments.

Input schema (JSON)

{
  "type": "object",
  "properties": {},
  "additionalProperties": false
}

list_routes

List all deployed 1-to-4 webhook routes, isolated whk_ ingest URLs, filter rules, and quota metrics for the authenticated EarlyFra.me Master Passkey.

read-only

No arguments.

Input schema (JSON)

{
  "type": "object",
  "properties": {},
  "additionalProperties": false
}

preview_alert_template

Dry-run a template against a payload without saving a route or charging quota: returns the rendered title and body, the exact JSON each configured destination would receive, which tokens were omitted because the payload did not carry them, and how the noise gate, confluence and approval gates would judge the same body. Send raw_payload to test an arbitrary body, or event_id to replay one of your real retained webhooks.

read-only

Argument	Type	Description
event_id	string	Or replay one of your retained inbound webhooks by event_id (takes precedence over raw_payload)
route_id	string	Use a saved route's destinations, filters and gates (defaults to the first route)
raw_payload	string	Body to test — JSON, plain text or form-encoded. The edge rescues unstructured text into fields.
template_body	string	Override the route's body template for this preview only
template_title	string	Override the route's title template for this preview only
custom_body_template	string	Override the JSON remapper sent to the custom webhook for this preview only

Input schema (JSON)

purchase_quota_boost

Create a crypto checkout that adds extra webhook quota to an existing paid passkey (e.g. agent_credit_100k, apex_overage_500k). Poll claim_subscription afterwards.

Argument	Type	Description
pack*	string	Credit pack plan_id, e.g. agent_credit_100k or apex_overage_500k
pay_currency	string	Settlement currency, default usdttrc20

Input schema (JSON)

{
  "type": "object",
  "required": [
    "pack"
  ],
  "properties": {
    "pack": {
      "type": "string",
      "description": "Credit pack plan_id, e.g. agent_credit_100k or apex_overage_500k"
    },
    "pay_currency": {
      "type": "string",
      "description": "Settlement currency, default usdttrc20"
    }
  }
}

query_signal_memory

Read the durable state plane for a Master Passkey: recently archived webhook executions (delivered / filtered / retry_pending / dlq_failed) and the signal legs currently parked in a confluence window, so an agent can see what is waiting, what failed, and what has already fired.

read-only

Argument	Type	Description
limit	number	Max rows per bucket (1-50, default 20)
route_id	string	Optional route_id filter (e.g. rt_1)
entity_key	string	Optional entity scope filter, matching the route's stateful_gate.entity_field (e.g. SOLUSDT)
status_filter	string	Optional archive status filter

Input schema (JSON)

{
  "type": "object",
  "properties": {
    "limit": {
      "type": "number",
      "description": "Max rows per bucket (1-50, default 20)"
    },
    "route_id": {
      "type": "string",
      "description": "Optional route_id filter (e.g. rt_1)"
    },
    "entity_key": {
      "type": "string",
      "description": "Optional entity scope filter, matching the route's stateful_gate.entity_field (e.g. SOLUSDT)"
    },
    "status_filter": {
      "enum": [
        "delivered",
        "filtered",
        "retry_pending",
        "dlq_failed",
        "dropped_cooldown",
        "dropped_blackout"
      ],
      "type": "string",
      "description": "Optional archive status filter"
    }
  }
}

replay_historical_signal

Re-run an ARCHIVED webhook against the route's CURRENT filter, enrichment, blackout, confluence and template rules — a time-travel backtest against real past traffic. dry_run=true reports the exact rule evaluation and transformed output without dispatching anything.

read-only

Argument	Type	Description
dry_run	boolean	true (default) = report only; false = re-dispatch through the current rules
event_id*	string	Archived event_id to replay (from query_signal_memory or inspect_live_telemetry)
route_id	string	Optional route whose current rules should be applied; defaults to the route that received the archived event

Input schema (JSON)

{
  "type": "object",
  "required": [
    "event_id"
  ],
  "properties": {
    "dry_run": {
      "type": "boolean",
      "description": "true (default) = report only; false = re-dispatch through the current rules"
    },
    "event_id": {
      "type": "string",
      "description": "Archived event_id to replay (from query_signal_memory or inspect_live_telemetry)"
    },
    "route_id": {
      "type": "string",
      "description": "Optional route whose current rules should be applied; defaults to the route that received the archived event"
    }
  }
}

rotate_route_token

Cryptographically rotate a route's public whk_... webhook ingest token without altering the Master Passkey. The previous URL stops working immediately.

destructive

Argument	Type	Description
route_id*	string	Target route ID (e.g. rt_1)

Input schema (JSON)

{
  "type": "object",
  "required": [
    "route_id"
  ],
  "properties": {
    "route_id": {
      "type": "string",
      "description": "Target route ID (e.g. rt_1)"
    }
  }
}

set_agent_callback

Register, rotate, or clear the HTTPS webhook that receives HMAC-signed subscription lifecycle events for this passkey.

Argument	Type	Description
callback_url*	string	HTTPS endpoint, or an empty string to clear the callback

Input schema (JSON)

{
  "type": "object",
  "required": [
    "callback_url"
  ],
  "properties": {
    "callback_url": {
      "type": "string",
      "description": "HTTPS endpoint, or an empty string to clear the callback"
    }
  }
}

simulate_webhook_frame

Run a zero-quota dry-run simulation of a raw plain-text or JSON webhook payload against a route's filter rules, templates, and Edge AI synthesis.

read-only

Argument	Type	Description
route_id	string	Optional route_id to test against
raw_payload*	string	Raw plain-text or JSON webhook payload to test

Input schema (JSON)

{
  "type": "object",
  "required": [
    "raw_payload"
  ],
  "properties": {
    "route_id": {
      "type": "string",
      "description": "Optional route_id to test against"
    },
    "raw_payload": {
      "type": "string",
      "description": "Raw plain-text or JSON webhook payload to test"
    }
  }
}

subscribe_plan

Create a crypto checkout for a subscription plan and receive a concrete deposit address so an autonomous agent or treasury can settle it without a browser. Poll claim_subscription afterwards to obtain the Master Passkey.

Argument	Type	Description
agent	object	Optional agent identity recorded on the subscription
email*	string	Owner/operator email for receipts and passkey recovery
plan_id*	string	Plan from list_plans, e.g. neural_monthly, pro_monthly, agent_credit_100k
metadata	object	Optional opaque metadata (<= 1024 bytes) stored with the subscription
callback_url	string	HTTPS endpoint that receives HMAC-signed subscription.activated / quota.topped_up lifecycle events
pay_currency	string	Settlement currency, e.g. usdttrc20 (default), usdterc20, usdc, btc, eth, sol
existing_api_key	string	Existing ef_live_... passkey when renewing, upgrading, or buying a credit top-up

Input schema (JSON)

{
  "type": "object",
  "required": [
    "plan_id",
    "email"
  ],
  "properties": {
    "agent": {
      "type": "object",
      "properties": {
        "name": {
          "type": "string"
        },
        "version": {
          "type": "string"
        },
        "homepage": {
          "type": "string"
        },
        "framework": {
          "type": "string"
        }
      },
      "description": "Optional agent identity recorded on the subscription"
    },
    "email": {
      "type": "string",
      "description": "Owner/operator email for receipts and passkey recovery"
    },
    "plan_id": {
      "type": "string",
      "description": "Plan from list_plans, e.g. neural_monthly, pro_monthly, agent_credit_100k"
    },
    "metadata": {
      "type": "object",
      "description": "Optional opaque metadata (<= 1024 bytes) stored with the subscription"
    },
    "callback_url": {
      "type": "string",
      "description": "HTTPS endpoint that receives HMAC-signed subscription.activated / quota.topped_up lifecycle events"
    },
    "pay_currency": {
      "type": "string",
      "description": "Settlement currency, e.g. usdttrc20 (default), usdterc20, usdc, btc, eth, sol"
    },
    "existing_api_key": {
      "type": "string",
      "description": "Existing ef_live_... passkey when renewing, upgrading, or buying a credit top-up"
    }
  }
}

synthesize_edge_ai

Run EarlyFra.me Edge AI over a raw webhook payload (JSON, form, or plain text) and return ai_summary, ai_sentiment and ai_score. Requires Neural Frame.

read-only

Argument	Type	Description
raw_payload*	string	Raw payload text or JSON to analyse

Input schema (JSON)

{
  "type": "object",
  "required": [
    "raw_payload"
  ],
  "properties": {
    "raw_payload": {
      "type": "string",
      "description": "Raw payload text or JSON to analyse"
    }
  }
}

update_route_template

Write template_title, template_body and the custom JSON remapper onto an existing route in one call. The edit is partial: every field you leave out keeps its stored value, so destinations, noise-gate rules and stateful gates survive a template-only change. Requires the Neural Frame tier, and charges no quota — but the saved route starts shaping live traffic immediately.

Argument	Type	Description
route_id*	string	Target route ID (e.g. rt_1)
template_body	string	New body template, up to 600 characters
template_title	string	New title template. An empty string clears it; omit the field to keep the current one.
custom_body_template	string	JSON remapper for the 4th destination. Must stay valid JSON once placeholders are substituted.

Input schema (JSON)

{
  "type": "object",
  "required": [
    "route_id"
  ],
  "properties": {
    "route_id": {
      "type": "string",
      "description": "Target route ID (e.g. rt_1)"
    },
    "template_body": {
      "type": "string",
      "description": "New body template, up to 600 characters"
    },
    "template_title": {
      "type": "string",
      "description": "New title template. An empty string clears it; omit the field to keep the current one."
    },
    "custom_body_template": {
      "type": "string",
      "description": "JSON remapper for the 4th destination. Must stay valid JSON once placeholders are substituted."
    }
  }
}

EarlyFra.me — Stateful Edge Webhook Orchestration & MCP Server

Try it

arm_confluence_trap

EarlyFra.me — Stateful Edge Webhook Orchestration & MCP Server

Try it

arm_confluence_trap

Tools (19)