feedBack/tests/test_profile_api.py
Byron Gamatos 97a941c45d
fix(tests): join background scan/enrich workers before closing the DB (#735)
Root cause of the flaky pytest segfault (exit 139): the background scan and enrichment daemon threads (_scan_runner/_enrich_runner) use the shared MetadataDB connection, but test fixtures closed that connection in teardown without stopping them. A daemon thread mid-query on a freed SQLite conn is a native use-after-free → SIGSEGV. The app's startup kicks a scan, so almost any app-booting fixture was vulnerable. It only surfaced now because got-feedback/feedBack#728 added a push trigger, so ci/test runs on every push to main.

Fix: server.py retains the scan/enrich thread handles and adds _join_background_db_threads(); every test fixture now joins the workers before conn.close(). Verified: the full suite runs to completion (no segfault) where it previously crashed at ~25%.

Co-authored-by: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
2026-07-03 12:15:43 +02:00

156 lines
6.2 KiB
Python

"""Tests for the fee[dB]ack v0.3.0 player profile, unified XP, and streak.
Uses an isolated CONFIG_DIR per test (fresh meta.db) and FastAPI's TestClient.
"""
import importlib
import sys
import pytest
from fastapi.testclient import TestClient
@pytest.fixture()
def server(tmp_path, monkeypatch, isolate_logging):
monkeypatch.setenv("CONFIG_DIR", str(tmp_path))
monkeypatch.setenv("FEEDBACK_SKIP_STARTUP_TASKS", "1")
sys.modules.pop("server", None)
srv = importlib.import_module("server")
try:
yield srv
finally:
conn = getattr(getattr(srv, "meta_db", None), "conn", None)
if conn is not None:
getattr(__import__("sys").modules.get("server"), "_join_background_db_threads", lambda: None)()
conn.close()
sys.modules.pop("server", None)
@pytest.fixture()
def client(server):
return TestClient(server.app)
# ── Profile + onboarding ─────────────────────────────────────────────────────
def test_fresh_profile_not_onboarded(client):
r = client.get("/api/profile")
assert r.status_code == 200
body = r.json()
assert body == {"display_name": None, "avatar_url": None, "player_hash": None,
"onboarded": False, "cosmetics": {}}
def test_post_profile_onboards_and_hashes(client):
r = client.post("/api/profile", json={"display_name": " Metsamies "})
assert r.status_code == 200
body = r.json()
assert body["display_name"] == "Metsamies" # trimmed
assert body["onboarded"] is True
assert body["player_hash"] and len(body["player_hash"]) == 64
def test_player_hash_stable_across_rename(client):
client.post("/api/profile", json={"display_name": "First"})
h1 = client.get("/api/profile").json()["player_hash"]
client.post("/api/profile", json={"display_name": "Renamed"})
h2 = client.get("/api/profile").json()["player_hash"]
assert h1 == h2
assert client.get("/api/profile").json()["display_name"] == "Renamed"
@pytest.mark.parametrize("name", ["", " ", "x" * 33])
def test_post_profile_rejects_bad_name(client, name):
r = client.post("/api/profile", json={"display_name": name})
assert r.status_code == 400
def test_default_avatar_validation(client):
avatars = client.get("/api/profile/avatars").json()
assert avatars, "bundled avatars should be listed"
good = avatars[0]["name"]
r = client.post("/api/profile", json={"display_name": "A", "avatar": {"type": "default", "value": good}})
assert r.status_code == 200
assert r.json()["avatar_url"] == f"/static/v3/avatars/{good}"
# Unknown default rejected
r2 = client.post("/api/profile", json={"display_name": "A", "avatar": {"type": "default", "value": "../etc/passwd"}})
assert r2.status_code == 400
def test_unknown_upload_reference_rejected(client):
r = client.post("/api/profile", json={"display_name": "A", "avatar": {"type": "upload", "value": "/api/profile/avatar/nope.png"}})
assert r.status_code == 400
# ── Unified XP ───────────────────────────────────────────────────────────────
def test_xp_award_and_progress(client, server):
from xp import xp_for_run
r = client.post("/api/xp/award", json={"source": "song_play", "amount": xp_for_run(250)})
assert r.status_code == 200
body = r.json()
assert body["xp"] == 158 and body["level"] == 2
# progress endpoint matches
prog = client.get("/api/profile/progress").json()
assert prog["xp"] == 158 and prog["level"] == 2
def test_xp_award_rejects_negative(client):
assert client.post("/api/xp/award", json={"amount": -5}).status_code == 400
assert client.post("/api/xp/award", json={"amount": "x"}).status_code == 400
def test_seed_xp_once(server):
db = server.meta_db
assert db.get_xp() == 0
assert db.seed_xp_once(500, "minigames") is True
assert db.get_xp() == 500
# second seed is a no-op
assert db.seed_xp_once(999, "minigames") is False
assert db.get_xp() == 500
def test_seed_skipped_when_store_nonempty(server):
db = server.meta_db
db.award_xp(100)
assert db.seed_xp_once(500, "minigames") is False
assert db.get_xp() == 100
# ── Streak ───────────────────────────────────────────────────────────────────
def test_streak_transitions(server):
db = server.meta_db
assert db.record_active_day("2026-06-02") == {"current_streak": 1, "best_streak": 1, "last_active_date": "2026-06-02"}
# consecutive day → +1
assert db.record_active_day("2026-06-03")["current_streak"] == 2
# same day → unchanged
assert db.record_active_day("2026-06-03")["current_streak"] == 2
# gap → reset to 1, best preserved
after_gap = db.record_active_day("2026-06-06")
assert after_gap["current_streak"] == 1
assert after_gap["best_streak"] == 2
def test_progress_includes_streak(client, server):
server.meta_db.record_active_day("2026-06-02")
server.meta_db.record_active_day("2026-06-03")
prog = client.get("/api/profile/progress").json()
assert prog["current_streak"] == 2 and prog["best_streak"] == 2
# ── Codex-preflight regression: wrong-typed JSON fields are 400, not 500 ──────
def test_profile_wrong_typed_fields_are_400(client):
# Non-string display_name / non-dict avatar / non-string avatar.value must
# validate to 400 rather than raise AttributeError → 500.
assert client.post("/api/profile", json={"display_name": 1}).status_code == 400
assert client.post("/api/profile", json={"display_name": "Ok", "avatar": [1, 2]}).status_code == 400
assert client.post("/api/profile",
json={"display_name": "Ok", "avatar": {"type": "default", "value": 5}}).status_code == 400
def test_avatar_upload_non_string_image_is_400(client):
assert client.post("/api/profile/avatar", json={"image": 123}).status_code == 400
assert client.post("/api/profile/avatar", json={"image": []}).status_code == 400