Pup - the AI's own browser

@@ -4,7 +4,7 @@ members = ["core", "host", "host-win", "host-mac", "cdp", "browser", "session",  # One version for the whole bridge, in lockstep with src/BRIDGE_VERSION (tools/ship.sh bumps both). [workspace.package]-version = "2.0.694"+version = "2.0.695" edition = "2021" license = "MIT" 

@@ -169,6 +169,9 @@ pub fn reload_stale_worker(ctx: &Ctx) {     }     let pending = ctx.sessions.read_files().iter().filter(|f| f["transport"].as_str() == Some("ext")).filter_map(|f| f["sessionId"].as_str().map(|x| x.to_string())).any(|id| !ctx.sessions.exists(&id));     if pending { return; }+    // 2.0.695: and never while a window the browser holds has no session yet. adopt_stray_windows gives it one+    // (and a file) within 5 s; cycling first closed such windows for good.+    if STRAYS_WAITING.load(std::sync::atomic::Ordering::Relaxed) != 0 { return; }     let shim = crate::lane_shim(ctx);     let staged = pup_browser::stage_extensions_lane(&*ctx.host, ctx.port, "adom-you", true, Some(&lane), shim);     if staged.is_empty() { pup_core::log("[extdrive] worker reload skipped: re-staging the extension produced nothing".to_string()); return; }@@ -623,6 +626,10 @@ pub fn rebind_unbound(ctx: &Ctx) -> usize { /// dragged out of (pup still lists that tab there), else the thread whose tab opened it. rebind_unbound then /// binds its OS window and stamps the thread's tile, exactly like a window pup opened itself. A window must /// stay unowned for 5 s first, so a window pup is opening right now is never taken.+/// How many unowned windows adopt_stray_windows saw but has not adopted yet (they are inside their 5 s wait).+/// reload_stale_worker never cycles the browser while this is above zero: a window with no session has no file,+/// so the cycle would close it for good (John's laptop, 2.0.694 install: an "AI Flow" page and a YouTube video).+pub static STRAYS_WAITING: std::sync::atomic::AtomicUsize = std::sync::atomic::AtomicUsize::new(usize::MAX);   // MAX = not scanned yet pub fn adopt_stray_windows(ctx: &Ctx) -> usize {     static SEEN: Mutex<Option<std::collections::HashMap<i64, u64>>> = Mutex::new(None);     if !alive(ctx) { return 0; }@@ -638,11 +645,12 @@ pub fn adopt_stray_windows(ctx: &Ctx) -> usize {     let seen = seen.get_or_insert_with(Default::default);     seen.retain(|w, _| wins.contains_key(w));     let mut n = 0;+    let mut waiting = 0;     for (wid, wtabs) in wins {         // about:blank-only windows are close_orphan_blank_windows' job         if wtabs.iter().all(|t| { let u = t["url"].as_str().unwrap_or(""); u.is_empty() || u == "about:blank" }) { continue; }         let first = *seen.entry(wid).or_insert(now);-        if now.saturating_sub(first) < 5000 { continue; }+        if now.saturating_sub(first) < 5000 { waiting += 1; continue; }         let ids: Vec<String> = wtabs.iter().filter_map(|t| t["tabId"].as_i64()).map(|i| i.to_string()).collect();         let openers: Vec<String> = wtabs.iter().filter_map(|t| t["openerTabId"].as_i64()).map(|i| i.to_string()).collect();         let from_drag = sessions.iter().find(|s| s.tabs.iter().any(|t| ids.contains(&t.target_id)));@@ -675,6 +683,7 @@ pub fn adopt_stray_windows(ctx: &Ctx) -> usize {         seen.remove(&wid);         n += 1;     }+    STRAYS_WAITING.store(waiting, std::sync::atomic::Ordering::Relaxed);     n }