Agents

result = client.agents.list

result.each { |agent| puts agent.name }  # List is Enumerable
result.meta  # => { "total" => 3 }

agent = client.agents.create(
  name: "Hotel Concierge",
  system_prompt: "You are a hotel operations agent...",
  business_account_id: "acc_01hx..."
)

agent.id     # => "agt_01hx..."
agent.name   # => "Hotel Concierge"
agent.status # => "active"

agent = client.agents.create(
  name: "Hotel Concierge",
  system_prompt: "Extract structured tasks from hotel guest messages.",
  payload_schema: [
    { name: "room_number", field_type: "text", required: true },
    { name: "description", field_type: "text", required: true },
    { name: "due_at", field_type: "datetime", required: false },
    { name: "priority", field_type: "text", required: false }
  ]
)

agent.payload_schema  # => [{ "name" => "room_number", "field_type" => "text", "required" => true }, ...]

agent = client.agents.create(
  name: "Support Agent",
  system_prompt: "Handle customer support requests.",
  allowed_actions: [
    "support.refund.process",
    "support.ticket.create",
    "support.escalation.request"
  ]
)

agent.allowed_actions  # => ["support.refund.process", "support.ticket.create", ...]

run = agent.run(input: { last_message: "I want a refund for order #1234" })

run.actions.each do |action|
  case action["type"]
  when "support.refund.process"
    Refunds::Process.call(action["payload"])
  when "support.ticket.create"
    Tickets::Create.call(action["payload"])
  when "support.escalation.request"
    Escalations::Notify.call(action["payload"])
  end
end

agent = client.agents.retrieve("agt_01hx...")
agent.active?   # => true
agent.auto_run? # => false

agent = client.agents.update("agt_01hx...", name: "Updated Concierge")

client.agents.delete("agt_01hx...")  # => true

# String input (auto-wrapped as last_message)
run = agent.run(input: "Clean room 204 tomorrow at 8")

# Hash input (full control)
run = agent.run(input: {
  last_message: "Clean room 204 tomorrow at 8",
  recent_messages: ["Hi, I have a request"]
})

run.status  # => "pending"

run.refresh
run.completed?      # => true
run.intent          # => "task_extraction"
run.confidence      # => 0.95
run.actions         # => [{ "type" => "hospitality.room_service.request", "payload" => { ... } }]
run.suggested_reply # => "I'll arrange cleaning for room 204 tomorrow at 8am."
run.context_summary # => "Guest requested room 204 cleaning for tomorrow 8am."

# From an agent object
runs = agent.runs.list

# From the client
runs = client.runs("agt_01hx...").list

run = client.runs("agt_01hx...").retrieve("run_01hx...")

registry = WhatsrbCloud::ActionRegistry.new

registry.register("create_task") do |action|
  Task.create!(
    description: action["description"],
    room_number: action["room_number"],
    priority: action["priority"]
  )
end

registry.register("create_ticket") do |action|
  Ticket.create!(message: action["message"])
end

# Dispatch all actions from a completed run
run = agent.run(input: { last_message: "Fix the AC in room 107" })
run.dispatch(registry)

# Enable confirmation mode
agent = client.agents.update("agt_xxx",
  confirmation_mode: "confirm",
  confirmation_timeout_minutes: 30
)

# Run the agent
run = agent.run(input: "I want a refund for order #1234")

# Review action_statuses
run.action_statuses  # => [{ "status" => "pending", ... }, ...]

# Confirm specific actions (by index)
run.confirm_actions([0, 2])

# Reject specific actions (by index)
run.reject_actions([1])

# Or decide individually
run.decide_actions([
  { index: 0, status: "confirmed" },
  { index: 1, status: "rejected" }
])

# Dispatch only executes confirmed actions
run.dispatch(registry)