gestalt/

agent.rs

// Code generated by sdkgen. DO NOT EDIT.

//! Generated native types and clients for agent.proto.

use crate::app::{AgentToolRef, OperationAnnotations, RequestContext, SubjectContext};
use crate::codec::agent::{
    from_wire_agent_interaction, from_wire_agent_provider_capabilities, from_wire_agent_session,
    from_wire_agent_turn, from_wire_list_agent_provider_interactions_response,
    from_wire_list_agent_provider_sessions_response,
    from_wire_list_agent_provider_turn_events_response,
    from_wire_list_agent_provider_turns_response, to_wire_cancel_agent_provider_turn_request,
    to_wire_create_agent_provider_session_request, to_wire_create_agent_provider_turn_request,
    to_wire_get_agent_provider_capabilities_request,
    to_wire_get_agent_provider_interaction_request, to_wire_get_agent_provider_session_request,
    to_wire_get_agent_provider_turn_request, to_wire_list_agent_provider_interactions_request,
    to_wire_list_agent_provider_sessions_request, to_wire_list_agent_provider_turn_events_request,
    to_wire_list_agent_provider_turns_request, to_wire_resolve_agent_provider_interaction_request,
    to_wire_update_agent_provider_session_request,
};
use crate::codec::host_service::{HostServiceChannel, connect_host_service, plain_channel};
use crate::generated::v1;
use crate::rpc_support::GestaltError;

/// Open enum for `gestalt.provider.v1.AgentExecutionStatus`; unknown numeric values are preserved.
pub type AgentExecutionStatus = i32;

/// Named values of `AgentExecutionStatus`.
pub mod agent_execution_status {
    /// AGENT_EXECUTION_STATUS_UNSPECIFIED.
    pub const AGENT_EXECUTION_STATUS_UNSPECIFIED: i32 = 0;
    /// AGENT_EXECUTION_STATUS_PENDING.
    pub const AGENT_EXECUTION_STATUS_PENDING: i32 = 1;
    /// AGENT_EXECUTION_STATUS_RUNNING.
    pub const AGENT_EXECUTION_STATUS_RUNNING: i32 = 2;
    /// AGENT_EXECUTION_STATUS_SUCCEEDED.
    pub const AGENT_EXECUTION_STATUS_SUCCEEDED: i32 = 3;
    /// AGENT_EXECUTION_STATUS_FAILED.
    pub const AGENT_EXECUTION_STATUS_FAILED: i32 = 4;
    /// AGENT_EXECUTION_STATUS_CANCELED.
    pub const AGENT_EXECUTION_STATUS_CANCELED: i32 = 5;
    /// AGENT_EXECUTION_STATUS_WAITING_FOR_INPUT.
    pub const AGENT_EXECUTION_STATUS_WAITING_FOR_INPUT: i32 = 6;
}

/// Open enum for `gestalt.provider.v1.AgentInteractionState`; unknown numeric values are preserved.
pub type AgentInteractionState = i32;

/// Named values of `AgentInteractionState`.
pub mod agent_interaction_state {
    /// AGENT_INTERACTION_STATE_UNSPECIFIED.
    pub const AGENT_INTERACTION_STATE_UNSPECIFIED: i32 = 0;
    /// AGENT_INTERACTION_STATE_PENDING.
    pub const AGENT_INTERACTION_STATE_PENDING: i32 = 1;
    /// AGENT_INTERACTION_STATE_RESOLVED.
    pub const AGENT_INTERACTION_STATE_RESOLVED: i32 = 2;
    /// AGENT_INTERACTION_STATE_CANCELED.
    pub const AGENT_INTERACTION_STATE_CANCELED: i32 = 3;
}

/// Open enum for `gestalt.provider.v1.AgentInteractionType`; unknown numeric values are preserved.
pub type AgentInteractionType = i32;

/// Named values of `AgentInteractionType`.
pub mod agent_interaction_type {
    /// AGENT_INTERACTION_TYPE_UNSPECIFIED.
    pub const AGENT_INTERACTION_TYPE_UNSPECIFIED: i32 = 0;
    /// AGENT_INTERACTION_TYPE_APPROVAL.
    pub const AGENT_INTERACTION_TYPE_APPROVAL: i32 = 1;
    /// AGENT_INTERACTION_TYPE_CLARIFICATION.
    pub const AGENT_INTERACTION_TYPE_CLARIFICATION: i32 = 2;
    /// AGENT_INTERACTION_TYPE_INPUT.
    pub const AGENT_INTERACTION_TYPE_INPUT: i32 = 3;
}

/// Open enum for `gestalt.provider.v1.AgentMessagePartType`; unknown numeric values are preserved.
pub type AgentMessagePartType = i32;

/// Named values of `AgentMessagePartType`.
pub mod agent_message_part_type {
    /// AGENT_MESSAGE_PART_TYPE_UNSPECIFIED.
    pub const AGENT_MESSAGE_PART_TYPE_UNSPECIFIED: i32 = 0;
    /// AGENT_MESSAGE_PART_TYPE_TEXT.
    pub const AGENT_MESSAGE_PART_TYPE_TEXT: i32 = 1;
    /// AGENT_MESSAGE_PART_TYPE_JSON.
    pub const AGENT_MESSAGE_PART_TYPE_JSON: i32 = 2;
    /// AGENT_MESSAGE_PART_TYPE_TOOL_CALL.
    pub const AGENT_MESSAGE_PART_TYPE_TOOL_CALL: i32 = 3;
    /// AGENT_MESSAGE_PART_TYPE_TOOL_RESULT.
    pub const AGENT_MESSAGE_PART_TYPE_TOOL_RESULT: i32 = 4;
    /// AGENT_MESSAGE_PART_TYPE_IMAGE_REF.
    pub const AGENT_MESSAGE_PART_TYPE_IMAGE_REF: i32 = 5;
}

/// Open enum for `gestalt.provider.v1.AgentSessionState`; unknown numeric values are preserved.
pub type AgentSessionState = i32;

/// Named values of `AgentSessionState`.
pub mod agent_session_state {
    /// AGENT_SESSION_STATE_UNSPECIFIED.
    pub const AGENT_SESSION_STATE_UNSPECIFIED: i32 = 0;
    /// AGENT_SESSION_STATE_ACTIVE.
    pub const AGENT_SESSION_STATE_ACTIVE: i32 = 1;
    /// AGENT_SESSION_STATE_ARCHIVED.
    pub const AGENT_SESSION_STATE_ARCHIVED: i32 = 2;
}

/// Open enum for `gestalt.provider.v1.AgentToolSourceMode`; unknown numeric values are preserved.
pub type AgentToolSourceMode = i32;

