chore(release): 0.27.0-fork.29 — plugin overflowTest fix, popup-free auto-connect, ab-connect rebrand+icon, README

- stealth(plugins): stop overwriting real native navigator.plugins in headed
  mode (the JS fake had a non-native item(), broken uint32 wrap → incolumitas
  overflowTest FAIL, and an anachronistic Native Client plugin). Leave native
  plugins untouched when present; modernize the headless-escape fallback to the
  real 5 PDF-viewer set with masked-native item()/namedItem().
- connect: auto_connect_cdp() now prefers the dialog-free ab-connect relay over
  the raw :9222 CDP port, so Chrome 136+'s "Allow remote debugging?" consent
  modal no longer fires when the extension relay is live. Gated by a bare-TCP
  relay_is_live() probe (+3 unit tests).
- extension: rename ab-connect to "agent-browser-stealth" + new stealth icon set
  (16/32/48/128).
- docs(README): hero/shield/fingerprint images, expanded detector results
  (CreepJS 0% stealth, incolumitas all-OK, BrowserScan CDP-clean), and a
  "Verify it yourself" section. .gitignore: allow assets/ + extension icons.

.gitignore

@@ -38,6 +38,10 @@ __pycache__/
 *.webm
 test/e2e/.dogfood-output/
 
+# ...but these are real repo assets, not test artifacts — keep them tracked
+!assets/*.png
+!extensions/ab-connect/icons/*.png
+
 # Package manager
 package-lock.json
 yarn.lock

README.md

@@ -1,11 +1,15 @@
 # agent-browser-stealth
 
+![agent-browser-stealth](assets/hero.png)
+
 Stealth fork of [agent-browser](https://github.com/vercel-labs/agent-browser) — connects to your real Chrome, shares your login sessions, and is undetectable by anti-bot systems.
 
 For basic usage, commands, and API reference, see the [upstream documentation](https://github.com/vercel-labs/agent-browser).
 
 ## Why this fork?
 
+<img src="assets/fingerprint.png" alt="real but undetectable fingerprint" width="300" align="right" />
+
 **agent-browser** launches a fresh browser with an empty profile. You need to log in again, and websites can detect it's automated.
 
 **agent-browser-stealth** connects to your existing Chrome. Your cookies, sessions, and browser fingerprint are all real — because it IS your real browser.
@@ -115,6 +119,8 @@ In CI environments, standalone mode is used automatically.
 
 ## Anti-detection
 
+<img src="assets/shield.png" alt="stealth shield" width="320" align="right" />
+
 When connected to your real Chrome, we inject **zero** JavaScript patches. Your browser's fingerprint is completely genuine. The guiding rule is **native CDP/Chrome overrides over JS lies** — a re-defined getter is itself detectable; a native override isn't.
 
 - `navigator.webdriver = false` via `Emulation.setAutomationOverride` (native, undetectable by CreepJS-style lie tests).
@@ -124,11 +130,27 @@ When connected to your real Chrome, we inject **zero** JavaScript patches. Your
 
 | Test site | Result |
 |---|---|
-| [CreepJS](https://abrahamjuliot.github.io/creepjs/) | 0% stealth, 0% headless |
-| [bot.sannysoft.com](https://bot.sannysoft.com) | All green |
-| [Cloudflare Turnstile](https://nowsecure.nl) | Passed |
+| [CreepJS](https://abrahamjuliot.github.io/creepjs/) | **0% stealth · 0% headless** (no override traces at all) |
+| [bot.incolumitas.com](https://bot.incolumitas.com/) | all checks OK — `overflowTest`, `overrideTest`, `puppeteerExtraStealthUsed`, worker consistency |
+| [bot.sannysoft.com](https://bot.sannysoft.com) | all green |
+| [BrowserScan](https://www.browserscan.net/bot-detection) | Webdriver · User-Agent · CDP all clean |
+| [Cloudflare Turnstile](https://nowsecure.nl) | passed |
 
-When using `--launch` mode (standalone browser), a full suite of 32 stealth patches is applied for headless Chrome.
+`0% stealth` on CreepJS is the key number: because the connect path patches **nothing**, there is no override for a lie-detector to catch. (Dashboards that read `navigator.languages` order or IP geolocation may show a soft "navigator"/"location" flag — that tracks *your real Chrome's* language list and network, not an automation tell.)
+
+When using `--launch` mode (standalone browser), a full suite of stealth patches is applied instead, and it still passes the suite above.
+
+### Verify it yourself
+
+Don't take our word for it — point your connected Chrome at the toughest public detectors and compare:
+
+- **[CreepJS](https://abrahamjuliot.github.io/creepjs/)** — the most thorough fingerprint / lie detector
+- **[bot.incolumitas.com](https://bot.incolumitas.com/)** — behavioral + fingerprint scoring with a public methodology
+- **[BrowserScan](https://www.browserscan.net/bot-detection)** — Webdriver / User-Agent / CDP / Navigator
+- **[bot.sannysoft.com](https://bot.sannysoft.com)** — the classic automation-marker checklist
+- **[pixelscan.net](https://pixelscan.net/)** · **[iphey.com](https://iphey.com/)** — consistency & identity
+
+We deliberately **don't ship our own bot detector** — the strongest, most honest benchmark is the market's best detectors run against your real browser.
 
 ### Tuning knobs (environment variables)
 

cli/Cargo.lock

@@ -45,7 +45,7 @@ dependencies = [
 
 [[package]]
 name = "agent-browser-stealth"
-version = "0.27.0-fork.19"
+version = "0.27.0-fork.29"
 dependencies = [
  "aes-gcm",
  "async-trait",

cli/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "agent-browser-stealth"
-version = "0.27.0-fork.19"
+version = "0.27.0-fork.29"
 edition = "2021"
 description = "Fast browser automation CLI for AI agents"
 license = "Apache-2.0"

cli/src/connect.rs

@@ -399,9 +399,14 @@ pub fn run_nm_host() {
 
 async fn nm_host_main() {
     use crate::native::relay::{RelayOut, RelayState};
+    use std::collections::HashMap;
+    use std::sync::atomic::{AtomicU64, Ordering};
     use std::sync::Arc;
     use tokio::io::{AsyncReadExt, AsyncWriteExt};
-    use tokio::sync::{broadcast, mpsc, Mutex};
+    use tokio::sync::{mpsc, Mutex};
+
+    /// client_id -> unbounded sender feeding that client's ws writer.
+    type ClientMap = Arc<Mutex<HashMap<u64, mpsc::UnboundedSender<String>>>>;
 
     nm_log(&format!(
         "[nm-host] start argv={:?}",
@@ -432,7 +437,8 @@ async fn nm_host_main() {
     nm_log(&format!("[nm-host] cdp endpoint {url}"));
 
     let state = Arc::new(Mutex::new(RelayState::new()));
-    let (to_clients, _) = broadcast::channel::<String>(4096);
+    let clients: ClientMap = Arc::new(Mutex::new(HashMap::new()));
+    let next_client_id = Arc::new(AtomicU64::new(1));
     let (to_ext, mut to_ext_rx) = mpsc::channel::<Vec<u8>>(4096);
 
     // Single writer to Chrome (extension) over stdout, native-messaging framed.
@@ -450,7 +456,8 @@ async fn nm_host_main() {
     // Accept agent-browser CDP clients on the guid-scoped ws endpoint.
     {
         let state = state.clone();
-        let to_clients = to_clients.clone();
+        let clients = clients.clone();
+        let next_client_id = next_client_id.clone();
         let to_ext = to_ext.clone();
         let guid = guid.clone();
         tokio::spawn(async move {
@@ -460,11 +467,14 @@ async fn nm_host_main() {
                     Err(_) => break,
                 };
                 let st = state.clone();
-                let rx = to_clients.subscribe();
+                let client_id = next_client_id.fetch_add(1, Ordering::Relaxed);
+                let (ctx, crx) = mpsc::unbounded_channel::<String>();
+                clients.lock().await.insert(client_id, ctx);
                 let tx = to_ext.clone();
                 let g = guid.clone();
+                let cls = clients.clone();
                 tokio::spawn(async move {
-                    handle_cdp_client(stream, g, st, rx, tx).await;
+                    handle_cdp_client(stream, g, st, client_id, crx, tx, cls).await;
                 });
             }
         });
@@ -492,8 +502,23 @@ async fn nm_host_main() {
         };
         for o in outs {
             match o {
-                RelayOut::ToClient(m) => {
-                    let _ = to_clients.send(m.to_string());
+                RelayOut::ToClient { to, msg } => {
+                    let text = msg.to_string();
+                    let cls = clients.lock().await;
+                    match to {
+                        // Command reply → only the client that issued it.
+                        Some(cid) => {
+                            if let Some(tx) = cls.get(&cid) {
+                                let _ = tx.send(text);
+                            }
+                        }
+                        // CDP event → fan out to every connected client.
+                        None => {
+                            for tx in cls.values() {
+                                let _ = tx.send(text.clone());
+                            }
+                        }
+                    }
                 }
                 RelayOut::ToExt(m) => {
                     let _ = to_ext.send(m.to_string().into_bytes()).await;
@@ -505,16 +530,20 @@ async fn nm_host_main() {
     let _ = std::fs::remove_file(relay_url_path());
 }
 
+#[allow(clippy::too_many_arguments)]
 async fn handle_cdp_client(
     stream: tokio::net::TcpStream,
     guid: String,
     state: std::sync::Arc<tokio::sync::Mutex<crate::native::relay::RelayState>>,
-    mut from_relay: tokio::sync::broadcast::Receiver<String>,
+    client_id: u64,
+    mut from_relay: tokio::sync::mpsc::UnboundedReceiver<String>,
     to_ext: tokio::sync::mpsc::Sender<Vec<u8>>,
+    clients: std::sync::Arc<
+        tokio::sync::Mutex<std::collections::HashMap<u64, tokio::sync::mpsc::UnboundedSender<String>>>,
+    >,
 ) {
     use crate::native::relay::ClientRoute;
     use futures_util::{SinkExt, StreamExt};
-    use tokio::sync::broadcast::error::RecvError;
     use tokio_tungstenite::tungstenite::Message;
 
     let want_path = format!("/{guid}");
@@ -542,9 +571,8 @@ async fn handle_cdp_client(
     loop {
         tokio::select! {
             relayed = from_relay.recv() => match relayed {
-                Ok(text) => { if tx.send(Message::Text(text)).await.is_err() { break } }
-                Err(RecvError::Lagged(_)) => continue,
-                Err(RecvError::Closed) => break,
+                Some(text) => { if tx.send(Message::Text(text)).await.is_err() { break } }
+                None => break,
             },
             incoming = rx.next() => match incoming {
                 Some(Ok(Message::Text(text))) => {
@@ -552,7 +580,7 @@ async fn handle_cdp_client(
                         Ok(v) => v,
                         Err(_) => continue,
                     };
-                    let route = { state.lock().await.route_client_command(&v) };
+                    let route = { state.lock().await.route_client_command(client_id, &v) };
                     match route {
                         ClientRoute::Local(reply) => {
                             if tx.send(Message::Text(reply.to_string())).await.is_err() { break }
@@ -567,5 +595,8 @@ async fn handle_cdp_client(
             },
         }
     }
+    // Unregister and forget this client's in-flight commands.
+    clients.lock().await.remove(&client_id);
+    state.lock().await.drop_client(client_id);
     nm_log("[nm-host] cdp client disconnected");
 }

cli/src/main.rs

@@ -658,8 +658,15 @@ fn main() {
         if clean.get(1).map(|s| s.as_str()) == Some("connect") {
             match connect::relay_url() {
                 Some(url) => {
+                    // The connect path reads `flags.cdp` (parsed from the original
+                    // argv, which was `extension connect` → None), NOT `clean`.
+                    // Without this the relay URL is dropped and we fall through to
+                    // auto-connect, grabbing some other Chrome (stale :9222) or
+                    // popping the remote-debug prompt. Point the daemon at the
+                    // relay explicitly.
+                    flags.cdp = Some(url.clone());
+                    flags.auto_connect = false;
                     clean = vec!["connect".to_string(), url];
-                    // fall through to the normal connect handling below
                 }
                 None => {
                     eprintln!(

cli/src/native/actions.rs

@@ -672,7 +672,10 @@ impl DaemonState {
                     }
 
                     let tab_id = mgr.assign_tab_id();
-                    mgr.add_page(super::browser::PageInfo {
+                    // Passively discovered (event-driven) — must NOT steal the
+                    // active tab, or a foreign/user/other-session tab opening
+                    // hijacks this session's eval/screenshot target.
+                    mgr.add_background_page(super::browser::PageInfo {
                         tab_id,
                         label: None,
                         target_id: te.target_info.target_id.clone(),

cli/src/native/browser.rs

@@ -12,6 +12,11 @@ use super::cdp::lightpanda::{launch_lightpanda, LightpandaLaunchOptions, Lightpa
 use super::cdp::types::*;
 use super::element::{resolve_element_object_id, RefMap};
 
+/// The daemon's session name, set once at daemon start. Names the Chrome tab
+/// group that abs-created tabs land in when driving the user's real Chrome via
+/// the `ab-connect` extension, so each agent/session gets its own group.
+pub static DAEMON_SESSION: std::sync::OnceLock<String> = std::sync::OnceLock::new();
+
 // ---------------------------------------------------------------------------
 // Launch validation
 // ---------------------------------------------------------------------------
@@ -568,12 +573,14 @@ impl BrowserManager {
 
         if page_targets.is_empty() {
             // Create a new tab
+            let agent_group = self.agent_group();
             let result: CreateTargetResult = self
                 .client
                 .send_command_typed(
                     "Target.createTarget",
                     &CreateTargetParams {
                         url: "about:blank".to_string(),
+                        agent_group,
                     },
                     None,
                 )
@@ -958,12 +965,14 @@ impl BrowserManager {
             return Ok(());
         }
 
+        let agent_group = self.agent_group();
         let result: CreateTargetResult = self
             .client
             .send_command_typed(
                 "Target.createTarget",
                 &CreateTargetParams {
                     url: "about:blank".to_string(),
+                    agent_group,
                 },
                 None,
             )
@@ -1072,6 +1081,27 @@ impl BrowserManager {
         self.pages.iter().any(|p| p.label.as_deref() == Some(label))
     }
 
+    /// Chrome tab-group name for tabs this manager creates, or `None` when not
+    /// driving the user's real Chrome via the `ab-connect` extension relay.
+    ///
+    /// Grouping only makes sense on the shared real browser (one Chrome, many
+    /// agents): each session's tabs go into its own group. On a launched / direct
+    /// CDP browser the endpoint is strict, so we must NOT send the custom param —
+    /// hence `None` there. We detect the relay by matching our `ws_url` against
+    /// the live relay URL the native-messaging host published.
+    fn agent_group(&self) -> Option<String> {
+        let via_relay = crate::connect::relay_url().as_deref() == Some(self.ws_url.as_str());
+        if !via_relay {
+            return None;
+        }
+        let name = DAEMON_SESSION.get().map(String::as_str).unwrap_or("default");
+        if name.is_empty() {
+            None
+        } else {
+            Some(name.to_string())
+        }
+    }
+
     pub async fn tab_new(
         &mut self,
         url: Option<&str>,
@@ -1096,12 +1126,14 @@ impl BrowserManager {
 
         let target_url = url.unwrap_or("about:blank");
 
+        let agent_group = self.agent_group();
         let result: CreateTargetResult = self
             .client
             .send_command_typed(
                 "Target.createTarget",
                 &CreateTargetParams {
                     url: target_url.to_string(),
+                    agent_group,
                 },
                 None,
             )
@@ -1500,6 +1532,21 @@ impl BrowserManager {
         self.active_page_index = index;
     }
 
+    /// Add a passively-discovered page WITHOUT changing the active tab.
+    ///
+    /// On a shared browser (ab-connect), `Target.targetCreated` events stream in
+    /// for tabs the user or OTHER agent sessions open. Those are drained on every
+    /// command; routing them through `add_page` made the active tab silently jump
+    /// to a foreign tab, so the session's own `eval`/`get title`/`screenshot`
+    /// landed on the wrong page. Passively-tracked pages must not steal focus —
+    /// only explicit opens (`tab new`, switch) set the active tab.
+    pub fn add_background_page(&mut self, page: PageInfo) {
+        if self.pages.iter().any(|p| p.target_id == page.target_id) {
+            return;
+        }
+        self.pages.push(page);
+    }
+
     pub fn update_page_target_info(&mut self, target: &TargetInfo) -> bool {
         update_page_target_info_in_pages(&mut self.pages, target)
     }

cli/src/native/cdp/chrome.rs

@@ -146,6 +146,16 @@ struct ChromeArgs {
     temp_user_data_dir: Option<PathBuf>,
 }
 
+/// Whether to launch Chrome headless. The stealth fork FORBIDS headless (it's a
+/// bot-detection tell), so this is `false` unless an operator explicitly opts in
+/// via `AGENT_BROWSER_ALLOW_HEADLESS=1` for a display-less server. The `headless`
+/// LaunchOption is intentionally ignored — headed is non-negotiable for stealth.
+fn launch_headless() -> bool {
+    std::env::var("AGENT_BROWSER_ALLOW_HEADLESS")
+        .map(|v| v == "1" || v.eq_ignore_ascii_case("true"))
+        .unwrap_or(false)
+}
+
 /// Decide the `--force-webrtc-ip-handling-policy` value, if any, for a launched
 /// Chrome. Returns `None` to leave WebRTC at Chrome's default behavior.
 fn webrtc_ip_handling_policy(has_proxy: bool) -> Option<&'static str> {
@@ -202,9 +212,13 @@ fn build_chrome_args(options: &LaunchOptions) -> Result<ChromeArgs, String> {
         .as_ref()
         .is_some_and(|exts| !exts.is_empty());
 
-    // Extensions require headed mode in native Chrome (content scripts are not
-    // injected in headless mode).  Skip --headless when extensions are loaded.
-    if options.headless && !has_extensions {
+    // Stealth fork: NEVER launch headless. Headless Chrome is a detectable tell
+    // (creepjs scores ~33% headless even with new-headless; a real GPU and a
+    // headed window score 0%). So we always launch headed and ignore the
+    // `headless` option. The only escape is an explicit AGENT_BROWSER_ALLOW_HEADLESS=1
+    // for genuinely display-less servers (discouraged — it forfeits stealth).
+    // Extensions also require headed mode (content scripts aren't injected headless).
+    if launch_headless() && !has_extensions {
         args.push("--headless=new".to_string());
         // Linux paints native scrollbars into viewport screenshots unless
         // Chrome is launched with this flag. `--hide-scrollbars` is
@@ -278,7 +292,7 @@ fn build_chrome_args(options: &LaunchOptions) -> Result<ChromeArgs, String> {
         .iter()
         .any(|a| a.starts_with("--start-maximized") || a.starts_with("--window-size="));
 
-    if !has_window_size && options.headless && !has_extensions {
+    if !has_window_size && launch_headless() && !has_extensions {
         let (w, h) = options.viewport_size.unwrap_or((1280, 720));
         args.push(format!("--window-size={},{}", w, h));
     }
@@ -759,6 +773,26 @@ fn running_process_cmdlines() -> Option<Vec<String>> {
 }
 
 pub async fn auto_connect_cdp() -> Result<String, String> {
+    // Prefer the dialog-free `ab-connect` extension relay when it is live.
+    // The relay drives the user's REAL Chrome via the extension's
+    // `chrome.debugger` permission, which — unlike a raw `--remote-debugging-port`
+    // CDP attach — never triggers Chrome 136+'s per-connection
+    // "Allow remote debugging?" consent modal. The native-messaging host writes
+    // ~/.agent-browser/relay-cdp-url while connected and removes it on exit, so a
+    // present URL means the relay is up. This must win over the DevToolsActivePort
+    // / :9222 probes below: if the user's Chrome happens to also be listening on a
+    // debug port, attaching there would pop the consent dialog and defeat the
+    // whole zero-interaction extension path.
+    if let Some(relay) = crate::connect::relay_url() {
+        // The relay is a local CDP-over-WS endpoint we connect to like Chrome.
+        // A bare TCP liveness check (no WS upgrade) confirms it is actually
+        // accepting before we commit, mirroring the consent-free probe used for
+        // DevToolsActivePort.
+        if relay_is_live(&relay).await {
+            return Ok(relay);
+        }
+    }
+
     let user_data_dirs = get_chrome_user_data_dirs();
 
     for dir in &user_data_dirs {
@@ -836,6 +870,22 @@ async fn tcp_port_alive(port: u16) -> bool {
     )
 }
 
+/// Consent-free liveness for the `ab-connect` relay ws URL (`ws://127.0.0.1:<port>/…`).
+/// Parses the port and does a bare TCP connect — a stale relay-cdp-url file
+/// (host exited without cleanup) must not divert auto-connect away from the
+/// working port path.
+async fn relay_is_live(ws_url: &str) -> bool {
+    let port = ws_url
+        .strip_prefix("ws://")
+        .and_then(|rest| rest.split('/').next())
+        .and_then(|hostport| hostport.rsplit(':').next())
+        .and_then(|p| p.parse::<u16>().ok());
+    match port {
+        Some(p) => tcp_port_alive(p).await,
+        None => false,
+    }
+}
+
 /// Returns the default Chrome user-data directory paths for the current platform.
 /// Includes Chrome, Chrome Canary, Chromium, and Brave.
 pub fn get_chrome_user_data_dirs() -> Vec<PathBuf> {
@@ -1520,24 +1570,44 @@ mod tests {
     }
 
     #[test]
-    fn test_build_args_headless_includes_headless_flag() {
+    fn test_build_args_forbids_headless_by_default() {
+        // Stealth fork: headless is FORBIDDEN. `headless: true` is ignored — the
+        // launch is always headed (no --headless / swiftshader / forced size).
+        let g = EnvGuard::new(&["AGENT_BROWSER_ALLOW_HEADLESS"]);
+        g.remove("AGENT_BROWSER_ALLOW_HEADLESS");
+        let opts = LaunchOptions {
+            headless: true,
+            ..Default::default()
+        };
+        let result = build_chrome_args(&opts).unwrap();
+        assert!(
+            !result.args.iter().any(|a| a.contains("--headless")),
+            "headless must be forbidden even when the headless option is true"
+        );
+        assert!(!result
+            .args
+            .iter()
+            .any(|a| a == "--enable-unsafe-swiftshader"));
+        if let Some(dir) = result.temp_user_data_dir {
+            let _ = std::fs::remove_dir_all(&dir);
+        }
+    }
+
+    #[test]
+    fn test_build_args_allow_headless_escape() {
+        // The only way back to headless: an explicit opt-in for display-less servers.
+        let g = EnvGuard::new(&["AGENT_BROWSER_ALLOW_HEADLESS"]);
+        g.set("AGENT_BROWSER_ALLOW_HEADLESS", "1");
         let opts = LaunchOptions {
             headless: true,
             ..Default::default()
         };
         let result = build_chrome_args(&opts).unwrap();
         assert!(result.args.iter().any(|a| a == "--headless=new"));
-        assert!(result.args.iter().any(|a| a == "--hide-scrollbars"));
-        assert!(result
-            .args
-            .iter()
-            .any(|a| a == "--enable-unsafe-swiftshader"));
         assert!(result.args.iter().any(|a| a == "--window-size=1280,720"));
-        // Temp dir created when no profile
-        assert!(result.temp_user_data_dir.is_some());
-        let dir = result.temp_user_data_dir.unwrap();
-        assert!(dir.exists());
-        let _ = std::fs::remove_dir_all(&dir);
+        if let Some(dir) = result.temp_user_data_dir {
+            let _ = std::fs::remove_dir_all(&dir);
+        }
     }
 
     #[test]
@@ -2166,4 +2236,35 @@ mod tests {
         let result = resolve_cdp_from_active_port(port, "/devtools/browser/dead").await;
         assert!(result.is_err(), "should fail when nothing is listening");
     }
+
+    #[tokio::test]
+    async fn test_relay_is_live_true_when_listening() {
+        let listener = tokio::net::TcpListener::bind("127.0.0.1:0").await.unwrap();
+        let port = listener.local_addr().unwrap().port();
+        let url = format!("ws://127.0.0.1:{}/abc-guid", port);
+        assert!(
+            relay_is_live(&url).await,
+            "relay_is_live should be true while the port is accepting"
+        );
+    }
+
+    #[tokio::test]
+    async fn test_relay_is_live_false_when_dead() {
+        // Bind to grab a free port, then drop so nothing is listening.
+        let listener = tokio::net::TcpListener::bind("127.0.0.1:0").await.unwrap();
+        let port = listener.local_addr().unwrap().port();
+        drop(listener);
+        let url = format!("ws://127.0.0.1:{}/abc-guid", port);
+        assert!(
+            !relay_is_live(&url).await,
+            "relay_is_live must be false for a stale relay-cdp-url (host exited)"
+        );
+    }
+
+    #[tokio::test]
+    async fn test_relay_is_live_false_on_malformed_url() {
+        assert!(!relay_is_live("not-a-ws-url").await);
+        assert!(!relay_is_live("ws://127.0.0.1/no-port").await);
+        assert!(!relay_is_live("ws://127.0.0.1:notaport/x").await);
+    }
 }

cli/src/native/cdp/types.rs

@@ -106,7 +106,13 @@ pub struct TargetInfo {
     pub target_id: String,
     #[serde(rename = "type")]
     pub target_type: String,
+    // Tolerate minimal targetInfo: the ab-connect relay's synthesized
+    // Target.attachedToTarget (re-announce path) omits title/url, and real CDP
+    // occasionally omits them too. Default to empty rather than fail the whole
+    // Target.getTargets deserialize.
+    #[serde(default)]
     pub title: String,
+    #[serde(default)]
     pub url: String,
     pub attached: Option<bool>,
     pub browser_context_id: Option<String>,
@@ -141,6 +147,12 @@ pub struct SetDiscoverTargetsParams {
 #[serde(rename_all = "camelCase")]
 pub struct CreateTargetParams {
     pub url: String,
+    /// Non-CDP hint consumed only by the `ab-connect` extension: the Chrome
+    /// tab-group name to drop the new tab into (per-session grouping on the
+    /// shared real Chrome). `None` on the normal CDP path so a strict real-Chrome
+    /// endpoint never receives an unknown parameter.
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub agent_group: Option<String>,
 }
 
 #[derive(Debug, Deserialize)]

cli/src/native/daemon.rs

@@ -17,6 +17,10 @@ use super::state;
 use super::stream::StreamServer;
 
 pub async fn run_daemon(session: &str) {
+    // Record this daemon's session so tabs it opens on the shared real Chrome
+    // (via the ab-connect extension) land in a per-session Chrome tab group.
+    let _ = super::browser::DAEMON_SESSION.set(session.to_string());
+
     let socket_dir = get_daemon_socket_dir();
     if !socket_dir.exists() {
         let _ = fs::create_dir_all(&socket_dir);

cli/src/native/relay.rs

@@ -10,6 +10,17 @@
 //! extension as `forwardCDPCommand`. That keeps `CdpClient` and `browser.rs`
 //! unchanged.
 //!
+//! ## Multiple clients (concurrent agents on one shared browser)
+//!
+//! Several agent-browser daemons (one per `--session`) can connect to the same
+//! relay/Chrome at once. The extension is a single peer, so the relay must
+//! demultiplex: every forwarded command is re-keyed to a relay-global id mapped
+//! back to the originating client, and the extension's reply is routed to **only
+//! that client** (with its original id restored). Command ids from different
+//! clients therefore never collide, and one client never sees another's command
+//! replies. CDP *events* (no id) fan out to all clients, which ignore events for
+//! sessions they didn't attach.
+//!
 //! This module is the pure translation core (no I/O) so the protocol can be
 //! unit-tested; the tokio WebSocket server that drives it lives alongside.
 
@@ -20,6 +31,9 @@ use serde_json::{json, Value};
 /// Protocol version advertised in the connect handshake (matches the extension).
 pub const RELAY_PROTOCOL: i64 = 3;
 
+/// Identifies one connected CDP client (agent-browser daemon) for routing.
+pub type ClientId = u64;
+
 /// One target (tab) the extension has attached, as the relay tracks it.
 #[derive(Clone)]
 struct TargetEntry {
@@ -27,27 +41,36 @@ struct TargetEntry {
     target_info: Value,
 }
 
-/// Relay translation state: the set of targets the extension currently exposes.
+/// Relay translation state: the targets the extension exposes, plus the
+/// in-flight command map used to route extension replies back to the right
+/// client.
 #[derive(Default)]
 pub struct RelayState {
     /// targetId -> entry
     targets: HashMap<String, TargetEntry>,
+    /// relay-global command id -> (client that sent it, its original id)
+    pending: HashMap<i64, (ClientId, Value)>,
+    /// monotonic source of relay-global command ids
+    next_global_id: i64,
 }
 
-/// What to do with a raw CDP command received from the `CdpClient`.
+/// What to do with a raw CDP command received from a `CdpClient`.
 #[derive(Debug, PartialEq)]
 pub enum ClientRoute {
-    /// Answer locally; the value is a raw CDP response `{id, result}`.
+    /// Answer locally; the value is a raw CDP response `{id, result}` to send
+    /// back to the originating client only.
     Local(Value),
-    /// Forward to the extension; the value is a `forwardCDPCommand` envelope.
+    /// Forward to the extension; the value is a `forwardCDPCommand` envelope
+    /// already re-keyed to a relay-global id.
     Forward(Value),
 }
 
 /// An output the relay emits while handling an extension message.
 #[derive(Debug, PartialEq)]
 pub enum RelayOut {
-    /// Send this raw CDP message to the `CdpClient`.
-    ToClient(Value),
+    /// Send this raw CDP message to clients. `to = Some(id)` targets one client
+    /// (a command reply); `to = None` broadcasts (a CDP event).
+    ToClient { to: Option<ClientId>, msg: Value },
     /// Send this envelope message back to the extension.
     ToExt(Value),
 }
@@ -68,16 +91,38 @@ impl RelayState {
         json!({ "method": "ping" })
     }
 
-    /// Route a raw CDP command `{id, method, params?, sessionId?}` from the
+    /// Forget a disconnected client's in-flight commands so its orphaned
+    /// `pending` entries don't leak.
+    pub fn drop_client(&mut self, client_id: ClientId) {
+        self.pending.retain(|_, (cid, _)| *cid != client_id);
+    }
+
+    /// Route a raw CDP command `{id, method, params?, sessionId?}` from a
     /// `CdpClient`: answer browser-level `Target.*` discovery locally, forward
-    /// the rest to the extension.
-    pub fn route_client_command(&self, raw: &Value) -> ClientRoute {
+    /// the rest to the extension under a relay-global id keyed to `client_id`.
+    pub fn route_client_command(&mut self, client_id: ClientId, raw: &Value) -> ClientRoute {
         let id = raw.get("id").cloned().unwrap_or(Value::Null);
         let method = raw.get("method").and_then(|m| m.as_str()).unwrap_or("");
         let params = raw.get("params").cloned().unwrap_or_else(|| json!({}));
         let session_id = raw.get("sessionId").and_then(|s| s.as_str());
 
         match method {
+            // Browser-level command the daemon uses as its liveness probe
+            // (`is_connection_alive` → `Browser.getVersion`). The extension only
+            // speaks per-tab `chrome.debugger`, so forwarding it errors → the
+            // daemon would deem the connection dead and reconnect+re-discover on
+            // EVERY command, resetting the active tab (eval/screenshot drift).
+            // Answer it locally so the relay connection reads as alive.
+            "Browser.getVersion" => ClientRoute::Local(json!({
+                "id": id,
+                "result": {
+                    "protocolVersion": "1.3",
+                    "product": "Chrome/ab-connect-relay",
+                    "revision": "",
+                    "userAgent": "",
+                    "jsVersion": ""
+                }
+            })),
             // Discovery is best-effort and event-driven in real CDP; abs only
             // reads the getTargets result, so an empty ack is enough here.
             "Target.setDiscoverTargets" | "Target.setAutoAttach" => {
@@ -100,17 +145,23 @@ impl RelayState {
                     })),
                 }
             }
-            // Everything else goes to the extension's chrome.debugger.
-            _ => ClientRoute::Forward(json!({
-                "id": id,
-                "method": "forwardCDPCommand",
-                "params": { "method": method, "params": params, "sessionId": session_id },
-            })),
+            // Everything else goes to the extension's chrome.debugger. Re-key the
+            // id so this client's reply can be routed back unambiguously.
+            _ => {
+                self.next_global_id += 1;
+                let gid = self.next_global_id;
+                self.pending.insert(gid, (client_id, id));
+                ClientRoute::Forward(json!({
+                    "id": gid,
+                    "method": "forwardCDPCommand",
+                    "params": { "method": method, "params": params, "sessionId": session_id },
+                }))
+            }
         }
     }
 
     /// Handle one decoded message from the extension. Updates target state and
-    /// returns the messages to emit (to the client and/or back to the
+    /// returns the messages to emit (routed to a client and/or back to the
     /// extension). `expected_token` is matched against the connect handshake.
     pub fn handle_ext_message(&mut self, msg: &Value, expected_token: &str) -> Vec<RelayOut> {
         // Connect handshake request from the extension.
@@ -137,12 +188,20 @@ impl RelayState {
             return vec![];
         }
 
-        // Response to a forwardCDPCommand we sent → raw CDP response to client.
+        // Response to a forwardCDPCommand we sent → route the raw CDP response
+        // back to the client that issued it, with its original id restored.
         if msg.get("id").is_some()
             && (msg.get("result").is_some() || msg.get("error").is_some())
             && msg.get("method").is_none()
         {
-            let mut out = json!({ "id": msg.get("id").cloned().unwrap_or(Value::Null) });
+            let gid = msg.get("id").and_then(|i| i.as_i64());
+            let (to, orig_id) = match gid.and_then(|g| self.pending.remove(&g)) {
+                Some((client_id, orig)) => (Some(client_id), orig),
+                // No mapping (stale/unknown id) — fall back to broadcasting with
+                // whatever id the extension echoed.
+                None => (None, msg.get("id").cloned().unwrap_or(Value::Null)),
+            };
+            let mut out = json!({ "id": orig_id });
             if let Some(r) = msg.get("result") {
                 out["result"] = r.clone();
             }
@@ -153,7 +212,7 @@ impl RelayState {
                     other => other.clone(),
                 };
             }
-            return vec![RelayOut::ToClient(out)];
+            return vec![RelayOut::ToClient { to, msg: out }];
         }
 
         // CDP event forwarded from a tab.
@@ -194,12 +253,13 @@ impl RelayState {
                 _ => {}
             }
 
-            // Regular CDP event → deliver to the client with its sessionId.
+            // Regular CDP event → fan out to all clients (each filters by the
+            // sessions it attached to).
             let mut ev = json!({ "method": inner_method, "params": inner_params });
             if let Some(sid) = session_id {
                 ev["sessionId"] = json!(sid);
             }
-            return vec![RelayOut::ToClient(ev)];
+            return vec![RelayOut::ToClient { to: None, msg: ev }];
         }
 
         vec![]
@@ -247,7 +307,7 @@ mod tests {
         let out = s.handle_ext_message(&attached_event("T1", "cb-tab-1"), "tok");
         assert!(out.is_empty(), "attachedToTarget should be consumed, not forwarded");
         // Now getTargets must report it.
-        let route = s.route_client_command(&json!({ "id": 1, "method": "Target.getTargets" }));
+        let route = s.route_client_command(1, &json!({ "id": 1, "method": "Target.getTargets" }));
         match route {
             ClientRoute::Local(v) => {
                 let infos = v["result"]["targetInfos"].as_array().unwrap();
@@ -258,11 +318,27 @@ mod tests {
         }
     }
 
+    #[test]
+    fn browser_get_version_is_answered_locally() {
+        // Liveness probe must NOT be forwarded (the extension can't do
+        // browser-level commands) — else the daemon reconnects on every command.
+        let mut s = RelayState::new();
+        let route = s.route_client_command(1, &json!({ "id": 7, "method": "Browser.getVersion" }));
+        match route {
+            ClientRoute::Local(v) => {
+                assert_eq!(v["id"], 7);
+                assert!(v["result"]["protocolVersion"].is_string());
+            }
+            _ => panic!("Browser.getVersion must be answered locally"),
+        }
+    }
+
     #[test]
     fn attach_to_target_returns_known_session() {
         let mut s = RelayState::new();
         s.seed_target("T1", "cb-tab-1");
         let route = s.route_client_command(
+            7,
             &json!({ "id": 5, "method": "Target.attachToTarget", "params": { "targetId": "T1", "flatten": true } }),
         );
         assert_eq!(
@@ -273,8 +349,9 @@ mod tests {
 
     #[test]
     fn attach_to_unknown_target_errors_locally() {
-        let s = RelayState::new();
+        let mut s = RelayState::new();
         let route = s.route_client_command(
+            1,
             &json!({ "id": 6, "method": "Target.attachToTarget", "params": { "targetId": "nope" } }),
         );
         match route {
@@ -284,16 +361,17 @@ mod tests {
     }
 
     #[test]
-    fn other_commands_forward_as_envelope() {
-        let s = RelayState::new();
-        let route = s.route_client_command(&json!({
-            "id": 9, "method": "Page.navigate",
-            "params": { "url": "https://x" }, "sessionId": "cb-tab-1"
-        }));
+    fn other_commands_forward_under_global_id() {
+        let mut s = RelayState::new();
+        let route = s.route_client_command(
+            42,
+            &json!({ "id": 9, "method": "Page.navigate", "params": { "url": "https://x" }, "sessionId": "cb-tab-1" }),
+        );
         match route {
             ClientRoute::Forward(v) => {
                 assert_eq!(v["method"], "forwardCDPCommand");
-                assert_eq!(v["id"], 9);
+                // id is re-keyed to a relay-global id (not the client's 9).
+                assert_eq!(v["id"], 1);
                 assert_eq!(v["params"]["method"], "Page.navigate");
                 assert_eq!(v["params"]["sessionId"], "cb-tab-1");
                 assert_eq!(v["params"]["params"]["url"], "https://x");
@@ -303,30 +381,62 @@ mod tests {
     }
 
     #[test]
-    fn forward_command_response_becomes_client_response() {
+    fn reply_routes_back_to_the_issuing_client_with_original_id() {
         let mut s = RelayState::new();
-        let out = s.handle_ext_message(&json!({ "id": 9, "result": { "frameId": "F1" } }), "tok");
+        // Two clients each send a command that happens to share original id 1.
+        let r1 = s.route_client_command(100, &json!({ "id": 1, "method": "Page.navigate", "params": {} }));
+        let r2 = s.route_client_command(200, &json!({ "id": 1, "method": "Page.reload", "params": {} }));
+        let g1 = match r1 {
+            ClientRoute::Forward(v) => v["id"].as_i64().unwrap(),
+            _ => panic!(),
+        };
+        let g2 = match r2 {
+            ClientRoute::Forward(v) => v["id"].as_i64().unwrap(),
+            _ => panic!(),
+        };
+        assert_ne!(g1, g2, "global ids must be distinct across clients");
+
+        // Extension replies for g2 → must go to client 200 with original id 1.
+        let out = s.handle_ext_message(&json!({ "id": g2, "result": { "ok": true } }), "tok");
         assert_eq!(
             out,
-            vec![RelayOut::ToClient(json!({ "id": 9, "result": { "frameId": "F1" } }))]
+            vec![RelayOut::ToClient {
+                to: Some(200),
+                msg: json!({ "id": 1, "result": { "ok": true } })
+            }]
+        );
+        // And g1 → client 100.
+        let out = s.handle_ext_message(&json!({ "id": g1, "result": { "ok": false } }), "tok");
+        assert_eq!(
+            out,
+            vec![RelayOut::ToClient {
+                to: Some(100),
+                msg: json!({ "id": 1, "result": { "ok": false } })
+            }]
         );
     }
 
     #[test]
-    fn forward_command_error_is_wrapped() {
+    fn forward_command_error_is_wrapped_and_routed() {
         let mut s = RelayState::new();
-        let out = s.handle_ext_message(&json!({ "id": 9, "error": "boom" }), "tok");
+        let r = s.route_client_command(5, &json!({ "id": 3, "method": "Page.navigate", "params": {} }));
+        let gid = match r {
+            ClientRoute::Forward(v) => v["id"].as_i64().unwrap(),
+            _ => panic!(),
+        };
+        let out = s.handle_ext_message(&json!({ "id": gid, "error": "boom" }), "tok");
         match &out[0] {
-            RelayOut::ToClient(v) => {
-                assert_eq!(v["id"], 9);
-                assert_eq!(v["error"]["message"], "boom");
+            RelayOut::ToClient { to, msg } => {
+                assert_eq!(*to, Some(5));
+                assert_eq!(msg["id"], 3);
+                assert_eq!(msg["error"]["message"], "boom");
             }
             _ => panic!("expected ToClient"),
         }
     }
 
     #[test]
-    fn regular_event_is_forwarded_with_session() {
+    fn regular_event_broadcasts_with_session() {
         let mut s = RelayState::new();
         let ev = json!({
             "method": "forwardCDPEvent",
@@ -335,14 +445,34 @@ mod tests {
         let out = s.handle_ext_message(&ev, "tok");
         assert_eq!(
             out,
-            vec![RelayOut::ToClient(json!({
-                "method": "Page.loadEventFired",
-                "params": { "timestamp": 1.0 },
-                "sessionId": "cb-tab-1"
-            }))]
+            vec![RelayOut::ToClient {
+                to: None,
+                msg: json!({
+                    "method": "Page.loadEventFired",
+                    "params": { "timestamp": 1.0 },
+                    "sessionId": "cb-tab-1"
+                })
+            }]
         );
     }
 
+    #[test]
+    fn drop_client_clears_its_pending() {
+        let mut s = RelayState::new();
+        let r = s.route_client_command(9, &json!({ "id": 1, "method": "Page.navigate", "params": {} }));
+        let gid = match r {
+            ClientRoute::Forward(v) => v["id"].as_i64().unwrap(),
+            _ => panic!(),
+        };
+        s.drop_client(9);
+        // Reply now has no mapping → broadcast fallback (to: None), echoed id.
+        let out = s.handle_ext_message(&json!({ "id": gid, "result": {} }), "tok");
+        match &out[0] {
+            RelayOut::ToClient { to, .. } => assert_eq!(*to, None),
+            _ => panic!(),
+        }
+    }
+
     #[test]
     fn connect_handshake_validates_token() {
         let mut s = RelayState::new();

cli/src/native/state.rs

@@ -119,6 +119,8 @@ async fn collect_storage_via_temp_target(
             "Target.createTarget",
             &CreateTargetParams {
                 url: "about:blank".to_string(),
+                // Transient internal target (storage collection) — never grouped.
+                agent_group: None,
             },
             None,
         )

cli/src/native/stealth.rs

@@ -270,13 +270,18 @@ pub fn strip_source_url_labels(input: &str) -> String {
     re_block.replace_all(&output, "").to_string()
 }
 
+/// The legacy `navigator.platform` value (set via the CDP
+/// `Emulation.setUserAgentOverride` `platform` field). This is NOT the UA-CH
+/// platform (see `platform_hint`): real Chrome reports `MacIntel` on macOS and
+/// `Linux x86_64` on Linux, so emitting the UA-CH form ("macOS"/"Linux") here is
+/// a detectable mismatch against the UA's "Intel Mac OS X" / Linux strings.
 fn platform_string() -> &'static str {
     if cfg!(target_os = "macos") {
-        "macOS"
+        "MacIntel"
     } else if cfg!(target_os = "windows") {
         "Win32"
     } else {
-        "Linux"
+        "Linux x86_64"
     }
 }
 

cli/src/native/stealth_scripts.js

@@ -394,6 +394,24 @@ const __abStealth = { locale: "en-US", languages: ["en-US", "en"], allowWebGLCon
   defineVendor(navigator);
 })();
 (function(){
+  // Native > JS lies: a real headed Chrome already exposes the correct, fully
+  // native navigator.plugins (5 PDF-viewer aliases, a native item() that does
+  // the WebIDL uint32-index wrap, length on the prototype). Overriding that
+  // with a JS fake is strictly worse — it ships a non-native item() whose
+  // .toString() reveals the patch, breaks the uint32 wrap (incolumitas
+  // overflowTest), and pins an anachronistic "Native Client" plugin that modern
+  // Chrome removed. Since this fork forbids headless and always launches headed,
+  // the native plugins are present, so we leave them alone. We only fall back to
+  // a synthetic list when native plugins are genuinely empty (e.g. the
+  // discouraged AGENT_BROWSER_ALLOW_HEADLESS escape on old headless).
+  try {
+    const np = navigator.plugins;
+    const itemNative =
+      np && typeof np.item === 'function' &&
+      /\[native code\]/.test(Function.prototype.toString.call(np.item));
+    if (np && np.length > 0 && itemNative) return;
+  } catch (e) {}
+
   const makeMimeType = (type, suffixes, description) => {
     const mime = Object.create(MimeType.prototype);
     Object.defineProperties(mime, {
@@ -427,40 +445,54 @@ const __abStealth = { locale: "en-US", languages: ["en-US", "en"], allowWebGLCon
     return plugin;
   };
 
+  // Make a fake method masquerade as native: name + `[native code]` toString.
+  const maskNative = (fn, name) => {
+    Object.defineProperty(fn, 'name', { value: name, configurable: true });
+    Object.defineProperty(fn, 'toString', {
+      value: () => `function ${name}() { [native code] }`,
+      configurable: true,
+      writable: true,
+    });
+    return fn;
+  };
+
+  // Modern Chrome (since ~v109) exposes exactly these 5 PDF-viewer aliases and
+  // two mimeTypes (application/pdf, text/pdf). Native Client was removed years
+  // ago, so it must NOT appear. Each plugin carries both mimeTypes.
   const pdfMime = makeMimeType('application/pdf', 'pdf', 'Portable Document Format');
-  const chromePdfMime = makeMimeType(
-    'application/x-google-chrome-pdf',
-    'pdf',
-    'Portable Document Format'
-  );
-  const naclMime = makeMimeType('application/x-nacl', '', 'Native Client Executable');
-  const pnaclMime = makeMimeType('application/x-pnacl', '', 'Portable Native Client Executable');
+  const textPdfMime = makeMimeType('text/pdf', 'pdf', 'Portable Document Format');
+  const mimes = [pdfMime, textPdfMime];
 
   const plugins = [
-    makePlugin('Chrome PDF Plugin', 'Portable Document Format', 'internal-pdf-viewer', [chromePdfMime]),
-    makePlugin('Chrome PDF Viewer', '', 'mhjfbmdgcfjbbpaeojofohoefgiehjai', [pdfMime]),
-    makePlugin('Native Client', '', 'internal-nacl-plugin', [naclMime, pnaclMime]),
-  ];
+    'PDF Viewer',
+    'Chrome PDF Viewer',
+    'Chromium PDF Viewer',
+    'Microsoft Edge PDF Viewer',
+    'WebKit built-in PDF',
+  ].map((name) => makePlugin(name, 'Portable Document Format', 'internal-pdf-viewer', mimes));
+
   const pluginArray = Object.create(PluginArray.prototype);
   plugins.forEach((p, i) => {
     pluginArray[i] = p;
     pluginArray[p.name] = p;
   });
   Object.defineProperty(pluginArray, 'length', { get: () => plugins.length });
-  pluginArray.item = (i) => plugins[i] || null;
-  pluginArray.namedItem = (name) => plugins.find(p => p.name === name) || null;
-  pluginArray.refresh = () => {};
+  // `i >>> 0` replicates the WebIDL unsigned-long index coercion, so
+  // item(2**32) wraps to item(0) like the real native PluginArray.item.
+  pluginArray.item = maskNative((i) => plugins[i >>> 0] || null, 'item');
+  pluginArray.namedItem = maskNative((name) => plugins.find(p => p.name === name) || null, 'namedItem');
+  pluginArray.refresh = maskNative(() => {}, 'refresh');
   pluginArray[Symbol.iterator] = function*() { for (const p of plugins) yield p; };
 
-  const mimeTypes = [chromePdfMime, pdfMime, naclMime, pnaclMime];
+  const mimeTypes = [pdfMime, textPdfMime];
   const mimeTypeArray = Object.create(MimeTypeArray.prototype);
   mimeTypes.forEach((m, i) => {
     mimeTypeArray[i] = m;
     mimeTypeArray[m.type] = m;
   });
   Object.defineProperty(mimeTypeArray, 'length', { get: () => mimeTypes.length });
-  mimeTypeArray.item = (i) => mimeTypes[i] || null;
-  mimeTypeArray.namedItem = (name) => mimeTypes.find(m => m.type === name) || null;
+  mimeTypeArray.item = maskNative((i) => mimeTypes[i >>> 0] || null, 'item');
+  mimeTypeArray.namedItem = maskNative((name) => mimeTypes.find(m => m.type === name) || null, 'namedItem');
   mimeTypeArray[Symbol.iterator] = function*() { for (const m of mimeTypes) yield m; };
 
   Object.defineProperty(navigator, 'plugins', {

cli/src/output.rs

@@ -1082,7 +1082,7 @@ Global Options:
   --json               Output as JSON
   --session <name>     Use specific session
   --headers <json>     Set HTTP headers (scoped to this origin)
-  --headed             Show browser window
+  --headed             Show browser window (default; headless is forbidden — it's a bot tell)
   --enable react-devtools   Inject the React DevTools hook before any page JS
   --init-script <path>      Register a page init script (repeatable)
 
@@ -3114,7 +3114,8 @@ Options:
   --screenshot-dir <path>    Default screenshot output directory (or AGENT_BROWSER_SCREENSHOT_DIR)
   --screenshot-quality <n>   JPEG quality 0-100; ignored for PNG (or AGENT_BROWSER_SCREENSHOT_QUALITY)
   --screenshot-format <fmt>  Screenshot format: png, jpeg (or AGENT_BROWSER_SCREENSHOT_FORMAT)
-  --headed                   Show browser window (not headless) (or AGENT_BROWSER_HEADED env)
+  --headed                   Always on (default). Headless is forbidden (bot-detection tell);
+                             display-less servers can opt back in with AGENT_BROWSER_ALLOW_HEADLESS=1
   --cdp <port>               Connect via CDP (Chrome DevTools Protocol)
   --color-scheme <scheme>    Color scheme: dark, light, no-preference (or AGENT_BROWSER_COLOR_SCHEME)
   --download-path <path>     Default download directory (or AGENT_BROWSER_DOWNLOAD_PATH)

extensions/ab-connect/background.js

@@ -28,6 +28,46 @@ const tabs = new Map()
 const sessionToTab = new Map()
 /** child (OOPIF/worker) sessionId -> tabId */
 const childSessionToTab = new Map()
