Adom TTS: Text to Speech

@@ -406,6 +406,7 @@ fn enqueue(mp3: &Path) -> Result<()> {         "mp3": stored.to_string_lossy(),         "name": name,         "label": sidecar_label(mp3),+        "desc": sidecar_field(mp3, "desc"),         "meta": sidecar_meta_line(mp3),         "words": words,         "snapshot": stored == snap,@@ -586,6 +587,8 @@ pub fn drain(surface_cli: Option<Surface>) -> Result<()> {                                 .unwrap_or_else(|| mp3.file_name().and_then(|s| s.to_str()).unwrap_or("clip").to_string());                             let label = v.get("label").and_then(|s| s.as_str()).map(str::to_string)                                 .unwrap_or_else(|| sidecar_label(&mp3));+                            let desc = v.get("desc").and_then(|s| s.as_str()).map(str::to_string)+                                .unwrap_or_else(|| sidecar_field(&mp3, "desc"));                             let meta = v.get("meta").and_then(|s| s.as_str()).map(str::to_string)                                 .unwrap_or_else(|| sidecar_meta_line(&mp3));                             let words_json = v.get("words").map(|w| w.to_string())@@ -602,7 +605,8 @@ pub fn drain(surface_cli: Option<Surface>) -> Result<()> {                                 break;                             }                             set_current_clip(&player.shared, CurrentClip {-                                id, bytes: Arc::new(bytes), title: name.clone(), meta, label, words_json,+                                id, bytes: Arc::new(bytes), title: name.clone(), meta,+                                label: label.clone(), desc: desc.clone(), words_json,                             });                             log_event("clip_start", serde_json::json!({ "clip": name, "port": player.port, "surface": surface.as_str(), "id": id }));                             wait_for_clip(&player.shared, id, surface, &url, &cfg.play);@@ -622,6 +626,12 @@ pub fn drain(surface_cli: Option<Surface>) -> Result<()> {                             } else if verdict == "no-playback" {                                 log_event("clip_gave_up", serde_json::json!({ "clip": name, "attempts": attempts }));                             }+                            // Final outcome (not an in-place retry) → replayable history,+                            // with the audio preserved and the sender's label + desc.+                            if !retry_in_place {+                                let dur = player.shared.dur_ms.load(Ordering::SeqCst) as f64 / 1000.0;+                                record_play_history(&name, &label, &desc, verdict, dur, &mp3);+                            }                         }                         // Delete the byte-snapshot we owned (kept the source safe                         // from overwrites) — but only once we're done retrying.@@ -990,6 +1000,7 @@ struct CurrentClip {     title: String,     meta: String,     label: String,+    desc: String,     words_json: String, } impl Default for CurrentClip {@@ -997,11 +1008,81 @@ impl Default for CurrentClip {         CurrentClip {             id: 0, bytes: Arc::new(Vec::new()),             title: String::new(), meta: String::new(), label: String::new(),-            words_json: "[]".into(),+            desc: String::new(), words_json: "[]".into(),         }     } } +/// Persist a just-played clip into the replayable HISTORY: the human misses+/// clips (drives through a dead zone, two updates land back-to-back) and needs+/// to go BACK. Each entry keeps the audio bytes + WHO sent it (thread label) ++/// WHAT it says (the sender's --desc) so the list is human-scannable, never+/// just mp3 filenames. Capped to the newest 40 entries.+fn record_play_history(name: &str, label: &str, desc: &str, verdict: &str, dur_s: f64, mp3: &Path) {+    let Ok(home) = tts_home() else { return };+    let dir = home.join(".adom/tts/history/played");+    let _ = std::fs::create_dir_all(&dir);+    let seq = now_millis() as u64;+    let stored = dir.join(format!("{seq}.mp3"));+    if std::fs::copy(mp3, &stored).is_err() { return; }+    let entry = serde_json::json!({+        "seq": seq, "ts_ms": seq, "name": name, "label": label, "desc": desc,+        "verdict": verdict, "dur_s": (dur_s * 10.0).round() / 10.0,+        "file": stored.to_string_lossy(),+    });+    let log = home.join(".adom/tts/play_history.jsonl");+    let mut lines: Vec<String> = std::fs::read_to_string(&log).unwrap_or_default()+        .lines().map(str::to_string).collect();+    lines.push(entry.to_string());+    // prune: keep newest 40, delete evicted audio files+    while lines.len() > 40 {+        let old = lines.remove(0);+        if let Ok(v) = serde_json::from_str::<serde_json::Value>(&old) {+            if let Some(f) = v.get("file").and_then(|x| x.as_str()) { let _ = std::fs::remove_file(f); }+        }+    }+    let _ = std::fs::write(&log, lines.join("\n") + "\n");+}++/// Newest-first history entries for the player UI (label + desc + when).+fn read_play_history(limit: usize) -> Vec<serde_json::Value> {+    let Ok(home) = tts_home() else { return Vec::new() };+    let raw = std::fs::read_to_string(home.join(".adom/tts/play_history.jsonl")).unwrap_or_default();+    let mut v: Vec<serde_json::Value> = raw.lines()+        .filter_map(|l| serde_json::from_str(l).ok()).collect();+    v.reverse();+    v.truncate(limit);+    v+}++/// Re-queue a history entry (the "play that one again" button). Writes a queue+/// entry pointing at the PRESERVED history audio (snapshot:false so the drain+/// loop doesn't delete it) with "(replay)" prefixed to the description.+fn replay_history_entry(seq: u64) -> bool {+    let Some(entry) = read_play_history(40).into_iter()+        .find(|e| e.get("seq").and_then(|s| s.as_u64()) == Some(seq)) else { return false };+    let Some(file) = entry.get("file").and_then(|f| f.as_str()) else { return false };+    if !Path::new(file).exists() { return false; }+    let Ok(home) = tts_home() else { return false };+    let dir = home.join(QUEUE_SUBDIR);+    let _ = std::fs::create_dir_all(&dir);+    let qseq = format!("{:020}-{:07}", now_millis(), std::process::id());+    let desc = entry.get("desc").and_then(|d| d.as_str()).unwrap_or("")+        .trim_start_matches("(replay) ");+    let body = serde_json::json!({+        "mp3": file,+        "name": entry.get("name").and_then(|n| n.as_str()).unwrap_or("clip"),+        "label": entry.get("label").and_then(|l| l.as_str()).unwrap_or(""),+        "desc": format!("(replay) {desc}"),+        "meta": "", "words": [], "snapshot": false, "replay": true,+    }).to_string();+    let tmp = dir.join(format!(".{qseq}.tmp"));+    if std::fs::write(&tmp, body).is_err() { return false; }+    let ok = std::fs::rename(&tmp, dir.join(format!("{qseq}.json"))).is_ok();+    if ok { log_event("history_replay", serde_json::json!({ "seq": seq })); }+    ok+}+ /// State shared between the persistent HTTP worker (serves the page + audio + /// telemetry, all keyed to the current clip id) and the drainer loop (sets the /// current clip, reads back the verdict).@@ -1171,11 +1252,22 @@ fn handle_player_request(request: tiny_http::Request, method: &Method, route: &s                 "title": clip.title,                 "meta": clip.meta,                 "label": clip.label,+                "desc": clip.desc,                 "words": words,                 "queued": shared.queued.load(Ordering::SeqCst),+                "now_ms": now_ms(),+                "history": read_play_history(12),             }).to_string();             respond_inline(request, 200, "application/json", body.into_bytes())         }+        // "Play that one again" from the History drawer — re-queues the+        // preserved audio; it plays after anything already queued.+        (Method::Get, "/histplay" | "histplay") => {+            let seq = qnum(query, "seq").map(|n| n as u64).unwrap_or(0);+            let ok = seq != 0 && replay_history_entry(seq);+            respond_inline(request, 200, "application/json",+                format!("{{\"ok\":{ok}}}").into_bytes())+        }         (Method::Get, "/meta" | "meta") => {             if id_matches(query, shared) { if let Some(d) = qnum(query, "dur") { shared.dur_ms.store((d * 1000.0) as u64, Ordering::SeqCst); } }             respond_inline(request, 200, "application/json", b"{\"ok\":true}".to_vec())@@ -1358,10 +1450,15 @@ fn respond_inline(req: tiny_http::Request, status: u16, content_type: &str, body /// Read the `label` (thread name) from a `<file>.json` sidecar, for the /// player header. Empty when unset. fn sidecar_label(mp3: &Path) -> String {+    sidecar_field(mp3, "label")+}++/// Read any string field from a `<file>.json` sidecar. Empty when unset.+fn sidecar_field(mp3: &Path, key: &str) -> String {     let sidecar = mp3.with_extension("json");     std::fs::read_to_string(&sidecar).ok()         .and_then(|raw| serde_json::from_str::<serde_json::Value>(&raw).ok())-        .and_then(|v| v.get("label").and_then(|t| t.as_str()).map(str::to_string))+        .and_then(|v| v.get(key).and_then(|t| t.as_str()).map(str::to_string))         .unwrap_or_default() } 

@@ -157,6 +157,25 @@   }   .transcript:empty, .transcript.hidden { display: none; } +  /* ---- replayable history ---- */+  .history {+    margin-top: 16px; padding: 12px 14px; border-radius: 12px;+    background: rgba(0,0,0,0.22); border: 1px solid var(--border);+    max-height: 190px; overflow-y: auto;+  }+  .history.hidden { display: none; }+  .hist-label { font-size: 11px; letter-spacing: 1.5px; text-transform: uppercase; color: var(--teal); margin-bottom: 8px; opacity:.9; }+  .hist-hint { text-transform: none; letter-spacing: 0; color: var(--muted); font-size: 10.5px; margin-left: 8px; }+  .hist-row { display: flex; align-items: center; gap: 8px; padding: 5px 0; border-top: 1px solid rgba(43,58,82,.5); }+  .hist-row:first-of-type { border-top: 0; }+  .hist-thread { flex: none; font-size: 10.5px; color: var(--purple); border: 1px solid rgba(140,107,247,0.45); background: rgba(140,107,247,0.10); padding: 1px 7px; border-radius: 999px; white-space: nowrap; max-width: 34%; overflow: hidden; text-overflow: ellipsis; }+  .hist-desc { flex: 1; min-width: 0; font-size: 12.5px; color: var(--fg); white-space: nowrap; overflow: hidden; text-overflow: ellipsis; }+  .hist-desc.missed { color: var(--amber); }+  .hist-when { flex: none; font-size: 10.5px; color: var(--muted); font-variant-numeric: tabular-nums; }+  .hist-replay { flex: none; width: 26px; height: 26px; border-radius: 50%; border: 1px solid var(--border); background: var(--elevated); color: var(--teal); cursor: pointer; font-size: 13px; line-height: 1; display: flex; align-items: center; justify-content: center; transition: background .12s, transform .08s; }+  .hist-replay:hover { background: var(--teal-soft); }+  .hist-replay:active { transform: scale(.9); }+   .diag { margin-top: 14px; font-size: 10.5px; color: var(--muted); font-family: ui-monospace, Menlo, monospace; opacity: .6; word-break: break-all; }   footer { padding: 12px; text-align: center; font-size: 11px; color: var(--muted); opacity: .6; } @@ -234,6 +253,15 @@       </div>        <div id="transcript" class="transcript hidden"></div>++      <!-- Replayable history: the human misses clips (dead zones, back-to-back+           updates) — every played clip is listed with WHO sent it and WHAT it+           says, with one-tap replay. -->+      <div id="histwrap" class="history hidden">+        <div class="hist-label">History <span class="hist-hint">tap ↻ to replay</span></div>+        <div id="histlist"></div>+      </div>+       <div class="diag" id="diag"></div>     </div>   </main>@@ -323,7 +351,8 @@   function applyClip(c){     curClipId = c.id;     subjectName.textContent = c.title || 'audio clip';-    metaBase = c.meta || '';+    // show WHAT this clip is about (the sender's --desc) next to the filename+    metaBase = c.desc ? c.desc : (c.meta || '');     meta.textContent = metaBase;     if (c.label && c.label.toLowerCase() !== APP_NAME) { threadChip.textContent = c.label; threadChip.style.display = ''; }     else { threadChip.style.display = 'none'; }@@ -412,6 +441,39 @@     }   }, 2500); +  // ---- replayable history drawer ----+  const histwrap = document.getElementById('histwrap');+  const histlist = document.getElementById('histlist');+  let histKey = '';+  function ago(ms){ const s=Math.max(0,Math.round(ms/1000)); if(s<60)return s+'s'; const m=Math.round(s/60); if(m<60)return m+'m'; return Math.round(m/60)+'h'; }+  function renderHistory(items, nowMs){+    const key = items.map(e => e.seq).join(',');+    if (key === histKey) {  // entries unchanged → just refresh the ago labels+      const whens = histlist.querySelectorAll('.hist-when');+      items.forEach((e,i)=>{ if(whens[i]) whens[i].textContent = ago(nowMs - (e.ts_ms||nowMs)); });+      return;+    }+    histKey = key;+    histlist.innerHTML = '';+    if (!items.length) { histwrap.classList.add('hidden'); return; }+    histwrap.classList.remove('hidden');+    items.forEach(e => {+      const row = document.createElement('div'); row.className = 'hist-row';+      const th = document.createElement('span'); th.className = 'hist-thread'; th.textContent = e.label || '?'; row.appendChild(th);+      const d = document.createElement('span'); d.className = 'hist-desc';+      d.textContent = e.desc || e.name || 'clip';+      // a clip that never fully played is the one you MISSED — flag it+      if (e.verdict && e.verdict !== 'ok') { d.classList.add('missed'); d.textContent += '  (missed?)'; }+      d.title = (e.label?e.label+' — ':'') + (e.desc||'') + (e.dur_s?(' · '+e.dur_s+'s'):'');+      row.appendChild(d);+      const w = document.createElement('span'); w.className = 'hist-when'; w.textContent = ago(nowMs - (e.ts_ms||nowMs)); row.appendChild(w);+      const b = document.createElement('button'); b.className = 'hist-replay'; b.title = 'Play this again'; b.textContent = '↻';+      b.addEventListener('click', () => { b.textContent='…'; fetch('histplay?seq='+e.seq,{cache:'no-store'}).then(()=>{ b.textContent='✓'; setTimeout(()=>b.textContent='↻',1500); }).catch(()=>{ b.textContent='↻'; }); });+      row.appendChild(b);+      histlist.appendChild(row);+    });+  }+   // ---- live link + clip poll: one poll drives BOTH the LED heartbeat AND   // the clip swap. Each successful poll proves the front-end↔back-end pipe. ----   const led = document.getElementById('live');@@ -431,6 +493,7 @@       // queue depth chip       if (typeof j.queued === 'number' && j.queued > 0) { queueChip.textContent = '+' + j.queued + ' queued'; queueChip.classList.remove('hidden'); }       else queueChip.classList.add('hidden');+      renderHistory(j.history || [], j.now_ms || Date.now());       // NEW clip? swap without reloading the page.       if (j.id && j.id !== curClipId) applyClip(j);       else if (!j.id && curClipId && a.ended) { subjectName.textContent = 'waiting for a clip…'; }