/// Named values of `AgentToolSourceMode`.
pub mod agent_tool_source_mode {
    /// AGENT_TOOL_SOURCE_MODE_UNSPECIFIED.
    pub const AGENT_TOOL_SOURCE_MODE_UNSPECIFIED: i32 = 0;
    /// AGENT_TOOL_SOURCE_MODE_CATALOG.
    pub const AGENT_TOOL_SOURCE_MODE_CATALOG: i32 = 2;
    /// AGENT_TOOL_SOURCE_MODE_NONE.
    pub const AGENT_TOOL_SOURCE_MODE_NONE: i32 = 3;
}

/// Native message type for `gestalt.provider.v1.AgentCatalogToolConfig`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentCatalogToolConfig {
    /// The `refs` field.
    pub refs: Vec<AgentToolRef>,
    /// The `tools` field.
    pub tools: Vec<ListedAgentTool>,
}

/// Native message type for `gestalt.provider.v1.AgentInteraction`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentInteraction {
    /// The `id` field.
    pub id: String,
    /// The `type` field.
    pub r#type: AgentInteractionType,
    /// The `state` field.
    pub state: AgentInteractionState,
    /// The `title` field.
    pub title: String,
    /// The `prompt` field.
    pub prompt: String,
    /// The `request` field; None when unset.
    pub request: Option<serde_json::Map<String, serde_json::Value>>,
    /// The `resolution` field; None when unset.
    pub resolution: Option<serde_json::Map<String, serde_json::Value>>,
    /// The `created_at` field; None when unset.
    pub created_at: Option<std::time::SystemTime>,
    /// The `resolved_at` field; None when unset.
    pub resolved_at: Option<std::time::SystemTime>,
    /// The `turn_id` field.
    pub turn_id: String,
    /// The `session_id` field.
    pub session_id: String,
}

/// Native message type for `gestalt.provider.v1.AgentMessage`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentMessage {
    /// The `role` field.
    pub role: String,
    /// The `text` field.
    pub text: String,
    /// The `parts` field.
    pub parts: Vec<AgentMessagePart>,
    /// The `metadata` field; None when unset.
    pub metadata: Option<serde_json::Map<String, serde_json::Value>>,
}

/// Native message type for `gestalt.provider.v1.AgentMessagePart`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentMessagePart {
    /// The `type` field.
    pub r#type: AgentMessagePartType,
    /// The `text` field.
    pub text: String,
    /// The `json` field; None when unset.
    pub json: Option<serde_json::Map<String, serde_json::Value>>,
    /// The `tool_call` field; None when unset.
    pub tool_call: Option<AgentMessagePartToolCall>,
    /// The `tool_result` field; None when unset.
    pub tool_result: Option<AgentMessagePartToolResult>,
    /// The `image_ref` field; None when unset.
    pub image_ref: Option<AgentMessagePartImageRef>,
}

/// Native message type for `gestalt.provider.v1.AgentMessagePartImageRef`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentMessagePartImageRef {
    /// The `uri` field.
    pub uri: String,
    /// The `mime_type` field.
    pub mime_type: String,
}

/// Native message type for `gestalt.provider.v1.AgentMessagePartToolCall`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentMessagePartToolCall {
    /// The `id` field.
    pub id: String,
    /// The `tool_id` field.
    pub tool_id: String,
    /// The `arguments` field; None when unset.
    pub arguments: Option<serde_json::Map<String, serde_json::Value>>,
}

/// Native message type for `gestalt.provider.v1.AgentMessagePartToolResult`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentMessagePartToolResult {
    /// The `tool_call_id` field.
    pub tool_call_id: String,
    /// The `status` field.
    pub status: i32,
    /// The `content` field.
    pub content: String,
    /// The `output` field; None when unset.
    pub output: Option<serde_json::Map<String, serde_json::Value>>,
}

/// Native message type for `gestalt.provider.v1.AgentNoTools`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentNoTools {}

/// Values of the `kind` oneof in `AgentOutput`; the message field is None when unset.
#[allow(clippy::enum_variant_names, clippy::large_enum_variant)]
#[derive(Clone, Debug, PartialEq)]
pub enum AgentOutputKind {
    /// The `text` variant.
    Text(AgentTextOutput),
    /// The `structured` variant.
    Structured(AgentStructuredOutput),
}

/// Native message type for `gestalt.provider.v1.AgentOutput`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentOutput {
    /// The `kind` oneof; None when unset.
    pub kind: Option<AgentOutputKind>,
}

/// Native message type for `gestalt.provider.v1.AgentProviderCapabilities`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentProviderCapabilities {
    /// The `streaming_text` field.
    pub streaming_text: bool,
    /// The `tool_calls` field.
    pub tool_calls: bool,
    /// The `parallel_tool_calls` field.
    pub parallel_tool_calls: bool,
    /// The `interactions` field.
    pub interactions: bool,
    /// The `resumable_turns` field.
    pub resumable_turns: bool,
    /// The `reasoning_summaries` field.
    pub reasoning_summaries: bool,
    /// Provider list APIs can apply non-zero limits and summary projections without
    /// hydrating every source record. Providers that set this must order sessions
    /// and turns by the relevant newest-first recency fields before applying limit.
    ///
    /// The `bounded_list_hydration` field.
    pub bounded_list_hydration: bool,
    /// The `supported_tool_sources` field.
    pub supported_tool_sources: Vec<AgentToolSourceMode>,
    /// The `supports_session_start` field.
    pub supports_session_start: bool,
    /// The `supports_prepared_workspace` field.
    pub supports_prepared_workspace: bool,
}

/// Native message type for `gestalt.provider.v1.AgentSession`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentSession {
    /// The `id` field.
    pub id: String,
    /// The `provider_name` field.
    pub provider_name: String,
    /// The `model` field.
    pub model: String,
    /// The `client_ref` field.
    pub client_ref: String,
    /// The `state` field.
    pub state: AgentSessionState,
    /// The `metadata` field; None when unset.
    pub metadata: Option<serde_json::Map<String, serde_json::Value>>,
    /// The `created_by_subject_id` field.
    pub created_by_subject_id: String,
    /// The `created_at` field; None when unset.
    pub created_at: Option<std::time::SystemTime>,
    /// The `updated_at` field; None when unset.
    pub updated_at: Option<std::time::SystemTime>,
    /// The `last_turn_at` field; None when unset.
    pub last_turn_at: Option<std::time::SystemTime>,
}

/// Native message type for `gestalt.provider.v1.AgentSessionStartConfig`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentSessionStartConfig {
    /// The `hooks` field.
    pub hooks: Vec<AgentSessionStartHook>,
}

