fin-pulse

Files (78)

• CHANGELOG.md
• README.md
• SKILL.md
• USER_TEST_CASES.md
• VALIDATION.md
• __init__.py
• fomc_release_calendar.txt · extra/
• __init__.py · finpulse_ai/
• dedupe.py · finpulse_ai/
• filter.py · finpulse_ai/
• prompts.py · finpulse_ai/
• rules_suggest.py · finpulse_ai/
• finpulse_dispatch.py
• finpulse_errors.py
• __init__.py · finpulse_fetchers/
• _http.py · finpulse_fetchers/
• base.py · finpulse_fetchers/
• eastmoney.py · finpulse_fetchers/
• fed_fomc.py · finpulse_fetchers/
• nbd.py · finpulse_fetchers/
• nbs.py · finpulse_fetchers/
• newsnow.py · finpulse_fetchers/
• newsnow_base.py · finpulse_fetchers/
• pbc_omo.py · finpulse_fetchers/
• rss.py · finpulse_fetchers/
• sec_edgar.py · finpulse_fetchers/
• stcn.py · finpulse_fetchers/
• yicai.py · finpulse_fetchers/
• finpulse_frequency.py
• finpulse_models.py
• __init__.py · finpulse_notification/
• splitter.py · finpulse_notification/
• finpulse_pipeline.py
• __init__.py · finpulse_report/
• render.py · finpulse_report/
• __init__.py · finpulse_services/
• query.py · finpulse_services/
• radar_library.py · finpulse_services/
• finpulse_task_manager.py
• icon.svg
• plugin.json
• plugin.py
• __init__.py · tests/
• conftest.py · tests/
• test_ai_filter.py · tests/
• test_dedupe.py · tests/
• test_dispatch.py · tests/
• test_errors.py · tests/
• test_fetchers.py · tests/
• test_fetchers_hybrid.py · tests/
• test_fetchers_impl.py · tests/
• test_fetchers_newsnow.py · tests/
• test_frequency.py · tests/
• test_frequency_regex.py · tests/
• test_freshness.py · tests/
• test_hot_radar.py · tests/
• test_init_readiness.py · tests/
• test_models.py · tests/
• test_pipeline_hybrid.py · tests/
• test_plan_defaults.py · tests/
• …and 18 more

SKILL.md (first lines)

# fin-pulse — finance news radar for the OpenAkita Brain

Use this skill whenever the user asks about **finance headlines, daily
briefs, hot-topic keyword alerts, or scheduled IM pushes** from the
fin-pulse plugin. The plugin exposes seven agent tools that let you
create ingest / daily_brief / hot_radar tasks, inspect their status,
paginate tasks, cancel a running job, read / write the plugin config,
and search the article index by keyword / source / `days` window.

---

## 1. Triggers

Call fin-pulse tools when the user says (or implies):

- 「帮我看下今天美股 / 美联储 / 财经的大事」 → `fin_pulse_search_news`
- 「生成今天的早报 / 午报 / 晚报」→ `fin_pulse_create(mode="daily_brief", session=...)`
- 「把早报 / 雷达告警推到飞书 / 企微」→ `fin_pulse_create(mode="hot_radar", ...)`
  + `targets=[{"channel":"feishu","chat_id":"..."}]`
- 「关键词 X 有什么新闻」→ `fin_pulse_search_news(q="X")`
- 「抓一下 fin-pulse 的 8 个源」→ `fin_pulse_create(mode="ingest")`
- 「查一下任务 Y 跑完了吗」→ `fin_pulse_status(task_id="Y")`
- 「fin-pulse 最近都跑了哪些」→ `fin_pulse_list`
- 「把 radar_rules 改成 +美联储 +降息」→ `fin_pulse_settings_set`
- 「fin-pulse 当前是怎么配的」→ `fin_pulse_settings_get`

Do **not** call these tools when the user only wants general finance
commentary; prefer web search for commentary and fin-pulse only for
*their* plugin state.

---

## 2. Tool reference

### `fin_pulse_create`

Creates + runs a task synchronously (returns when done). `mode` is
required and must be one of `ingest` / `daily_brief` / `hot_radar`.
Pass extra params either nested under `params` or flat — both work.

Canonical shapes:

```json
{"mode": "ingest", "since_hours": 24}
{"mode": "daily_brief", "session": "morning", "since_hours": 12, "top_k": 20, "lang": "zh"}
{"mode": "hot_radar", "rules_text": "+美联储\n+降息\n!传闻",
 "targets": [{"channel": "feishu", "chat_id": "oc_xxx"}],
 "since_hours": 24, "cooldown_s": 600}
```

- `since_hours`: int in `[1, 72]` for ingest / daily_brief,
  `[1, 168]` for hot_radar — out of range values clamp silently.
- `top_k`: int in `[1, 60]`, defaults to 20.
- `session`: `morning` / `noon` / `evening`. Reject anything else
  instead of guessing.
- `min_score`: float in `[0, 10]`. Optional.

The returned envelope always has `ok: bool` and either a typed
payload (`task_id`, `digest`, `result`) or an `error` / `hint`.
Never retry on `invalid_mode` / `missing_rules` — surface to the user.

### `fin_pulse_status(task_id)` / `fin_pulse_cancel(task_id)`

- `status` returns the full task row (params + progress +
  `error_kind` if failed).
- `cancel` is idempotent and safe to call twice.

### `fin_pulse_list`

`limit` clamps to `[1, 200]` default 50. Filter by `mode` / `status`
as needed. Use it to *confirm* state before suggesting a fresh
ingest.

### `fin_pulse_settings_get` / `fin_pulse_settings_set`

`get` returns a **redacted** map — any key containing `api_key`,
`token`, `webhook`, `secret`, or `password` is masked as `***`.
Never surface the `***` value to the user as real data.

`set` takes `{"updates": {k: v}}` where values are stringified on
store. Don't write large JSON blobs through this tool.

### `fin_pulse_search_news`

The daily-driver search tool:

```json
{"q": "美联储", "days": 1, "min_score": 6, "limit": 20}
{"source_id": "wallstreetcn", "days": 7, "sort": "score"}
```

- `q` supports plain LIKE matching today; the `+must` / `!exclude`
  DSL is **evaluated by hot_radar, not by this search** — don't
  promise that syntax here.
- `days` clamps to `[1, 90]`.
- Returns `items` sorted by time (default) or AI score
  (`sort=score`). Each item has `title`, `url`, `summary`,
  `source_id`, `ai_score`, `fetched_at`, `published_at`.

---

## 3. Response etiquette

- When a tool returns `ok=false`, quote the `error` kind plus any
  `hint` — don't invent explanations.
- When the tool returns no items, say so explicitly and suggest
  the user either run `fin_pulse_create(mode="ingest")` first or
  widen the `days` window.
- Daily briefs come back with `digest.stats` (`total_selected`,
  `source_breakdown`). Surface the count so the user knows whether
  the digest is meaningful.
- Every task_id follows `fp-<uuid>`; include it in your reply so
  the user can reference it later.

---

## 4. Cross-tool recipes

### Recipe A — "What's moving the Fed today?"

From LZM163126lzm/openakita, AGPL-3.0.

More from LZM163126lzm/openakita