Struct SqliteStore 

pub struct SqliteStore { /* private fields */ }

Implementations

impl SqliteStore

pub async fn create_acp_session( &self, session_id: &str, ) -> Result<(), MemoryError>

Create a new ACP session record.

Errors

Returns an error if the database write fails.

pub async fn save_acp_event( &self, session_id: &str, event_type: &str, payload: &str, ) -> Result<(), MemoryError>

Persist a single ACP session event.

Errors

Returns an error if the database write fails.

pub async fn load_acp_events( &self, session_id: &str, ) -> Result<Vec<AcpSessionEvent>, MemoryError>

Load all events for an ACP session in insertion order.

Errors

Returns an error if the database query fails.

pub async fn delete_acp_session( &self, session_id: &str, ) -> Result<(), MemoryError>

Delete an ACP session and its events (cascade).

Errors

Returns an error if the database write fails.

pub async fn list_acp_sessions( &self, limit: usize, ) -> Result<Vec<AcpSessionInfo>, MemoryError>

List ACP sessions ordered by last activity descending.

Includes title, updated_at, and message count per session. Pass limit = 0 for unlimited results.

Errors

Returns an error if the database query fails.

pub async fn get_acp_session_info( &self, session_id: &str, ) -> Result<Option<AcpSessionInfo>, MemoryError>

Fetch metadata for a single ACP session.

Returns None if the session does not exist.

Errors

Returns an error if the database query fails.

pub async fn import_acp_events( &self, session_id: &str, events: &[(&str, &str)], ) -> Result<(), MemoryError>

Insert multiple events for a session inside a single transaction.

Atomically writes all events or none. More efficient than individual inserts for bulk import use cases.

Errors

Returns an error if the transaction or any insert fails.

pub async fn update_session_title( &self, session_id: &str, title: &str, ) -> Result<(), MemoryError>

Update the title of an ACP session.

Errors

Returns an error if the database write fails.

pub async fn acp_session_exists( &self, session_id: &str, ) -> Result<bool, MemoryError>

Check whether an ACP session record exists.

Errors

Returns an error if the database query fails.

impl SqliteStore

pub async fn load_input_history( &self, limit: i64, ) -> Result<Vec<String>, MemoryError>

Load the most recent input history entries, ordered chronologically.

Errors

Returns an error if the query fails.

pub async fn save_input_entry(&self, text: &str) -> Result<(), MemoryError>

Persist a new input history entry.

Errors

Returns an error if the insert fails.

pub async fn clear_input_history(&self) -> Result<(), MemoryError>

Delete all input history entries.

Errors

Returns an error if the delete fails.

impl SqliteStore

pub async fn create_conversation(&self) -> Result<ConversationId, MemoryError>

Create a new conversation and return its ID.

Errors

Returns an error if the insert fails.

pub async fn save_message( &self, conversation_id: ConversationId, role: &str, content: &str, ) -> Result<MessageId, MemoryError>

Save a message to the given conversation and return the message ID.

Errors

Returns an error if the insert fails.

pub async fn save_message_with_parts( &self, conversation_id: ConversationId, role: &str, content: &str, parts_json: &str, ) -> Result<MessageId, MemoryError>

Save a message with structured parts JSON.

Errors

Returns an error if the insert fails.

pub async fn save_message_with_metadata( &self, conversation_id: ConversationId, role: &str, content: &str, parts_json: &str, agent_visible: bool, user_visible: bool, ) -> Result<MessageId, MemoryError>

Save a message with visibility metadata.

Errors

Returns an error if the insert fails.

pub async fn load_history( &self, conversation_id: ConversationId, limit: u32, ) -> Result<Vec<Message>, MemoryError>

Load the most recent messages for a conversation, up to limit.

Errors

Returns an error if the query fails.

pub async fn load_history_filtered( &self, conversation_id: ConversationId, limit: u32, agent_visible: Option<bool>, user_visible: Option<bool>, ) -> Result<Vec<Message>, MemoryError>

Load messages filtered by visibility flags.

Pass Some(true) to filter by a flag, None to skip filtering.

Errors

Returns an error if the query fails.

pub async fn replace_conversation( &self, conversation_id: ConversationId, compacted_range: RangeInclusive<MessageId>, summary_role: &str, summary_content: &str, ) -> Result<MessageId, MemoryError>

Atomically mark a range of messages as user-only and insert a summary as agent-only.

Within a single transaction:

1. Updates agent_visible=0, compacted_at=now for messages in compacted_range.
2. Inserts summary_content with agent_visible=1, user_visible=0.

Returns the MessageId of the inserted summary.

