Struct HttpPairingRelayClient 

pub struct HttpPairingRelayClient { /* private fields */ }

HTTP-backed implementation of PairingRelayClient.

Uses WebSocket for real-time session updates with HTTP polling as a fallback when WebSocket is unavailable.

Usage:

use auths_infra_http::HttpPairingRelayClient;

let relay = HttpPairingRelayClient::new();
let response = relay.create_session("https://registry.example.com", &request).await?;

Implementations

impl HttpPairingRelayClient

pub fn new() -> Self

Creates a new client with a default reqwest client.

Trait Implementations

impl Default for HttpPairingRelayClient

fn default() -> Self

Returns the “default value” for a type.

impl PairingRelayClient for HttpPairingRelayClient

fn create_session( &self, registry_url: &str, request: &CreateSessionRequest, ) -> impl Future<Output = Result<CreateSessionResponse, NetworkError>> + Send

Creates a new pairing session on the relay server.

fn get_session( &self, registry_url: &str, session_id: &str, ) -> impl Future<Output = Result<GetSessionResponse, NetworkError>> + Send

Fetches the current state of a pairing session.

fn lookup_by_code( &self, registry_url: &str, code: &str, ) -> impl Future<Output = Result<GetSessionResponse, NetworkError>> + Send

Looks up a session by its short human-readable code.

fn submit_response( &self, registry_url: &str, session_id: &str, response: &SubmitResponseRequest, ) -> impl Future<Output = Result<(), NetworkError>> + Send

Submits a device pairing response to a session.

fn submit_confirmation( &self, registry_url: &str, session_id: &str, request: &SubmitConfirmationRequest, ) -> impl Future<Output = Result<(), NetworkError>> + Send

Submits a SAS confirmation (encrypted attestation or abort signal).

fn get_confirmation( &self, registry_url: &str, session_id: &str, ) -> impl Future<Output = Result<GetConfirmationResponse, NetworkError>> + Send

Polls for a SAS confirmation from the initiator.

fn wait_for_update( &self, registry_url: &str, session_id: &str, timeout: Duration, ) -> impl Future<Output = Result<Option<GetSessionResponse>, NetworkError>> + Send

Waits for a session to reach a terminal state, using WebSocket with HTTP polling fallback.