zeekay
fe31141cfd
First-class services for agents, agent sessions, and machines with Hanzo IAM-native Bearer auth; raw send() escape hatch for the full /v1/cloud/* surface. Mirrors the @hanzo/cloud JavaScript client. dart format + analyze --fatal-infos clean, 22 tests green, pub publish dry-run: 0 warnings.
2.9 KiB
hanzoai
The Dart client for the Hanzo Cloud /v1/ platform API at
api.hanzo.ai. Auth is Hanzo IAM-native: the client holds
the IAM-issued Bearer JWT (or an API key) and sends it on every request.
First-class services for agents, agent sessions, and machines, plus
a raw send() escape hatch that reaches the full /v1/cloud/* surface. Mirrors
the @hanzo/cloud JavaScript client.
Where it sits
Orthogonal, IAM-native clients — hanzoai is the platform control plane (create
an agent, run it, watch its sessions, provision its machine). It does not do
inference itself; pair it with the Hanzo AI inference surface for completions.
Install
dependencies:
hanzoai: ^0.1.0
import 'package:hanzoai/hanzoai.dart';
final cloud = HanzoCloud(token: 'IAM_JWT'); // origin defaults to api.hanzo.ai
Agents
final agent = await cloud.agents.create(
name: 'researcher',
model: 'zen-coder',
instructions: 'You research and summarize.',
tools: ['search', 'fetch'],
);
final run = await cloud.agents.run('researcher', input: 'Summarize RFC 8628.');
print('${run.status}: ${run.output}');
final agents = await cloud.agents.list();
final detail = await cloud.agents.get('researcher');
final history = await cloud.agents.runs('researcher', limit: 20);
A long-running agent carries a 5-field cron and is invoked by the scheduler:
await cloud.agents.create(
name: 'nightly-digest',
model: 'zen-coder',
executionMode: 'long-running',
schedule: '0 9 * * *',
);
Agent sessions
final session = await cloud.sessions.register(agent: 'researcher');
await cloud.sessions.appendEvent(session.id, kind: 'log', payload: {'msg': 'started'});
await cloud.sessions.pause(session.id);
await cloud.sessions.resume(session.id);
await cloud.sessions.message(session.id, message: 'focus on section 3');
final tree = await cloud.sessions.tree(session.id);
Machines
final machines = await cloud.machines.list(pageSize: 50);
final one = await cloud.machines.get('org/name');
await cloud.machines.add(Machine(name: 'gpu-1', region: 'sfo3'));
The full surface
Every other /v1/cloud/* resource (nodes, pods, containers, providers,
connections, stores, vectors, workflows, …) is reachable through send():
final providers = await cloud.send('/v1/cloud/get-providers');
Auth
cloud.setToken(jwt); // seed or replace the Bearer token
cloud.authStore.isValid; // token present and, if a JWT, unexpired
cloud.signOut(); // clear it
Errors are thrown as HanzoException with statusCode and message.
Develop
dart pub get
dart analyze --fatal-infos
dart test
License
MIT © Hanzo AI, Inc. See LICENSE.