Errors

Returns an error if the transaction fails.

pub async fn oldest_message_ids( &self, conversation_id: ConversationId, n: u32, ) -> Result<Vec<MessageId>, MemoryError>

Return the IDs of the N oldest messages in a conversation (ascending order).

Errors

Returns an error if the query fails.

pub async fn latest_conversation_id( &self, ) -> Result<Option<ConversationId>, MemoryError>

Return the ID of the most recent conversation, if any.

Errors

Returns an error if the query fails.

pub async fn message_by_id( &self, message_id: MessageId, ) -> Result<Option<Message>, MemoryError>

Fetch a single message by its ID.

Errors

Returns an error if the query fails.

pub async fn messages_by_ids( &self, ids: &[MessageId], ) -> Result<Vec<(MessageId, Message)>, MemoryError>

Fetch messages by a list of IDs in a single query.

Errors

Returns an error if the query fails.

pub async fn unembedded_message_ids( &self, limit: Option<usize>, ) -> Result<Vec<(MessageId, ConversationId, String, String)>, MemoryError>

Return message IDs and content for messages without embeddings.

Errors

Returns an error if the query fails.

pub async fn count_messages( &self, conversation_id: ConversationId, ) -> Result<i64, MemoryError>

Count the number of messages in a conversation.

Errors

Returns an error if the query fails.

pub async fn count_messages_after( &self, conversation_id: ConversationId, after_id: MessageId, ) -> Result<i64, MemoryError>

Count messages in a conversation with id greater than after_id.

Errors

Returns an error if the query fails.

pub async fn keyword_search( &self, query: &str, limit: usize, conversation_id: Option<ConversationId>, ) -> Result<Vec<(MessageId, f64)>, MemoryError>

Full-text keyword search over messages using FTS5.

Returns message IDs with BM25 relevance scores (lower = more relevant, negated to positive for consistency with vector scores).

Errors

Returns an error if the query fails.

pub async fn message_timestamps( &self, ids: &[MessageId], ) -> Result<HashMap<MessageId, i64>, MemoryError>

Fetch creation timestamps (Unix epoch seconds) for the given message IDs.

Messages without a created_at column fall back to 0.

Errors

Returns an error if the query fails.

pub async fn load_messages_range( &self, conversation_id: ConversationId, after_message_id: MessageId, limit: usize, ) -> Result<Vec<(MessageId, String, String)>, MemoryError>

Load a range of messages after a given message ID.

Errors

Returns an error if the query fails.

impl SqliteStore

pub async fn record_skill_usage( &self, skill_names: &[&str], ) -> Result<(), MemoryError>

Record usage of skills (UPSERT: increment count and update timestamp).

Errors

Returns an error if the database operation fails.

pub async fn load_skill_usage(&self) -> Result<Vec<SkillUsageRow>, MemoryError>

Load all skill usage statistics.

Errors

Returns an error if the query fails.

pub async fn record_skill_outcome( &self, skill_name: &str, version_id: Option<i64>, conversation_id: Option<ConversationId>, outcome: &str, error_context: Option<&str>, ) -> Result<(), MemoryError>

Record a skill outcome event.

Errors

Returns an error if the insert fails.

pub async fn record_skill_outcomes_batch( &self, skill_names: &[String], conversation_id: Option<ConversationId>, outcome: &str, error_context: Option<&str>, ) -> Result<(), MemoryError>

Record outcomes for multiple skills in a single transaction.

Errors

Returns an error if any insert fails (whole batch is rolled back).

pub async fn skill_metrics( &self, skill_name: &str, ) -> Result<Option<SkillMetricsRow>, MemoryError>

Load metrics for a skill (latest version group).

Errors

Returns an error if the query fails.

pub async fn load_skill_outcome_stats( &self, ) -> Result<Vec<SkillMetricsRow>, MemoryError>

Load all skill outcome stats grouped by skill name.

Errors

Returns an error if the query fails.

pub async fn save_skill_version( &self, skill_name: &str, version: i64, body: &str, description: &str, source: &str, error_context: Option<&str>, predecessor_id: Option<i64>, ) -> Result<i64, MemoryError>

Save a new skill version and return its ID.

Errors

Returns an error if the insert fails.

pub async fn active_skill_version( &self, skill_name: &str, ) -> Result<Option<SkillVersionRow>, MemoryError>

Load the active version for a skill.

Errors

Returns an error if the query fails.

pub async fn activate_skill_version( &self, skill_name: &str, version_id: i64, ) -> Result<(), MemoryError>

Activate a specific version (deactivates others for the same skill).

