Slash Command

/intel-pull

From market-radar

Pull intelligence content from cyber-pulse API with incremental sync support

Popularity

Parent stars

Parent forks

Invocation

How this command is triggered — by the user, by Claude, or both

Slash command

/market-radar:intel-pull [--source <name>] [--all] [--output <dir>] [--init] [--list-sources] [--add-source] [--remove-source <name>] [--set-default <name>]

Model invocable

No pre-commands

Tool Access

This command is limited to the following tools:

ReadWriteGrepGlobBashAgent

Context Preview

The summary Claude sees in its command listing — used to decide when to auto-load this command

## 命令概述

从 cyber-pulse 情报服务 API 拉取标准化情报内容，存储为本地 Markdown 文件，供 `intel-distill` 命令进一步处理。

**职责分离**：
- `intel-pull`：从远程 API 拉取情报 → 写入 `inbox/`
- `intel-distill`：处理 `inbox/` → 生成情报卡片



## 参数与使用示例

| 参数 | 必填 | 说明 |
|------|------|------|
| `--source <name>` | 否 | 指定情报源名称（默认使用 default_source） |
| `--all` | 否 | 顺序拉取所有配置的情报源 |
| `--output <dir>` | 否 | 输出目录（默认 `inbox/`） |
| `--init` | 否 | 全量同步，从头遍历所有历史数据 |
| `--list-sources` | 否 | 列出所有已配置的情报源 |
| `--add-source` | 否 | 交互式添加情报源 |
| `--remove-source <name>` | 否 | 删除指定情报源 |
| `--set-default <name>` | 否 | 设置默认情报源 |



---

## 执行流程

### 步骤 0：参数解析与路径初始化

...

Command Content

597 lines · ~3.2k tokens

Stats

LanguageTypeScript

Parent stars3

Parent forks1

MaintenanceExcellent

Last CommitApr 6, 2026

Actions

View Source View Plugin View on GitHub View README

Stats

Actions

命令概述

从 cyber-pulse 情报服务 API 拉取标准化情报内容，存储为本地 Markdown 文件，供 intel-distill 命令进一步处理。

职责分离：

intel-pull：从远程 API 拉取情报 → 写入 inbox/
intel-distill：处理 inbox/ → 生成情报卡片

cyber-pulse (情报采集系统)
    ↓ Pull API (since + cursor)
intel-pull (情报拉取命令)
    ↓ 写入 inbox/
intel-distill (情报提取命令)
    ↓ 处理并移动
intelligence/ (情报卡片)

参数与使用示例

参数	必填	说明
`--source <name>`	否	指定情报源名称（默认使用 default_source）
`--all`	否	顺序拉取所有配置的情报源
`--output <dir>`	否	输出目录（默认 `inbox/`）
`--init`	否	全量同步，从头遍历所有历史数据
`--list-sources`	否	列出所有已配置的情报源
`--add-source`	否	交互式添加情报源
`--remove-source <name>`	否	删除指定情报源
`--set-default <name>`	否	设置默认情报源

# === 增量同步（默认模式） ===
/intel-pull

# === 全量同步 ===
/intel-pull --init

# === 指定输出目录 ===
/intel-pull --output ./docs/inbox

# === 源管理 ===
/intel-pull --list-sources
/intel-pull --add-source
/intel-pull --remove-source cloud
/intel-pull --set-default cloud

执行流程

步骤 0：参数解析与路径初始化

解析命令参数，确定执行模式：

条件	执行模式	后续流程
`--list-sources`	列出源模式	执行源列表显示（步骤 L1）
`--add-source`	添加源模式	执行交互式添加（步骤 A1-A3）
`--remove-source <name>`	删除源模式	执行源删除（步骤 D1-D2）
`--set-default <name>`	设置默认源模式	执行默认源设置（步骤 S1-S2）
`--init`	全量同步模式	执行全量同步（步骤 P3）
默认	增量同步模式	执行增量同步（步骤 P1-P2）

路径初始化：

root_dir = 当前工作目录（用户执行命令的位置）
output_dir = --output 参数或 ./inbox

# 固定位置（始终在 root_dir 下）
config_file = root_dir/.intel/pulse-sources.json
state_file = root_dir/.intel/state.json

