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 0000000000000000000000000000000000000000..702cbf18e01e5811cab6f3b34cd0220b4ee0a08e --- /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 0000000000000000000000000000000000000000..37744b81510920b3732f2e40a53c76e5cf2895c6 --- /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 0000000000000000000000000000000000000000..64ae9dcf958235ece25856502e3447e51931b6dc --- /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()) +