Struct SessionMap 

pub struct SessionMap { /* private fields */ }

Maps Telegram chat IDs to daemon sessions.

Implementations

impl SessionMap

pub fn new() -> Self

Create an empty session map.

pub async fn get_session_id(&self, chat_id: ChatId) -> Option<SessionId>

Get the session ID for a chat, if one exists.

pub async fn insert(&self, chat_id: ChatId, session_id: SessionId)

Insert a new session mapping.

Also clears any in-progress creation lock for this chat to keep internal invariants consistent.

pub async fn try_start_existing_turn(&self, chat_id: ChatId) -> TurnStartResult

Atomically check if a session exists and start a turn.

Also returns TurnBusy if a session is currently being created for this chat (prevents the caller from starting a duplicate creation).

pub async fn try_claim_creation(&self, chat_id: ChatId) -> bool

Atomically claim the right to create a session for this chat.

Returns true if the caller should proceed with create_session. Returns false if a session already exists or another task is already creating one.

pub async fn finish_creation(&self, chat_id: ChatId, session_id: SessionId)

Complete session creation: insert the session and clear the creation lock.

pub async fn finish_creation_and_start_turn( &self, chat_id: ChatId, session_id: SessionId, ) -> SessionId

Atomically complete session creation and start a turn in one lock acquisition. Prevents a race where another message starts the turn between finish_creation and try_start_existing_turn.

pub async fn cancel_creation(&self, chat_id: ChatId)

Cancel session creation (on failure) and clear the creation lock.

pub async fn remove(&self, chat_id: ChatId) -> Option<SessionId>

Remove a session mapping.

Also clears any in-progress creation lock for this chat so a concurrent finish_creation_and_start_turn doesn’t silently re-insert the session after a /reset.

pub async fn try_start_turn(&self, chat_id: ChatId) -> bool

Atomically check and start a turn for this chat.

Returns true if the turn was started (was not already in progress). Returns false if a turn is already in progress or no session exists.

pub async fn is_turn_in_progress(&self, chat_id: ChatId) -> bool

Check if a turn is currently in progress for this chat.

pub async fn set_turn_in_progress(&self, chat_id: ChatId, in_progress: bool)

Mark a turn as finished for this chat.

Trait Implementations

impl Clone for SessionMap

fn clone(&self) -> SessionMap

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for SessionMap

fn default() -> Self

Returns the “default value” for a type.