Struct AgentSessionState 

pub struct AgentSessionState {

    pub session_id: String,
    pub conversation: Vec<Content>,
    pub messages: Vec<Message>,
    pub stats: SessionStats,
    pub constraints: SessionConstraints,
    pub outcome: TaskOutcome,
    pub stop_reason: Option<String>,
    pub total_cost_usd: Option<f64>,
    pub is_completed: bool,
    pub current_stage: Option<String>,
    pub created_contexts: Vec<String>,
    pub modified_files: Vec<String>,
    pub executed_commands: Vec<String>,
    pub warnings: Vec<String>,
    pub last_file_path: Option<String>,
    pub last_dir_path: Option<String>,
    pub consecutive_tool_loops: usize,
    pub tool_loop_limit_hit: bool,
    pub last_processed_message_idx: usize,
    pub previous_response_chains: HashMap<(String, String), ResponsesContinuationState>,
    pub error_recovery: Arc<Mutex<ErrorRecoveryState>>,
    pub consecutive_idle_turns: usize,
    pub max_tool_loop_streak: usize,
    pub turn_count: usize,
    pub turn_total_ms: u128,
    pub turn_max_ms: u128,
    pub turn_durations_ms: Vec<u128>,
}

Manages the state of an active agent session, including conversation history, statistics, and turn-based constraints.

Fields

session_id: String

The thread or session ID.

conversation: Vec<Content>

Provider-specific conversation history (e.g., Gemini style).

messages: Vec<Message>

Standardized conversation messages (OpenAI/Anthropic style).

stats: SessionStats

Statistics for the current session.

constraints: SessionConstraints

Constraints and limits for the session.

outcome: TaskOutcome

Outcome of the session if completed.

stop_reason: Option<String>

Provider stop reason associated with the last model turn, when available.

total_cost_usd: Option<f64>

Estimated total API cost in USD for the session, when available.

is_completed: bool

Whether the session has completed.

current_stage: Option<String>

Current reasoning stage.

created_contexts: Vec<String>

modified_files: Vec<String>

executed_commands: Vec<String>

warnings: Vec<String>

last_file_path: Option<String>

last_dir_path: Option<String>

consecutive_tool_loops: usize

tool_loop_limit_hit: bool

last_processed_message_idx: usize

previous_response_chains: HashMap<(String, String), ResponsesContinuationState>

Responses-style continuation state keyed by normalized provider/model pairs.

error_recovery: Arc<Mutex<ErrorRecoveryState>>

Agent-local recent error diagnostics for interrupted or repeated tool failures.

consecutive_idle_turns: usize

max_tool_loop_streak: usize

turn_count: usize

turn_total_ms: u128

turn_max_ms: u128

turn_durations_ms: Vec<u128>

Implementations

impl AgentSessionState

pub fn new( session_id: String, max_turns: usize, max_tool_loops: usize, max_context_tokens: usize, ) -> Self

pub fn record_turn(&mut self, start: &Instant, recorded: &mut bool)

Record a completed turn.

pub fn finalize_outcome(&mut self, max_turns: usize)

pub fn register_tool_loop(&mut self) -> usize

pub fn reset_tool_loop_guard(&mut self)

pub fn previous_response_id_for( &self, provider: &str, model: &str, ) -> Option<String>

pub fn previous_response_chain_for( &self, provider: &str, model: &str, ) -> Option<&ResponsesContinuationState>

pub fn set_previous_response_chain( &mut self, provider: &str, model: &str, response_id: Option<&str>, messages: Vec<Message>, )

pub fn clear_previous_response_chain_for(&mut self, provider: &str, model: &str)

pub fn clear_previous_response_chain(&mut self)

pub fn mark_tool_loop_limit_hit(&mut self)

pub fn add_user_message(&mut self, text: String)

Add a user message to the history.

pub fn utilization(&self) -> f64

Check if context limits are approaching.

pub fn total_tokens(&self) -> usize

Calculate total estimated tokens in the conversation.

pub fn find_safe_split_point(&self, preferred_split_at: usize) -> usize

Find a safe split point for history trimming that doesn’t break tool call/output pairs.

pub fn normalize(&mut self)

Normalize history to enforce call/output pairing invariants.

pub fn into_results( self, summary: String, thread_events: Vec<ThreadEvent>, total_duration_ms: u128, ) -> TaskResults

pub fn push_tool_result( &mut self, call_id: String, tool_name: &str, result: &Value, is_gemini: bool, )

Push a successful tool result to both conversation (for Gemini) and messages.

Accepts a &Value to avoid redundant serialize/deserialize cycles for Gemini providers — the value is used directly in FunctionResponse instead of being serialized to a string and then re-parsed.

pub fn push_tool_error( &mut self, call_id: String, tool_name: &str, error_payload: &Value, is_gemini: bool, )

Push a tool error to both conversation (for Gemini) and messages.

Accepts a &Value to avoid redundant serialize/deserialize cycles for Gemini providers.