+/** tab-group name -> chrome tabGroups id (best-effort cache) */
+const groupIdByName = new Map()
+
+// Deterministic color per group name so a given session keeps the same color.
+const GROUP_COLORS = ['blue', 'cyan', 'green', 'yellow', 'orange', 'red', 'pink', 'purple', 'grey']
+function colorForName(name) {
+  let h = 0
+  for (let i = 0; i < name.length; i++) h = (h * 31 + name.charCodeAt(i)) >>> 0
+  return GROUP_COLORS[h % GROUP_COLORS.length]
+}
+
+// Put a freshly-created tab into the agent/session's own Chrome tab group, so
+// each agent's tabs are visually separated (from each other and from the user's
+// own tabs) on the shared real browser. Best-effort: grouping failures never
+// break tab creation.
+async function groupTabInto(tabId, name) {
+  if (!name || !chrome.tabGroups || !chrome.tabs.group) return
+  const tab = await chrome.tabs.get(tabId).catch(() => null)
+  if (!tab) return
+  let gid = groupIdByName.get(name)
+  if (gid != null) {
+    const ok = await chrome.tabGroups.get(gid).then(() => true).catch(() => false)
+    if (!ok) {
+      gid = null
+      groupIdByName.delete(name)
+    }
+  }
+  if (gid == null) {
+    // Reuse a same-titled group already in this window (survives SW restarts).
+    const found = await chrome.tabGroups.query({ windowId: tab.windowId, title: name }).catch(() => [])
+    if (found && found[0]) gid = found[0].id
+  }
+  if (gid == null) {
+    gid = await chrome.tabs.group({ tabIds: tabId })
+    await chrome.tabGroups.update(gid, { title: name, color: colorForName(name) }).catch(() => {})
+  } else {
+    await chrome.tabs.group({ groupId: gid, tabIds: tabId }).catch(() => {})
+  }
+  groupIdByName.set(name, gid)
+}
 
 function postToHost(msg) {
   try {
@@ -121,6 +161,13 @@ async function handleForwardCdpCommand(msg) {
     if (!tab.id) throw new Error('createTarget: no tab id')
     await new Promise((r) => setTimeout(r, 100))
     const t = await attachTab(tab.id)
+    // Per-session tab grouping (non-CDP hint from the daemon). Best-effort.
+    const group = typeof params?.agentGroup === 'string' ? params.agentGroup.trim() : ''
+    if (group) {
+      try {
+        await groupTabInto(tab.id, group)
+      } catch {}
+    }
     return { targetId: t.targetId }
   }
   if (method === 'Target.closeTarget') {

extensions/ab-connect/manifest.json

@@ -1,7 +1,7 @@
 {
   "manifest_version": 3,
-  "name": "agent-browser connect",
-  "version": "0.3.0",
+  "name": "agent-browser-stealth",
+  "version": "0.4.0",
   "description": "Let agent-browser drive your logged-in Chrome — install once, no token, no per-use confirmation.",
   "key": "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEA6vQIyscGIPYPZdSpPwPL0+0gxUROyRgCpmvCSDoc8XUm4qm97VbKnD9Ijc1lV22lNWZtE78gaRjt6BeSfuMgnBymnhLKjN1gU6AI5QUU0mrJyeHdWKvrKQR5FmsM2A7Xr1ykE2SiiS8zNUS3Y/6O5l+Nva7wrVy6E4a2dkBVQkOsu+DV+nEZvhIyuDY5D5SPXqNwUTWTaglwj5mjvHz36xSwCWlPmrtJ+ED0AUyrb2z4GIOmvk4kqtBVrh/UD058klLo4CkYOnIybB5aV6WYuwarfPY4bF/dLggPem+ewLNTUNBuwrxj/A4nUv0LJTuRO8rR7f8WR9qnRCY0Ic5saQIDAQAB",
   "icons": {
@@ -13,6 +13,7 @@
   "permissions": [
     "debugger",
     "tabs",
+    "tabGroups",
     "nativeMessaging",
     "storage",
     "alarms",
@@ -23,6 +24,6 @@
     "type": "module"
   },
   "action": {
-    "default_title": "agent-browser connect"
+    "default_title": "agent-browser-stealth"
   }
 }

package.json

@@ -1,7 +1,7 @@
 {
   "name": "agent-browser-stealth",
-  "version": "0.27.0-fork.19",
-  "description": "Browser automation CLI for AI agents \u2014 stealth fork with anti-detection",
+  "version": "0.27.0-fork.29",
+  "description": "Browser automation CLI for AI agents — stealth fork with anti-detection",
   "type": "module",
   "packageManager": "pnpm@11.1.3",
   "files": [

skill-data/core/SKILL.md

@@ -57,6 +57,15 @@ GUI-automation tool** like the `cua-driver` skill — see
 `agent-browser extension connect`. After that it's zero-confirmation, zero-token
 CLI. Use `--launch` instead when a fresh, isolated browser is fine.
 
+Each `--session` that connects gets its **own colored Chrome tab group** (named
+after the session) and drives only its own tabs — multiple agents share the one
+real browser without cross-talk, and the user's own tabs are never grouped. CDP
+drives the page without moving the user's mouse/keyboard, so it doesn't fight
+them for control. **Anti-detection ranking: this real logged-in Chrome (extension
+connect) > a headed launched browser > headless (forbidden).** A genuine human
+browser has no headless/automation tells at all, so prefer it for anything
+anti-bot-sensitive.
+
 ## Two ways to drive a page — and when to drop to `eval`
 
 You have a **real Chrome with the user's DOM**. Two layers, mix them freely:
@@ -506,7 +515,9 @@ and [references/authentication.md](references/authentication.md).
 ```bash
 --session <name>        # isolated browser session
 --json                  # JSON output (for machine parsing)
---headed                # show the window (default is headless)
+--headed                # default & always-on for stealth — headless is FORBIDDEN
+                        #   (a bot tell: creepjs flags ~33% headless vs 0% headed).
+                        #   Display-less servers only: AGENT_BROWSER_ALLOW_HEADLESS=1
 --auto-connect          # connect to an already-running Chrome
 --cdp <port>            # connect to a specific CDP port
 --profile <name|path>   # use a Chrome profile (login state survives)

skill-data/core/references/commands.md

@@ -302,7 +302,8 @@ agent-browser state load auth.json    # Restore saved state
 ```bash
 agent-browser --session <name> ...    # Isolated browser session
 agent-browser --json ...              # JSON output for parsing
-agent-browser --headed ...            # Show browser window (not headless)
+agent-browser --headed ...            # Default & always-on (stealth). Headless is FORBIDDEN
+                                      #   (bot tell); display-less servers: AGENT_BROWSER_ALLOW_HEADLESS=1
 agent-browser --full ...              # Full page screenshot (-f)
 agent-browser --cdp <port> ...        # Connect via Chrome DevTools Protocol
 agent-browser -p <provider> ...       # Cloud browser provider (--provider)