Anthropic SDKs

import os

from anthropic import Anthropic

client = Anthropic(
    api_key=os.environ["BMA_API_KEY"],
    base_url=os.environ["BMA_BASE_URL"],  # the API origin; the SDK adds /v1
    default_headers={"x-bma-project-id": os.environ["BMA_PROJECT_ID"]},
)

import Anthropic from "@anthropic-ai/sdk";

const client = new Anthropic({
  apiKey: process.env.BMA_API_KEY!,
  baseURL: process.env.BMA_BASE_URL!, // the API origin; the SDK adds /v1
  defaultHeaders: { "x-bma-project-id": process.env.BMA_PROJECT_ID! },
});

# List machines, open a terminal session on one and mint a single-use connect ticket
machines = client.get("/v1/machines", cast_to=object, options={"params": {"limit": 20}})
machine_id = machines["data"][0]["id"]

terminal = client.post("/v1/terminal_sessions", cast_to=object, body={"machine_id": machine_id})
ticket = client.post(f"/v1/terminal_sessions/{terminal['id']}/tickets", cast_to=object, body={})
print(ticket["purpose"], ticket["ws_url"], ticket["expires_at"])

client.post(f"/v1/terminal_sessions/{terminal['id']}/close", cast_to=object, body={})

// List machines, open a terminal session on one and mint a single-use connect ticket
const machines = (await client.get("/v1/machines", { query: { limit: 20 } })) as { data: { id: string }[] };
const machineId = machines.data[0].id;

const terminal = (await client.post("/v1/terminal_sessions", { body: { machine_id: machineId } })) as { id: string };
const ticket = (await client.post(`/v1/terminal_sessions/${terminal.id}/tickets`, { body: {} })) as {
  purpose: string; ws_url: string; expires_at: string;
};
console.log(ticket.purpose, ticket.ws_url, ticket.expires_at);

await client.post(`/v1/terminal_sessions/${terminal.id}/close`, { body: {} });

curl -sS "$BMA_BASE_URL/v1/machines?limit=20" \
  -H "x-api-key: $BMA_API_KEY" -H "x-bma-project-id: $BMA_PROJECT_ID"

curl -sS -X POST "$BMA_BASE_URL/v1/terminal_sessions" \
  -H "x-api-key: $BMA_API_KEY" -H "x-bma-project-id: $BMA_PROJECT_ID" \
  -H "content-type: application/json" -d '{"machine_id": "mch_..."}'

curl -sS -X POST "$BMA_BASE_URL/v1/terminal_sessions/tsn_.../tickets" \
  -H "x-api-key: $BMA_API_KEY" -H "x-bma-project-id: $BMA_PROJECT_ID" \
  -H "content-type: application/json" -d '{}'

go get github.com/beeos-ai/bma-sdk/v2@v2.1.0

npm install @beeos-ai/bma-sdk@2.1.0

pip install bma-sdk==2.1.0

import bmasdk "github.com/beeos-ai/bma-sdk/v2"

client := bmasdk.NewClient() // BMA_API_KEY, BMA_BASE_URL, BMA_PROJECT_ID

import { BmaClient } from "@beeos-ai/bma-sdk";

const client = new BmaClient({ apiKey: process.env.BMA_API_KEY, baseURL: process.env.BMA_BASE_URL });

from bma_sdk import Bma

client = Bma()  # BMA_API_KEY, BMA_BASE_URL, BMA_PROJECT_ID

res, err := client.Beta.Sessions.Events.SendAndStream(ctx, sessionID, anthropic.BetaSessionEventSendParams{
	Events: []anthropic.BetaManagedAgentsEventParamsUnion{{OfUserMessage: &anthropic.BetaManagedAgentsUserMessageEventParams{
		Content: []anthropic.BetaManagedAgentsUserMessageEventParamsContentUnion{{OfText: &anthropic.BetaManagedAgentsTextBlockParam{Text: "Next step."}}},
	}}},
}, anthropic.BetaSessionEventStreamParams{})
if err != nil {
	return err
}
defer res.Stream.Close()
// res.Sent is the send response; res.Replayed is true when the server gave no cursor
for res.Stream.Next() {
	if res.Stream.Current().Type == "session.status_idle" {
		break
	}
}

const { sent, stream, replayed } = await client.beta.sessions.events.sendAndStream(sessionId, {
  events: [{ type: "user.message", content: [{ type: "text", text: "Next step." }] }],
});
for await (const event of stream) {
  if (event.type === "session.status_idle") break;
}

result = client.beta.sessions.events.send_and_stream(session_id, events=[
    {"type": "user.message", "content": [{"type": "text", "text": "Next step."}]},
])
with result.stream as stream:
    for event in stream:
        if event.type == "session.status_idle":
            break
# result.sent is the send response; result.replayed is True when the server gave no cursor