mirror of
https://github.com/razzant/ouroboros.git
synced 2026-10-02 19:58:46 +00:00
5085f7d0f2
Preserve durable required-ask facts after closed quiz eviction, leaving optional asks unchanged. Fold older Main cards from fresh positive single-wait census evidence without a history refetch or a multi-wait lifecycle. Preserve narration titles across finalizing outcome overlays. Cover consumer history, DOM, negative optional, stale snapshots, and desktop/narrow browser flows. Publish the launcher test fixture PID atomically; runtime launcher semantics are unchanged. Restore useful contract context and align documentation.
39 lines
2.3 KiB
Python
39 lines
2.3 KiB
Python
"""History retains wait evidence even after a closed quiz leaves the hot projection."""
|
|
import json
|
|
|
|
import pytest
|
|
|
|
from ouroboros.gateway.history import _assemble_history_response
|
|
from ouroboros.owner_quiz import record_asked, record_answered, quiz_states
|
|
from ouroboros.owner_wait import set_owner_wait
|
|
from ouroboros.projects_registry import create_project
|
|
from ouroboros.task_results import write_task_result
|
|
from ouroboros.utils import append_jsonl
|
|
|
|
|
|
@pytest.mark.parametrize("required", [True, False])
|
|
def test_evicted_closed_question_uses_durable_ask_wait_evidence(tmp_path, required):
|
|
project = create_project(tmp_path, "eviction", name="Eviction")
|
|
write_task_result(tmp_path, "t", "running", project_id=project["id"], chat_id=project["chat_id"])
|
|
for i in range(17):
|
|
qid = f"q{i}"
|
|
record_asked(tmp_path, "t", quiz_id=qid, question=qid, options=["A", "B"],
|
|
wait_for_answer=required if i == 0 else True)
|
|
if i == 0:
|
|
# A page can retain the ask without the later answer event. The hot
|
|
# projection still knows the answer until the following asks evict it.
|
|
append_jsonl(tmp_path / "logs/chat.jsonl", {
|
|
"type": "quiz", "direction": "out", "chat_id": project["chat_id"],
|
|
"task_id": "t", "ts": "2026-09-18T20:00:00Z", "text": qid,
|
|
"quiz": {"quiz_id": qid, "question": qid, "options": ["A", "B"],
|
|
"state": "open", "wait_for_answer": required}})
|
|
record_answered(tmp_path, "t", quiz_id=qid, option_index=0, request_id="answer")
|
|
set_owner_wait(tmp_path, "t", {"quiz_id": "q16", "wait_id": "w", "state": "waiting"})
|
|
assert "q0" not in quiz_states(tmp_path, "t")
|
|
rows = json.loads(_assemble_history_response(tmp_path, project["chat_id"], 100, 0))["messages"]
|
|
quiz = next(row["quiz"] for row in rows if row.get("msg_type") == "quiz")
|
|
assert quiz.get("owner_wait_state") == ("resumed" if required else None)
|
|
assert "answered_index" not in quiz, "Missing answer evidence must not be fabricated"
|
|
main = json.loads(_assemble_history_response(tmp_path, 1, 100, 0))["messages"][0]
|
|
assert main["quiz_state"] == "unknown", "Lost lifecycle remains unavailable, not guessed"
|
|
assert main.get("owner_wait_state") == ("resumed" if required else None)
|