File size: 1,495 Bytes
108e227 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 | """Extraction seams and lifecycle coverage for API run idempotency."""
from unittest.mock import MagicMock
import pytest
from gateway.config import Platform, PlatformConfig
from gateway.platforms import api_server
@pytest.mark.asyncio
async def test_api_server_constructor_uses_module_run_store_binding(monkeypatch):
store = MagicMock()
store_factory = MagicMock(return_value=store)
monkeypatch.setattr(api_server, "RunIdempotencyStore", store_factory)
adapter = api_server.APIServerAdapter(PlatformConfig(enabled=True))
try:
store_factory.assert_called_once_with()
assert adapter._run_idempotency_store is store
finally:
await adapter.disconnect()
store.close.assert_called_once_with()
@pytest.mark.asyncio
async def test_disconnect_tolerates_bare_fixture_without_run_idempotency_store():
adapter = api_server.APIServerAdapter.__new__(api_server.APIServerAdapter)
adapter.platform = Platform.API_SERVER
adapter._mark_disconnected = MagicMock()
adapter._close_cached_session_dbs = MagicMock()
adapter._response_store = MagicMock()
adapter._site = None
adapter._runner = None
adapter._app = object()
assert not hasattr(adapter, "_run_idempotency_store")
await adapter.disconnect()
adapter._mark_disconnected.assert_called_once_with()
adapter._response_store.close.assert_called_once_with()
adapter._close_cached_session_dbs.assert_called_once_with()
assert adapter._app is None
|