Files
interactive-story/backend/tests/test_take_edit.py
parththakkar106andClaude Opus 5 f1bebe18d0 Drop the eight legacy columns SP8 left behind
Migrations 66 to 73 drop `actions.index`, `variants`, `variant_index`,
`variant_count`, `state_before`, and `world_state_before`, plus
`adventures.memory_cursor` and `summary_cursor`. `index` is a keyword in
SQLite, so migration 71 quotes it.

Nothing outside the migrations read these. `models.py`, `schemas.py`, and
`ACTION_LIST_COLUMNS` lose the same eight fields, `Adventure.actions` orders
by `id`, and `attempts.renumber`, `context.history.max_action_index`, and
`nodes.next_index` are deleted.

Two changes keep the migration replayable on a `create_all` database:

- `_split_variants_into_siblings` wrote through the live ORM table, so it
  stopped compiling once migration 66 removed five of its columns. It now
  writes through `_ACTIONS_AT_60`, a frozen `Table` with its own `MetaData`.
- Five data passes read columns these migrations drop. Each now calls
  `_has_columns` and returns early when the columns are absent.

`bootstrap` takes a `through` version so a migration test can stop at the
schema it asserts on.

555 tests pass, up from 549. Eight of the new cases assert each column is
gone after a real schema-45 database migrates all the way.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_0198qDK3gmgSo7EtQ4GTPqqK
2026-08-29 17:15:49 +05:30

181 lines
6.6 KiB
Python

