Cue

io.github.murtazox04v0.1.0更新于 Oct 11, 2026

Notify people through Cue: preferences, attention budgets, quiet hours and approval apply.

概览

AI 生成的概览

让助手通过 Cue 实例向人发送通知,并受该实例的偏好、预算、免打扰时段和审批规则约束。

功能
Cue 是一个注意力层,决定某个事件是否值得通知某人、说什么、何时发送以及走哪条通道。该 MCP 服务器提供通知人员和查看投递情况的工具,并沿用 Cue 的策略与审计记录。决策涵盖规则、频率上限、冷却、免打扰时段、模板和通道回退,每个结果都会被记录。
适用场景
当智能体需要触达真实用户(如发货更新、故障、评审请求),且希望通知按收件人偏好、注意力预算和免打扰时段过滤,而不是直接发送时使用。适合已运行 Cue 实例、希望智能体在授权范围内通知并查看投递情况的团队。
运行要求
通过 stdio 在本地运行,使用 uvx 从 cue-notify 包启动,因此需要 Python 和 uv。需要可访问的 Cue 实例:CUE_URL 指定其基础地址,CUE_API_KEY(绑定到智能体的密钥)用于认证。仅限桌面端,不支持网页执行。
安装前请注意
服务器以 CUE_API_KEY 的身份行事,应将其绑定到设有每人注意力预算、重要性上限以及必要人工审批的智能体。通知会发送给真实收件人且难以撤回;投递经由你配置的连接器,可能涉及第三方服务商。Cue 处于早期开发阶段(0.x),API 仍可能变化。

安装

在 SourceWeft 中

  1. 打开 控制台中的 Cue,将其添加到工作区。
  2. 为需要使用其工具的对话启用该服务。

Desktop only,通过 STDIO。 STDIO 服务会启动本地进程,因此需要 SourceWeft 桌面宿主。

其他 MCP 客户端

参照 仓库 中的启动说明。

README

Cue

The attention layer between software, AI agents and people.

Your product and your agents report what happened;
Cue decides whether it is worth someone's attention, what to say, when, and over which route, then hands a ready-to-send message to the delivery you plug in.

[CI] [Python] [License: MIT]

Documentation · Getting started · Architecture


People now hear from more software than ever: your product, background jobs, and a growing number of AI agents acting on someone's behalf. Each sender is reasonable alone; together they bury the person, and phones increasingly silence them. Cue is the one place that decides. Your backend (or an agent) reports what happened — order.shipped, payment.failed, pr.review_requested — and Cue decides whether a notification is warranted, which template and language to use, when to send it in the recipient's time zone, how important it really is, and which route to try first. It renders the message and hands it to whatever delivery you connect: your own service, a webhook, or a ready-made connector.

Delivery is pluggable. The decisions are Cue's job — and every one of them is recorded, so "why didn't this user get the message?" becomes a query, not an investigation.

bash
curl -X POST https://cue.example.com/v1/events \  -H "Authorization: Bearer $CUE_KEY" -H "Content-Type: application/json" \  -d '{"name": "order.shipped", "recipient": "customer-42",       "data": {"order_id": "1001"}, "idempotency_key": "order-1001-shipped"}'

Your delivery endpoint then receives a signed, fully rendered message:

json
{  "id": "01a1…",  "channel": "push",  "address": "<device token>",  "locale": "en",  "importance": "normal",  "expires_at": null,  "content": {"title": "Your order is on its way", "body": "Order 1001 ships today.",              "url": "https://shop.example/orders/1001"},  "metadata": {"cue_message_id": "01a1…", "cue_tracking_token": "…"},  "links": {"preferences": "https://cue.example.com/preferences/…"}}

What Cue decides

  • Whether — rules with JSON Logic conditions, priorities, wildcards, deterministic rollouts and a dry-run endpoint; unsubscribes, frequency caps, cooldowns and deduplication applied to every message; fatigue that backs off from people who stopped paying attention.
  • What — localised, sandboxed Jinja2 templates with per-route variants (a short SMS, a rich e-mail), versioning and previews; optional AI rewording through any Pydantic AI model, with guardrails that keep numbers and links verbatim.
  • How often — digests that turn a burst of events into one message per window ("Ann, Bo and 10 others commented"), optionally summarised by AI, plus thread ids so phones and mail clients stack related messages.
  • When — delays, quiet hours in each recipient's time zone, scheduled broadcasts, expiry for messages that go stale, and importance levels phones understand.
  • Who decides — the person: a hosted preference page (or a JSON API for your own), RFC 8058 one-click unsubscribe for Gmail and Yahoo, and a consent ledger of every change.
  • Where — an ordered list of routes per rule (e.g. push, then SMS), every address a person has on a route, fallback on permanent failure, retries on transient failure, dead addresses disabled automatically.

