removing waitresponse, will be using *Service.response() to get a packet. trying to figure out async generator as a service listener. WIP

1 files changed, 39 insertions, 0 deletions

diff --git a/test_gps.py b/test_gps.py
new file mode 100644
index 0000000..4c8d245
--- /dev/null
+++ b/test_gps.py
@@ -0,0 +1,39 @@
+import asyncio
+import os
+import pytest
+from gps import GPSService
+from concurrent import futures
+import logging
+
+logger = logging.getLogger('pytest-gps')
+logger.setLevel(logging.DEBUG)
+
+@pytest.fixture
+async def service():
+    address = os.environ.get('AGL_TGT_IP', 'localhost')
+    gpss = await GPSService(ip=address)
+    yield gpss
+    gpss.websocket.close()
+
+# @pytest.fixture
+# async def listener(service):
+#     loop = asyncio.get_event_loop()
+#     xc = futures.ThreadPoolExecutor(1)
+#     l = await loop.run_in_executor(xc, service.listener)
+#     while True:
+#         try:
+#             yield l.__anext__()
+#         except RuntimeError:
+#             xc.shutdown()
+#         except asyncio.CancelledError:
+#             logger.warning("Websocket listener coroutine stopped")
+#         except Exception as e:
+#             logger.error(e)
+
+@pytest.mark.asyncio
+async def test_location(service):
+    await service.location()
+    r = await service.response()
+    print(r)
+    assert True
+