Frontend: scroll fix, SSE reconnect, toast global, stale states, theming
5 bloques en una pasada:
A. Scroll fixes (síntoma reportado por el usuario):
- run-timeline: nuevo flag _userScrolledUp con detección por rAF en
bindScroll. Auto-scroll al final SOLO si el usuario está abajo
(umbral 150px) o si él mismo disparó un optimistic bubble. Cuando
el usuario manda mensaje, se resetea el flag y se scrollea.
- conversation-inspector: mismo patrón. ui:chatScroll respeta el
flag userScrolledUp del emisor para no perseguir al usuario que
lee arriba.
- .bubble: + min-width:0, overflow-wrap:anywhere para URLs/JSON
largos sin espacios.
- <pre>: + overflow-x:auto, max-width:100%.
- chat-simulator: textarea con resize:vertical, min/max heights
viewport-friendly. inputs-col con overflow-y:auto.
B. Stale state options:
- conversation-list y conversations-crud: dropdowns ahora muestran
IDLE / CART / SHIPPING / AWAITING_HUMAN. Quitados BROWSING,
BUILDING_ORDER, WAITING_ADDRESS, WAITING_PAYMENT, COMPLETED.
- main.js: simulated plan.next_state pasa a CART.
C. SSE resilience (lib/sse.js):
- connect() con backoff exponencial (1s → 30s).
- safeParse() helper: cada evento envuelve JSON.parse en try-catch
para que un payload malformado no rompa otros listeners.
- reset retryDelay al primer "hello" exitoso.
- ops-shell: indicador con dot (verde "En vivo" / naranja pulsante
"Reconectando…") en lugar de texto plano.
D. Toast service global (public/lib/toast.js):
- API simple: toast({ kind, text, ms }). Apila, animación slide-in,
auto-dismiss 4s. Click para cerrar.
- safeFetch en api.js: wrapper que dispara toast en network error y
non-OK. Migrados simEvolution + retryLast.
- chat-simulator usa toast en lugar de status text efímero.
E. Theming con CSS vars:
- public/styles/theme.css con paleta completa (panels, borders,
text, accents, bubbles, charts, radii, shadows). Linkeado desde
index.html.
- Migrados a var(--*) los 5 componentes más visibles:
run-timeline, chat-simulator, conversation-inspector,
conversation-list, home-dashboard. Custom properties heredan a
través del shadow DOM, así que los demás componentes pueden
migrar gradualmente sin cambios estructurales.
- home-dashboard ya tenía vars locales: ahora apuntan a las globales.
Backend: 192/192 tests pasando. Sin cambios de API.
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
@@ -1,15 +1,71 @@
|
||||
import { emit } from "./bus.js";
|
||||
|
||||
export function connectSSE() {
|
||||
const es = new EventSource("/stream");
|
||||
/**
|
||||
* SSE client con reconnect exponencial y try-catch en parseo.
|
||||
* Si el server reinicia o un evento viene malformado, no rompe la app.
|
||||
*/
|
||||
|
||||
es.addEventListener("hello", () => emit("sse:status", { ok: true }));
|
||||
es.addEventListener("conversation.upsert", (e) => emit("conversation:upsert", JSON.parse(e.data)));
|
||||
es.addEventListener("run.created", (e) => emit("run:created", JSON.parse(e.data)));
|
||||
es.addEventListener("takeover.created", (e) => emit("takeover:created", JSON.parse(e.data)));
|
||||
es.addEventListener("order.created", (e) => emit("order:created", JSON.parse(e.data)));
|
||||
let _es = null;
|
||||
let _retryDelay = 1000;
|
||||
let _retryTimer = null;
|
||||
const MAX_RETRY = 30_000;
|
||||
|
||||
es.onerror = () => emit("sse:status", { ok: false });
|
||||
const EVENTS = [
|
||||
["conversation.upsert", "conversation:upsert"],
|
||||
["run.created", "run:created"],
|
||||
["takeover.created", "takeover:created"],
|
||||
["order.created", "order:created"],
|
||||
];
|
||||
|
||||
return es;
|
||||
function safeParse(rawData, evName) {
|
||||
try {
|
||||
return JSON.parse(rawData);
|
||||
} catch (err) {
|
||||
console.error(`[sse] bad payload for ${evName}:`, err?.message || err);
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
function attach(es) {
|
||||
es.addEventListener("hello", () => {
|
||||
_retryDelay = 1000; // reset on success
|
||||
emit("sse:status", { ok: true });
|
||||
});
|
||||
|
||||
for (const [serverName, busName] of EVENTS) {
|
||||
es.addEventListener(serverName, (e) => {
|
||||
const data = safeParse(e.data, serverName);
|
||||
if (data !== null) emit(busName, data);
|
||||
});
|
||||
}
|
||||
|
||||
es.onerror = () => {
|
||||
emit("sse:status", { ok: false });
|
||||
try { es.close(); } catch (_) {}
|
||||
if (_es === es) _es = null;
|
||||
scheduleReconnect();
|
||||
};
|
||||
}
|
||||
|
||||
function scheduleReconnect() {
|
||||
if (_retryTimer) return;
|
||||
const delay = _retryDelay;
|
||||
_retryTimer = setTimeout(() => {
|
||||
_retryTimer = null;
|
||||
connectSSE();
|
||||
}, delay);
|
||||
_retryDelay = Math.min(_retryDelay * 2, MAX_RETRY);
|
||||
}
|
||||
|
||||
export function connectSSE() {
|
||||
if (_retryTimer) {
|
||||
clearTimeout(_retryTimer);
|
||||
_retryTimer = null;
|
||||
}
|
||||
if (_es) {
|
||||
try { _es.close(); } catch (_) {}
|
||||
}
|
||||
_es = new EventSource("/stream");
|
||||
attach(_es);
|
||||
return _es;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user