use std::time::Duration;
use drission::prelude::*;
use tokio::io::{AsyncReadExt, AsyncWriteExt};
use tokio::net::TcpListener;
use tokio::time::{Instant, sleep};
const PAGE_HTML: &str = r#"<!doctype html><html><head><meta charset="utf-8"><title>CDP Advanced</title></head>
<body>
<h1 id="title">CDP 高级能力</h1>
<ul id="list"><li>one</li><li>two</li><li>three</li></ul>
<input id="name" type="text" />
<button id="go">GO</button>
<div id="out">idle</div>
<script>
window.__trusted = null;
document.getElementById('go').addEventListener('click', async function(e){
window.__trusted = e.isTrusted;
try {
const r = await fetch('/api/data');
const j = await r.json();
document.getElementById('out').textContent = 'got:' + j.hello;
} catch (err) { document.getElementById('out').textContent = 'err:' + err; }
});
</script>
</body></html>"#;
const API_JSON: &str = r#"{"hello":"cdp","n":42}"#;
#[tokio::main]
async fn main() -> drission::Result<()> {
let listener = TcpListener::bind("127.0.0.1:0").await?;
let port = listener.local_addr()?.port();
tokio::spawn(serve(listener));
let base = format!("http://127.0.0.1:{port}");
println!("[*] 本地服务: {base}");
let headless = std::env::var("HL").map(|v| v != "0").unwrap_or(true);
println!("[*] 启动 Chrome(headless={headless})");
let browser = ChromiumBrowser::launch(headless).await?;
let tab = browser.new_tab("about:blank").await?;
tab.get(&format!("{base}/")).await?;
let mut failed = false;
macro_rules! check {
($cond:expr, $($arg:tt)*) => {{
let ok = $cond;
println!("[{}] {}", if ok { "ok" } else { "FAIL" }, format!($($arg)*));
if !ok { failed = true; }
}};
}
let title = tab.ele("#title").await?;
check!(title.text().await? == "CDP 高级能力", "ele(#title).text");
let lis = tab.eles("css:li").await?;
check!(lis.len() == 3, "eles(li) == 3 (实得 {})", lis.len());
check!(lis[0].text().await? == "one", "li[0].text == one");
let second = lis[0].next().await?;
check!(second.text().await? == "two", "li[0].next().text == two");
let list = tab.ele("#list").await?;
check!(list.children().await?.len() == 3, "#list.children == 3");
let go = tab.ele("#go").await?;
check!(go.tag().await? == "button", "ele(#go).tag == button");
let name = tab.ele("#name").await?;
name.input_human("drission").await?;
check!(
name.value().await? == "drission",
"input_human → value == drission"
);
let listen = tab.listen();
listen.start_xhr(&["/api/"]).await?;
check!(listen.is_listening().await, "listen.is_listening == true");
tab.ele("#go").await?.click().await?; let pkt = listen.wait(Some(Duration::from_secs(5))).await?;
match pkt {
Some(p) => {
check!(
p.url.contains("/api/data"),
"监听到 /api/data(实得 {})",
p.url
);
check!(
p.response.status == 200,
"响应状态 200(实得 {})",
p.response.status
);
let body_hello = p
.json()
.and_then(|j| j["hello"].as_str().map(str::to_string));
check!(
body_hello.as_deref() == Some("cdp"),
"响应体 hello==cdp(实得 {:?})",
body_hello
);
}
None => check!(false, "监听超时,没抓到 /api/data"),
}
let trusted = tab.run_js("window.__trusted").await?;
check!(
trusted.as_bool() == Some(true),
"click 的 isTrusted == true(实得 {trusted})"
);
let out_real = poll_text(&tab, "#out", "got:cdp").await?;
check!(
out_real == "got:cdp",
"真实 fetch 后 #out == got:cdp(实得 {out_real})"
);
listen.stop().await?;
tab.run_js("document.getElementById('out').textContent='idle'")
.await?;
let intercept = tab.intercept();
intercept.start_xhr(&["/api/data"]).await?;
tab.ele("#go").await?.click().await?; let req = intercept.next(Some(Duration::from_secs(5))).await?;
match req {
Some(r) => {
check!(
r.url.contains("/api/data"),
"拦截到 /api/data(实得 {})",
r.url
);
r.fulfill(
200,
vec![
("Content-Type".into(), "application/json".into()),
("Access-Control-Allow-Origin".into(), "*".into()),
],
r#"{"hello":"FAKE"}"#,
)
.await?;
}
None => check!(false, "拦截超时,没拦到 /api/data"),
}
let out_fake = poll_text(&tab, "#out", "got:FAKE").await?;
check!(
out_fake == "got:FAKE",
"拦截 fulfill 后 #out == got:FAKE(实得 {out_fake})"
);
intercept.stop().await?;
browser.quit().await?;
if failed {
eprintln!("==== 有校验未通过 ====");
std::process::exit(1);
}
println!("ALL CHECKS PASSED");
Ok(())
}
async fn poll_text(tab: &ChromiumTab, selector: &str, want: &str) -> drission::Result<String> {
let deadline = Instant::now() + Duration::from_secs(2);
loop {
let t = tab.ele(selector).await?.text().await?;
if t == want || Instant::now() >= deadline {
return Ok(t);
}
sleep(Duration::from_millis(60)).await;
}
}
async fn serve(listener: TcpListener) {
loop {
let Ok((mut sock, _)) = listener.accept().await else {
break;
};
tokio::spawn(async move {
let mut buf = vec![0u8; 8192];
let n = sock.read(&mut buf).await.unwrap_or(0);
let req = String::from_utf8_lossy(&buf[..n]);
let path = req
.lines()
.next()
.and_then(|l| l.split_whitespace().nth(1))
.unwrap_or("/");
let (ctype, body) = if path.starts_with("/api/data") {
("application/json", API_JSON)
} else {
("text/html; charset=utf-8", PAGE_HTML)
};
let resp = format!(
"HTTP/1.1 200 OK\r\nContent-Type: {}\r\nContent-Length: {}\r\nAccess-Control-Allow-Origin: *\r\nConnection: close\r\n\r\n{}",
ctype,
body.len(),
body
);
let _ = sock.write_all(resp.as_bytes()).await;
});
}
}