viewpoint-cdp 0.4.3

Low-level Chrome DevTools Protocol implementation over WebSocket
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90

//! CDP error types.

use thiserror::Error;

/// Errors that can occur during CDP communication.
#[derive(Error, Debug)]
pub enum CdpError {
    /// WebSocket connection failed.
    #[error("WebSocket connection failed: {0}")]
    ConnectionFailed(String),

    /// WebSocket connection was lost during operation.
    #[error("WebSocket connection lost")]
    ConnectionLost,

    /// Failed to send a CDP message.
    #[error("failed to send CDP message: {0}")]
    SendFailed(String),

    /// CDP protocol error returned by the browser.
    #[error("CDP protocol error {code}: {message}")]
    Protocol { code: i64, message: String },

    /// JSON serialization/deserialization error.
    #[error("JSON error: {0}")]
    Json(#[from] serde_json::Error),

    /// Response timeout.
    #[error("response timeout after {0:?}")]
    Timeout(std::time::Duration),

    /// Invalid message ID in response.
    #[error("invalid message ID: expected {expected}, got {got}")]
    InvalidMessageId { expected: u64, got: u64 },

    /// Failed to parse WebSocket URL.
    #[error("invalid WebSocket URL: {0}")]
    InvalidUrl(String),

    /// Session not found.
    #[error("session not found: {0}")]
    SessionNotFound(String),

    /// Browser process spawn failed.
    #[error("failed to spawn browser process: {0}")]
    SpawnFailed(String),

    /// Failed to parse the debugging URL from browser output.
    #[error("failed to get debugging URL from browser")]
    NoDebuggingUrl,

    /// Chromium executable not found.
    #[error(
        "Chromium not found. Set CHROMIUM_PATH environment variable or ensure Chromium is installed."
    )]
    ChromiumNotFound,

    /// Browser launch timeout.
    #[error("browser launch timeout after {0:?}")]
    LaunchTimeout(std::time::Duration),

    /// Connection timeout.
    #[error("connection timeout after {0:?}")]
    ConnectionTimeout(std::time::Duration),

    /// Endpoint discovery failed.
    #[error("failed to discover WebSocket endpoint from {url}: {reason}")]
    EndpointDiscoveryFailed { url: String, reason: String },

    /// Invalid endpoint URL.
    #[error("invalid endpoint URL: {0}")]
    InvalidEndpointUrl(String),

    /// HTTP request failed.
    #[error("HTTP request failed: {0}")]
    HttpRequestFailed(String),
}

impl From<tokio_tungstenite::tungstenite::Error> for CdpError {
    fn from(err: tokio_tungstenite::tungstenite::Error) -> Self {
        match err {
            tokio_tungstenite::tungstenite::Error::ConnectionClosed
            | tokio_tungstenite::tungstenite::Error::AlreadyClosed => Self::ConnectionLost,
            other => Self::ConnectionFailed(other.to_string()),
        }
    }
}

#[cfg(test)]
mod tests;