/// Native message type for `gestalt.provider.v1.AgentSessionStartHook`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentSessionStartHook {
    /// The `id` field.
    pub id: String,
    /// The `type` field.
    pub r#type: String,
    /// The `command` field.
    pub command: Vec<String>,
    /// The `cwd` field.
    pub cwd: String,
    /// The `timeout` field.
    pub timeout: String,
    /// The `env` field.
    pub env: std::collections::BTreeMap<String, String>,
    /// The `output` field; None when unset.
    pub output: Option<AgentSessionStartHookOutput>,
}

/// Native message type for `gestalt.provider.v1.AgentSessionStartHookOutput`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentSessionStartHookOutput {
    /// The `additional_context` field.
    pub additional_context: bool,
    /// The `metadata` field.
    pub metadata: bool,
}

/// Native message type for `gestalt.provider.v1.AgentStructuredOutput`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentStructuredOutput {
    /// The `schema` field; None when unset.
    pub schema: Option<serde_json::Map<String, serde_json::Value>>,
}

/// Native message type for `gestalt.provider.v1.AgentTextOutput`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentTextOutput {}

/// Values of the `source` oneof in `AgentToolConfig`; the message field is None when unset.
#[allow(clippy::enum_variant_names, clippy::large_enum_variant)]
#[derive(Clone, Debug, PartialEq)]
pub enum AgentToolConfigSource {
    /// The `none` variant.
    None(AgentNoTools),
    /// The `catalog` variant.
    Catalog(AgentCatalogToolConfig),
}

/// Native message type for `gestalt.provider.v1.AgentToolConfig`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentToolConfig {
    /// The `source` oneof; None when unset.
    pub source: Option<AgentToolConfigSource>,
}

/// Values of the `output` oneof in `AgentTurn`; the message field is None when unset.
#[allow(clippy::enum_variant_names, clippy::large_enum_variant)]
#[derive(Clone, Debug, PartialEq)]
pub enum AgentTurnOutput {
    /// The `text` variant.
    Text(AgentTurnTextOutput),
    /// The `structured` variant.
    Structured(AgentTurnStructuredOutput),
}

/// Native message type for `gestalt.provider.v1.AgentTurn`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentTurn {
    /// The `id` field.
    pub id: String,
    /// The `session_id` field.
    pub session_id: String,
    /// The `provider_name` field.
    pub provider_name: String,
    /// The `model` field.
    pub model: String,
    /// The `status` field.
    pub status: AgentExecutionStatus,
    /// The `messages` field.
    pub messages: Vec<AgentMessage>,
    /// The `status_message` field.
    pub status_message: String,
    /// The `created_by_subject_id` field.
    pub created_by_subject_id: String,
    /// The `created_at` field; None when unset.
    pub created_at: Option<std::time::SystemTime>,
    /// The `started_at` field; None when unset.
    pub started_at: Option<std::time::SystemTime>,
    /// The `completed_at` field; None when unset.
    pub completed_at: Option<std::time::SystemTime>,
    /// The `execution_ref` field.
    pub execution_ref: String,
    /// The `output` oneof; None when unset.
    pub output: Option<AgentTurnOutput>,
}

/// Native message type for `gestalt.provider.v1.AgentTurnDisplay`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentTurnDisplay {
    /// The `kind` field.
    pub kind: String,
    /// The `phase` field.
    pub phase: String,
    /// The `text` field.
    pub text: String,
    /// The `label` field.
    pub label: String,
    /// The `ref` field.
    pub r#ref: String,
    /// The `parent_ref` field.
    pub parent_ref: String,
    /// The `input` field; None when unset.
    pub input: Option<serde_json::Value>,
    /// The `output` field; None when unset.
    pub output: Option<serde_json::Value>,
    /// The `error` field; None when unset.
    pub error: Option<serde_json::Value>,
    /// The `action` field.
    pub action: String,
    /// The `format` field.
    pub format: String,
    /// The `language` field.
    pub language: String,
}

/// Native message type for `gestalt.provider.v1.AgentTurnEvent`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentTurnEvent {
    /// The `id` field.
    pub id: String,
    /// The `turn_id` field.
    pub turn_id: String,
    /// The `seq` field.
    pub seq: i64,
    /// The `type` field.
    pub r#type: String,
    /// The `source` field.
    pub source: String,
    /// The `visibility` field.
    pub visibility: String,
    /// The `data` field; None when unset.
    pub data: Option<serde_json::Map<String, serde_json::Value>>,
    /// The `created_at` field; None when unset.
    pub created_at: Option<std::time::SystemTime>,
    /// The `display` field; None when unset.
    pub display: Option<AgentTurnDisplay>,
}

/// Native message type for `gestalt.provider.v1.AgentTurnStructuredOutput`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentTurnStructuredOutput {
    /// The `text` field.
    pub text: String,
    /// The `value` field; None when unset.
    pub value: Option<serde_json::Map<String, serde_json::Value>>,
}

/// Native message type for `gestalt.provider.v1.AgentTurnTextOutput`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentTurnTextOutput {
    /// The `text` field.
    pub text: String,
}

/// Native message type for `gestalt.provider.v1.AgentWorkspace`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentWorkspace {
    /// The `checkouts` field.
    pub checkouts: Vec<AgentWorkspaceGitCheckout>,
    /// The `cwd` field.
    pub cwd: String,
}

/// Native message type for `gestalt.provider.v1.AgentWorkspaceGitCheckout`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct AgentWorkspaceGitCheckout {
    /// The `url` field.
    pub url: String,
    /// The `ref` field.
    pub r#ref: String,
    /// The `path` field.
    pub path: String,
}

/// Native message type for `gestalt.provider.v1.CancelAgentProviderTurnRequest`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct CancelAgentProviderTurnRequest {
    /// The `turn_id` field.
    pub turn_id: String,
    /// The `reason` field.
    pub reason: String,
    /// The `subject` field; None when unset.
    pub subject: Option<SubjectContext>,
    /// The `context` field; None when unset.
    pub context: Option<RequestContext>,
    /// The `provider_name` field.
    pub provider_name: String,
}

