Struct Session 

pub struct Session {
    id: SessionId,
    is_mcp: bool,
    last_activity: Mutex<Instant>,
    sender: UnboundedSender<SessionMessage>,
    connection_count: AtomicU32,
    shutdown_requested: AtomicBool,
    pack_names: RwLock<BTreeMap<String, String>>,
    jobs: Arc<JobRegistry>,
    settings: RwLock<Arc<Settings>>,
    queued: AtomicUsize,
    diagnostics_check: Mutex<Option<DiagnosticsCheck>>,
}

A session represents a single client’s connection state.

Each session has its own background thread for processing commands, ensuring complete isolation between clients.

Fields

id: SessionId

Unique identifier for this session.

is_mcp: bool

Whether this is the session of the MCP clients, removed by inactivity instead of by connection count.

last_activity: Mutex<Instant>

Instant of the last command sent to this session’s background thread.

Only updated by Session::call, so it reflects actual work, not transport-level pings.

sender: UnboundedSender<SessionMessage>

Sender to communicate with this session’s background thread.

connection_count: AtomicU32

Number of active connections using this session.

shutdown_requested: AtomicBool

Whether this session has been marked for shutdown.

pack_names: RwLock<BTreeMap<String, String>>

Names of the packs currently open in this session, by pack key.

jobs: Arc<JobRegistry>

Jobs of this session.

settings: RwLock<Arc<Settings>>

Settings the session runs with. Behind an Arc so requests can hold them without copying.

queued: AtomicUsize

Amount of requests sent to the background thread that it hasn’t started yet.

diagnostics_check: Mutex<Option<DiagnosticsCheck>>

The last diagnostics check requested, so a new one can replace it.

Implementations

impl Session

pub fn new(id: SessionId, is_mcp: bool) -> Arc<Self>

Create a new session with its own background thread.

is_mcp marks the session of the MCP clients, which is removed by inactivity instead of by connection count (see Session::is_mcp).

fn start_autosave_timer(session: &Arc<Self>)

Starts the timer asking the background thread to autosave the changed packs, every autosave_interval minutes of the settings.

An interval of 0 disables autosaves. The timer stops when the session shuts down or is dropped.

pub fn id(&self) -> SessionId

Get the session ID.

pub fn is_mcp(&self) -> bool

Whether this is the session of the MCP clients.

fn touch(&self)

Record that a command was just sent to this session’s background thread.

pub fn last_activity(&self) -> Instant

Get the instant of the last command sent to this session.

pub fn connect(&self)

Increment the connection count.

pub fn disconnect(&self)

Decrement the connection count.

pub fn connection_count(&self) -> u32

Get the current connection count.

pub fn is_shutdown_requested(&self) -> bool

Check if shutdown has been requested.

pub fn pack_names(&self) -> Vec<String>

Get the names of the packs open in this session.

pub fn set_pack_name(&self, pack_key: &str, name: &str)

Set the name of an open pack of this session, adding it if it’s not there yet.

pub fn remove_pack(&self, pack_key: &str)

Remove a pack from the open ones of this session.

pub fn shutdown(&self)

Shutdown this session by stopping its background thread.

pub fn jobs(&self) -> &Arc<JobRegistry>

Returns the jobs of this session.

pub fn settings(&self) -> Arc<Settings>

Returns the settings of this session.

fn configure(&self, request: RpcRequest) -> RpcResponse

Replaces the settings of this session, applying their telemetry choices to the whole process.

pub fn call(&self, request: RpcRequest) -> UnboundedReceiver<RpcResponse>

Send a request to this session’s background thread.

Configuration and job control requests are answered without waiting for the background thread, and jobs are answered right away with their ID, before they run.

Returns a receiver to get the response.

fn enqueue( &self, message: SessionMessage, ) -> Result<(), SendError<SessionMessage>>

Sends a request to the background thread, counting it as queued until the thread starts it.

pub fn dequeued(&self)

Marks a request sent to the background thread as started.

pub fn has_queued_requests(&self) -> bool

Returns if there are requests waiting for the background thread.

fn replace_diagnostics_check(&self, job: u64, request: RpcRequest) -> RpcRequest

Makes a new diagnostics check replace the last one, if it hasn’t ended yet.

The new check also checks the paths the replaced one would have checked. A queued replaced check is cancelled, and a running one is cancelled once it stops for the new one (see Self::requeue_diagnostics_check).

Arguments

• job - Job of the new check.
• request - Request of the new check.

Returns

The request of the new check, with the paths of the replaced one added.

pub fn requeue_diagnostics_check(&self, job: u64, request: RpcRequest)

Queues again a diagnostics check that stopped to let other requests run, or cancels it if a newer one replaced it.

Arguments

• job - Job of the check.
• request - Request of the check.