Struct ChromeBridge 

pub struct ChromeBridge { /* private fields */ }

The live connection registry. One instance per process (see bridge).

Transport integration (in roder-app-server::remote), on each connection:

// on first `hello` frame:
let reg = bridge().register_client(Some(remote_addr.clone()), &frame);
// spawn a task draining reg.commands -> websocket as Message::Text(JSON)
// for every inbound bridge frame: bridge().ingest_frame(Some(reg.client_id), frame);
// on disconnect: bridge().unregister_client(reg.client_id);

Implementations

impl ChromeBridge

pub fn new() -> Self

pub fn register_client( &self, remote_addr: Option<String>, hello: &Value, ) -> ChromeClientRegistration

Register a newly-connected extension. Returns the receiver the transport must drain to deliver commands to that extension.

pub fn unregister_client(&self, client_id: u64)

Remove a disconnected extension and fail any of its pending commands.

pub fn ingest_frame(&self, client_id: Option<u64>, frame: Value)

Route an inbound bridge frame from the extension: resolve a pending command result or fold an unsolicited event into bridge state.

Trait Implementations

impl ChromeController for ChromeBridge

fn status(&self) -> ChromeStatus

Current connection status.

fn set_enabled(&self, enabled: bool)

Enable/disable Chrome tools for the session.

fn set_mode(&self, mode: ChromePermissionMode)

Set the permission mode.

fn dispatch<'life0, 'async_trait>( &'life0 self, command: ChromeCommand, ) -> Pin<Box<dyn Future<Output = Result<Value, ChromeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Forward a command to the connected extension and await its result.

fn is_enabled(&self) -> bool

Whether Chrome tools are enabled for the session.

impl Default for ChromeBridge

fn default() -> Self

Returns the “default value” for a type.