/// Native message type for `gestalt.provider.v1.CreateAgentProviderSessionRequest`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct CreateAgentProviderSessionRequest {
    /// The provider mints the session id returned on AgentSession. Creation is
    /// idempotent on idempotency_key scoped per subject (created_by_subject_id):
    /// a replayed key returns the existing session, an empty key always creates.
    /// Idempotency is scoped to the provider's session store.
    ///
    /// The `idempotency_key` field.
    pub idempotency_key: String,
    /// The `model` field.
    pub model: String,
    /// The `client_ref` field.
    pub client_ref: String,
    /// The `metadata` field; None when unset.
    pub metadata: Option<serde_json::Map<String, serde_json::Value>>,
    /// The `created_by_subject_id` field.
    pub created_by_subject_id: String,
    /// The `subject` field; None when unset.
    pub subject: Option<SubjectContext>,
    /// The `session_start` field; None when unset.
    pub session_start: Option<AgentSessionStartConfig>,
    /// The `prepared_workspace` field; None when unset.
    pub prepared_workspace: Option<PreparedAgentWorkspace>,
    /// The `provider_name` field.
    pub provider_name: String,
    /// The `workspace` field; None when unset.
    pub workspace: Option<AgentWorkspace>,
    /// The `context` field; None when unset.
    pub context: Option<RequestContext>,
    /// The `tools` field; None when unset.
    pub tools: Option<AgentToolConfig>,
}

/// Native message type for `gestalt.provider.v1.CreateAgentProviderTurnRequest`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct CreateAgentProviderTurnRequest {
    /// The `turn_id` field.
    pub turn_id: String,
    /// The `session_id` field.
    pub session_id: String,
    /// The `idempotency_key` field.
    pub idempotency_key: String,
    /// The `model` field.
    pub model: String,
    /// The `messages` field.
    pub messages: Vec<AgentMessage>,
    /// The `metadata` field; None when unset.
    pub metadata: Option<serde_json::Map<String, serde_json::Value>>,
    /// The `created_by_subject_id` field.
    pub created_by_subject_id: String,
    /// The `execution_ref` field.
    pub execution_ref: String,
    /// The `subject` field; None when unset.
    pub subject: Option<SubjectContext>,
    /// The `model_options` field; None when unset.
    pub model_options: Option<serde_json::Map<String, serde_json::Value>>,
    /// Optional provider-owned turn execution budget, in seconds.
    /// If unset or zero, the provider chooses its own execution timeout. This does
    /// not control the CreateTurn RPC deadline.
    ///
    /// The `timeout_seconds` field.
    pub timeout_seconds: i32,
    /// The `output` field; None when unset.
    pub output: Option<AgentOutput>,
    /// The `context` field; None when unset.
    pub context: Option<RequestContext>,
    /// The `provider_name` field.
    pub provider_name: String,
}

/// Native message type for `gestalt.provider.v1.GetAgentProviderCapabilitiesRequest`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct GetAgentProviderCapabilitiesRequest {}

/// Native message type for `gestalt.provider.v1.GetAgentProviderInteractionRequest`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct GetAgentProviderInteractionRequest {
    /// The `interaction_id` field.
    pub interaction_id: String,
    /// The `subject` field; None when unset.
    pub subject: Option<SubjectContext>,
    /// The `context` field; None when unset.
    pub context: Option<RequestContext>,
}

/// Native message type for `gestalt.provider.v1.GetAgentProviderSessionRequest`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct GetAgentProviderSessionRequest {
    /// The `session_id` field.
    pub session_id: String,
    /// The `subject` field; None when unset.
    pub subject: Option<SubjectContext>,
    /// The `context` field; None when unset.
    pub context: Option<RequestContext>,
    /// The `provider_name` field.
    pub provider_name: String,
}

/// Native message type for `gestalt.provider.v1.GetAgentProviderTurnRequest`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct GetAgentProviderTurnRequest {
    /// The `turn_id` field.
    pub turn_id: String,
    /// The `subject` field; None when unset.
    pub subject: Option<SubjectContext>,
    /// The `context` field; None when unset.
    pub context: Option<RequestContext>,
    /// The `provider_name` field.
    pub provider_name: String,
}

/// Native message type for `gestalt.provider.v1.ListAgentProviderInteractionsRequest`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct ListAgentProviderInteractionsRequest {
    /// The `turn_id` field.
    pub turn_id: String,
    /// The `subject` field; None when unset.
    pub subject: Option<SubjectContext>,
    /// The `context` field; None when unset.
    pub context: Option<RequestContext>,
    /// The `provider_name` field.
    pub provider_name: String,
}

/// Native message type for `gestalt.provider.v1.ListAgentProviderInteractionsResponse`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct ListAgentProviderInteractionsResponse {
    /// The `interactions` field.
    pub interactions: Vec<AgentInteraction>,
}

/// Native message type for `gestalt.provider.v1.ListAgentProviderSessionsRequest`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct ListAgentProviderSessionsRequest {
    /// The `subject` field; None when unset.
    pub subject: Option<SubjectContext>,
    /// The `session_ids` field.
    pub session_ids: Vec<String>,
    /// The `state` field.
    pub state: AgentSessionState,
    /// When non-zero and bounded_list_hydration is supported, cap results after
    /// ordering sessions newest-first by last_turn_at, updated_at, then created_at.
    ///
    /// The `limit` field.
    pub limit: i32,
    /// When true and bounded_list_hydration is supported, omit heavy fields such as
    /// metadata unless exact session_ids require direct lookup.
    ///
    /// The `summary_only` field.
    pub summary_only: bool,
    /// The `provider_name` field.
    pub provider_name: String,
    /// The `context` field; None when unset.
    pub context: Option<RequestContext>,
}

/// Native message type for `gestalt.provider.v1.ListAgentProviderSessionsResponse`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct ListAgentProviderSessionsResponse {
    /// The `sessions` field.
    pub sessions: Vec<AgentSession>,
}

/// Native message type for `gestalt.provider.v1.ListAgentProviderTurnEventsRequest`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct ListAgentProviderTurnEventsRequest {
    /// The `turn_id` field.
    pub turn_id: String,
    /// The `after_seq` field.
    pub after_seq: i64,
    /// The `limit` field.
    pub limit: i32,
    /// The `subject` field; None when unset.
    pub subject: Option<SubjectContext>,
    /// The `context` field; None when unset.
    pub context: Option<RequestContext>,
    /// The `provider_name` field.
    pub provider_name: String,
}

/// Native message type for `gestalt.provider.v1.ListAgentProviderTurnEventsResponse`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct ListAgentProviderTurnEventsResponse {
    /// The `events` field.
    pub events: Vec<AgentTurnEvent>,
}

