Rule Engine — SenClaw Space App

Luồng xử lý dữ liệu dạng đồ thị: node nguồn bơm sự kiện, các node lọc / rẽ nhánh / biến đổi nối với nhau qua cổng có tên, mỗi cạnh mang một bản sao dữ liệu.

Port 4550. MCP server rule-engine-mcp tại /api/mcp/sse.

Đây là bản viết lại bằng Rust của dipper-hub/services/engine-runner (Go) và thư viện lõi dipper-engine. Thiết kế và lý do khác bản gốc: [docs/rule-engine-app-design.md](../../docs/rule-engine-app-design.md).

Khác biệt cốt lõi so với bản Go

Chạy khi phát triển

cargo run -p rule-engine                 # backend :4550
cd apps/rule-engine/web && npm run dev   # UI dev server, proxy /api
cargo test -p rule-engine                # test

Đăng ký với daemon (daemon thấy port 4550 đã healthy sẽ dùng lại tiến trình của bạn thay vì spawn bản khác):

curl -X POST http://127.0.0.1:18788/api/space/apps/register-local \
  -H 'content-type: application/json' \
  -d '{"path":"/Users/benji/Projects/SemaClaw/apps/rule-engine"}'

Đóng gói: ./scripts/pack.sh → rule-engine-app.zip.

Mô hình

nguồn ──out──▶ ┌────────┐ ──true──▶ ...
               │  node  │ ──false─▶ ...
   ──in──────▶ └────────┘ ──error─▶ ...

• Chain — đồ thị đã lưu. ACTIVE thì được nạp và chạy.
• Run — một sự kiện chảy qua đồ thị. Kết thúc khi không còn message nào đang bay và không còn barrier nào đang chờ.
• Hop — một bước trong run. Chỉ ghi lại khi bật debug.
• Message — { data, meta }. data là payload phẳng; meta là thông tin kèm theo (nguồn, headers, thời điểm). Biểu thức thấy data ở tầng trên cùng và meta dưới tên meta_data.

Nhiều cổng vào

Mặc định (opts.join = "any") mỗi message vào node là một lần chạy độc lập — đúng như engine Go. Đổi thành:

• "all" — chờ đủ một message trên mỗi cổng vào đang được nối, chạy một lần với { "<tên cổng>": <data> }
• "merge" — như trên nhưng deep-merge thành một object

Barrier gom theo (run, node, thế hệ), hoặc theo opts.corrKey nếu muốn gom theo một giá trị nghiệp vụ. Quá joinTimeoutMs thì nhánh bị huỷ và ghi log — không treo im lặng.

Danh mục node

Gọi GET /api/registry (hoặc MCP rule_registry) để lấy danh sách đầy đủ kèm cổng và JSON Schema cấu hình. Nhóm chính:

• Nguồn — manual, webhook, schedule, telegram-poll
• Logic — conditional, switch, fork, join, merge, trigger-time
• Biến đổi — arithmetic, format, project, delay, split
• Lọc có state — moving-average, kalman
• Đích — http-request, telegram-send, notification, log, mcp-call, senclaw-send
• AI — ai-agent (bridge SenClaw / persona / provider trực tiếp), knowledge

REST

Biến môi trường

Giới hạn đã biết

• Bridge llm.request **không có temperature** (daemon hard-code 0.2). Node ai-agent chỉ cho chỉnh nó ở backend provider (gọi thẳng nhà cung cấp).
• finish == "length" được coi là lỗi, không phải kết quả — câu trả lời cụt sẽ ra cổng error thay vì đi tiếp với JSON gãy.
• Bridge mcp.call của core vẫn là stub, nên node mcp-call POST thẳng vào /api/mcp/message của app đích.
• Nhóm node IoT của Dipper (input-telemetry, output-model, get-last-model…) chưa có — chúng phụ thuộc bảng device/model của dipper-hub. Xem §10 của design doc.