Run AI agents from your code

curl -X POST https://dashboard.larkbot.app/api/agents/researcher/runs \
  -H "Authorization: Bearer $LARK_API_KEY" \
  -H "content-type: application/json" \
  -d '{"prompt": "Research Acme Inc. and write a one-page brief with sources."}'

# → {"id": "run_8kQ2…", "status": "queued", …}
curl https://dashboard.larkbot.app/api/runs/run_8kQ2… -H "Authorization: Bearer $LARK_API_KEY"

import { Lark } from "lark-agents";

const lark = new Lark({ apiKey: process.env.LARK_API_KEY, baseUrl: "https://dashboard.larkbot.app" });

const run = await lark.runs.create({
  agent: "researcher",
  prompt: "Research Acme Inc. and write a one-page brief with sources.",
});
const done = await lark.runs.wait(run.id);
console.log(done.status, done.result);

from lark_agents import Lark

lark = Lark(base_url="https://dashboard.larkbot.app")  # reads LARK_API_KEY

run = lark.runs.create(agent="researcher",
                       prompt="Research Acme Inc. and write a one-page brief with sources.")
done = lark.runs.wait(run["id"])
print(done["status"], done["result"])

# Node 18+, Deno, Bun or workers
npm install lark-agents

# Python 3.9+
pip install lark-agents

const run = await lark.runs.create({
  agent: "coder",
  prompt: "Fix the failing tests and open a pull request.",
  repo: "https://github.com/acme/web.git",
  webhookUrl: "https://acme.dev/hooks/lark",
});

// Later, or somewhere else:
const latest = await lark.runs.get(run.id);
if (latest.status === "failed") console.error(latest.error);
console.log(latest.cost); // { billableUsd, modelUsd, vmSeconds, … }

run = lark.runs.create(
    agent="coder",
    prompt="Fix the failing tests and open a pull request.",
    repo="https://github.com/acme/web.git",
    webhook_url="https://acme.dev/hooks/lark",
)

latest = lark.runs.get(run["id"])
if latest["status"] == "failed":
    print(latest["error"])
print(latest["cost"])

curl -X POST https://dashboard.larkbot.app/api/agents/coder/runs \
  -H "Authorization: Bearer $LARK_API_KEY" -H "content-type: application/json" \
  -d '{"prompt":"Fix the failing tests and open a pull request.","repo":"https://github.com/acme/web.git"}'

for await (const event of lark.runs.stream(run.id)) {
  if (event.text) console.log(event.text);         // "$ npm test", "⌁ browser goto …"
  if (event.type === "question") console.log("It's asking:", event.data.question);
}

for event in lark.runs.stream(run["id"]):
    if event.get("text"):
        print(event["text"])
    if event["type"] == "question":
        print("It's asking:", event["data"]["question"])

curl -N https://dashboard.larkbot.app/api/runs/run_8kQ2…/stream \
  -H "Authorization: Bearer $LARK_API_KEY" -H "Accept: text/event-stream"

await lark.runs.message(run.id, "Also include their pricing page.");

for await (const e of lark.runs.stream(run.id)) {
  if (e.type === "question") await lark.runs.message(run.id, "Use the staging account.");
}

lark.runs.message(run["id"], "Also include their pricing page.")

for e in lark.runs.stream(run["id"]):
    if e["type"] == "question":
        lark.runs.message(run["id"], "Use the staging account.")

curl -X POST https://dashboard.larkbot.app/api/runs/run_8kQ2…/messages \
  -H "Authorization: Bearer $LARK_API_KEY" -H "content-type: application/json" \
  -d '{"text":"Also include their pricing page."}'

await lark.agents.create({
  name: "researcher",
  description: "Researches companies on the web",
  model: { provider: "lark", model: "accounts/fireworks/models/glm-5p3" },
  browser: true,                             // a real browser in its machine
  sandbox: { type: "fly", persistent: true }, // keeps files, logins and notes between tasks
  systemPrompt: "Cite every source. Prefer primary sources.",
  secrets: ["CRM_TOKEN"],
  skills: ["company-research-brief"],
});

lark.agents.create(
    name="researcher",
    description="Researches companies on the web",
    model={"provider": "lark", "model": "accounts/fireworks/models/glm-5p3"},
    browser=True,
    sandbox={"type": "fly", "persistent": True},
    systemPrompt="Cite every source. Prefer primary sources.",
    secrets=["CRM_TOKEN"],
    skills=["company-research-brief"],
)

const hook = await lark.triggers.create("researcher", {
  name: "new-lead",
  kind: "webhook",
  prompt: "New lead: {{payload.name}} at {{payload.company}}. Research the company and write a brief.",
});
console.log(hook.url, hook.secret); // give these to the sending service; the secret is shown once

const nightly = await lark.triggers.create("coder", {
  name: "nightly-tests", kind: "schedule", schedule: "0 2 * * *", timezone: "America/New_York",
  prompt: "Run the test suite and fix anything that's red.",
});

hook = lark.triggers.create("researcher", name="new-lead", kind="webhook",
    prompt="New lead: {{payload.name}} at {{payload.company}}. Research the company and write a brief.")
print(hook["url"], hook["secret"])

lark.triggers.create("coder", name="nightly-tests", kind="schedule",
    schedule="0 2 * * *", timezone="America/New_York",
    prompt="Run the test suite and fix anything that's red.")

# The sending service signs its body with the trigger's secret:
BODY='{"name":"Ada Lovelace","company":"Analytical Engines"}'
SIG="sha256=$(printf '%s' "$BODY" | openssl dgst -sha256 -hmac "$TRIGGER_SECRET" -hex | sed 's/.* //')"
curl -X POST "$TRIGGER_URL" -H "content-type: application/json" -H "X-Lark-Signature: $SIG" -d "$BODY"
# → 202 {"runId": "run_…", "status": "queued"}

import { verifyWebhook } from "lark-agents";

app.post("/hooks/lark", express.raw({ type: "application/json" }), async (req, res) => {
  const ok = await verifyWebhook(req.body, req.get("x-lark-signature"), process.env.LARK_WEBHOOK_SECRET!);
  if (!ok) return res.sendStatus(401);
  const { event, run } = JSON.parse(req.body.toString());
  if (event === "run.succeeded") await saveReport(run.id, run.result);
  res.sendStatus(200);
});

from lark_agents import verify_webhook

@app.post("/hooks/lark")
def lark_hook():
    raw = request.get_data()
    if not verify_webhook(raw, request.headers.get("X-Lark-Signature"), os.environ["LARK_WEBHOOK_SECRET"]):
        abort(401)
    payload = json.loads(raw)
    if payload["event"] == "run.succeeded":
        save_report(payload["run"]["id"], payload["run"]["result"])
    return "", 200

const { draft } = await lark.skills.draft({ runId: run.id });  // learn from a run that went well
await lark.skills.create(draft);
await lark.agents.update("researcher", { skills: ["company-research-brief", draft.name] });

draft = lark.skills.draft(run_id=run["id"])["draft"]
lark.skills.create(**draft)
lark.agents.update("researcher", skills=["company-research-brief", draft["name"]])

await lark.secrets.set("GITHUB_TOKEN", process.env.GITHUB_TOKEN!);
await lark.agents.update("coder", { secrets: ["GITHUB_TOKEN"] });

lark.secrets.set("GITHUB_TOKEN", os.environ["GITHUB_TOKEN"])
lark.agents.update("coder", secrets=["GITHUB_TOKEN"])