┌─────────────────────────────────────────────────────────────┐
│                      参数解析                                │
└─────────────────────────────────────────────────────────────┘
                              │
        ┌──────────┬──────────┼──────────┬──────────┐
        ↓          ↓          ↓          ↓          ↓
    --list-sources  --add-source  --remove-source  --set-default  默认/其他
        │          │          │          │          │
        ↓          ↓          ↓          ↓          ↓
    列出源模式  添加源模式  删除源模式  设置默认源  拉取模式
                                                   │
                                   ┌───────┬───────┤
                                   ↓       ↓       ↓
                               --init   --all   默认增量
                                   │       │       │
                                   ↓       ↓       ↓
                               全量同步 多源拉取 增量同步

源管理模式

步骤 L1：列出源（`--list-sources`）

调用脚本列出所有配置的情报源：

cd ${CLAUDE_PLUGIN_ROOT}/scripts
pnpm exec tsx pulse/index.ts --root {root_dir} --list-sources

输出示例：

📡 已配置的情报源

┌─────────────┬─────────────────────────┬──────────┐
│ 名称        │ URL                     │ API Key  │
├─────────────┼─────────────────────────┼──────────┤
│ cyber-pulse*│ https://pulse.example.com│ ✅ 已设置 │
│ local       │ http://localhost:8000   │ ❌ 未设置 │
└─────────────┴─────────────────────────┴──────────┘
* 默认源

步骤 A1-A3：添加源（`--add-source`）

调用脚本执行交互式添加：

cd ${CLAUDE_PLUGIN_ROOT}/scripts
pnpm exec tsx pulse/index.ts --root {root_dir} --add-source

交互流程：

添加新的情报源
----------------

