前端 SDK

import { createNuva, Message } from "@nuva/sdk";

const nuva = createNuva({
  getAccessToken: getNuvaAccessToken,
});

const main = await nuva.sessions.getMain();
const agent = nuva.agent({ sessionId: main.id });
const receipt = await agent.send(Message.text("开始广告创作，请先列出需要的产品资料。"));

const script = await nuva.scripts.get(scriptId);
const plan = await nuva.directingPlans.get(planId);
const prompt = await nuva.prompts.get(promptId);
const ad = await nuva.ads.get(adId);
const batch = await nuva.batches.get(batchId);

const script = await nuva.scripts.get(scriptRef.id, {
  revision: scriptRef.revision,
});

await agent.send(
  Message.create().mention(script).text("修改开场，保留其他内容。")
);

const product = await nuva.products.create(productForm);
const current = await nuva.products.get(product.ref.id);

const saved = await nuva.products.update({
  base: current,
  data: editedBrief,
});

const script = await nuva.scripts.get(scriptId);
const revised = await nuva.scripts.update({
  base: script,
  data: editedScript,
});

const script = await nuva.scripts.generate(scriptRequest);

await agent.send(
  Message.create()
    .mention(script)
    .text("把开场改得更自然，保留其他内容。")
);

const unsubscribe = agent.subscribe((state) => {
  if (state.status === "loading") return;
  if (state.status === "error") {
    console.error(state.error);
    return;
  }

  console.log(state.status, state.messages.items);
});

// 不再需要接收更新时调用 unsubscribe()。

await agent.send(Message.text("继续修改第二条脚本。"));

await agent.send(
  Message.create()
    .text("修改 ")
    .mention(script)
    .text(" 的开场，保留其他内容。")
);

await agent.send(
  Message.create().replyTo(existingMessage).text("使用这一版。")
);

{
  "requestId": "request_21",
  "message": {
    "sessionId": "work_product_a",
    "messageId": "message_12"
  }
}

{
  "ref": { "kind": "script", "id": "script_1", "revision": "1" },
  "label": "脚本 1"
}

{
  "ref": { "sessionId": "work_product_a", "messageId": "message_10" },
  "role": "assistant",
  "createdAt": "2026-10-12T18:00:00Z",
  "state": "complete",
  "attachments": [],
  "content": [
    { "id": "part_text", "type": "text", "format": "markdown", "text": "脚本已生成。" },
    {
      "id": "part_script_1",
      "type": "resource",
      "record": {
        "ref": { "kind": "script", "id": "script_1", "revision": "1" },
        "label": "脚本 1"
      }
    }
  ]
}

{
  "type": "dynamic-tool",
  "toolName": "nuva.review",
  "toolCallId": "call_17",
  "state": "input-available",
  "input": {
    "prompt": "请审核这条脚本。批准后将继续细化导演计划。",
    "records": [{ "kind": "script", "id": "script_1", "revision": "1" }]
  }
}

// part 是消息中 state 为 input-available 的工具调用。
const receipt = await agent.respond(part, {
  decision: "reject",
  text: "先展示产品，再讲困扰。",
});

{
  "requestId": "request_22",
  "call": {
    "type": "dynamic-tool",
    "toolName": "nuva.review",
    "toolCallId": "call_17",
    "state": "output-available",
    "input": {
      "prompt": "请审核这条脚本。批准后将继续细化导演计划。",
      "records": [{ "kind": "script", "id": "script_1", "revision": "1" }]
    },
    "output": { "decision": "reject", "text": "先展示产品，再讲困扰。" }
  }
}

await agent.fail(part, {
  code: "EDITOR_UNAVAILABLE",
  message: "脚本编辑器加载失败。",
});

const unsubscribe = agent.onHostCall((part) => {
  if (part.type === "dynamic-tool") {
    if (part.state !== "input-available") return;
    host.receive(part.toolName, part.input, part);
  } else {
    host.receive(part.data.toolName, part.data.input, part);
  }
});

// 不再处理 host call 时调用 unsubscribe()。

{
  "type": "data-host-call",
  "id": "host_19",
  "data": {
    "toolName": "workspace.showScripts",
    "input": {
      "records": [{ "kind": "script", "id": "script_1", "revision": "1" }]
    }
  }
}