​

Lobster

​

Hook

​

Tại sao

• Một lần gọi thay vì nhiều lần: OpenClaw thực hiện một lần gọi công cụ Lobster và nhận kết quả có cấu trúc.
• Phê duyệt tích hợp: Các tác động phụ (gửi email, đăng bình luận) dừng quy trình cho đến khi được phê duyệt rõ ràng.
• Có thể tiếp tục: Quy trình bị dừng trả về một token; phê duyệt và tiếp tục mà không cần chạy lại mọi thứ.

​

Tại sao dùng DSL thay vì chương trình thông thường?

• Phê duyệt/tiếp tục tích hợp: Một chương trình thông thường có thể nhắc nhở con người, nhưng không thể tạm dừng và tiếp tục với một token bền vững mà không cần bạn tự tạo runtime đó.
• Xác định + có thể kiểm tra: Pipeline là dữ liệu, nên dễ dàng ghi log, so sánh, chạy lại và xem xét.
• Giới hạn bề mặt cho AI: Ngữ pháp nhỏ + JSON piping giảm các đường dẫn mã “sáng tạo” và làm cho việc xác thực trở nên thực tế.
• Chính sách an toàn tích hợp: Thời gian chờ, giới hạn đầu ra, kiểm tra sandbox và danh sách cho phép được thực thi bởi runtime, không phải từng script.
• Vẫn có thể lập trình: Mỗi bước có thể gọi bất kỳ CLI hoặc script nào. Nếu bạn muốn JS/TS, tạo file .lobster từ mã.

​

Cách hoạt động

​

Mẫu: CLI nhỏ + JSON pipes + phê duyệt

inbox list --json
inbox categorize --json
inbox apply --json

{
  "action": "run",
  "pipeline": "exec --json --shell 'inbox list --json' | exec --stdin json --shell 'inbox categorize --json' | exec --stdin json --shell 'inbox apply --json' | approve --preview-from-stdin --limit 5 --prompt 'Apply changes?'",
  "timeoutMs": 30000
}

{
  "action": "resume",
  "token": "<resumeToken>",
  "approve": true
}

gog.gmail.search --query 'newer_than:1d' \
  | openclaw.invoke --tool message --action send --each --item-key message --args-json '{"provider":"telegram","to":"..."}'

​

Bước LLM chỉ dùng JSON (llm-task)

{
  "plugins": {
    "entries": {
      "llm-task": { "enabled": true }
    }
  },
  "agents": {
    "list": [
      {
        "id": "main",
        "tools": { "allow": ["llm-task"] }
      }
    ]
  }
}

openclaw.invoke --tool llm-task --action json --args-json '{
  "prompt": "Given the input email, return intent and draft.",
  "thinking": "low",
  "input": { "subject": "Hello", "body": "Can you help?" },
  "schema": {
    "type": "object",
    "properties": {
      "intent": { "type": "string" },
      "draft": { "type": "string" }
    },
    "required": ["intent", "draft"],
    "additionalProperties": false
  }
}'

​

File workflow (.lobster)

name: inbox-triage
args:
  tag:
    default: "family"
steps:
  - id: collect
    command: inbox list --json
  - id: categorize
    command: inbox categorize --json
    stdin: $collect.stdout
  - id: approve
    command: inbox apply --approve
    stdin: $categorize.stdout
    approval: required
  - id: execute
    command: inbox apply --execute
    stdin: $categorize.stdout
    condition: $approve.approved

• stdin: $step.stdout và stdin: $step.json truyền đầu ra của bước trước đó.
• condition (hoặc when) có thể chặn các bước dựa trên $step.approved.

​

Cài đặt Lobster

​

Kích hoạt công cụ

{
  "tools": {
    "alsoAllow": ["lobster"]
  }
}

{
  "agents": {
    "list": [
      {
        "id": "main",
        "tools": {
          "alsoAllow": ["lobster"]
        }
      }
    ]
  }
}

​

Ví dụ: Phân loại email

Người dùng: "Kiểm tra email của tôi và soạn thảo trả lời"
→ openclaw gọi gmail.list
→ LLM tóm tắt
→ Người dùng: "soạn thảo trả lời cho #2 và #5"
→ LLM soạn thảo
→ Người dùng: "gửi #2"
→ openclaw gọi gmail.send
(lặp lại hàng ngày, không có bộ nhớ về những gì đã được phân loại)

{
  "action": "run",
  "pipeline": "email.triage --limit 20",
  "timeoutMs": 30000
}

{
  "ok": true,
  "status": "needs_approval",
  "output": [{ "summary": "5 cần trả lời, 2 cần hành động" }],
  "requiresApproval": {
    "type": "approval_request",
    "prompt": "Gửi 2 bản nháp trả lời?",
    "items": [],
    "resumeToken": "..."
  }
}

{
  "action": "resume",
  "token": "<resumeToken>",
  "approve": true
}

​

Tham số công cụ

​

run

{
  "action": "run",
  "pipeline": "gog.gmail.search --query 'newer_than:1d' | email.triage",
  "cwd": "workspace",
  "timeoutMs": 30000,
  "maxStdoutBytes": 512000
}

{
  "action": "run",
  "pipeline": "/path/to/inbox-triage.lobster",
  "argsJson": "{\"tag\":\"family\"}"
}

​

resume

{
  "action": "resume",
  "token": "<resumeToken>",
  "approve": true
}

​

Đầu vào tùy chọn

• cwd: Thư mục làm việc tương đối cho pipeline (phải nằm trong thư mục làm việc của tiến trình hiện tại).
• timeoutMs: Dừng tiến trình con nếu vượt quá thời gian này (mặc định: 20000).
• maxStdoutBytes: Dừng tiến trình con nếu stdout vượt quá kích thước này (mặc định: 512000).
• argsJson: Chuỗi JSON được truyền vào lobster run --args-json (chỉ dành cho file workflow).

​

Phong bì đầu ra

• ok → hoàn thành thành công
• needs_approval → tạm dừng; requiresApproval.resumeToken cần thiết để tiếp tục
• cancelled → bị từ chối hoặc hủy bỏ rõ ràng

​

Phê duyệt

• approve: true → tiếp tục và thực hiện các tác động phụ
• approve: false → hủy bỏ và hoàn tất workflow

​

OpenProse

​

An toàn

• Chỉ tiến trình con cục bộ — không có cuộc gọi mạng từ chính plugin.
• Không có bí mật — Lobster không quản lý OAuth; nó gọi các công cụ OpenClaw thực hiện điều đó.
• Nhận biết sandbox — bị vô hiệu hóa khi ngữ cảnh công cụ bị sandbox.
• Được bảo vệ — tên thực thi cố định (lobster) trên PATH; thời gian chờ và giới hạn đầu ra được thực thi.

​

Khắc phục sự cố

• lobster subprocess timed out → tăng timeoutMs, hoặc chia nhỏ một pipeline dài.
• lobster output exceeded maxStdoutBytes → tăng maxStdoutBytes hoặc giảm kích thước đầu ra.
• lobster returned invalid JSON → đảm bảo pipeline chạy ở chế độ công cụ và chỉ in JSON.
• lobster failed (code …) → chạy cùng pipeline trong terminal để kiểm tra stderr.

​

Tìm hiểu thêm

• Plugins
• Tạo công cụ plugin

​

Nghiên cứu trường hợp: quy trình cộng đồng

• Thread: https://x.com/plattenschieber/status/2014508656335770033
• Repo: https://github.com/bloomedai/brain-cli