test_musehub_sessions_service.py
python
sha256:73f24973678ceefd56628ee17c6d0535d86e33533828af6c63348f50941515ad
Merge branch 'fix/smoke-test-tag-label' into dev
Human
15 days ago
| 1 | """Unit tests for musehub/services/musehub_sessions.py. |
| 2 | |
| 3 | Tests the service layer directly (no HTTP) to validate session creation, |
| 4 | listing, retrieval, and ordering semantics. |
| 5 | """ |
| 6 | from __future__ import annotations |
| 7 | |
| 8 | from datetime import datetime, timedelta, timezone |
| 9 | |
| 10 | import pytest |
| 11 | from sqlalchemy.ext.asyncio import AsyncSession |
| 12 | |
| 13 | from musehub.models.musehub import SessionCreate |
| 14 | from musehub.services import musehub_sessions |
| 15 | from tests.factories import create_repo |
| 16 | |
| 17 | |
| 18 | def _session_create(**kwargs: str | int | list[str]) -> SessionCreate: |
| 19 | defaults = dict( |
| 20 | participants=["alice"], |
| 21 | intent="Recording session", |
| 22 | location="Studio A", |
| 23 | ) |
| 24 | defaults.update(kwargs) |
| 25 | return SessionCreate(**defaults) |
| 26 | |
| 27 | |
| 28 | async def test_upsert_session_creates_record(db_session: AsyncSession) -> None: |
| 29 | """upsert_session returns a SessionResponse with the expected fields.""" |
| 30 | repo = await create_repo(db_session, visibility="public") |
| 31 | data = _session_create(participants=["bob", "alice"]) |
| 32 | |
| 33 | result = await musehub_sessions.upsert_session(db_session, str(repo.repo_id), data) |
| 34 | |
| 35 | assert result.session_id is not None |
| 36 | assert set(result.participants) == {"bob", "alice"} |
| 37 | assert result.intent == "Recording session" |
| 38 | assert result.location == "Studio A" |
| 39 | assert result.is_active is True |
| 40 | |
| 41 | |
| 42 | async def test_upsert_session_uses_provided_started_at(db_session: AsyncSession) -> None: |
| 43 | """started_at from the request is preserved in the session record.""" |
| 44 | repo = await create_repo(db_session) |
| 45 | t = datetime(2026, 1, 15, 10, 0, 0, tzinfo=timezone.utc) |
| 46 | data = _session_create(started_at=t) |
| 47 | |
| 48 | result = await musehub_sessions.upsert_session(db_session, str(repo.repo_id), data) |
| 49 | await db_session.commit() |
| 50 | |
| 51 | assert result.started_at is not None |
| 52 | |
| 53 | |
| 54 | async def test_list_sessions_empty_for_new_repo(db_session: AsyncSession) -> None: |
| 55 | """A new repo with no sessions returns an empty list and total=0.""" |
| 56 | repo = await create_repo(db_session) |
| 57 | sessions, total, _ = await musehub_sessions.list_sessions(db_session, str(repo.repo_id)) |
| 58 | assert sessions == [] |
| 59 | assert total == 0 |
| 60 | |
| 61 | |
| 62 | async def test_list_sessions_returns_all_sessions(db_session: AsyncSession) -> None: |
| 63 | """list_sessions returns all sessions belonging to a repo.""" |
| 64 | repo = await create_repo(db_session) |
| 65 | rid = str(repo.repo_id) |
| 66 | |
| 67 | for i in range(3): |
| 68 | await musehub_sessions.upsert_session( |
| 69 | db_session, rid, _session_create(intent=f"Session {i}") |
| 70 | ) |
| 71 | await db_session.commit() |
| 72 | |
| 73 | sessions, total, _ = await musehub_sessions.list_sessions(db_session, rid) |
| 74 | assert total == 3 |
| 75 | assert len(sessions) == 3 |
| 76 | |
| 77 | |
| 78 | async def test_list_sessions_ordered_newest_first(db_session: AsyncSession) -> None: |
| 79 | """list_sessions returns sessions sorted by started_at descending.""" |
| 80 | repo = await create_repo(db_session) |
| 81 | rid = str(repo.repo_id) |
| 82 | now = datetime.now(tz=timezone.utc) |
| 83 | |
| 84 | for i in range(3): |
| 85 | t = now - timedelta(hours=i) |
| 86 | await musehub_sessions.upsert_session( |
| 87 | db_session, rid, _session_create(started_at=t, intent=f"Session {i}") |
| 88 | ) |
| 89 | await db_session.commit() |
| 90 | |
| 91 | sessions, _, _nc = await musehub_sessions.list_sessions(db_session, rid) |
| 92 | timestamps = [s.started_at for s in sessions] |
| 93 | assert timestamps == sorted(timestamps, reverse=True) |
| 94 | |
| 95 | |
| 96 | async def test_list_sessions_isolates_by_repo(db_session: AsyncSession) -> None: |
| 97 | """Sessions from one repo do not appear when listing another repo's sessions.""" |
| 98 | repo_a = await create_repo(db_session, slug="repo-a-sess") |
| 99 | repo_b = await create_repo(db_session, slug="repo-b-sess") |
| 100 | |
| 101 | await musehub_sessions.upsert_session( |
| 102 | db_session, str(repo_a.repo_id), _session_create() |
| 103 | ) |
| 104 | await db_session.commit() |
| 105 | |
| 106 | sessions, total, _ = await musehub_sessions.list_sessions(db_session, str(repo_b.repo_id)) |
| 107 | assert total == 0 |
| 108 | assert sessions == [] |
| 109 | |
| 110 | |
| 111 | async def test_get_session_by_id(db_session: AsyncSession) -> None: |
| 112 | """get_session returns the correct session given its ID.""" |
| 113 | repo = await create_repo(db_session) |
| 114 | rid = str(repo.repo_id) |
| 115 | |
| 116 | created = await musehub_sessions.upsert_session( |
| 117 | db_session, rid, _session_create(intent="Find me") |
| 118 | ) |
| 119 | await db_session.commit() |
| 120 | |
| 121 | found = await musehub_sessions.get_session(db_session, rid, created.session_id) |
| 122 | assert found is not None |
| 123 | assert found.session_id == created.session_id |
| 124 | assert found.intent == "Find me" |
| 125 | |
| 126 | |
| 127 | async def test_get_session_nonexistent_returns_none(db_session: AsyncSession) -> None: |
| 128 | """get_session returns None for an unknown session ID.""" |
| 129 | repo = await create_repo(db_session) |
| 130 | result = await musehub_sessions.get_session( |
| 131 | db_session, str(repo.repo_id), "00000000-0000-0000-0000-000000000000" |
| 132 | ) |
| 133 | assert result is None |
| 134 | |
| 135 | |
| 136 | async def test_list_sessions_limit_respected(db_session: AsyncSession) -> None: |
| 137 | """list_sessions respects the limit parameter.""" |
| 138 | repo = await create_repo(db_session) |
| 139 | rid = str(repo.repo_id) |
| 140 | |
| 141 | for i in range(5): |
| 142 | await musehub_sessions.upsert_session(db_session, rid, _session_create()) |
| 143 | await db_session.commit() |
| 144 | |
| 145 | sessions, total, _ = await musehub_sessions.list_sessions(db_session, rid, limit=2) |
| 146 | assert total == 5 |
| 147 | assert len(sessions) == 2 |
File History
12 commits
sha256:cfefc25a166c3c3eed8ea3529aee19ea350bc05f2954d007420e924133b7d8ce
chore: pivot to nightly channel — bump version to 0.2.0.dev…
Sonnet 5
patch
13 days ago
sha256:d035733f21ccff27735fddebfbbe0ed24565a32a22db8de5885402262671ecd2
chore: bump version to 0.2.0rc15 for musehub#113 fix release
Sonnet 4.6
patch
15 days ago
sha256:0032d6cfa33bc3c8367436ad768e7dd0e339b4332153160247da8266cb5fa352
Merge branch 'task/version-tags-phase3-server' into dev
Human
17 days ago
sha256:4669620efda9ff41c55bdefd1f7bfe1c239d468428744c84ead9957e5a003a53
merge: rescue snapshot-recovery hardening (c00aa21d) into d…
Opus 4.8
minor
⚠
30 days ago
sha256:a59da49c4611b970fc4b6ae48678ce4943261c213a07ddbd73ce9201df869b4a
fix: remove false-positive proposal_comments index drop fro…
Sonnet 4.6
patch
34 days ago
sha256:0a240d6dbff234f07d98a28a4a9a68db702f3f9ff9260196f24219bdb1c0b6f3
feat: render markdown mists as HTML with heading anchor links
Sonnet 4.6
patch
35 days ago
sha256:24a7d47486ebc4ebd1832830580e177ec6f877b48dced8c000e198cdec4ce9d6
Merge 'task/bump-version-rc12' into 'dev' — proposal: Bump …
Human
36 days ago
sha256:b9ff931d147e0114a1f17060f415b89ed551c170a91ff226c70437aa5c85f9ee
Merge 'task/bump-version-rc12' into 'dev' — proposal: Bump …
Human
36 days ago
sha256:d1122d21e73471879b460037b22c0b50fded7c423444a176f248428f75dac39c
Merge 'task/fix-issue-pagination-cursor' into 'dev' — propo…
Human
36 days ago
sha256:01e18975e73d2b3cd5b6db7929c895bef9aa6e0d4391dc5b2adfc548b41318dd
Merge 'feat/adding-debug-logs-to-staging' into 'dev' — prop…
Human
36 days ago
sha256:6b1949fc2797ca4c1936a637a4cbfec828ef56cf52398a2e74ca3c4f494e728f
fix: use wire_bytes not mpack_bytes_raw in compute_object_b…
Sonnet 4.6
patch
48 days ago
sha256:b99f2455dc346966d040133f5203297e6e3ef5803a93728a2c30568d0a0f7583
rename: delta_add → delta_upsert across wire format, models…
Sonnet 4.6
patch
50 days ago