安装与鉴权

npm install @beeos-ai/cloud-harness-sdk@1.0.0

import { AgentGatewayClient, agentIdentityFromKeyPair, loadAgentKeyPair } from "@beeos-ai/cloud-harness-sdk";

const keys = loadAgentKeyPair("./harness-key.json");
const gateway = new AgentGatewayClient({
  baseUrl: process.env.AGENT_GATEWAY_URL!,
  identity: agentIdentityFromKeyPair(keys),
});

// Every call is signed with the harness key and re-signed on each retry.
const canvasToken = await gateway.canvas.token();
console.log(canvasToken.relayUrl);

import { createHash, randomUUID } from "node:crypto";
import {
  AgentGatewayClient,
  InstanceAuthorityRuntimeRegistrationTransport,
  RuntimeRegistrationCoordinator,
  agentIdentityFromKeyPair,
  loadAgentKeyPair,
} from "@beeos-ai/cloud-harness-sdk";

// 1. Harness key pair. The file is created with mode 0600 when it does not exist.
const keys = loadAgentKeyPair("./harness-key.json");
const identity = agentIdentityFromKeyPair(keys);

// 2. Signed client for Agent Gateway.
const gateway = new AgentGatewayClient({
  baseUrl: process.env.AGENT_GATEWAY_URL!,
  identity,
});

// 3. Register and keep the lease alive. Persist registrationId and journalStoreId between restarts.
const registrationId = randomUUID();
const coordinator = new RuntimeRegistrationCoordinator(
  new InstanceAuthorityRuntimeRegistrationTransport({ gateway, registrationId }),
  {
    registrationId,
    handlerIdentity: "my-harness-1",
    contractRevision: "2026-07-14.3",
    runtimeMethods: ["session/prompt"],
    capabilities: ["transport", "conversation.control"],
    manifestDigest: process.env.RUNTIME_MANIFEST_DIGEST!, // SHA-256 digest of the method manifest you implement
    journalStoreId: randomUUID(),
    journalGeneration: "1",
    instanceIdentityKeyId: createHash("sha256").update(keys.publicKey).digest("hex"),
    targetInstanceId: process.env.BEEOS_INSTANCE_ID,
    signIdentityProof: message => identity.sign(message),
  },
  (reason, cause) => console.error("runtime lease lost:", reason, cause),
);

const lease = await coordinator.start();
if (lease) console.log("lease expires at", lease.leaseExpiresAt);
// ... later: coordinator.stop();

import os
from typing import Any

from beeos_cloud_harness_sdk import BeeOSAgentRuntime

runtime = BeeOSAgentRuntime(
    agent_gateway_url=os.environ["AGENT_GATEWAY_URL"],
    message_service_url=os.environ["MESSAGE_SERVICE_URL"],
    instance_id=os.environ["BEEOS_INSTANCE_ID"],
    agent_id=os.environ["BEEOS_AGENT_ID"],
    token=lambda: os.environ["BEEOS_RUNTIME_TOKEN"],  # a string or a function that returns the current one
)

def on_chat_message(event: dict[str, Any]) -> None:
    # Cloud pre-creates the reply message; complete it with the answer.
    runtime.chat.complete_reply(event["conversationId"], event["replyMessageId"], "You said: " + event["text"])

runtime.register(on_chat_message=on_chat_message)