Built for AI agents

  • Agents as first-class senders. Each agent gets its own key with a per-person attention budget, an importance ceiling and, where you want it, human approval before anything goes out. See agents.
  • Screening. Optionally, a decision model (Jev) reads each agent message before it is sent: pressure, deception or leaked secrets hold it for a person, and overstated importance is lowered. It costs under a cent per hundred messages and adds no latency to sends.
  • MCP built in. uvx cue-notify mcp gives Claude, Cursor or your own agent tools to notify people and inspect delivery, with the same policy and audit trail.
  • Claude Code plugin. /plugin marketplace add murtazox04/Cue, then /plugin install cue@cue, teaches Claude to integrate Cue into your app.
  • SDKs. pip install cue-notify-client and npm install cue-client, both with webhook signature verification. See SDKs.
  • Docs for machines. llms.txt and AGENTS.md.

Bring your own delivery

Each route (push, sms, email, ops-alerts…) is backed by a connector:

ConnectorUse it when
webhookYou already have a sending service, or want full control. Cue POSTs signed JSON to it.
fcm, twilio, smtp, telegramYou want a ready-made connector for these providers.
consoleLocal development.
your ownWrite a small class and register it as a plugin — see custom connectors.

Connectors are configuration, not code changes — swap SMS vendors without touching a rule.

Also

  • Engagement tracking — delivered, opened, clicked, converted; client apps report with a per-message token, no API key needed.
  • Broadcasts — audience filters, resumable batches, pause/resume/cancel without double sends.
  • AI agents — an MCP server (cuectl mcp) lets Claude, Cursor or your own agents notify people and inspect delivery within the scopes you grant.
  • Simple to run — one Python service and PostgreSQL (or SQLite). No Redis, no broker, no cron: the durable job queue lives in your database.
  • Observable — per-rule event outcomes, status reasons, Prometheus metrics, JSON logs.

Quick start

bash
git clone https://github.com/murtazox04/Cue && cd Cuedocker compose up --build -ddocker compose exec api cuectl keys create admin   # prints an API keyopen http://localhost:8000/docs

Or with Python 3.12+:

bash
pip install 'cue-notify[postgres]'export CUE_WORKER__EMBEDDED=true CUE_CHANNELS__PUSH__PROVIDER=consolecuectl db upgrade && cuectl keys create admin && cuectl serve

Then follow the getting-started guide.

How it works

mermaid
flowchart LR    E[POST /v1/events] --> R{Rules}    R --> P[Policy<br/>unsubscribe · caps · cooldown · quiet hours]    P --> T[Template<br/>locale · route variants]    T --> Q[(Queue)]    Q --> A[AI rewording<br/>optional]    A --> C{Your delivery<br/>webhook · connectors}
ConceptIn one line
EventSomething that happened to a recipient. Idempotent, stored with per-rule outcomes.
RuleWhen event X (and condition) → send template Y over routes [A, B].
TemplateLocalised content with route-specific variants.
CategoryPolicy bundle: frequency caps, quiet hours, whether unsubscribing is allowed.
ChannelA named route (push, sms…) backed by a connector.
MessageOne notification to one recipient, with a full status trail.
BroadcastOne template to an audience, in resumable batches.

Configuration

Environment variables (CUE_SECTION__KEY) or a cue.toml:

toml
[database]url = "postgresql+asyncpg://cue:secret@db/cue"
[channels.push]provider = "webhook"url = "https://notifications.internal.example/push"# secret from CUE_CHANNELS__PUSH__SECRET
[channels.sms]provider = "twilio"account_sid = "AC…"from_number = "+15550100"   # auth token via CUE_CHANNELS__SMS__AUTH_TOKEN

See the configuration reference and examples/cue.toml.

Project status

Cue is in early development (0.x): the model and API are stable in shape but may still change before 1.0. See the roadmap for what comes next. Feedback and contributions are very welcome — see CONTRIBUTING.md.

License

MIT

来源:README.md,提交 f9aea56

工具

0
工具元数据尚未被收录。

版本历史

1
  1. v0.1.0最新Oct 11, 2026