aboutsummaryrefslogtreecommitdiff
path: root/backend/microservice/api/ml_socket.py
diff options
context:
space:
mode:
authorSonja Galovic <galovicsonja@gmail.com>2022-04-13 22:44:06 +0200
committerSonja Galovic <galovicsonja@gmail.com>2022-04-13 22:44:06 +0200
commit5d856cf20177711074b473cc2d2133b85826fe63 (patch)
treec7029d75af6d53e40bf806c51f1f4fcfc2136104 /backend/microservice/api/ml_socket.py
parent3c4bfb16f55aa51a50ee99327caca639e072cdab (diff)
parent3cb8b60ed4e36f39187e64270479f472e08fb615 (diff)
Merge branch 'dev' of http://gitlab.pmf.kg.ac.rs/igrannonica/neuronstellar into dev
Diffstat (limited to 'backend/microservice/api/ml_socket.py')
-rw-r--r--backend/microservice/api/ml_socket.py30
1 files changed, 0 insertions, 30 deletions
diff --git a/backend/microservice/api/ml_socket.py b/backend/microservice/api/ml_socket.py
deleted file mode 100644
index cab157eb..00000000
--- a/backend/microservice/api/ml_socket.py
+++ /dev/null
@@ -1,30 +0,0 @@
-import asyncio
-import websockets
-import json
-
-def get_or_create_eventloop():
- try:
- return asyncio.get_event_loop()
- except RuntimeError as ex:
- if "There is no current event loop in thread" in str(ex):
- loop = asyncio.new_event_loop()
- asyncio.set_event_loop(loop)
- return asyncio.get_event_loop()
-
-# create handler for each connection
-async def handler(websocket, path):
- #data = json.loads(await websocket.recv())
- #print(data['test'])
- msg = await websocket.recv()
- print(msg)
-
-async def start():
- start_server = websockets.serve(handler, "localhost", 5027)
- print('Websocket starting...')
- get_or_create_eventloop().run_until_complete(start_server)
- get_or_create_eventloop().run_forever()
-
-async def send(msg):
- print("WS sending message:")
- print(msg)
- await websocket.send(msg) \ No newline at end of file