From 5bd5f0966a48fb3a65a109e3e89a62d94a82fd97 Mon Sep 17 00:00:00 2001 From: Vladislav Vlasuk <vladislav.vlasuk@th-koeln.de> Date: Mon, 29 Nov 2021 12:06:42 +0100 Subject: [PATCH] tests --- leap_py3/e_websocket/e_websocket_client.py | 16 ++++++++++++++ leap_py3/e_websocket/e_websocket_server.py | 17 ++++++++++++++ .../e_websocket_server_for_leap.py | 22 +++++++++++++++++++ 3 files changed, 55 insertions(+) create mode 100755 leap_py3/e_websocket/e_websocket_client.py create mode 100755 leap_py3/e_websocket/e_websocket_server.py create mode 100755 leap_py3/e_websocket/e_websocket_server_for_leap.py diff --git a/leap_py3/e_websocket/e_websocket_client.py b/leap_py3/e_websocket/e_websocket_client.py new file mode 100755 index 0000000..702cbf1 --- /dev/null +++ b/leap_py3/e_websocket/e_websocket_client.py @@ -0,0 +1,16 @@ +#!/usr/bin/env python + +import asyncio +import websockets + +async def hello(): + async with websockets.connect('ws://localhost:8765') as websocket: + + name = input("What's your name? ") + await websocket.send(name) + print("> {}".format(name)) + + greeting = await websocket.recv() + print("< {}".format(greeting)) + +asyncio.get_event_loop().run_until_complete(hello()) diff --git a/leap_py3/e_websocket/e_websocket_server.py b/leap_py3/e_websocket/e_websocket_server.py new file mode 100755 index 0000000..37744b8 --- /dev/null +++ b/leap_py3/e_websocket/e_websocket_server.py @@ -0,0 +1,17 @@ +#!/usr/bin/env python + +import asyncio +import websockets + +async def hello(websocket, path): + name = await websocket.recv() + print("< {}".format(name)) + + greeting = "Hello {}!".format(name) + await websocket.send(greeting) + print("> {}".format(greeting)) + +start_server = websockets.serve(hello, 'localhost', 8765) + +asyncio.get_event_loop().run_until_complete(start_server) +asyncio.get_event_loop().run_forever() diff --git a/leap_py3/e_websocket/e_websocket_server_for_leap.py b/leap_py3/e_websocket/e_websocket_server_for_leap.py new file mode 100755 index 0000000..64ae9dc --- /dev/null +++ b/leap_py3/e_websocket/e_websocket_server_for_leap.py @@ -0,0 +1,22 @@ +#!/usr/bin/env python +# sudo lsof -i -P -n | grep LISTEN. + +import asyncio +import websockets +import json + +async def hello(): + async with websockets.connect('ws://127.0.0.1:6437') as websocket: #6437 , 8765 + + msg=json.dumps({"background": True}) + await websocket.send(msg) + print("send {} to leapc".format(msg)) + + greeting = await websocket.recv() + print("i receive {}".format(greeting)) + + #print(json.loads(greeting)) + + +asyncio.get_event_loop().run_until_complete(hello()) + -- GitLab