- test case for server modul

DHParser/server.py

@@ -34,7 +34,6 @@ of module `server`, i.e. the compilation-modules, to decide.
 """
 
 
-
 import asyncio
 from typing import Callable, Any
 
@@ -66,13 +65,10 @@ class CompilerServer:
         await writer.drain()
         writer.close()
 
-    async def _compiler_server(self, address: str, port: int):
-        server = await syncio.start_server(self.handle_compilation_request, address, port)
+    async def serve(self, address: str='127.0.0.1', port: int=8888):
+        server = await asyncio.start_server(self.handle_compilation_request, address, port)
         async with server:
-            await server.serve_forever
-
-    def serve(self, address: str='127.0.0.1', port: int=8888):
-        # TODO: Replace this by a python 3.5. compatible construct...
-        asyncio.run(self._compiler_server())
-
+            await server.serve_forever()
 
+    def run_server(self, address: str='127.0.0.1', port: int=8888):
+        asyncio.run(self.serve(address, port))

test/test_server.py

+#!/usr/bin/python3
+
+"""test_server.py - tests of the server module of DHParser
+
+
+Author: Eckhart Arnold <arnold@badw.de>
+
+Copyright 2019 Bavarian Academy of Sciences and Humanities
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+"""
+
+import asyncio
+import os
+from multiprocessing import Process
+import sys
+from typing import Tuple
+
+from DHParser.server import CompilerServer
+
+sys.path.extend(['../', './'])
+
+scriptdir = os.path.dirname(os.path.realpath(__file__))
+
+
+def compiler_dummy(src: str, log_dir: str) -> Tuple[str, str]:
+    return (src, log_dir)
+
+class TestServer:
+    def test_server(self):
+        cs = CompilerServer(compiler_dummy)
+        p = Process(target=cs.run_server)
+        p.start()
+        async def compile(src, log_dir):
+            reader, writer = await asyncio.open_connection(
+                '127.0.0.1', 8888)
+            writer.write(src.encode())
+            data = await reader.read(100)
+            print(f'Received: {data.decode()!r}')
+            writer.close()
+        asyncio.run(compile('Test', ''))
+        p.terminate()
+
+
+
+if __name__ == "__main__":
+    from DHParser.testing import runner
+    runner("", globals())