Struct SessionStore 

pub struct SessionStore { /* private fields */ }

Thread-safe persistent session store backed by SQLite.

Manages active Claude Code sessions, tracking which Slack threads correspond to which agent sessions. Uses WAL mode for concurrent read access and per-row updates.

Thread Safety

All methods are async and use spawn_blocking with a sync Mutex to avoid holding locks across await points.

Implementations

impl SessionStore

pub fn new(path: PathBuf) -> Self

Creates a new session store, opening or creating the SQLite database.

If a legacy sessions.json file exists next to the database path, it will be migrated automatically.

Arguments

• path - Path to the SQLite database file

Returns

A new SessionStore instance.

pub async fn insert(&self, session: SessionInfo) -> Result<()>

Inserts a new session into the database.

pub async fn get_by_thread(&self, thread_ts: &str) -> Option<SessionInfo>

Retrieves a session by its Slack thread timestamp.

pub async fn update<F>(&self, thread_ts: &str, f: F) -> Result<()>

where F: FnOnce(&mut SessionInfo) + Send + 'static,

Updates a session in-place within a transaction.

Arguments

• thread_ts - Thread timestamp of the session to update
• f - Closure that modifies the session

Errors

Returns SessionNotFound if the thread doesn’t exist.

pub async fn active_sessions(&self) -> Vec<SessionInfo>

pub async fn has_session_id(&self, session_id: &str) -> bool

Checks if any session has the given agent session ID (indexed lookup).

pub async fn prune_stale_channels( &self, repo_channels: &HashMap<String, String>, )

Remove sessions whose channel_id doesn’t match the current channel for their repo.

pub async fn prune_expired(&self, ttl_days: i64)

Remove sessions whose last_active is older than the TTL.

Trait Implementations

impl Clone for SessionStore

fn clone(&self) -> SessionStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.