"""Phase 14 SP9: editing the take you are actually reading.
The pager can display a turn on take 2 of 4. The transcript row for that
turn stays keyed by the live take, because that is the row the transcript
reports and the one the window carries. The take currently displayed is
known only to the client, by its own node id.
So "edit this" has two ids to choose from, and the page shipped with the
wrong one. It opened the editor on the live take's text and saved over it,
even from a row that was displaying take 2. This is a client bug, and it
is fixed in Play.jsx. The fix depends on a guarantee only the server can
make:
A take is an ordinary row to the edit endpoint, addressed by its own id,
whether or not it is the one the path runs through.
The fix also depends on the group listing reporting this correctly
afterward. This file asserts both guarantees, so the client's fix cannot
be silently broken.
python -m pytest tests/test_take_edit.py -v
"""
import pytest
from fastapi import Depends
from fastapi.testclient import TestClient
from app import auth, limits, models
from app.database import Base, SessionLocal, engine, get_db
from app.main import app
from app.routers import adventures
from fakes import ScriptedProvider
@pytest.fixture()
def client(monkeypatch):
Base.metadata.create_all(bind=engine)
setup = SessionLocal()
user = models.User(is_guest=False, email="takeedit@example.com")
setup.add(user)
setup.flush()
setup.add(models.Settings(user_id=user.id, api_key="enc:dummy", model="test-model"))
scenario = models.Scenario(user_id=user.id, title="S")
setup.add(scenario)
setup.flush()
adv = models.Adventure(
user_id=user.id, title="Vault", scenario_id=scenario.id,
script_state={}, world_state={},
)
setup.add(adv)
setup.flush()
setup.add(models.Action(adventure_id=adv.id, type="start", text="You begin."))
setup.commit()
adv_id, user_id = adv.id, user.id
setup.close()
ScriptedProvider.replies = [f"Take {n}." for n in range(1, 40)]
ScriptedProvider.calls = 0
monkeypatch.setattr(adventures.turns, "OpenAICompatibleProvider", ScriptedProvider)
monkeypatch.setattr(auth, "resolve_provider_config", lambda s: auth.ProviderConfig(
"http://fake", "k", "test-model", False))
monkeypatch.setattr(limits, "rate_limit", lambda *a, **k: None)
monkeypatch.setattr(limits, "check_row_cap", lambda *a, **k: None)
def _current_user(db=Depends(get_db)):
return db.get(models.User, user_id)
app.dependency_overrides[auth.get_current_user] = _current_user
c = TestClient(app)
c.adv_id = adv_id
try:
yield c
finally:
app.dependency_overrides.clear()
adventures.turns._active_turns.clear()
Base.metadata.drop_all(bind=engine)
def _play(client, text="look around"):
r = client.post(f"/api/adventures/{client.adv_id}/actions",
json={"type": "do", "text": text})
assert r.status_code == 200, r.text
def _retry(client):
r = client.post(f"/api/adventures/{client.adv_id}/retry")
assert r.status_code == 200, r.text
def _takes(client, action_id):
r = client.get(f"/api/adventures/{client.adv_id}/actions/{action_id}/variants")
assert r.status_code == 200, r.text
return r.json()
def _edit(client, action_id, text):
return client.patch(f"/api/adventures/{client.adv_id}/actions/{action_id}",
json={"text": text})
def _live_ai(client):
"""The AI row the transcript currently reports as live."""
adv = client.get(f"/api/adventures/{client.adv_id}").json()
return [a for a in adv["actions"] if a["type"] == "ai"][-1]
def _four_takes(client):
"""One turn, played four times. Returns (row the page holds, take list)."""
_play(client)
for _ in range(3):
_retry(client)
row = _live_ai(client)
assert row["take_count"] == 4
return row, _takes(client, row["id"])
def test_the_pager_reads_four_distinct_takes(client):
"""The premise: 2/4 and 4/4 are different rows with different words."""
row, takes = _four_takes(client)
assert [t["text"] for t in takes] == ["Take 1.", "Take 2.", "Take 3.", "Take 4."]
assert takes[3]["id"] == row["id"], "the newest take is the one the story tells"
assert takes[1]["id"] != row["id"], "2/4 is not the row the transcript is keyed by"
def test_editing_a_take_that_is_not_live_edits_that_take(client):
"""The bug, at the level the client's fix depends on.
Saving against take 2's own id must land on take 2. The request must
not be refused for being off the path, and must not be redirected onto
the live row.
"""
row, takes = _four_takes(client)
second = takes[1]
r = _edit(client, second["id"], "Take 2, rewritten.")
assert r.status_code == 200, r.text
assert r.json()["text"] == "Take 2, rewritten."
after = _takes(client, row["id"])
assert [t["text"] for t in after] == [
"Take 1.", "Take 2, rewritten.", "Take 3.", "Take 4.",
], "one take changed, and only the one addressed"
def test_editing_a_take_leaves_the_live_one_alone(client):
"""What the page did instead: the reader saw 2/4 and 4/4 was overwritten."""
row, takes = _four_takes(client)
_edit(client, takes[1]["id"], "Take 2, rewritten.")
assert _live_ai(client)["text"] == "Take 4.", "the story still tells what it told"
def test_a_take_edit_survives_paging_away_and_back(client):
"""The listing is the pager's only source, so the edit must appear in it.
The client caches this list per message, and the fix drops that cache
after an edit. If the server ever started answering from a stale copy
of its own, stepping away and back would show the text before the
edit, and this test would not catch it. That is why this test makes
the round trip.
"""
row, takes = _four_takes(client)
_edit(client, takes[1]["id"], "Take 2, rewritten.")
# Addressed by the live row, as the pager does, and by the edited take
# itself, as a client holding that id would.
assert _takes(client, row["id"])[1]["text"] == "Take 2, rewritten."
assert _takes(client, takes[1]["id"])[1]["text"] == "Take 2, rewritten."
def test_an_edited_take_is_still_the_take_it_was(client):
"""Editing text is not switching, forking, or reordering."""
row, takes = _four_takes(client)
_edit(client, takes[1]["id"], "Take 2, rewritten.")
after = _takes(client, row["id"])
assert [t["id"] for t in after] == [t["id"] for t in takes], "same rows, same order"
assert [t["active"] for t in after] == [False, False, False, True]
assert _live_ai(client)["take_index"] == 3, "still 4/4 on screen"