Struct AuthTracker 

pub struct AuthTracker { /* private fields */ }

Generic authentication state tracker for WebSocket connections.

Coordinates authentication attempts by providing a channel-based signaling mechanism. Each authentication attempt receives a dedicated oneshot channel that will be resolved when the server responds.

State Management

The tracker maintains a three-state machine:

• Unauthenticated: after begin(), invalidate(), or initial construction.
• Authenticated: after succeed(). Queryable via is_authenticated().
• Failed: after fail(). Causes wait_for_authenticated() to return early.

Superseding Behavior

If a new authentication attempt begins while a previous one is pending, the old attempt is automatically cancelled with an error. This prevents auth response race conditions during rapid reconnections.

Thread Safety

All operations are thread-safe and can be called concurrently from multiple tasks.

Implementations

impl AuthTracker

pub fn new() -> Self

Creates a new authentication tracker.

pub fn auth_state(&self) -> AuthState

Returns the current authentication state.

pub fn is_authenticated(&self) -> bool

Returns whether the client is currently authenticated.

pub fn invalidate(&self)

Clears the authentication state without affecting pending auth attempts.

Call this on disconnect or when the connection is closed to ensure operations requiring authentication are properly guarded.

pub fn begin(&self) -> AuthResultReceiver

Begins a new authentication attempt.

Returns a receiver that will be notified when authentication completes. If a previous authentication attempt is still pending, it will be cancelled with an error message indicating it was superseded.

Transitions to Unauthenticated since a new attempt invalidates any previous status.

pub fn succeed(&self)

Marks the current authentication attempt as successful.

Transitions to Authenticated and notifies any waiting receiver with Ok(()). This should be called when the server sends a successful authentication response.

The state is always updated even if no receiver is waiting (e.g., after a timeout), since the server has confirmed authentication.

pub fn fail(&self, error: impl Into<String>)

Marks the current authentication attempt as failed.

Transitions to Failed and notifies any waiting receiver with Err(message). This should be called when the server sends an authentication error response.

The state is always updated even if no receiver is waiting, since the server has rejected authentication.

pub async fn wait_for_result<E>( &self, timeout: Duration, receiver: AuthResultReceiver, ) -> Result<(), E>

where E: From<String>,

Waits for the authentication result with a timeout.

Returns Ok(()) if authentication succeeds, or an error if it fails, times out, or the channel is closed.

Type Parameters

• E: Error type that implements From<String> for error message conversion

Errors

Returns an error in the following cases:

• Authentication fails (server rejects credentials)
• Authentication times out (no response within timeout duration)
• Authentication channel closes unexpectedly
• Authentication attempt is superseded by a new attempt

pub async fn wait_for_authenticated(&self, timeout: Duration) -> bool

Waits for the tracker to enter the authenticated state.

Returns true if authenticated within the timeout, false if the timeout expires or authentication explicitly fails. Uses event-driven notification from succeed() / fail() / invalidate() to avoid polling.

Returns early with false when fail() is called (e.g., the exchange rejects credentials), so callers are not blocked for the full timeout on a definitive auth rejection.

This is intended for callers on a separate task who need to gate operations on authentication state (e.g., order sends that must wait for re-authentication after a WebSocket reconnection).

Trait Implementations

impl Clone for AuthTracker

fn clone(&self) -> AuthTracker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AuthTracker

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

Formats the value using the given formatter.

impl Default for AuthTracker

fn default() -> Self

Returns the “default value” for a type.