Run format

Sytten · Sytten · commit d8e5b67294cb · 2026-02-20T14:13:15.000-05:00
diff --git a/chromiumoxide_cdp/src/lib.rs b/chromiumoxide_cdp/src/lib.rs
@@ -12,6 +12,7 @@ use crate::revision::Revision;
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[allow(unreachable_patterns)]
 #[allow(deprecated)]
+#[rustfmt::skip]
 pub mod cdp;
 pub mod revision;
 
diff --git a/chromiumoxide_pdl/src/build/mod.rs b/chromiumoxide_pdl/src/build/mod.rs
@@ -3,7 +3,7 @@ mod event;
 pub mod generator;
 mod types;
 
-pub use crate::build::generator::{compile_pdls, Generator, SerdeSupport};
+pub use crate::build::generator::{Generator, SerdeSupport, compile_pdls};
 
 pub const CHROMIUM_BASE: &str = "https://chromium.googlesource.com/chromium/src";
 
diff --git a/chromiumoxide_pdl/src/build/types.rs b/chromiumoxide_pdl/src/build/types.rs
@@ -2,7 +2,7 @@ use crate::build::SerdeSupport;
 use crate::pdl::{Command, DataType, Domain, Event, Item, Param, Type, TypeDef, Variant};
 use heck::ToUpperCamelCase;
 use proc_macro2::{Ident, TokenStream};
-use quote::{quote, ToTokens};
+use quote::{ToTokens, quote};
 use std::slice::Iter;
 
 pub struct DomainDataTypeIter<'a> {
diff --git a/chromiumoxide_pdl/src/pdl/ser.rs b/chromiumoxide_pdl/src/pdl/ser.rs
@@ -1,6 +1,6 @@
 use serde::{
-    ser::{SerializeMap, SerializeSeq},
     Serialize, Serializer,
+    ser::{SerializeMap, SerializeSeq},
 };
 
 use crate::pdl::*;
diff --git a/examples/block-navigation.rs b/examples/block-navigation.rs
@@ -2,17 +2,17 @@ use std::collections::HashMap;
 use std::sync::Arc;
 use std::time::Duration;
 
-use base64::prelude::BASE64_STANDARD;
 use base64::Engine;
+use base64::prelude::BASE64_STANDARD;
+use chromiumoxide::Page;
 use chromiumoxide::browser::{Browser, BrowserConfig};
 use chromiumoxide::cdp::browser_protocol::fetch::{
     self, ContinueRequestParams, EventRequestPaused, FailRequestParams, FulfillRequestParams,
 };
 use chromiumoxide::cdp::browser_protocol::network::{
     self, ErrorReason, EventRequestWillBeSent, ResourceType,
 };
-use chromiumoxide::Page;
-use futures::{select, StreamExt};
+use futures::{StreamExt, select};
 use tokio::time::sleep;
 
 const CONTENT: &str = "<html><head><meta http-equiv=\"refresh\" content=\"0;URL='http://www.example.com/'\" /></head><body><h1>TEST</h1></body></html>";
diff --git a/examples/console-logs.rs b/examples/console-logs.rs
@@ -2,7 +2,7 @@
 
 use std::time::Duration;
 
-use chromiumoxide::{cdp::js_protocol::runtime::EventConsoleApiCalled, BrowserConfig};
+use chromiumoxide::{BrowserConfig, cdp::js_protocol::runtime::EventConsoleApiCalled};
 use futures::StreamExt;
 
 const TARGET: &str = "https://www.microsoft.com/";
diff --git a/examples/evaluate.rs b/examples/evaluate.rs
@@ -64,11 +64,12 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let eval = EvaluateParams::builder().expression("() => {return 42;}");
     // this will fail because the `EvaluationResult` returned by the browser will be
     // of type `Function`
-    assert!(page
-        .evaluate(eval.clone().build().unwrap())
-        .await?
-        .into_value::<usize>()
-        .is_err());
+    assert!(
+        page.evaluate(eval.clone().build().unwrap())
+            .await?
+            .into_value::<usize>()
+            .is_err()
+    );
 
     let val: usize = page
         .evaluate(eval.eval_as_function_fallback(true).build().unwrap())
diff --git a/examples/interception.rs b/examples/interception.rs
@@ -1,7 +1,7 @@
 use std::sync::Arc;
 
-use base64::prelude::BASE64_STANDARD;
 use base64::Engine;
