#![allow(clippy::all, missing_docs, unused_imports)]
use serde::{Deserialize, Serialize};
use super::*;
use crate::playwright::connection::{
Binary, Channel, ChannelType, ObjectRef, ProtocolError, ProtocolEvent, Ref,
};
#[derive(Debug, Clone, Default, PartialEq, Serialize, Deserialize)]
pub struct WebSocketInitializer {
#[serde(rename = "url")]
pub url: String,
}
#[derive(Debug, Clone, Default, PartialEq, Serialize, Deserialize)]
pub struct WebSocketFrameSentEventParams {
#[serde(rename = "opcode")]
pub opcode: i64,
#[serde(rename = "data")]
pub data: String,
}
#[derive(Debug, Clone, Default, PartialEq, Serialize, Deserialize)]
pub struct WebSocketFrameReceivedEventParams {
#[serde(rename = "opcode")]
pub opcode: i64,
#[serde(rename = "data")]
pub data: String,
}
#[derive(Debug, Clone, Default, PartialEq, Serialize, Deserialize)]
pub struct WebSocketSocketErrorEventParams {
#[serde(rename = "error")]
pub error: String,
}
#[derive(Debug, Clone, PartialEq)]
pub enum WebSocketEvent {
Open,
FrameSent(WebSocketFrameSentEventParams),
FrameReceived(WebSocketFrameReceivedEventParams),
SocketError(WebSocketSocketErrorEventParams),
Close,
Unknown {
method: String,
params: serde_json::Value,
},
}
impl ProtocolEvent for WebSocketEvent {
fn parse(method: &str, params: serde_json::Value) -> Result<Self, serde_json::Error> {
match method {
"open" => Ok(Self::Open),
"frameSent" => Ok(Self::FrameSent(serde_json::from_value(params)?)),
"frameReceived" => Ok(Self::FrameReceived(serde_json::from_value(params)?)),
"socketError" => Ok(Self::SocketError(serde_json::from_value(params)?)),
"close" => Ok(Self::Close),
_ => Ok(Self::Unknown { method: method.to_string(), params }),
}
}
}
#[derive(Debug, Clone)]
pub struct WebSocket {
channel: Channel,
}
impl ChannelType for WebSocket {
const INTERFACE: &'static str = "WebSocket";
type Initializer = WebSocketInitializer;
type Event = WebSocketEvent;
fn accepts(interface: &str) -> bool {
matches!(interface, "WebSocket")
}
fn from_channel(channel: Channel) -> Self {
Self { channel }
}
fn channel(&self) -> &Channel {
&self.channel
}
}
impl WebSocket {
}