/// Native message type for `gestalt.provider.v1.ListAgentProviderTurnsRequest`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct ListAgentProviderTurnsRequest {
    /// The `session_id` field.
    pub session_id: String,
    /// The `subject` field; None when unset.
    pub subject: Option<SubjectContext>,
    /// The `turn_ids` field.
    pub turn_ids: Vec<String>,
    /// The `status` field.
    pub status: AgentExecutionStatus,
    /// When non-zero and bounded_list_hydration is supported, cap results after
    /// ordering turns newest-first by created_at.
    ///
    /// The `limit` field.
    pub limit: i32,
    /// When true and bounded_list_hydration is supported, omit heavy fields such as
    /// messages, output text, and structured output unless exact turn_ids require
    /// direct lookup.
    ///
    /// The `summary_only` field.
    pub summary_only: bool,
    /// The `context` field; None when unset.
    pub context: Option<RequestContext>,
    /// The `provider_name` field.
    pub provider_name: String,
}

/// Native message type for `gestalt.provider.v1.ListAgentProviderTurnsResponse`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct ListAgentProviderTurnsResponse {
    /// The `turns` field.
    pub turns: Vec<AgentTurn>,
}

/// Native message type for `gestalt.provider.v1.ListedAgentTool`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct ListedAgentTool {
    /// The `id` field.
    pub id: String,
    /// The `mcp_name` field.
    pub mcp_name: String,
    /// The `title` field.
    pub title: String,
    /// The `description` field.
    pub description: String,
    /// The `input_schema` field.
    pub input_schema: String,
    /// The `output_schema` field.
    pub output_schema: String,
    /// The `annotations` field; None when unset.
    pub annotations: Option<OperationAnnotations>,
    /// The `ref` field; None when unset.
    pub r#ref: Option<AgentToolRef>,
    /// The `tags` field.
    pub tags: Vec<String>,
    /// The `search_text` field.
    pub search_text: String,
}

/// Native message type for `gestalt.provider.v1.PreparedAgentWorkspace`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct PreparedAgentWorkspace {
    /// The `root` field.
    pub root: String,
    /// The `cwd` field.
    pub cwd: String,
}

/// Native message type for `gestalt.provider.v1.ResolveAgentProviderInteractionRequest`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct ResolveAgentProviderInteractionRequest {
    /// The `interaction_id` field.
    pub interaction_id: String,
    /// The `resolution` field; None when unset.
    pub resolution: Option<serde_json::Map<String, serde_json::Value>>,
    /// The `subject` field; None when unset.
    pub subject: Option<SubjectContext>,
    /// The `turn_id` field.
    pub turn_id: String,
    /// The `context` field; None when unset.
    pub context: Option<RequestContext>,
    /// The `provider_name` field.
    pub provider_name: String,
}

/// Native message type for `gestalt.provider.v1.UpdateAgentProviderSessionRequest`.
#[derive(Clone, Debug, Default, PartialEq)]
pub struct UpdateAgentProviderSessionRequest {
    /// The `session_id` field.
    pub session_id: String,
    /// The `client_ref` field.
    pub client_ref: String,
    /// The `state` field.
    pub state: AgentSessionState,
    /// The `metadata` field; None when unset.
    pub metadata: Option<serde_json::Map<String, serde_json::Value>>,
    /// The `subject` field; None when unset.
    pub subject: Option<SubjectContext>,
    /// The `context` field; None when unset.
    pub context: Option<RequestContext>,
    /// The `provider_name` field.
    pub provider_name: String,
}

/// Agent is the authoritative agent data boundary. Read RPCs for
/// sessions, turns, turn events, and interactions should use provider-owned
/// control-plane state and should not require a live execution sandbox,
/// pod-level transport, or cached tunnel.
///
/// Client for the `gestalt.provider.v1.Agent` service.
pub struct Agent {
    inner: v1::agent_client::AgentClient<HostServiceChannel>,
    timeout: Option<std::time::Duration>,
    context: Option<RequestContext>,
}

impl Agent {
    /// Creates a client over an established channel.
    pub fn new(channel: tonic::transport::Channel) -> Self {
        Self {
            inner: v1::agent_client::AgentClient::new(plain_channel(channel)),
            timeout: None,
            context: None,
        }
    }

    /// Sets a deadline applied to every unary call; calls that run past it
    /// fail with DEADLINE_EXCEEDED. Streaming calls are unaffected.
    pub fn with_timeout(mut self, timeout: std::time::Duration) -> Self {
        self.timeout = Some(timeout);
        self
    }

    /// Sets the default request context, injected into outgoing requests
    /// that do not carry one.
    pub fn with_context(mut self, context: RequestContext) -> Self {
        self.context = Some(context);
        self
    }

    /// Connects to the `agent` host service described by the environment.
    pub async fn connect() -> Result<Self, GestaltError> {
        Self::connect_named("").await
    }

    /// Connects to the named `agent` host-service binding.
    pub async fn connect_named(name: &str) -> Result<Self, GestaltError> {
        Ok(Self {
            inner: v1::agent_client::AgentClient::new(connect_host_service("agent", name).await?),
            timeout: None,
            context: None,
        })
    }

