From 1e874e790c12839695761a654b44fb427149a353 Mon Sep 17 00:00:00 2001
From: "bozo.kopic" <bozo@kopic.xyz>
Date: Wed, 28 Jul 2021 01:43:55 +0200
Subject: init

---
 test_pytest/test_server.py | 50 ++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 50 insertions(+)
 create mode 100644 test_pytest/test_server.py

(limited to 'test_pytest/test_server.py')

diff --git a/test_pytest/test_server.py b/test_pytest/test_server.py
new file mode 100644
index 0000000..2287f57
--- /dev/null
+++ b/test_pytest/test_server.py
@@ -0,0 +1,50 @@
+import itertools
+
+import pytest
+
+from hat import aio
+from hat import util
+
+import restlog.server
+
+
+pytestmark = pytest.mark.asyncio
+
+
+@pytest.fixture
+def port():
+    return util.get_unused_tcp_port()
+
+
+class Backend(aio.Resource):
+
+    def __init__(self):
+        self._async_group = aio.Group()
+        self._next_entry_ids = itertools.count(1)
+
+    @property
+    def async_group(self):
+        return self._async_group
+
+    async def register(self, timestamp, address, source, type, data):
+        return {'entry_id': next(self._next_entry_ids),
+                'timestamp': timestamp,
+                'address': address,
+                'source': source,
+                'type': type,
+                'data': data}
+
+    async def get_entries(self, source=None, type=None, last_entry_id=None,
+                          max_results=None):
+        return {'entries': [],
+                'more': False}
+
+    async def get_entry(self, entry_id):
+        return
+
+
+async def test_create(port):
+    backend = Backend()
+    server = await restlog.server.create('127.0.0.1', port, backend)
+    assert server.is_open
+    await server.async_close()
-- 
cgit v1.2.3-70-g09d2