3807c247e9
Clear stale busy/stream state before async message loads and restore snapshotted turn HTML when returning to an active stream. Co-authored-by: Cursor <cursoragent@cursor.com>
79 lines
3.5 KiB
Python
79 lines
3.5 KiB
Python
"""Regression coverage for session-switch busy-state race and live-turn restore.
|
|
|
|
Switching from a streaming session to an idle one must clear S.busy before the
|
|
async _ensureMessagesLoaded gap. Otherwise _isSessionLocallyStreaming() treats
|
|
the newly opened session as locally streaming while messages are still loading.
|
|
|
|
Switching back to a streaming session must restore the snapshotted live turn
|
|
instead of rebuilding thinking/worklog chrome from scratch.
|
|
"""
|
|
|
|
from pathlib import Path
|
|
|
|
REPO = Path(__file__).resolve().parents[1]
|
|
SESSIONS_SRC = (REPO / "static" / "sessions.js").read_text(encoding="utf-8")
|
|
UI_SRC = (REPO / "static" / "ui.js").read_text(encoding="utf-8")
|
|
|
|
|
|
def _function_body(src: str, signature: str) -> str:
|
|
start = src.find(signature)
|
|
assert start != -1, f"missing {signature}"
|
|
brace = src.find("{", start)
|
|
assert brace != -1, f"missing opening brace for {signature}"
|
|
depth = 0
|
|
for i in range(brace, len(src)):
|
|
ch = src[i]
|
|
if ch == "{":
|
|
depth += 1
|
|
elif ch == "}":
|
|
depth -= 1
|
|
if depth == 0:
|
|
return src[brace + 1 : i]
|
|
raise AssertionError(f"could not extract function body for {signature}")
|
|
|
|
|
|
def test_loadSession_clears_busy_before_async_message_load_when_server_idle():
|
|
body = _function_body(SESSIONS_SRC, "async function loadSession(")
|
|
|
|
idle_reset = body.find("if(!activeStreamId){")
|
|
assert idle_reset != -1, "loadSession must gate idle cleanup on missing active_stream_id"
|
|
idle_block = body[idle_reset : idle_reset + 500]
|
|
assert "S.busy=false" in idle_block, "idle switch must clear S.busy immediately"
|
|
assert "S.activeStreamId=null" in idle_block, "idle switch must clear S.activeStreamId immediately"
|
|
|
|
ensure_load = body.find("await _ensureMessagesLoaded(sid)")
|
|
assert ensure_load != -1, "loadSession must still lazy-load messages for idle sessions"
|
|
assert idle_reset < ensure_load, (
|
|
"S.busy must be cleared before _ensureMessagesLoaded so session-list polling "
|
|
"during the async gap does not mark the new session as locally streaming"
|
|
)
|
|
|
|
|
|
def test_loadSession_snapshots_live_turn_before_wiping_message_pane():
|
|
body = _function_body(SESSIONS_SRC, "async function loadSession(")
|
|
|
|
snap_pos = body.find("snapshotLiveTurnHtmlForSession(currentSid)")
|
|
wipe_pos = body.find('_msgInner.innerHTML=\'<div style="display:flex')
|
|
assert snap_pos != -1, "loadSession must snapshot the outgoing live turn before switching"
|
|
assert wipe_pos != -1, "loadSession must still show the loading placeholder on switch"
|
|
assert snap_pos < wipe_pos, "snapshot must run before msgInner is replaced"
|
|
|
|
|
|
def test_loadSession_restores_live_turn_on_active_stream_return_path():
|
|
body = _function_body(SESSIONS_SRC, "async function loadSession(")
|
|
|
|
phase2b = body.find("Phase 2b")
|
|
assert phase2b != -1, "loadSession must keep the idle lazy-load branch"
|
|
tail = body[phase2b:]
|
|
active_branch = tail.find("if(activeStreamId){")
|
|
assert active_branch != -1, "idle-branch active_stream_id path must exist"
|
|
restore_in_branch = tail.find("restoreLiveTurnHtmlForSession(sid)", active_branch)
|
|
assert restore_in_branch != -1, (
|
|
"active_stream_id return path must restore snapshotted live turn HTML"
|
|
)
|
|
|
|
|
|
def test_activity_timer_reads_pending_started_at():
|
|
body = _function_body(UI_SRC, "function _activityElapsedStartedAt(")
|
|
assert "pending_started_at" in body
|
|
assert "data-turn-started-at" in body or "turnStartedAt" in body
|