    /// Calls `gestalt.provider.v1.Agent.CreateSession`.
    pub async fn create_session(
        &mut self,
        idempotency_key: String,
        model: String,
        options: AgentCreateSessionOptions,
    ) -> Result<AgentSession, GestaltError> {
        let request = CreateAgentProviderSessionRequest {
            idempotency_key,
            model,
            provider_name: options.provider_name,
            client_ref: options.client_ref,
            metadata: options.metadata,
            workspace: options.workspace,
            tools: options.tools,
            context: self.context.clone(),
            ..Default::default()
        };
        let mut tonic_request =
            tonic::Request::new(to_wire_create_agent_provider_session_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.create_session(tonic_request).await?;
        Ok(from_wire_agent_session(response.into_inner()))
    }

    /// Calls `gestalt.provider.v1.Agent.CreateSession` with the full request and response messages.
    pub async fn create_session_raw(
        &mut self,
        request: CreateAgentProviderSessionRequest,
    ) -> Result<AgentSession, GestaltError> {
        let mut request = request;
        if request.context.is_none() {
            request.context = self.context.clone();
        }
        let mut tonic_request =
            tonic::Request::new(to_wire_create_agent_provider_session_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.create_session(tonic_request).await?;
        Ok(from_wire_agent_session(response.into_inner()))
    }

    /// Calls `gestalt.provider.v1.Agent.GetSession`.
    pub async fn get_session(
        &mut self,
        session_id: String,
        options: AgentGetSessionOptions,
    ) -> Result<AgentSession, GestaltError> {
        let request = GetAgentProviderSessionRequest {
            session_id,
            provider_name: options.provider_name,
            context: self.context.clone(),
            ..Default::default()
        };
        let mut tonic_request =
            tonic::Request::new(to_wire_get_agent_provider_session_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.get_session(tonic_request).await?;
        Ok(from_wire_agent_session(response.into_inner()))
    }

    /// Calls `gestalt.provider.v1.Agent.GetSession` with the full request and response messages.
    pub async fn get_session_raw(
        &mut self,
        request: GetAgentProviderSessionRequest,
    ) -> Result<AgentSession, GestaltError> {
        let mut request = request;
        if request.context.is_none() {
            request.context = self.context.clone();
        }
        let mut tonic_request =
            tonic::Request::new(to_wire_get_agent_provider_session_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.get_session(tonic_request).await?;
        Ok(from_wire_agent_session(response.into_inner()))
    }

    /// Calls `gestalt.provider.v1.Agent.ListSessions`.
    pub async fn list_sessions(
        &mut self,
        options: AgentListSessionsOptions,
    ) -> Result<Vec<AgentSession>, GestaltError> {
        let request = ListAgentProviderSessionsRequest {
            session_ids: options.session_ids,
            state: options.state,
            limit: options.limit,
            summary_only: options.summary_only,
            provider_name: options.provider_name,
            context: self.context.clone(),
            ..Default::default()
        };
        let mut tonic_request =
            tonic::Request::new(to_wire_list_agent_provider_sessions_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = from_wire_list_agent_provider_sessions_response(
            self.inner.list_sessions(tonic_request).await?.into_inner(),
        );
        Ok(response.sessions)
    }

    /// Calls `gestalt.provider.v1.Agent.ListSessions` with the full request and response messages.
    pub async fn list_sessions_raw(
        &mut self,
        request: ListAgentProviderSessionsRequest,
    ) -> Result<ListAgentProviderSessionsResponse, GestaltError> {
        let mut request = request;
        if request.context.is_none() {
            request.context = self.context.clone();
        }
        let mut tonic_request =
            tonic::Request::new(to_wire_list_agent_provider_sessions_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.list_sessions(tonic_request).await?;
        Ok(from_wire_list_agent_provider_sessions_response(
            response.into_inner(),
        ))
    }

    /// Calls `gestalt.provider.v1.Agent.UpdateSession`.
    pub async fn update_session(
        &mut self,
        session_id: String,
        options: AgentUpdateSessionOptions,
    ) -> Result<AgentSession, GestaltError> {
        let request = UpdateAgentProviderSessionRequest {
            session_id,
            client_ref: options.client_ref,
            state: options.state,
            provider_name: options.provider_name,
            metadata: options.metadata,
            context: self.context.clone(),
            ..Default::default()
        };
        let mut tonic_request =
            tonic::Request::new(to_wire_update_agent_provider_session_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.update_session(tonic_request).await?;
        Ok(from_wire_agent_session(response.into_inner()))
    }

    /// Calls `gestalt.provider.v1.Agent.UpdateSession` with the full request and response messages.
    pub async fn update_session_raw(
        &mut self,
        request: UpdateAgentProviderSessionRequest,
    ) -> Result<AgentSession, GestaltError> {
        let mut request = request;
        if request.context.is_none() {
            request.context = self.context.clone();
        }
        let mut tonic_request =
            tonic::Request::new(to_wire_update_agent_provider_session_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.update_session(tonic_request).await?;
        Ok(from_wire_agent_session(response.into_inner()))
    }

    /// Calls `gestalt.provider.v1.Agent.CreateTurn`.
    pub async fn create_turn(
        &mut self,
        session_id: String,
        idempotency_key: String,
        model: String,
        messages: Vec<AgentMessage>,
        options: AgentCreateTurnOptions,
    ) -> Result<AgentTurn, GestaltError> {
        let request = CreateAgentProviderTurnRequest {
            session_id,
            idempotency_key,
            model,
            messages,
            execution_ref: options.execution_ref,
            timeout_seconds: options.timeout_seconds,
            provider_name: options.provider_name,
            metadata: options.metadata,
            model_options: options.model_options,
            output: options.output,
            context: self.context.clone(),
            ..Default::default()
        };
        let mut tonic_request =
            tonic::Request::new(to_wire_create_agent_provider_turn_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.create_turn(tonic_request).await?;
        Ok(from_wire_agent_turn(response.into_inner()))
    }

    /// Calls `gestalt.provider.v1.Agent.CreateTurn` with the full request and response messages.
    pub async fn create_turn_raw(
        &mut self,
        request: CreateAgentProviderTurnRequest,
    ) -> Result<AgentTurn, GestaltError> {
        let mut request = request;
        if request.context.is_none() {
            request.context = self.context.clone();
        }
        let mut tonic_request =
            tonic::Request::new(to_wire_create_agent_provider_turn_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.create_turn(tonic_request).await?;
        Ok(from_wire_agent_turn(response.into_inner()))
    }

    /// Calls `gestalt.provider.v1.Agent.GetTurn`.
    pub async fn get_turn(
        &mut self,
        turn_id: String,
        options: AgentGetTurnOptions,
    ) -> Result<AgentTurn, GestaltError> {
        let request = GetAgentProviderTurnRequest {
            turn_id,
            provider_name: options.provider_name,
            context: self.context.clone(),
            ..Default::default()
        };
        let mut tonic_request =
            tonic::Request::new(to_wire_get_agent_provider_turn_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.get_turn(tonic_request).await?;
        Ok(from_wire_agent_turn(response.into_inner()))
    }

    /// Calls `gestalt.provider.v1.Agent.GetTurn` with the full request and response messages.
    pub async fn get_turn_raw(
        &mut self,
        request: GetAgentProviderTurnRequest,
    ) -> Result<AgentTurn, GestaltError> {
        let mut request = request;
        if request.context.is_none() {
            request.context = self.context.clone();
        }
        let mut tonic_request =
            tonic::Request::new(to_wire_get_agent_provider_turn_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.get_turn(tonic_request).await?;
        Ok(from_wire_agent_turn(response.into_inner()))
    }

    /// Calls `gestalt.provider.v1.Agent.ListTurns`.
    pub async fn list_turns(
        &mut self,
        session_id: String,
        options: AgentListTurnsOptions,
    ) -> Result<Vec<AgentTurn>, GestaltError> {
        let request = ListAgentProviderTurnsRequest {
            session_id,
            turn_ids: options.turn_ids,
            status: options.status,
            limit: options.limit,
            summary_only: options.summary_only,
            provider_name: options.provider_name,
            context: self.context.clone(),
            ..Default::default()
        };
        let mut tonic_request =
            tonic::Request::new(to_wire_list_agent_provider_turns_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = from_wire_list_agent_provider_turns_response(
            self.inner.list_turns(tonic_request).await?.into_inner(),
        );
        Ok(response.turns)
    }

    /// Calls `gestalt.provider.v1.Agent.ListTurns` with the full request and response messages.
    pub async fn list_turns_raw(
        &mut self,
        request: ListAgentProviderTurnsRequest,
    ) -> Result<ListAgentProviderTurnsResponse, GestaltError> {
        let mut request = request;
        if request.context.is_none() {
            request.context = self.context.clone();
        }
        let mut tonic_request =
            tonic::Request::new(to_wire_list_agent_provider_turns_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.list_turns(tonic_request).await?;
        Ok(from_wire_list_agent_provider_turns_response(
            response.into_inner(),
        ))
    }

    /// Calls `gestalt.provider.v1.Agent.CancelTurn`.
    pub async fn cancel_turn(
        &mut self,
        turn_id: String,
        options: AgentCancelTurnOptions,
    ) -> Result<AgentTurn, GestaltError> {
        let request = CancelAgentProviderTurnRequest {
            turn_id,
            reason: options.reason,
            provider_name: options.provider_name,
            context: self.context.clone(),
            ..Default::default()
        };
        let mut tonic_request =
            tonic::Request::new(to_wire_cancel_agent_provider_turn_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.cancel_turn(tonic_request).await?;
        Ok(from_wire_agent_turn(response.into_inner()))
    }

    /// Calls `gestalt.provider.v1.Agent.CancelTurn` with the full request and response messages.
    pub async fn cancel_turn_raw(
        &mut self,
        request: CancelAgentProviderTurnRequest,
    ) -> Result<AgentTurn, GestaltError> {
        let mut request = request;
        if request.context.is_none() {
            request.context = self.context.clone();
        }
        let mut tonic_request =
            tonic::Request::new(to_wire_cancel_agent_provider_turn_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.cancel_turn(tonic_request).await?;
        Ok(from_wire_agent_turn(response.into_inner()))
    }

    /// Calls `gestalt.provider.v1.Agent.ListTurnEvents`.
    pub async fn list_turn_events(
        &mut self,
        turn_id: String,
        options: AgentListTurnEventsOptions,
    ) -> Result<Vec<AgentTurnEvent>, GestaltError> {
        let request = ListAgentProviderTurnEventsRequest {
            turn_id,
            after_seq: options.after_seq,
            limit: options.limit,
            provider_name: options.provider_name,
            context: self.context.clone(),
            ..Default::default()
        };
        let mut tonic_request =
            tonic::Request::new(to_wire_list_agent_provider_turn_events_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = from_wire_list_agent_provider_turn_events_response(
            self.inner
                .list_turn_events(tonic_request)
                .await?
                .into_inner(),
        );
        Ok(response.events)
    }

    /// Calls `gestalt.provider.v1.Agent.ListTurnEvents` with the full request and response messages.
    pub async fn list_turn_events_raw(
        &mut self,
        request: ListAgentProviderTurnEventsRequest,
    ) -> Result<ListAgentProviderTurnEventsResponse, GestaltError> {
        let mut request = request;
        if request.context.is_none() {
            request.context = self.context.clone();
        }
        let mut tonic_request =
            tonic::Request::new(to_wire_list_agent_provider_turn_events_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.list_turn_events(tonic_request).await?;
        Ok(from_wire_list_agent_provider_turn_events_response(
            response.into_inner(),
        ))
    }

    /// Calls `gestalt.provider.v1.Agent.GetInteraction`.
    pub async fn get_interaction(
        &mut self,
        interaction_id: String,
    ) -> Result<AgentInteraction, GestaltError> {
        let request = GetAgentProviderInteractionRequest {
            interaction_id,
            context: self.context.clone(),
            ..Default::default()
        };
        let mut tonic_request =
            tonic::Request::new(to_wire_get_agent_provider_interaction_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.get_interaction(tonic_request).await?;
        Ok(from_wire_agent_interaction(response.into_inner()))
    }

    /// Calls `gestalt.provider.v1.Agent.GetInteraction` with the full request and response messages.
    pub async fn get_interaction_raw(
        &mut self,
        request: GetAgentProviderInteractionRequest,
    ) -> Result<AgentInteraction, GestaltError> {
        let mut request = request;
        if request.context.is_none() {
            request.context = self.context.clone();
        }
        let mut tonic_request =
            tonic::Request::new(to_wire_get_agent_provider_interaction_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.get_interaction(tonic_request).await?;
        Ok(from_wire_agent_interaction(response.into_inner()))
    }

    /// Calls `gestalt.provider.v1.Agent.ListInteractions`.
    pub async fn list_interactions(
        &mut self,
        turn_id: String,
        options: AgentListInteractionsOptions,
    ) -> Result<Vec<AgentInteraction>, GestaltError> {
        let request = ListAgentProviderInteractionsRequest {
            turn_id,
            provider_name: options.provider_name,
            context: self.context.clone(),
            ..Default::default()
        };
        let mut tonic_request =
            tonic::Request::new(to_wire_list_agent_provider_interactions_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = from_wire_list_agent_provider_interactions_response(
            self.inner
                .list_interactions(tonic_request)
                .await?
                .into_inner(),
        );
        Ok(response.interactions)
    }

    /// Calls `gestalt.provider.v1.Agent.ListInteractions` with the full request and response messages.
    pub async fn list_interactions_raw(
        &mut self,
        request: ListAgentProviderInteractionsRequest,
    ) -> Result<ListAgentProviderInteractionsResponse, GestaltError> {
        let mut request = request;
        if request.context.is_none() {
            request.context = self.context.clone();
        }
        let mut tonic_request =
            tonic::Request::new(to_wire_list_agent_provider_interactions_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.list_interactions(tonic_request).await?;
        Ok(from_wire_list_agent_provider_interactions_response(
            response.into_inner(),
        ))
    }

    /// Calls `gestalt.provider.v1.Agent.ResolveInteraction`.
    pub async fn resolve_interaction(
        &mut self,
        interaction_id: String,
        resolution: Option<serde_json::Map<String, serde_json::Value>>,
        options: AgentResolveInteractionOptions,
    ) -> Result<AgentInteraction, GestaltError> {
        let request = ResolveAgentProviderInteractionRequest {
            interaction_id,
            resolution,
            turn_id: options.turn_id,
            provider_name: options.provider_name,
            context: self.context.clone(),
            ..Default::default()
        };
        let mut tonic_request =
            tonic::Request::new(to_wire_resolve_agent_provider_interaction_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.resolve_interaction(tonic_request).await?;
        Ok(from_wire_agent_interaction(response.into_inner()))
    }

    /// Calls `gestalt.provider.v1.Agent.ResolveInteraction` with the full request and response messages.
    pub async fn resolve_interaction_raw(
        &mut self,
        request: ResolveAgentProviderInteractionRequest,
    ) -> Result<AgentInteraction, GestaltError> {
        let mut request = request;
        if request.context.is_none() {
            request.context = self.context.clone();
        }
        let mut tonic_request =
            tonic::Request::new(to_wire_resolve_agent_provider_interaction_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.resolve_interaction(tonic_request).await?;
        Ok(from_wire_agent_interaction(response.into_inner()))
    }

    /// Calls `gestalt.provider.v1.Agent.GetCapabilities`.
    pub async fn get_capabilities(
        &mut self,
        request: GetAgentProviderCapabilitiesRequest,
    ) -> Result<AgentProviderCapabilities, GestaltError> {
        let mut tonic_request =
            tonic::Request::new(to_wire_get_agent_provider_capabilities_request(request));
        if let Some(timeout) = self.timeout {
            tonic_request.set_timeout(timeout);
        }
        let response = self.inner.get_capabilities(tonic_request).await?;
        Ok(from_wire_agent_provider_capabilities(response.into_inner()))
    }
}

/// Optional parameters of [`Agent::create_session`]; the default value leaves every
/// option unset.
#[derive(Clone, Debug, Default)]
pub struct AgentCreateSessionOptions {
    /// The `provider_name` field.
    pub provider_name: String,
    /// The `client_ref` field.
    pub client_ref: String,
    /// The `metadata` field; None when unset.
    pub metadata: Option<serde_json::Map<String, serde_json::Value>>,
    /// The `workspace` field; None when unset.
    pub workspace: Option<AgentWorkspace>,
    /// The `tools` field; None when unset.
    pub tools: Option<AgentToolConfig>,
}

/// Optional parameters of [`Agent::get_session`]; the default value leaves every
/// option unset.
#[derive(Clone, Debug, Default)]
pub struct AgentGetSessionOptions {
    /// The `provider_name` field.
    pub provider_name: String,
}

/// Optional parameters of [`Agent::list_sessions`]; the default value leaves every
/// option unset.
#[derive(Clone, Debug, Default)]
pub struct AgentListSessionsOptions {
    /// The `session_ids` field.
    pub session_ids: Vec<String>,
    /// The `state` field.
    pub state: AgentSessionState,
    /// When non-zero and bounded_list_hydration is supported, cap results after
    /// ordering sessions newest-first by last_turn_at, updated_at, then created_at.
    ///
    /// The `limit` field.
    pub limit: i32,
    /// When true and bounded_list_hydration is supported, omit heavy fields such as
    /// metadata unless exact session_ids require direct lookup.
    ///
    /// The `summary_only` field.
    pub summary_only: bool,
    /// The `provider_name` field.
    pub provider_name: String,
}

/// Optional parameters of [`Agent::update_session`]; the default value leaves every
/// option unset.
#[derive(Clone, Debug, Default)]
pub struct AgentUpdateSessionOptions {
    /// The `client_ref` field.
    pub client_ref: String,
    /// The `state` field.
    pub state: AgentSessionState,
    /// The `provider_name` field.
    pub provider_name: String,
    /// The `metadata` field; None when unset.
    pub metadata: Option<serde_json::Map<String, serde_json::Value>>,
}

/// Optional parameters of [`Agent::create_turn`]; the default value leaves every
/// option unset.
#[derive(Clone, Debug, Default)]
pub struct AgentCreateTurnOptions {
    /// The `execution_ref` field.
    pub execution_ref: String,
    /// Optional provider-owned turn execution budget, in seconds.
    /// If unset or zero, the provider chooses its own execution timeout. This does
    /// not control the CreateTurn RPC deadline.
    ///
    /// The `timeout_seconds` field.
    pub timeout_seconds: i32,
    /// The `provider_name` field.
    pub provider_name: String,
    /// The `metadata` field; None when unset.
    pub metadata: Option<serde_json::Map<String, serde_json::Value>>,
    /// The `model_options` field; None when unset.
    pub model_options: Option<serde_json::Map<String, serde_json::Value>>,
    /// The `output` field; None when unset.
    pub output: Option<AgentOutput>,
}

/// Optional parameters of [`Agent::get_turn`]; the default value leaves every
/// option unset.
#[derive(Clone, Debug, Default)]
pub struct AgentGetTurnOptions {
    /// The `provider_name` field.
    pub provider_name: String,
}

/// Optional parameters of [`Agent::list_turns`]; the default value leaves every
/// option unset.
#[derive(Clone, Debug, Default)]
pub struct AgentListTurnsOptions {
    /// The `turn_ids` field.
    pub turn_ids: Vec<String>,
    /// The `status` field.
    pub status: AgentExecutionStatus,
    /// When non-zero and bounded_list_hydration is supported, cap results after
    /// ordering turns newest-first by created_at.
    ///
    /// The `limit` field.
    pub limit: i32,
    /// When true and bounded_list_hydration is supported, omit heavy fields such as
    /// messages, output text, and structured output unless exact turn_ids require
    /// direct lookup.
    ///
    /// The `summary_only` field.
    pub summary_only: bool,
    /// The `provider_name` field.
    pub provider_name: String,
}

/// Optional parameters of [`Agent::cancel_turn`]; the default value leaves every
/// option unset.
#[derive(Clone, Debug, Default)]
pub struct AgentCancelTurnOptions {
    /// The `reason` field.
    pub reason: String,
    /// The `provider_name` field.
    pub provider_name: String,
}

/// Optional parameters of [`Agent::list_turn_events`]; the default value leaves every
/// option unset.
#[derive(Clone, Debug, Default)]
pub struct AgentListTurnEventsOptions {
    /// The `after_seq` field.
    pub after_seq: i64,
    /// The `limit` field.
    pub limit: i32,
    /// The `provider_name` field.
    pub provider_name: String,
}

/// Optional parameters of [`Agent::list_interactions`]; the default value leaves every
/// option unset.
#[derive(Clone, Debug, Default)]
pub struct AgentListInteractionsOptions {
    /// The `provider_name` field.
    pub provider_name: String,
}

/// Optional parameters of [`Agent::resolve_interaction`]; the default value leaves every
/// option unset.
#[derive(Clone, Debug, Default)]
pub struct AgentResolveInteractionOptions {
    /// The `turn_id` field.
    pub turn_id: String,
    /// The `provider_name` field.
    pub provider_name: String,
}