Skip to main content

SessionManager

Struct SessionManager 

Source
pub struct SessionManager { /* private fields */ }
Expand description

Manager maintaining session slots, concurrency bounds, and token authentication.

Implementations§

Source§

impl SessionManager

Source

pub fn new() -> Self

Source

pub fn pin_tracker(&self) -> &PinTracker

Returns a reference to the PIN attempt tracker.

Source

pub async fn has_active_session(&self) -> bool

Checks if a session is currently pending or active.

Source

pub async fn claim_pending( &self, session_id: String, sender_ip: IpAddr, cert_fingerprint: Option<String>, cancel: CancellationToken, ) -> Result<(), StatusCode>

Claims the session slot for a pending prepare-upload request. Returns hyper::StatusCode::CONFLICT (409) if a session is already active or pending.

Source

pub async fn clear_pending(&self, session_id: &str)

Releases the pending session if it still matches session_id.

Source

pub async fn activate_session( &self, session_id: &str, sender_ip: IpAddr, cert_fingerprint: Option<String>, files: HashMap<String, SessionFile>, ) -> Result<(), StatusCode>

Promotes a pending session into an active upload session with accepted files.

Source

pub async fn validate_and_start_upload( &self, session_id: &str, file_id: &str, token: &str, sender_ip: IpAddr, ) -> Result<SessionFile, StatusCode>

Validates upload authorization parameters for /api/localsend/v2/upload.

Verifies:

  1. An active session exists matching session_id.
  2. Sender IP matches the session’s recorded IP.
  3. The requested file_id was accepted and has not completed.
  4. The upload token matches the token issued during prepare-upload.

Returns the corresponding SessionFile and sets its status to InProgress.

Source

pub async fn mark_file_status( &self, session_id: &str, file_id: &str, status: FileTransferStatus, ) -> bool

Updates the status of a file in the active session. If all files reach terminal status, the session is completed and the slot is freed. Returns whether the entire session finished.

Source

pub async fn cancel_session( &self, session_id: Option<&str>, remote_ip: IpAddr, ) -> Option<SessionEndReason>

Cancels the session if the request matches the current pending or active session. Returns Some(SessionEndReason) if an active or pending session was cancelled.

Source

pub async fn abort_locally(&self) -> Option<SessionEndReason>

Forcibly aborts and clears the current session locally.

Trait Implementations§

Source§

impl Debug for SessionManager

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for SessionManager

Source§

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

Source§

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

Source§

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

Source§

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more