Errors

Returns an error if the update fails.

pub async fn next_skill_version( &self, skill_name: &str, ) -> Result<i64, MemoryError>

Get the next version number for a skill.

Errors

Returns an error if the query fails.

pub async fn last_improvement_time( &self, skill_name: &str, ) -> Result<Option<String>, MemoryError>

Get the latest auto-generated version’s created_at for cooldown check.

Errors

Returns an error if the query fails.

pub async fn ensure_skill_version_exists( &self, skill_name: &str, body: &str, description: &str, ) -> Result<(), MemoryError>

Ensure a base (v1 manual) version exists for a skill. Idempotent.

Errors

Returns an error if the DB operation fails.

pub async fn load_skill_versions( &self, skill_name: &str, ) -> Result<Vec<SkillVersionRow>, MemoryError>

Load all versions for a skill, ordered by version number.

Errors

Returns an error if the query fails.

pub async fn count_auto_versions( &self, skill_name: &str, ) -> Result<i64, MemoryError>

Count auto-generated versions for a skill.

Errors

Returns an error if the query fails.

pub async fn prune_skill_versions( &self, skill_name: &str, max_versions: u32, ) -> Result<u32, MemoryError>

Delete oldest non-active auto versions exceeding max limit. Returns the number of pruned versions.

Errors

Returns an error if the delete fails.

pub async fn predecessor_version( &self, version_id: i64, ) -> Result<Option<SkillVersionRow>, MemoryError>

Get the predecessor version for rollback.

Errors

Returns an error if the query fails.

impl SqliteStore

pub async fn save_summary( &self, conversation_id: ConversationId, content: &str, first_message_id: MessageId, last_message_id: MessageId, token_estimate: i64, ) -> Result<i64, MemoryError>

Save a summary and return its ID.

Errors

Returns an error if the insert fails.

pub async fn load_summaries( &self, conversation_id: ConversationId, ) -> Result<Vec<(i64, ConversationId, String, MessageId, MessageId, i64)>, MemoryError>

Load all summaries for a conversation.

Errors

Returns an error if the query fails.

pub async fn latest_summary_last_message_id( &self, conversation_id: ConversationId, ) -> Result<Option<MessageId>, MemoryError>

Get the last message ID covered by the most recent summary.

Errors

Returns an error if the query fails.

impl SqliteStore

pub async fn upsert_skill_trust( &self, skill_name: &str, trust_level: &str, source_kind: SourceKind, source_url: Option<&str>, source_path: Option<&str>, blake3_hash: &str, ) -> Result<(), MemoryError>

Upsert trust metadata for a skill.

Errors

Returns an error if the database operation fails.

pub async fn load_skill_trust( &self, skill_name: &str, ) -> Result<Option<SkillTrustRow>, MemoryError>

Load trust metadata for a single skill.

Errors

Returns an error if the query fails.

pub async fn load_all_skill_trust( &self, ) -> Result<Vec<SkillTrustRow>, MemoryError>

Load all skill trust entries.

Errors

Returns an error if the query fails.

pub async fn set_skill_trust_level( &self, skill_name: &str, trust_level: &str, ) -> Result<bool, MemoryError>

Update only the trust level for a skill.

Errors

Returns an error if the skill does not exist or the update fails.

pub async fn delete_skill_trust( &self, skill_name: &str, ) -> Result<bool, MemoryError>

Delete trust entry for a skill.

Errors

Returns an error if the delete fails.

pub async fn update_skill_hash( &self, skill_name: &str, blake3_hash: &str, ) -> Result<bool, MemoryError>

Update the blake3 hash for a skill.

Errors

Returns an error if the update fails.

impl SqliteStore

pub async fn new(path: &str) -> Result<Self, MemoryError>

Open (or create) the SQLite database and run migrations.

Enables foreign key constraints at connection level so that ON DELETE CASCADE and other FK rules are enforced.

Errors

Returns an error if the database cannot be opened or migrations fail.

pub async fn with_pool_size( path: &str, pool_size: u32, ) -> Result<Self, MemoryError>

Open (or create) the SQLite database with a configurable connection pool size.

Errors

Returns an error if the database cannot be opened or migrations fail.

pub fn pool(&self) -> &SqlitePool

Expose the underlying pool for shared access by other stores.

pub async fn run_migrations(pool: &SqlitePool) -> Result<(), MemoryError>

Run all migrations on the given pool.

Errors

Returns an error if any migration fails.

Trait Implementations

impl Clone for SqliteStore

fn clone(&self) -> SqliteStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteStore

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

Formats the value using the given formatter.