+use base64::prelude::BASE64_STANDARD;
 use chromiumoxide::browser::{Browser, BrowserConfig};
 use chromiumoxide::cdp::browser_protocol::fetch::{
     ContinueRequestParams, EventRequestPaused, FulfillRequestParams,
diff --git a/examples/simple-google.rs b/examples/simple-google.rs
@@ -1,7 +1,7 @@
 use std::time::Duration;
 
-use chromiumoxide::browser::BrowserConfigBuilder;
 use chromiumoxide::Browser;
+use chromiumoxide::browser::BrowserConfigBuilder;
 use futures::StreamExt;
 
 #[tokio::main]
diff --git a/examples/storage-cookie.rs b/examples/storage-cookie.rs
@@ -26,7 +26,9 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         .path("/")
         .build()?;
 
-    println!("\x1b[32mType 'c' to clear all cookies, 's' to set a cookie, 'q' to quit the browser\x1b[0m");
+    println!(
+        "\x1b[32mType 'c' to clear all cookies, 's' to set a cookie, 'q' to quit the browser\x1b[0m"
+    );
     loop {
         // Read Cookies
         println!("All Browser cookies: {:?}", browser.get_cookies().await?);
diff --git a/src/browser/config.rs b/src/browser/config.rs
@@ -8,8 +8,8 @@ use std::{
 use super::argument::{Arg, ArgConst, ArgsBuilder};
 use crate::async_process::{self, Child, Stdio};
 use crate::detection::{self, DetectionOptions};
-use crate::handler::viewport::Viewport;
 use crate::handler::REQUEST_TIMEOUT;
+use crate::handler::viewport::Viewport;
 
 /// Default `Browser::launch` timeout in MS
 pub const LAUNCH_TIMEOUT: u64 = 20_000;
diff --git a/src/browser/mod.rs b/src/browser/mod.rs
@@ -1,10 +1,10 @@
 use std::future::Future;
 use std::io;
 
-use futures::channel::mpsc::{channel, unbounded, Sender};
+use futures::SinkExt;
+use futures::channel::mpsc::{Sender, channel, unbounded};
 use futures::channel::oneshot::channel as oneshot_channel;
 use futures::select;
-use futures::SinkExt;
 
 use chromiumoxide_cdp::cdp::browser_protocol::browser::{
     BrowserContextId, CloseReturns, GetVersionParams, GetVersionReturns,
@@ -22,7 +22,7 @@ use chromiumoxide_types::*;
 
 pub use self::config::{BrowserConfig, BrowserConfigBuilder, LAUNCH_TIMEOUT};
 use crate::async_process::{Child, ExitStatus};
-use crate::cmd::{to_command_response, CommandMessage};
+use crate::cmd::{CommandMessage, to_command_response};
 use crate::conn::Connection;
 use crate::error::{BrowserStderr, CdpError, Result};
 use crate::handler::browser::BrowserContext;
@@ -521,7 +521,9 @@ impl Drop for Browser {
                 // so it won't leave any resources locked. It is, however, a better practice for the user to
                 // do it himself since the runtime doesn't provide garantees as to when the reap occurs, so we
                 // warn him here.
-                tracing::warn!("Browser was not closed manually, it will be killed automatically in the background");
+                tracing::warn!(
+                    "Browser was not closed manually, it will be killed automatically in the background"
+                );
             }
         }
     }
diff --git a/src/conn.rs b/src/conn.rs
@@ -4,7 +4,7 @@ use std::pin::Pin;
 use std::task::ready;
 
 use async_tungstenite::tungstenite::Message as WsMessage;
-use async_tungstenite::{tungstenite::protocol::WebSocketConfig, WebSocketStream};
+use async_tungstenite::{WebSocketStream, tungstenite::protocol::WebSocketConfig};
 use futures::stream::Stream;
 use futures::task::{Context, Poll};
 use futures::{SinkExt, StreamExt};
diff --git a/src/element.rs b/src/element.rs
@@ -5,7 +5,7 @@ use std::sync::Arc;
 use std::task::{Context, Poll};
 
 use chromiumoxide_types::ClickOptions;
-use futures::{future, Future, FutureExt, Stream};
+use futures::{Future, FutureExt, Stream, future};
 
 use chromiumoxide_cdp::cdp::browser_protocol::dom::{
     BackendNodeId, DescribeNodeParams, GetBoxModelParams, GetContentQuadsParams, Node, NodeId,
diff --git a/src/error.rs b/src/error.rs
@@ -33,7 +33,9 @@ pub enum CdpError {
     UnexpectedWsMessage(Message),
     #[error("{0}")]
     ChannelSendError(#[from] ChannelError),
-    #[error("Browser process exited with status {0:?} before websocket URL could be resolved, stderr: {1:?}")]
+    #[error(
+        "Browser process exited with status {0:?} before websocket URL could be resolved, stderr: {1:?}"
+    )]
     LaunchExit(ExitStatus, BrowserStderr),
     #[error("Timeout while resolving websocket URL from browser process, stderr: {0:?}")]
     LaunchTimeout(BrowserStderr),
diff --git a/src/handler/commandfuture.rs b/src/handler/commandfuture.rs
@@ -8,7 +8,7 @@ use std::marker::PhantomData;
 use std::pin::Pin;
 use std::task::{Context, Poll};
 
-use crate::cmd::{to_command_response, CommandMessage};
+use crate::cmd::{CommandMessage, to_command_response};
 use crate::error::Result;
 use crate::handler::target::TargetMessage;
 use chromiumoxide_cdp::cdp::browser_protocol::target::SessionId;
diff --git a/src/handler/frame.rs b/src/handler/frame.rs
@@ -20,10 +20,10 @@ use chromiumoxide_cdp::cdp::{
 use chromiumoxide_types::{Method, MethodId, Request};
 
 use crate::error::DeadlineExceeded;
+use crate::handler::REQUEST_TIMEOUT;
 use crate::handler::domworld::DOMWorld;
 use crate::handler::http::HttpRequest;
-use crate::handler::REQUEST_TIMEOUT;
-use crate::{cmd::CommandChain, ArcHttpRequest};
+use crate::{ArcHttpRequest, cmd::CommandChain};
 
 pub const UTILITY_WORLD_NAME: &str = "__chromiumoxide_utility_world__";
 const EVALUATION_SCRIPT_URL: &str = "____chromiumoxide_utility_world___evaluation_script__";
diff --git a/src/handler/httpfuture.rs b/src/handler/httpfuture.rs
@@ -1,6 +1,6 @@
+use futures::FutureExt;
 use futures::channel::mpsc;
 use futures::future::{Fuse, FusedFuture};
-use futures::FutureExt;
 use pin_project_lite::pin_project;
 use std::future::Future;
 use std::pin::Pin;
diff --git a/src/handler/mod.rs b/src/handler/mod.rs
@@ -17,7 +17,7 @@ use chromiumoxide_types::{CallId, Message, Method, Response};
 use chromiumoxide_types::{MethodId, Request as CdpRequest};
 pub(crate) use page::PageInner;
 
-use crate::cmd::{to_command_response, CommandMessage};
+use crate::cmd::{CommandMessage, to_command_response};
 use crate::conn::Connection;
 use crate::error::{CdpError, Result};
 use crate::handler::browser::BrowserContext;
diff --git a/src/handler/page.rs b/src/handler/page.rs
@@ -1,6 +1,6 @@
 use std::sync::Arc;
 
-use futures::channel::mpsc::{channel, Receiver, Sender};
+use futures::channel::mpsc::{Receiver, Sender, channel};
 use futures::channel::oneshot::channel as oneshot_channel;
 use futures::stream::Fuse;
 use futures::{SinkExt, StreamExt};
@@ -27,7 +27,7 @@ use chromiumoxide_cdp::cdp::js_protocol::runtime::{
 };
 use chromiumoxide_types::{Command, CommandResponse};
 
-use crate::cmd::{to_command_response, CommandMessage};
+use crate::cmd::{CommandMessage, to_command_response};
 use crate::error::{CdpError, Result};
 use crate::handler::commandfuture::CommandFuture;
 use crate::handler::domworld::DOMWorldKind;
@@ -37,7 +37,7 @@ use crate::handler::target_message_future::TargetMessageFuture;
 use crate::js::EvaluationResult;
 use crate::layout::Point;
 use crate::page::ScreenshotParams;
-use crate::{keys, utils, ArcHttpRequest};
+use crate::{ArcHttpRequest, keys, utils};
 
 #[derive(Debug)]
 pub struct PageHandle {
diff --git a/src/handler/target.rs b/src/handler/target.rs
@@ -8,14 +8,14 @@ use futures::channel::oneshot::Sender;
 use futures::stream::Stream;
 use futures::task::{Context, Poll};
 
+use chromiumoxide_cdp::cdp::CdpEventMessage;
 use chromiumoxide_cdp::cdp::browser_protocol::page::{FrameId, GetFrameTreeParams};
 use chromiumoxide_cdp::cdp::browser_protocol::{
     browser::BrowserContextId,
     log as cdplog, performance,
     target::{AttachToTargetParams, SessionId, SetAutoAttachParams, TargetId, TargetInfo},
 };
 use chromiumoxide_cdp::cdp::events::CdpEvent;
-use chromiumoxide_cdp::cdp::CdpEventMessage;
 use chromiumoxide_types::{Command, Method, Request, Response};
 
 use crate::auth::Credentials;
@@ -35,7 +35,7 @@ use crate::handler::page::PageHandle;
 use crate::handler::viewport::Viewport;
 use crate::handler::{PageInner, REQUEST_TIMEOUT};
 use crate::listeners::{EventListenerRequest, EventListeners};
-use crate::{page::Page, ArcHttpRequest};
+use crate::{ArcHttpRequest, page::Page};
 use chromiumoxide_cdp::cdp::js_protocol::runtime::{
     ExecutionContextId, RunIfWaitingForDebuggerParams,
 };
diff --git a/src/handler/target_message_future.rs b/src/handler/target_message_future.rs
@@ -8,7 +8,7 @@ use std::pin::Pin;
 use std::task::{Context, Poll};
 
 use crate::handler::target::TargetMessage;
-use crate::{error::Result, ArcHttpRequest};
+use crate::{ArcHttpRequest, error::Result};
 
 type TargetSender = mpsc::Sender<TargetMessage>;
 
diff --git a/src/listeners.rs b/src/listeners.rs
@@ -211,8 +211,8 @@ impl<T: IntoEventKind + Unpin> Stream for EventStream<T> {
 mod tests {
     use futures::{SinkExt, StreamExt};
 
-    use chromiumoxide_cdp::cdp::browser_protocol::animation::EventAnimationCanceled;
     use chromiumoxide_cdp::cdp::CustomEvent;
+    use chromiumoxide_cdp::cdp::browser_protocol::animation::EventAnimationCanceled;
     use chromiumoxide_types::MethodType;
 
     use super::*;
diff --git a/src/page.rs b/src/page.rs
@@ -3,7 +3,7 @@ use std::sync::Arc;
 
 use futures::channel::mpsc::unbounded;
 use futures::channel::oneshot::channel as oneshot_channel;
-use futures::{stream, SinkExt, StreamExt};
+use futures::{SinkExt, StreamExt, stream};
 
 use chromiumoxide_cdp::cdp::browser_protocol::dom::*;
 use chromiumoxide_cdp::cdp::browser_protocol::emulation::{
@@ -23,21 +23,21 @@ use chromiumoxide_cdp::cdp::js_protocol::runtime::{
     AddBindingParams, CallArgument, CallFunctionOnParams, EvaluateParams, ExecutionContextId,
     RemoteObjectType, ScriptId,
 };
-use chromiumoxide_cdp::cdp::{browser_protocol, IntoEventKind};
+use chromiumoxide_cdp::cdp::{IntoEventKind, browser_protocol};
 use chromiumoxide_types::*;
 
 use crate::auth::Credentials;
 use crate::element::Element;
 use crate::error::{CdpError, Result};
+use crate::handler::PageInner;
 use crate::handler::commandfuture::CommandFuture;
 use crate::handler::domworld::DOMWorldKind;
 use crate::handler::httpfuture::HttpFuture;
 use crate::handler::target::{GetName, GetParent, GetUrl, TargetMessage};
-use crate::handler::PageInner;
 use crate::js::{Evaluation, EvaluationResult};
 use crate::layout::Point;
 use crate::listeners::{EventListenerRequest, EventStream};
-use crate::{utils, ArcHttpRequest};
+use crate::{ArcHttpRequest, utils};
 
 #[derive(Debug, Clone)]
 pub struct Page {
@@ -1145,13 +1145,9 @@ impl Page {
                 if expr.context_id.is_none() {
                     expr.context_id = self.execution_context().await?;
                 }
-                let fallback = expr.eval_as_function_fallback.and_then(|p| {
-                    if p {
-                        Some(expr.clone())
-                    } else {
-                        None
-                    }
-                });
+                let fallback = expr
+                    .eval_as_function_fallback
+                    .and_then(|p| if p { Some(expr.clone()) } else { None });
                 let res = self.evaluate_expression(expr).await?;
 
                 if res.object().r#type == RemoteObjectType::Function {
diff --git a/tests/config.rs b/tests/config.rs
@@ -1,4 +1,4 @@
-use crate::{test_config, BrowserConfig};
+use crate::{BrowserConfig, test_config};
 
 #[tokio::test]
 #[ignore] // For some reason, this test fails on CI but works locally
diff --git a/tests/stealth/incolumitas.rs b/tests/stealth/incolumitas.rs
diff --git a/tests/stealth/mod.rs b/tests/stealth/mod.rs
diff --git a/tests/stealth/rebrowser.rs b/tests/stealth/rebrowser.rs
