Struct LocalPlatformStore 

pub struct LocalPlatformStore { /* private fields */ }

Local platform store for one (org, session) scope, backed by a LocalSessionRunner.

Implementations

impl LocalPlatformStore

pub fn new( runner: Arc<dyn LocalSessionRunner>, base_url: impl Into<String>, ) -> Self

Trait Implementations

impl Clone for LocalPlatformStore

fn clone(&self) -> LocalPlatformStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl PlatformStore for LocalPlatformStore

fn create_session<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, harness_id: HarnessId, agent_id: Option<AgentId>, title: Option<&'life1 str>, locale: Option<&'life2 str>, blueprint_id: Option<&'life3 str>, _blueprint_config: Option<&'life4 Value>, parent_session_id: Option<SessionId>, ) -> Pin<Box<dyn Future<Output = Result<Session>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Create a new session.

fn get_session_by_id<'life0, 'async_trait>( &'life0 self, id: SessionId, ) -> Pin<Box<dyn Future<Output = Result<Option<Session>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get a session by ID.

fn list_sessions<'life0, 'async_trait>( &'life0 self, limit: Option<usize>, agent_id: Option<AgentId>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Session>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List sessions, optionally filtered by agent.

fn send_message<'life0, 'life1, 'async_trait>( &'life0 self, session_id: SessionId, content: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a user message to a session, triggering a turn.

fn get_messages<'life0, 'async_trait>( &'life0 self, session_id: SessionId, limit: Option<usize>, ) -> Pin<Box<dyn Future<Output = Result<Vec<PlatformMessage>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get messages from a session (most recent first). Default limit is 10.

fn wait_for_idle<'life0, 'async_trait>( &'life0 self, session_id: SessionId, _timeout_secs: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Wait for a session to become idle (turn completed). Returns the final session status as a string. Default timeout is 120 seconds.

fn base_url(&self) -> &str

Base URL for constructing UI links (e.g., “http://localhost:9300”).

fn list_harnesses<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Harness>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all harnesses in the organization.

fn get_harness<'life0, 'async_trait>( &'life0 self, _id: HarnessId, ) -> Pin<Box<dyn Future<Output = Result<Option<Harness>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get a harness by ID.

fn create_harness<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, _name: &'life1 str, _display_name: Option<&'life2 str>, _description: Option<&'life3 str>, _system_prompt: Option<&'life4 str>, _parent_harness_id: Option<HarnessId>, _capabilities: &'life5 [String], ) -> Pin<Box<dyn Future<Output = Result<Harness>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

Create a new harness.

fn update_harness<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, _id: HarnessId, _name: Option<&'life1 str>, _display_name: Option<&'life2 str>, _description: Option<&'life3 str>, _system_prompt: Option<&'life4 str>, _parent_harness_id: Option<Option<HarnessId>>, ) -> Pin<Box<dyn Future<Output = Result<Harness>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Update a harness (only provided fields are changed).

fn delete_harness<'life0, 'async_trait>( &'life0 self, _id: HarnessId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete (archive) a harness.

fn copy_harness<'life0, 'life1, 'async_trait>( &'life0 self, _id: HarnessId, _new_name: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = Result<Harness>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Copy a harness, optionally with a new name.

fn list_agents<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Agent>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all agents in the organization.

fn get_agent_by_id<'life0, 'async_trait>( &'life0 self, _id: AgentId, ) -> Pin<Box<dyn Future<Output = Result<Option<Agent>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get an agent by public ID.

fn create_agent<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, _name: &'life1 str, _display_name: Option<&'life2 str>, _description: Option<&'life3 str>, _system_prompt: &'life4 str, _capabilities: &'life5 [String], ) -> Pin<Box<dyn Future<Output = Result<Agent>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

Create a new agent.

fn update_agent<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, _id: AgentId, _name: Option<&'life1 str>, _display_name: Option<&'life2 str>, _description: Option<&'life3 str>, _system_prompt: Option<&'life4 str>, ) -> Pin<Box<dyn Future<Output = Result<Agent>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Update an agent (only provided fields are changed).

fn delete_agent<'life0, 'async_trait>( &'life0 self, _id: AgentId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete (archive) an agent.

fn list_apps<'life0, 'life1, 'async_trait>( &'life0 self, _search: Option<&'life1 str>, _include_archived: bool, ) -> Pin<Box<dyn Future<Output = Result<Vec<App>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List all apps in the organization.

fn get_app<'life0, 'async_trait>( &'life0 self, _id: AppId, ) -> Pin<Box<dyn Future<Output = Result<Option<App>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get an app by ID.

fn create_app<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _name: &'life1 str, _description: Option<&'life2 str>, _harness_id: HarnessId, _agent_id: Option<AgentId>, _agent_identity_id: Option<AgentIdentityId>, _channel_type: Option<ChannelType>, _channel_config: Option<&'life3 Value>, ) -> Pin<Box<dyn Future<Output = Result<App>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Create a new app.

fn update_app<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _id: AppId, _name: Option<&'life1 str>, _description: Option<&'life2 str>, _harness_id: Option<HarnessId>, _agent_id: Option<AgentId>, _agent_identity_id: Option<Option<AgentIdentityId>>, ) -> Pin<Box<dyn Future<Output = Result<App>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Update an app (only provided fields are changed).

fn delete_app<'life0, 'async_trait>( &'life0 self, _id: AppId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Archive an app.

fn destroy_app<'life0, 'async_trait>( &'life0 self, _id: AppId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Permanently destroy an archived app.

fn publish_app<'life0, 'async_trait>( &'life0 self, _id: AppId, ) -> Pin<Box<dyn Future<Output = Result<App>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Publish an app.

fn unpublish_app<'life0, 'async_trait>( &'life0 self, _id: AppId, ) -> Pin<Box<dyn Future<Output = Result<App>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Unpublish an app back to draft.

fn add_app_channel<'life0, 'life1, 'async_trait>( &'life0 self, _app_id: AppId, _channel_type: ChannelType, _channel_config: Option<&'life1 Value>, _enabled: Option<bool>, ) -> Pin<Box<dyn Future<Output = Result<AppChannel>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Add a channel to an app.

fn update_app_channel<'life0, 'life1, 'async_trait>( &'life0 self, _app_id: AppId, _channel_id: AppChannelId, _channel_type: Option<ChannelType>, _channel_config: Option<&'life1 Value>, _enabled: Option<bool>, ) -> Pin<Box<dyn Future<Output = Result<AppChannel>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update a channel on an app.

fn delete_app_channel<'life0, 'async_trait>( &'life0 self, _app_id: AppId, _channel_id: AppChannelId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete a channel from an app.

fn get_session_context_report<'life0, 'async_trait>( &'life0 self, _id: SessionId, ) -> Pin<Box<dyn Future<Output = Result<SessionContextReport>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the latest estimated context breakdown for a session.

fn delete_session<'life0, 'async_trait>( &'life0 self, _id: SessionId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete (archive) a session.

fn list_capabilities<'life0, 'life1, 'async_trait>( &'life0 self, _search: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = Result<Vec<CapabilityInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List all available capabilities (built-in + MCP servers + skills).