Adom TTS: Text to Speech

@@ -837,6 +837,7 @@ fn set_current_clip(shared: &Arc<PlayerShared>, clip: CurrentClip) {     shared.last_ms.store(0, Ordering::SeqCst);     shared.err_code.store(0, Ordering::SeqCst);     shared.done.store(false, Ordering::SeqCst);+    shared.user_paused.store(false, Ordering::SeqCst);     if let Ok(mut e) = shared.events.lock() { e.clear(); }     if let Ok(mut c) = shared.clip.lock() { *c = clip; } }@@ -898,7 +899,8 @@ fn wait_for_clip(shared: &Arc<PlayerShared>, id: u64, surface: Surface, url: &st     const START_SECS: u64 = 28;   // room for poll latency + one re-open attempt     let started = Instant::now();     let mut deadline = started + Duration::from_secs(SERVER_DEFAULT_TIMEOUT_SECS);-    let max_deadline = started + Duration::from_secs(SERVER_MAX_TIMEOUT_SECS);+    let mut max_deadline = started + Duration::from_secs(SERVER_MAX_TIMEOUT_SECS);+    let mut pause_hold_logged = false;     let mut last_reached = 0u64;     let mut last_advance = Instant::now();     let mut last_reopen = started;@@ -924,6 +926,21 @@ fn wait_for_clip(shared: &Arc<PlayerShared>, id: u64, surface: Surface, url: &st         let reached = shared.reached_ms.load(Ordering::SeqCst);         if reached > last_reached { last_reached = reached; last_advance = Instant::now(); }         let now = Instant::now();+        // HUMAN PAUSE = hold everything. No stall-advance (a paused clip is+        // not a stuck clip), no deadline, no tab reopen, no next clip. The+        // human un-pauses when they want sound again; supersede and replay+        // preempts (checked above) still break in immediately.+        if shared.user_paused.load(Ordering::SeqCst) {+            if !pause_hold_logged {+                pause_hold_logged = true;+                log_event("pause_hold", serde_json::json!({ "id": id, "at_s": reached as f64 / 1000.0 }));+            }+            last_advance = now;+            deadline = now + Duration::from_secs(SERVER_DEFAULT_TIMEOUT_SECS);+            max_deadline = now + Duration::from_secs(SERVER_MAX_TIMEOUT_SECS);+            thread::sleep(Duration::from_millis(400));+            continue;+        }         // Recover a dead page: if it hasn't polled recently the tab is gone —         // re-open it (throttled to once / 8s) so the clip still gets heard.         let poll_age = shared.poll_age_ms();@@ -1213,6 +1230,9 @@ struct PlayerShared {     queued: AtomicU64,     served: AtomicU64,     last_poll_ms: AtomicU64,   // wall-clock ms of the page's last /poll (liveness)+    // The HUMAN paused the player. Pause = "stop talking to me": the drainer+    // holds the current clip AND the whole queue until they press play again.+    user_paused: AtomicBool,     // HUMAN PREEMPT SLOT: a history-replay tap lands here and plays IMMEDIATELY,     // interrupting the current AI clip (which re-queues and restarts after).     // Principle: the human preempts; the AI queues.@@ -1262,6 +1282,7 @@ fn start_player_server() -> Result<Player> {         events: std::sync::Mutex::new(Vec::new()),         cmd_seq: AtomicU64::new(0), cmd_str: std::sync::Mutex::new(String::new()),         queued: AtomicU64::new(0), served: AtomicU64::new(0), last_poll_ms: AtomicU64::new(0),+        user_paused: AtomicBool::new(false),         preempt: std::sync::Mutex::new(None),     });     let html = Arc::new(player_page_html());@@ -1360,6 +1381,7 @@ fn handle_player_request(request: tiny_http::Request, method: &Method, route: &s                     shared.reached_ms.fetch_max(shared.dur_ms.load(Ordering::SeqCst), Ordering::SeqCst);                     shared.done.store(true, Ordering::SeqCst);                 }+                shared.user_paused.store(qnum(query, "paused").map(|x| x >= 1.0).unwrap_or(false), Ordering::SeqCst);             }             let clip = shared.clip.lock().map(|c| c.clone()).unwrap_or_default();             let cmd = shared.cmd_str.lock().map(|s| s.clone()).unwrap_or_default();@@ -1434,12 +1456,12 @@ fn handle_player_request(request: tiny_http::Request, method: &Method, route: &s             let clip = shared.clip.lock().map(|c| c.clone()).unwrap_or_default();             let poll_age = shared.poll_age_ms().min(999_999_999);             let body = format!(-                "{{\"dur_ms\":{},\"reached_ms\":{},\"last_ms\":{},\"done\":{},\"err\":{},\"clip\":\"{}\",\"served\":{},\"queued\":{},\"poll_age_ms\":{},\"timeline\":\"{}\"}}",+                "{{\"dur_ms\":{},\"reached_ms\":{},\"last_ms\":{},\"done\":{},\"err\":{},\"clip\":\"{}\",\"served\":{},\"queued\":{},\"poll_age_ms\":{},\"paused\":{},\"timeline\":\"{}\"}}",                 shared.dur_ms.load(Ordering::SeqCst), shared.reached_ms.load(Ordering::SeqCst),                 shared.last_ms.load(Ordering::SeqCst), shared.done.load(Ordering::SeqCst),                 shared.err_code.load(Ordering::SeqCst), clip.title.replace('"', "'"),                 shared.served.load(Ordering::SeqCst), shared.queued.load(Ordering::SeqCst),-                poll_age, timeline.replace('"', "'"));+                poll_age, shared.user_paused.load(Ordering::SeqCst), timeline.replace('"', "'"));             respond_inline(request, 200, "application/json", body.into_bytes())         }         _ => respond_inline(request, 404, "text/plain", b"not found".to_vec()),