Struct AgentSession 

pub struct AgentSession {

    pub id: SessionId,
    pub user_id: [u8; 8],
    pub messages: Vec<Message>,
    pub capabilities: Arc<CapabilityStore>,
    pub allowance_store: Arc<AllowanceStore>,
    pub approval_manager: Arc<ApprovalManager>,
    pub system_prompt: String,
    pub created_at: DateTime<Utc>,
    pub token_count: usize,
    pub metadata: SessionMetadata,
    pub escape_handler: EscapeHandler,
    pub budget_tracker: Arc<BudgetTracker>,
    pub workspace_budget_tracker: Option<Arc<WorkspaceBudgetTracker>>,
    pub workspace_path: Option<PathBuf>,
    pub model: Option<String>,
    pub is_subagent: bool,
    pub capsule_context: Option<String>,
}

An agent session.

Fields

id: SessionId

Unique session identifier.

user_id: [u8; 8]

User identifier (key ID).

messages: Vec<Message>

Conversation messages.

capabilities: Arc<CapabilityStore>

Session capabilities.

allowance_store: Arc<AllowanceStore>

Session allowance store.

approval_manager: Arc<ApprovalManager>

Session approval manager.

system_prompt: String

System prompt.

created_at: DateTime<Utc>

When the session was created.

token_count: usize

Estimated token count.

metadata: SessionMetadata

Session metadata.

escape_handler: EscapeHandler

Workspace escape handler for tracking allowed paths.

budget_tracker: Arc<BudgetTracker>

Per-session budget tracker.

workspace_budget_tracker: Option<Arc<WorkspaceBudgetTracker>>

Workspace cumulative budget tracker (shared across sessions).

workspace_path: Option<PathBuf>

Workspace path this session belongs to (for workspace-scoped listing).

model: Option<String>

Model used for this session (e.g. "claude-sonnet-4-20250514").

is_subagent: bool

Whether this session belongs to a sub-agent (skip spark preamble in run_loop).

capsule_context: Option<String>

Plugin-provided context (fetched dynamically per subagent/session, not persisted).

Implementations

impl AgentSession

pub fn new(user_id: [u8; 8], system_prompt: impl Into<String>) -> Self

Create a new session.

pub fn with_id( id: SessionId, user_id: [u8; 8], system_prompt: impl Into<String>, ) -> Self

Create with a specific session ID.

pub fn with_shared_stores( id: SessionId, user_id: [u8; 8], system_prompt: impl Into<String>, allowance_store: Arc<AllowanceStore>, capabilities: Arc<CapabilityStore>, budget_tracker: Arc<BudgetTracker>, ) -> Self

Create a child session that shares parent’s stores.

The child inherits the parent’s AllowanceStore, CapabilityStore, and BudgetTracker (same Arc — spend is visible bidirectionally). The ApprovalManager and DeferredResolutionStore are fresh (independent handler registration and independent deferred queue).

pub fn with_workspace(self, path: impl Into<PathBuf>) -> Self

Set the workspace path for this session.

pub fn with_model(self, model: impl Into<String>) -> Self

Set the model name for this session.

pub fn with_capability_store(self, store: Arc<CapabilityStore>) -> Self

Replace the capability store with a persistent one.

Call this after session construction when a persistent store is available (e.g. at daemon startup).

pub fn with_workspace_budget(self, tracker: Arc<WorkspaceBudgetTracker>) -> Self

Set the workspace cumulative budget tracker.

pub fn import_workspace_allowances(&self, allowances: Vec<Allowance>)

Import workspace-scoped allowances into this session.

These allowances were previously persisted in the workspace state.db and are loaded when a session is created or resumed in the same workspace.

pub fn export_workspace_allowances(&self) -> Vec<Allowance>

Export workspace-scoped allowances from this session for persistence.

pub async fn with_persistent_deferred_queue( self, store: ScopedKvStore, ) -> Result<Self, RuntimeError>

Replace the deferred resolution queue with a persistent one.

This reconstructs the ApprovalManager with the new persistent queue. Call this after session construction when a persistent store is available.

Errors

Returns an error if the persistent store cannot be initialized.

pub fn add_message(&mut self, message: Message)

Add a message to the session.

pub fn last_messages(&self, n: usize) -> &[Message]

Get the last N messages.

pub fn clear_messages(&mut self)

Clear messages (keeping system prompt).

pub fn duration(&self) -> Duration

Get session duration.

pub fn end_session(&self)

Clean up session-scoped state.

Clears session-only allowances, leaving workspace and persistent ones intact.

pub fn is_near_limit(&self, max_tokens: usize, threshold: f32) -> bool

Check if session is near context limit.

Trait Implementations

impl Debug for AgentSession

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl From<&AgentSession> for SerializableSession

fn from(session: &AgentSession) -> Self

Converts to this type from the input type.