pyr0ball
1bc47b8e0f
Backend:
- Session.last_subscriber_left_at: monotonic timestamp set when last SSE subscriber
leaves, cleared when a new one arrives
- Session.subscriber_count(): replaces len(_subscribers) access from outside the model
- session_store._reaper_loop(): kills sessions with no subscribers for >SESSION_IDLE_TTL_S
(default 90s); runs every TTL/2 seconds via asyncio.create_task at startup
- session_store._reaper_loop_once(): single-cycle variant for deterministic tests
- app/main.py lifespan: starts reaper on startup, cancels it cleanly on shutdown
- config.py: SESSION_IDLE_TTL_S setting (90s default, overridable per-env)
Frontend:
- useWakeLock.ts: Screen Wake Lock API wrapper; acquires on connect, releases on
disconnect; degrades silently when unsupported (battery saver, iOS Safari)
- useToneStream.ts: visibilitychange handler — on hidden: closes EventSource without
ending backend session (grace window stays open); on visible: GET /session/{id}
liveness check, reconnects SSE + re-acquires wake lock if alive, sets expired=true
and calls store.reset() if reaped
- ComposeBar.vue: surfaces expired state with calm 'Session timed out' notice
(not an error — expected behaviour on long screen-off)
Tests:
- test_reaper.py: 7 tests covering subscriber idle tracking, reaper eligibility
(kills idle, spares active subscriber, spares within-TTL)
32 lines
1 KiB
Python
32 lines
1 KiB
Python
# app/models/queue_event.py — call queue state and environment events
|
|
from __future__ import annotations
|
|
|
|
import json
|
|
from dataclasses import dataclass
|
|
|
|
|
|
@dataclass
|
|
class QueueEvent:
|
|
"""
|
|
Call queue state or environmental classification from cf-voice AST.
|
|
|
|
event_type is either "queue" or "environ".
|
|
Broadcasts via SSE as `event: queue-event` or `event: environ-event`.
|
|
Not stored in session history.
|
|
"""
|
|
session_id: str
|
|
event_type: str # "queue" or "environ"
|
|
label: str # e.g. "hold_music", "ringback", "call_center", "quiet"
|
|
confidence: float
|
|
timestamp: float
|
|
|
|
def to_sse(self) -> str:
|
|
payload = {
|
|
"event_type": self.event_type,
|
|
"session_id": self.session_id,
|
|
"label": self.label,
|
|
"confidence": self.confidence,
|
|
"timestamp": self.timestamp,
|
|
}
|
|
sse_name = "queue-event" if self.event_type == "queue" else "environ-event"
|
|
return f"event: {sse_name}\ndata: {json.dumps(payload)}\n\n"
|