Struct SessionStore 

pub struct SessionStore { /* private fields */ }

Thread-safe persistent session store backed by a JSON file.

Manages active Claude Code sessions, tracking which Slack threads correspond to which agent sessions. Persists to disk atomically to survive restarts.

Thread Safety

All methods are async and internally use RwLock for concurrent access. Multiple readers can access simultaneously; writes are exclusive.

Implementations

impl SessionStore

pub fn new(path: PathBuf) -> Self

Creates a new session store, loading existing sessions from disk if present.

Arguments

• path - Path to the JSON file for persisting sessions

Returns

A new SessionStore instance. If the file doesn’t exist or is invalid, starts with an empty session map (does not error). Creates a new session store using blocking I/O for initial load.

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

Inserts a new session and persists to disk atomically.

Arguments

• session - Session information to store

Errors

Returns an error if the write to disk fails (filesystem error, permissions, etc.)

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

Retrieves a session by its Slack thread timestamp.

Arguments

• thread_ts - Slack thread timestamp (unique identifier for the thread)

Returns

The session if found, or None if no session exists for this thread

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

where F: FnOnce(&mut SessionInfo),

Updates a session in-place and persists to disk atomically.

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, or a write error if persistence fails.

Example

store.update("1234.5678", |session| {
    session.total_turns += 1;
    session.last_active = Utc::now();
}).await?;

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.

Used to prevent duplicate sessions and detect races in session sync.

Arguments

• session_id - Agent session ID to search for

Returns

true if a session with this ID exists, false otherwise

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.