# OGraph Dispatcher

本地常驻进程，轮询 OGraph projection 变化，并在 OpenClaw (OC) 空闲时推送任务通知。

## 架构：双 Loop Actor

```
┌─ Loop A: Projection Watcher ──────────────┐
│  轮询 OGraph projection → diff → pending  │
│  无变化: 30s    有变化: 5s                 │
└──────────────┬────────────────────────────┘
               │ pending queue (合并缓冲)
               ▼
┌─ Loop B: OC Scheduler ───────────────────┐
│  轮询 OC 忙闲状态                         │
│  pending 空: 60s (低频)                   │
│  pending 有: 5s (高频，等空闲立刻推)      │
│  空闲 + pending → 推送 → 清 pending      │
└──────────────────────────────────────────┘
```

**Loop A** 持续 diff OGraph projections，合并变化到 pending queue（Map，按 projection name 去重合并）。

**Loop B** 持续查 OC session-status，发现空闲 + pending 非空时推送，推送后进入冷却期。

## 快速开始

```bash
cd packages/dispatcher
npm install
npm run build
node dist/index.js
```

## 配置

配置文件：`~/.config/ograph/dispatcher.json`

```json
{
  "ograph": {
    "endpoint": "https://ograph.shazhou.workers.dev",
    "token": "your-ograph-token",
    "projections": ["my-projection", "another-projection"]
  },
  "oc": {
    "statusEndpoint": "http://localhost:18789/plugins/session-status/status",
    "statusToken": "ograph-status-token-2026",
    "minAvailable": 2
  },
  "intervals": {
    "watcherIdle": 30000,
    "watcherActive": 5000,
    "schedulerIdle": 60000,
    "schedulerActive": 5000,
    "cooldownAfterPush": 60000
  }
}
```

## 环境变量覆盖

| 变量 | 对应配置 |
|------|----------|
| `OGRAPH_ENDPOINT` | `ograph.endpoint` |
| `OGRAPH_TOKEN` | `ograph.token` |
| `OGRAPH_PROJECTIONS` | `ograph.projections`（逗号分隔） |
| `OC_STATUS_ENDPOINT` | `oc.statusEndpoint` |
| `OC_STATUS_TOKEN` | `oc.statusToken` |
| `OC_MIN_AVAILABLE` | `oc.minAvailable` |

## 推送机制

当 OC 空闲且 pending 非空时，Scheduler 通过两种方式推送（均 best-effort）：

1. **Dispatch 文件**：写入 `/tmp/ograph-dispatch.json`，可被其他工具读取
2. **openclaw message send**：通过 CLI 发送通知消息（需 openclaw 在 PATH）

## 文件结构

```
packages/dispatcher/
├── src/
│   ├── index.ts          # 入口，启动两个 loop
│   ├── watcher.ts        # Loop A: Projection Watcher
│   ├── scheduler.ts      # Loop B: OC Scheduler
│   ├── ograph-client.ts  # OGraph API 客户端
│   ├── oc-client.ts      # OC session-status API 客户端
│   ├── config.ts         # 配置加载
│   └── types.ts          # 类型定义
├── build.mjs             # esbuild 打包脚本
├── package.json
├── tsconfig.json
└── README.md
```

## 依赖

- 零外部运行时依赖
- 仅使用 Node.js 内置模块（`fs`, `path`, `os`, `child_process`）和全局 `fetch`（Node ≥ 18）
- 构建时仅依赖 `esbuild` + `typescript`