55 lines
1.5 KiB
Python
55 lines
1.5 KiB
Python
|
import asyncio
|
||
|
|
import websockets
|
||
|
|
import time
|
||
|
|
import json
|
||
|
|
import threading
|
||
|
|
|
||
|
|
connected = set()
|
||
|
|
outreg = [{"player": "1", "data": []}, {"player": "2", "data": []}]
|
||
|
|
|
||
|
|
async def socket_broadcast(data):
|
||
|
|
for client in connected:
|
||
|
|
await client.send(str(data))
|
||
|
|
|
||
|
|
async def hello(websocket, path):
|
||
|
|
global outreg
|
||
|
|
i = 0
|
||
|
|
connected.add(websocket)
|
||
|
|
try:
|
||
|
|
while i == 0:
|
||
|
|
try:
|
||
|
|
await socket_broadcast(json.dumps(outreg))
|
||
|
|
x = await websocket.recv()
|
||
|
|
try:
|
||
|
|
datareg = json.loads(x)
|
||
|
|
if datareg['player'] == 1:
|
||
|
|
outreg[0]["data"] = datareg["data"]
|
||
|
|
elif datareg['player'] == 2:
|
||
|
|
outreg[1]["data"] = datareg["data"]
|
||
|
|
#print(json.dumps(datareg)+"\n\n\n"+json.dumps(outreg))
|
||
|
|
await socket_broadcast(json.dumps(outreg))
|
||
|
|
except Exception as e:
|
||
|
|
print(e)
|
||
|
|
except Exception as e:
|
||
|
|
print(e)
|
||
|
|
connected.remove(websocket)
|
||
|
|
i = 1
|
||
|
|
finally:
|
||
|
|
# Unregister.
|
||
|
|
connected.remove(websocket)
|
||
|
|
|
||
|
|
|
||
|
|
start_server = websockets.serve(hello, "localhost", 8765)
|
||
|
|
|
||
|
|
loop = asyncio.get_event_loop()
|
||
|
|
|
||
|
|
def loop_in_thread():
|
||
|
|
loop.run_until_complete(start_server)
|
||
|
|
loop.run_forever()
|
||
|
|
|
||
|
|
t = threading.Thread(target=loop_in_thread, args=tuple())
|
||
|
|
t.start()
|
||
|
|
|
||
|
|
|
||
|
|
print("hello")
|