源名称 (如: cyber-pulse): my-source
API URL (如: https://api.example.com): https://pulse.example.com
API Key: cp_live_a1b2c3d4e5f6789012345678abcdef01

成功添加源: my-source

步骤 D1-D2：删除源（`--remove-source <name>`）

调用脚本删除指定源：

cd ${CLAUDE_PLUGIN_ROOT}/scripts
pnpm exec tsx pulse/index.ts --root {root_dir} --remove-source {name}

输出示例：

✅ 已删除源 "cloud"

步骤 S1-S2：设置默认源（`--set-default <name>`）

调用脚本设置默认源：

cd ${CLAUDE_PLUGIN_ROOT}/scripts
pnpm exec tsx pulse/index.ts --root {root_dir} --set-default {name}

输出示例：

✅ 已将 "cloud" 设置为默认源

拉取模式

步骤 P0：检查并安装脚本依赖

在执行脚本前，检查 node_modules 是否存在：

检查 ${CLAUDE_PLUGIN_ROOT}/scripts/node_modules 目录是否存在

如果不存在，自动安装依赖：

cd ${CLAUDE_PLUGIN_ROOT}/scripts && pnpm install

输出示例：

📦 正在安装脚本依赖...
Done in 262ms using pnpm v10.33.0
✅ 依赖安装完成

步骤 P1：检查配置文件

检查配置文件是否存在：

配置文件位置：${root_dir}/.intel/pulse-sources.json（与 state.json 同目录）

如果不存在，显示错误提示和配置示例，退出：

⚠️  未找到情报源配置文件

配置文件位置：.intel/pulse-sources.json

请创建配置文件：

{
  "sources": [
    {
      "name": "cyber-pulse",
      "url": "https://pulse.example.com",
      "api_key": "cp_live_xxx"
    }
  ],
  "default_source": "cyber-pulse"
}

完成后重新执行命令。

步骤 P2：增量同步（默认模式）

调用脚本执行增量同步：

cd ${CLAUDE_PLUGIN_ROOT}/scripts
pnpm exec tsx pulse/index.ts --root {root_dir} [--source {name}] [--output {dir}]

脚本执行逻辑：

加载状态文件（不存在则创建默认结构）
获取对应源的 last_fetched_at 和 last_item_id
调用 API：GET /api/v1/items?since={last_fetched_at}&limit=50
解析响应：response.data 为内容列表，获取 last_item_id 和 last_fetched_at
遍历返回数据，写入 Markdown 文件（文件去重检查）
更新状态文件中的 last_fetched_at 和 last_item_id
如果 has_more=true，使用 since + cursor 继续请求：GET /api/v1/items?since={ts}&cursor={last_item_id}&limit=50
输出拉取统计报告

步骤 P3：全量同步（`--init`）

调用脚本执行全量同步：

cd ${CLAUDE_PLUGIN_ROOT}/scripts
pnpm exec tsx pulse/index.ts --root {root_dir} --init [--source {name}] [--output {dir}]

脚本执行逻辑：

清空状态文件中的 last_fetched_at 和 last_item_id
调用 API：GET /api/v1/items?since=beginning&limit=50
解析响应：response.data 为内容列表，获取 last_item_id 和 last_fetched_at
遍历返回数据，写入 Markdown 文件（文件去重检查）
更新状态文件中的 last_fetched_at 和 last_item_id
如果 has_more=true，使用 since + cursor 继续请求
输出拉取统计报告

步骤 P4：`--all` 多源拉取

调用脚本执行多源拉取：

cd ${CLAUDE_PLUGIN_ROOT}/scripts
pnpm exec tsx pulse/index.ts --root {root_dir} --all [--output {dir}]

脚本执行逻辑：

遍历配置中的所有源
对每个源执行增量同步流程
记录每个源的执行结果（成功/失败/部分成功）
仅更新成功拉取的源的状态
失败的源保留原有状态，下次拉取时可重试
一个源失败不影响其他源继续
输出汇总报告

步骤 P5：输出拉取报告

增量同步报告：

════════════════════════════════════════════════════════
📡 情报拉取报告
════════════════════════════════════════════════════════

源: cyber-pulse (https://pulse.example.com)
模式: 增量同步

【拉取统计】
• 新增情报: 15 条
• 写入位置: ./inbox/

【状态更新】
• last_fetched_at: 2026-04-01T10:00:00Z
• last_item_id: item_0050
• 更新时间: 2026-04-01T10:30:00Z

💡 提示: 使用 /intel-distill 处理情报

════════════════════════════════════════════════════════

多源拉取报告：

════════════════════════════════════════════════════════
📡 情报拉取报告
════════════════════════════════════════════════════════

【cyber-pulse】✅ 成功
• 新增情报: 15 条

【local】❌ 失败
• 错误: API 连接超时

【汇总】
• 总计: 15 条
• 写入位置: ./inbox/

════════════════════════════════════════════════════════

配置管理

配置文件

位置：{root_dir}/.intel/pulse-sources.json（项目根目录下，与 state.json 同目录）

{
  "sources": [
    {
      "name": "cyber-pulse",
      "url": "https://pulse.example.com",
      "api_key": "cp_live_a1b2c3d4e5f6789012345678abcdef01"
    },
    {
      "name": "local",
      "url": "http://localhost:8000",
      "api_key": "cp_live_xxx"
    }
  ],
  "default_source": "cyber-pulse"
}

API Key 管理

API Key 直接存储在配置文件中，简化用户配置流程：

配置文件位于插件目录，属于项目级配置
可通过 --add-source 交互式添加源时输入 API Key
支持多个情报源配置，每个源独立管理

状态管理

状态文件

位置：{root_dir}/.intel/state.json

与 intel-distill 共享同一状态文件，在现有结构中维护 pulse 字段：

{
  "version": "2.3.0",
  "updated_at": "2026-04-01T10:30:00+08:00",

  "pulse": {
    "sources": {
      "cyber-pulse": {
        "last_fetched_at": "2026-04-01T10:00:00Z",
        "last_item_id": "item_0050",
        "last_sync_at": "2026-04-01T10:30:00Z"
      },
      "local": {
        "last_fetched_at": "2026-04-01T09:30:00Z",
        "last_item_id": "item_0030",
        "last_sync_at": "2026-04-01T09:45:00Z"
      }
    }
  },

  "queue": { ... },
  "review": { ... },
  "processed": { ... },
  "stats": { ... }
}

状态字段说明

字段	类型	说明
`pulse.sources.{source}`	object	各情报源的同步状态
`pulse.sources.{source}.last_fetched_at`	string	API 返回的最后一条数据的 fetched_at 时间（ISO 8601）
`pulse.sources.{source}.last_item_id`	string	API 返回的最后一条数据的 ID（格式 `item_{8位hex}`）
`pulse.sources.{source}.last_sync_at`	string	本地同步完成时间（ISO 8601）

状态更新规则

模式	首次请求参数	分页请求参数	状态操作
增量（默认）	`since={last_fetched_at}`	`since={ts}&cursor={last_item_id}`	读取 → 更新
`--init`	`since=beginning`	`since={ts}&cursor={last_item_id}`	清空 → 重建

设计说明：

复用 .intel/state.json，避免多个状态文件
pulse 字段独立，不影响 intel-distill 现有字段
last_fetched_at 作为增量同步的时间锚点
last_item_id 作为分页游标，避免重复拉取同页数据

去重策略

双重去重保障：

时间锚点去重：since={last_fetched_at} 保证 API 只返回新数据
文件去重检查：写入前检查文件是否已存在，存在则跳过

文件去重逻辑（幂等写入）：

检查 {output_dir}/{filename}.md 是否存在
存在则跳过写入，计入"已存在"统计
不存在则正常写入

输出文件格式

文件命名

格式：{YYYYMMDD}-{item_id}.md

示例：20260401-item_a1b2c3d4.md

YYYYMMDD：从 published_at 提取（若无则使用 first_seen_at）
item_id：API 返回的 ID，格式 item_{8位hex}

文件内容

---
# ============================================
# 第一组：核心标识（必须填写）
# ============================================
item_id: "item_a1b2c3d4"
source_type: "cyber-pulse"
first_seen_at: "2026-04-01T09:00:00Z"

# ============================================
# 第二组：内容元数据
# ============================================
title: "某APT组织近期攻击活动分析"
url: "https://example.com/article"
author: "安全研究员"
tags: ["APT", "威胁情报"]
published_at: "2026-04-01T08:00:00Z"

# ============================================
# 第三组：来源信息
# ============================================
source_id: "src_abc12345"
source_name: "Security Weekly"
source_url: "https://example.com/feed.xml"
source_tier: "T1"
source_score: 75.0

# ============================================
# 第四组：质量指标
# ============================================
completeness_score: 0.85
word_count: 1500

# ============================================
# 第五组：处理追溯（预处理脚本填充）
# ============================================
content_hash: ""
archived_path: ""
---

# {title}

{body}

Frontmatter 字段说明

字段	类型	必填	说明
`item_id`	string	✅	唯一标识符（格式 `item_{8位hex}`）
`source_type`	string	✅	来源类型，固定为 `cyber-pulse`
`first_seen_at`	datetime	✅	采集时间（来自 API `fetched_at` 字段）
`title`	string	✅	文档标题
`url`	string	❌	原文链接
`author`	string	❌	作者
`tags`	array	❌	标签列表
`published_at`	datetime	❌	原文发布时间
`source_id`	string	❌	情报源 ID（来自 `source.source_id`）
`source_name`	string	❌	情报源名称（来自 `source.source_name`）
`source_url`	string	❌	情报源 URL（来自 `source.source_url`）
`source_tier`	string	❌	情报源等级 T0-T3（来自 `source.source_tier`）
`source_score`	number	❌	情报源评分 0-100（来自 `source.source_score`）
`completeness_score`	number	❌	内容完整度 0-1
`word_count`	number	❌	正文字数
`content_hash`	string	✅	正文 MD5 哈希（预处理脚本填充）
`archived_path`	string	❌	归档路径（cyber-pulse 文件为空）

字段映射说明（API v1 → frontmatter）：

id → item_id
title → Markdown 标题 + title 字段
body → Markdown 正文
fetched_at → first_seen_at
source.* → 对应 source_* 字段

错误处理

错误场景	处理方式
配置文件不存在	显示配置示例和设置步骤，退出
配置文件格式错误	显示具体错误位置，退出
API Key 未配置	提示用户配置 API Key，退出
API 连接失败	显示错误信息，建议检查网络/URL
API 认证失败	提示 API Key 无效，建议检查配置
API 请求超时	重试 1 次（间隔 2 秒）；仍失败则记录错误，继续处理下一个源（`--all` 模式）或退出
状态无效（首次拉取）	自动执行 `since=beginning` 初始化
响应数据过大	分批写入，避免内存溢出
源名称不存在	显示可用源列表，退出

网络请求配置

参数	值	说明
连接超时	10 秒	建立连接的超时时间
请求超时	30 秒	单次请求的总超时时间
重试次数	1 次	超时后重试一次
重试间隔	2 秒	重试前等待时间

与 cyber-pulse API 对应

intel-pull 参数	cyber-pulse API
默认（增量）	`GET /api/v1/items?since={last_fetched_at}&limit=50`
`--init`	`GET /api/v1/items?since=beginning&limit=50`
分页继续	`GET /api/v1/items?since={ts}&cursor={last_item_id}&limit=50`

API 响应格式（v1）：

{
  "data": [ /* PulseItem 数组 */ ],
  "last_item_id": "item_0050",
  "last_fetched_at": "2026-04-01T10:00:00Z",
  "has_more": true,
  "count": 50
}

API 参数约束：

since 为必填参数，值可以是 ISO 8601 时间戳或 beginning
cursor 为可选参数，用于分页游标
cursor 格式为 item_{8位hex}

注意事项

配置文件存储在插件目录，API Key 直接配置在文件中
状态文件与 intel-distill 共享，位于输出目录的 .intel/ 下
输出文件采用统一 frontmatter 格式，兼容 intel-distill
建议将 .intel/ 添加到 .gitignore
使用 /intel-distill 处理拉取后的情报文件
last_item_id 格式为 item_{8位hex}（如 item_a1b2c3d4）
文件去重检查保证幂等写入，可安全重复执行

/intel-pull

Popularity

Invocation

Tool Access

Context Preview

Command Content

/intel-pull

Popularity

Invocation

Tool Access

Context Preview

Command Content

命令概述

参数与使用示例

执行流程

步骤 0：参数解析与路径初始化

源管理模式

步骤 L1：列出源（--list-sources）

步骤 A1-A3：添加源（--add-source）

步骤 D1-D2：删除源（--remove-source <name>）

步骤 S1-S2：设置默认源（--set-default <name>）

拉取模式

步骤 P0：检查并安装脚本依赖

步骤 P1：检查配置文件

步骤 P2：增量同步（默认模式）

步骤 P3：全量同步（--init）

步骤 P4：--all 多源拉取

步骤 P5：输出拉取报告

配置管理

配置文件

API Key 管理

状态管理

状态文件

状态字段说明

状态更新规则

去重策略

输出文件格式

文件命名

文件内容

Frontmatter 字段说明

错误处理

网络请求配置

与 cyber-pulse API 对应

注意事项

命令概述

参数与使用示例

执行流程

步骤 0：参数解析与路径初始化

源管理模式

步骤 L1：列出源（--list-sources）

步骤 A1-A3：添加源（--add-source）

步骤 D1-D2：删除源（--remove-source <name>）

步骤 S1-S2：设置默认源（--set-default <name>）

拉取模式

步骤 P0：检查并安装脚本依赖

步骤 P1：检查配置文件

步骤 P2：增量同步（默认模式）

步骤 P3：全量同步（--init）

步骤 P4：--all 多源拉取

步骤 P5：输出拉取报告

配置管理

配置文件

API Key 管理

状态管理

状态文件

状态字段说明

状态更新规则

去重策略

输出文件格式

文件命名

文件内容

Frontmatter 字段说明

错误处理

网络请求配置

与 cyber-pulse API 对应

注意事项

步骤 L1：列出源（`--list-sources`）

步骤 A1-A3：添加源（`--add-source`）

步骤 D1-D2：删除源（`--remove-source <name>`）

步骤 S1-S2：设置默认源（`--set-default <name>`）

步骤 P3：全量同步（`--init`）

步骤 P4：`--all` 多源拉取

步骤 L1：列出源（`--list-sources`）

步骤 A1-A3：添加源（`--add-source`）

步骤 D1-D2：删除源（`--remove-source <name>`）

步骤 S1-S2：设置默认源（`--set-default <name>`）

步骤 P3：全量同步（`--init`）

步骤 P4：`--all` 多源拉取