Skip to content

Commit 52318d4

Browse files
committed
tests(integration): add stream_events integration test using real ASCII input
1 parent 7efe47a commit 52318d4

File tree

1 file changed

+18
-0
lines changed

1 file changed

+18
-0
lines changed

nessclient_tests/test_integration.py

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -197,6 +197,24 @@ async def test_event_received_callback_invoked(
197197
assert event.zone == 3
198198

199199

200+
@pytest.mark.asyncio
201+
async def test_stream_events_receives_event(
202+
client: Client, connection: Connection, alarm: Alarm
203+
) -> None:
204+
"""Integration: stream_events yields when a system status packet arrives."""
205+
stream = client.stream_events()
206+
task = asyncio.create_task(stream.__anext__())
207+
208+
# Feed a SystemStatusEvent: Zone 3 unsealed
209+
await _feed_ascii(client, connection, "87020361000301080510234500E5")
210+
211+
event = await asyncio.wait_for(task, 1.0)
212+
assert isinstance(event, SystemStatusEvent)
213+
assert event.type == SystemStatusEvent.EventType.UNSEALED
214+
assert event.zone == 3
215+
await stream.aclose()
216+
217+
200218
@pytest.fixture
201219
def alarm() -> Alarm:
202220
return Alarm()

0 commit comments

Comments
 (0)