Watch and steer sessions

hai sessions status "$SESSION_ID"
hai sessions watch "$SESSION_ID"   # stream events until the session settles

curl "https://agp.eu.hcompany.ai/api/v2/sessions/$SESSION_ID/status" -H "Authorization: Bearer $HAI_API_KEY"
curl "https://agp.eu.hcompany.ai/api/v2/sessions/$SESSION_ID/changes?from_index=0&wait_for_seconds=25" -H "Authorization: Bearer $HAI_API_KEY"
curl "https://agp.eu.hcompany.ai/api/v2/sessions/$SESSION_ID/events?size=50" -H "Authorization: Bearer $HAI_API_KEY"

from hai_agents import Client

client = Client()
session = client.start_session(
    agent="h/web-surfer-flash",
    messages=[{"type": "user_message", "message": "Find the top story on Hacker News"}],
)

session.status()               # cheap snapshot
session.changes(from_index=0)  # new events + final answer, long-polled
session.get()                  # the full Session resource

result = session.wait_for_completion()  # block until terminal
print(result.status, result.answer)

import { HaiAgentsClient } from "hai-agents";

const client = new HaiAgentsClient();
const session = await client.startSession({
  agent: "h/web-surfer-flash",
  messages: [{ type: "user_message", message: "Find the top story on Hacker News" }],
});

await session.status();                  // cheap snapshot
await session.changes({ fromIndex: 0 }); // new events + final answer, long-polled
await session.get();                     // the full Session resource

const result = await session.waitForCompletion(); // block until terminal
console.log(result.status, result.answer);

for event in session.stream():  # `async for` with the async client
    print(event.type)

for await (const event of session.stream()) {
  console.log(event.type);
}

hai sessions send "$SESSION_ID" "Only consider results from the last 24 hours"
hai sessions cancel "$SESSION_ID" --yes

API=https://agp.eu.hcompany.ai/api/v2/sessions/$SESSION_ID
AUTH="Authorization: Bearer $HAI_API_KEY"

curl -X POST "$API/messages" -H "$AUTH" -H "Content-Type: application/json" \
  -d '{"type": "user_message", "message": "Only consider results from the last 24 hours"}'
curl -X POST "$API/pause" -H "$AUTH"
curl -X POST "$API/resume" -H "$AUTH"
curl -X POST "$API/force_answer" -H "$AUTH"
curl -X DELETE "$API" -H "$AUTH"   # cancel

session.send_message({"type": "user_message", "message": "Only consider results from the last 24 hours"})
session.pause()
session.resume()
session.force_answer()
session.cancel()

await session.sendMessage({ type: "user_message", message: "Only consider results from the last 24 hours" });
await session.pause();
await session.resume();
await session.forceAnswer();
await session.cancel();

SESSION_ID=$(curl -sX POST https://agp.eu.hcompany.ai/api/v2/sessions \
  -H "Authorization: Bearer $HAI_API_KEY" -H "Content-Type: application/json" \
  -d '{
    "agent": "h/web-surfer-flash",
    "idle_timeout_s": 600,
    "messages": [{"type": "user_message", "message": "Find the top story on Hacker News"}]
  }' | jq -r .id)

# Once it answers and goes idle, follow up in the same context
curl -X POST "https://agp.eu.hcompany.ai/api/v2/sessions/$SESSION_ID/messages" \
  -H "Authorization: Bearer $HAI_API_KEY" -H "Content-Type: application/json" \
  -d '{"type": "user_message", "message": "Now open its comments and summarize the discussion"}'

session = client.start_session(
    agent="h/web-surfer-flash",
    idle_timeout_s=600,
    messages=[{"type": "user_message", "message": "Find the top story on Hacker News"}],
)
session.send_message({"type": "user_message", "message": "Now open its comments and summarize the discussion"})

const session = await client.startSession({
  agent: "h/web-surfer-flash",
  idleTimeoutS: 600,
  messages: [{ type: "user_message", message: "Find the top story on Hacker News" }],
});
await session.sendMessage({ type: "user_message", message: "Now open its comments and summarize the discussion" });