gwoe-antragspruefer/tests/test_bewertung_repository.py

50 lines
1.8 KiB
Python
Raw Permalink Normal View History

"""Tests für BewertungRepository — Assessment-Versionshistorie (#136, ADR 0008)."""
from __future__ import annotations
import asyncio
from app.repositories import (
BewertungRepository,
InMemoryBewertungRepository,
SqliteBewertungRepository,
)
def _run(coro):
return asyncio.get_event_loop().run_until_complete(coro)
class TestProtocolConformance:
def test_in_memory_implements_protocol(self):
repo = InMemoryBewertungRepository()
assert isinstance(repo, BewertungRepository)
def test_sqlite_implements_protocol(self):
repo = SqliteBewertungRepository()
assert isinstance(repo, BewertungRepository)
class TestVersionHistory:
def test_empty_history_for_unknown_drucksache(self):
repo = InMemoryBewertungRepository()
assert _run(repo.versions("18/1")) == []
def test_versions_sorted_newest_first(self):
"""Contract: neueste Version zuerst — wie bei
database.get_assessment_history (ORDER BY version DESC)."""
repo = InMemoryBewertungRepository()
repo.add_version("18/1", version=1, gwoe_score=4.0, model="qwen-plus")
repo.add_version("18/1", version=2, gwoe_score=7.0, model="qwen-plus")
repo.add_version("18/1", version=3, gwoe_score=6.5, model="qwen-plus")
rows = _run(repo.versions("18/1"))
assert [r["version"] for r in rows] == [3, 2, 1]
def test_versions_filter_by_drucksache(self):
repo = InMemoryBewertungRepository()
repo.add_version("18/1", version=1, gwoe_score=5.0, model="qwen-plus")
repo.add_version("18/2", version=1, gwoe_score=8.0, model="qwen-plus")
rows_a = _run(repo.versions("18/1"))
rows_b = _run(repo.versions("18/2"))
assert len(rows_a) == 1 and rows_a[0]["gwoe_score"] == 5.0
assert len(rows_b) == 1 and rows_b[0]["gwoe_score"] == 8.0