Struct CdpClient 

pub struct CdpClient { /* private fields */ }

CDP client wrapping a shared chromiumoxide Browser.

Interior mutability

browser uses tokio::sync::Mutex because guards are held across .await points (Browser::execute, pages(), event_listener). A std::sync::Mutex here would block the async runtime (rules: never hold std mutex across .await). The mutex is not exposed in the public agent JSON API — only as an internal handle for FINALIZE.

Ownership

Holds the event-handler task and shared browser mutex — do not discard without FINALIZE (#[must_use]).

Implementations

impl CdpClient

pub async fn from_browser( browser: Browser, handler: Handler, ) -> Result<Self, String>

Build client from an already-launched or connected chromiumoxide Browser + handler.

pub async fn connect(url: &str) -> Result<Self, String>

Attach via chromiumoxide Browser::connect (lightpanda only).

pub async fn connect_with_headers( url: &str, _headers: Option<Vec<(String, String)>>, ) -> Result<Self, String>

Headers are ignored on the oxide path (chromiumoxide connect has no custom WS headers API).

pub fn browser(&self) -> Arc<Mutex<Browser>>

Shared browser handle (for FINALIZE close/wait/kill).

pub async fn send_command( &self, method: &str, params: Option<Value>, session_id: Option<&str>, ) -> Result<Value, String>

pub fn subscribe(&self) -> Receiver<CdpEvent>

pub async fn send_command_typed<P: Serialize, R: DeserializeOwned>( &self, method: &str, params: &P, session_id: Option<&str>, ) -> Result<R, String>

pub async fn send_command_no_params( &self, method: &str, session_id: Option<&str>, ) -> Result<Value, String>

pub async fn send_command_no_wait( &self, method: &str, params: Option<Value>, session_id: Option<&str>, ) -> Result<(), String>

Best-effort command (still awaits oxide execute).

impl CdpClient

pub async fn attach_page_console_forwarders(&self) -> Result<(), String>

Attach page-level console listeners (context7 pattern: page.event_listener). Complements browser-level forwarders when Runtime events are page-scoped.

pub async fn attach_page_network_forwarders(&self) -> Result<(), String>

Page-level Network.requestWillBeSent (page-scoped CDP events).

pub async fn attach_page_session_forwarders(&self) -> Result<(), String>

Page-scoped CDP events (heap chunks, screencast frames, JS dialogs). Browser-level listeners miss target-session events; attach after pages exist.

Multi-page attach is I/O-bound → [join_bounded] after releasing the browser lock (PAR-53).