diff examples/serve_inline_graph_test.py @ 11:0bc06da6bf74

start ferry1 patch protocol
author drewp@bigasterisk.com
date Mon, 18 Mar 2024 16:42:21 -0700
parents 52e1bb1532f2
children ba73d8ba81dc
line wrap: on
line diff
--- a/examples/serve_inline_graph_test.py	Sat Mar 16 16:02:23 2024 -0700
+++ b/examples/serve_inline_graph_test.py	Mon Mar 18 16:42:21 2024 -0700
@@ -1,9 +1,11 @@
 from pathlib import Path
-
+import logging
 import pytest
 
-from examples._run_server_child import RunHttpServerChildProcess
+from examples._run_server_child import RunHttpServerChildProcess, assert_event_stream_starts_with
 
+log = logging.getLogger('test')
+logging.basicConfig(level=logging.INFO)
 server_path = Path('examples/serve_inline_graph.py')
 
 
@@ -34,9 +36,15 @@
 '''
 
 
-# @pytest.mark.asyncio
-# async def test_server_returns_events():
-#     async with RunHttpServerChildProcess(server_path) as http_server:
-#         response = await http_server.get('http://localhost:8005/g1/events')
-#         assert response.headers['content-type'] == 'x-sse-todo'
-#         assert (await response.text()) == 'clear event then add-patch event'
+@pytest.mark.asyncio
+async def test_server_returns_startup_events():
+    async with RunHttpServerChildProcess(server_path) as http_server:
+        await assert_event_stream_starts_with(
+            http_server,
+            'http://localhost:8005/g1/events',
+            expected_events=[
+                ('clear', 'ferry1'),
+                ('patch',
+                 '-\n+\n["http://example.com/greeting", "http://www.w3.org/2000/01/rdf-schema#label", "hello world", "http://www.w3.org/2001/XMLSchema#string", "", "http://example.com/process"]'
+                 ),
+            ])