​

Lobster

​

हुक

​

क्यों

• कई के बजाय एक कॉल: OpenClaw एक Lobster टूल कॉल चलाता है और एक संरचित परिणाम प्राप्त करता है।
• अंतर्निहित अनुमोदन: साइड इफेक्ट्स (ईमेल भेजना, टिप्पणी पोस्ट करना) तब तक वर्कफ़्लो को रोकते हैं जब तक स्पष्ट रूप से अनुमोदित न हों।
• पुनःआरंभ योग्य: रुके हुए वर्कफ़्लो एक टोकन लौटाते हैं; सब कुछ दोबारा चलाए बिना अनुमोदन दें और पुनःआरंभ करें।

​

साधारण प्रोग्राम्स की बजाय DSL क्यों?

• अनुमोदन/रिज़्यूम अंतर्निहित: एक सामान्य प्रोग्राम किसी मानव से पूछ सकता है, लेकिन बिना खुद वह रनटाइम बनाए रोकना और पुनःआरंभ नहीं कर सकता।
• निर्धारकता + ऑडिटेबिलिटी: पाइपलाइंस डेटा हैं, इसलिए उन्हें लॉग, डिफ़, रीप्ले और रिव्यू करना आसान है।
• AI के लिए सीमित सतह: छोटा व्याकरण + JSON पाइपिंग “रचनात्मक” कोड पाथ्स को घटाती है और वैलिडेशन को यथार्थवादी बनाती है।
• सुरक्षा नीति अंतर्निहित: टाइमआउट्स, आउटपुट कैप्स, sandbox चेक्स और allowlists रनटाइम द्वारा लागू होते हैं, न कि हर स्क्रिप्ट द्वारा।
• फिर भी प्रोग्रामेबल: प्रत्येक चरण किसी भी CLI या स्क्रिप्ट को कॉल कर सकता है। यदि आप JS/TS चाहते हैं, तो कोड से .lobster फ़ाइलें जनरेट करें।

​

यह कैसे काम करता है

​

Pattern: छोटा CLI + JSON पाइप्स + अनुमोदन

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":"..."}'

​

केवल‑JSON LLM चरण (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.",
  "input": { "subject": "Hello", "body": "Can you help?" },
  "schema": {
    "type": "object",
    "properties": {
      "intent": { "type": "string" },
      "draft": { "type": "string" }
    },
    "required": ["intent", "draft"],
    "additionalProperties": false
  }
}'

​

वर्कफ़्लो फ़ाइलें (.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 और stdin: $step.json किसी पूर्व चरण के आउटपुट को पास करते हैं।
• condition (या when) चरणों को $step.approved पर गेट कर सकता है।

​

Lobster इंस्टॉल करें

​

टूल सक्षम करें

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

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

​

उदाहरण: ईमेल ट्रायेज

User: "Check my email and draft replies"
→ openclaw calls gmail.list
→ LLM summarizes
→ User: "draft replies to #2 and #5"
→ LLM drafts
→ User: "send #2"
→ openclaw calls gmail.send
(repeat daily, no memory of what was triaged)

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

{
  "ok": true,
  "status": "needs_approval",
  "output": [{ "summary": "5 need replies, 2 need action" }],
  "requiresApproval": {
    "type": "approval_request",
    "prompt": "Send 2 draft replies?",
    "items": [],
    "resumeToken": "..."
  }
}

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

​

टूल पैरामीटर्स

​

run

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

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

​

resume

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

​

वैकल्पिक इनपुट्स

• lobsterPath: Lobster बाइनरी का absolute पथ (छोड़ने पर PATH उपयोग होगा)।
• cwd: पाइपलाइन के लिए वर्किंग डायरेक्टरी (डिफ़ॉल्ट: वर्तमान प्रोसेस वर्किंग डायरेक्टरी)।
• timeoutMs: यदि सबप्रोसेस इस अवधि से अधिक हो जाए तो उसे किल करें (डिफ़ॉल्ट: 20000)।
• maxStdoutBytes: यदि stdout इस आकार से अधिक हो जाए तो सबप्रोसेस किल करें (डिफ़ॉल्ट: 512000)।
• argsJson: lobster run --args-json को पास की गई JSON स्ट्रिंग (केवल वर्कफ़्लो फ़ाइलें)।

​

आउटपुट एनवेलप

• ok → सफलतापूर्वक पूर्ण
• needs_approval → रुका हुआ; पुनःआरंभ के लिए requiresApproval.resumeToken आवश्यक
• cancelled → स्पष्ट रूप से अस्वीकृत या रद्द

​

अनुमोदन

• approve: true → पुनःआरंभ करें और साइड इफेक्ट्स जारी रखें
• approve: false → रद्द करें और वर्कफ़्लो को अंतिम रूप दें

​

OpenProse

​

सुरक्षा

• केवल स्थानीय सबप्रोसेस — प्लगइन स्वयं से कोई नेटवर्क कॉल नहीं।
• कोई सीक्रेट्स नहीं — Lobster OAuth प्रबंधित नहीं करता; यह OpenClaw टूल्स को कॉल करता है जो करते हैं।
• Sandbox‑aware — टूल कॉन्टेक्स्ट sandboxed होने पर अक्षम।
• Hardened — यदि निर्दिष्ट हो तो lobsterPath absolute होना चाहिए; टाइमआउट्स और आउटपुट कैप्स लागू।

​

समस्या निवारण

• lobster subprocess timed out → timeoutMs बढ़ाएँ, या लंबी पाइपलाइन को विभाजित करें।
• lobster output exceeded maxStdoutBytes → maxStdoutBytes बढ़ाएँ या आउटपुट आकार घटाएँ।
• lobster returned invalid JSON → सुनिश्चित करें कि पाइपलाइन tool mode में चलती है और केवल JSON प्रिंट करती है।
• lobster failed (code …) → stderr की जाँच के लिए उसी पाइपलाइन को टर्मिनल में चलाएँ।

​

Learn more

• Plugins
• Plugin tool authoring

​

केस स्टडी: समुदाय वर्कफ़्लो

• थ्रेड: https://x.com/plattenschieber/status/2014508656335770033
• रिपो: https://github.com/bloomedai/brain-cli