Struct ServerCommunicationConfigMiddleware 

pub struct ServerCommunicationConfigMiddleware {
    provider: Arc<dyn CookieProvider>,
    in_flight: Arc<Mutex<HashMap<String, Arc<Notify>>>>,
}

Middleware that injects SSO load balancer cookies and re-acquires them on 302/307.

Must be outermost in the middleware chain so it observes raw 3xx responses before auth middleware. Auto-redirect must be disabled on the underlying reqwest::Client.

On WASM targets, uses a proactive strategy: checks needs_bootstrap() before each request, acquires cookies if needed, injects them, then sends. This is required because reqwest::redirect::Policy is unavailable on WASM and the browser auto-follows redirects, making reactive 302/307 detection impossible.

Security

Cookie values are NEVER logged.

Fields

provider: Arc<dyn CookieProvider>

in_flight: Arc<Mutex<HashMap<String, Arc<Notify>>>>

Tracks in-flight cookie acquisitions per hostname to prevent duplicate concurrent SSO acquisition flows. When a task is acquiring for a hostname, other tasks wait on the Notify rather than starting a redundant acquisition.

Not used on WASM targets (single-threaded, proactive strategy).

Implementations

impl ServerCommunicationConfigMiddleware

pub fn new(provider: Arc<dyn CookieProvider>) -> Self

Creates a new middleware instance wrapping the given cookie provider.

Trait Implementations

impl Clone for ServerCommunicationConfigMiddleware

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Middleware for ServerCommunicationConfigMiddleware

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, req: Request, extensions: &'life1 mut Extensions, next: Next<'life2>, ) -> Pin<Box<dyn Future<Output = Result<Response>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Invoked with a request before sending it. If you want to continue processing the request, you should explicitly call next.run(req, extensions).