Spaces:
Running
Running
Update main.py
Browse files
main.py
CHANGED
|
@@ -80,11 +80,11 @@ app.add_middleware(
|
|
| 80 |
async def websocket_endpoint(websocket: WebSocket, version: str):
|
| 81 |
await websocket.accept()
|
| 82 |
|
| 83 |
-
stockfish = EngineChess(f"engines/stockfish-{version}-uci")
|
| 84 |
|
| 85 |
async def read_from_socket(websocket: WebSocket):
|
| 86 |
async for data in websocket.iter_text():
|
| 87 |
-
print(f"Client: {data}")
|
| 88 |
stockfish.put(data)
|
| 89 |
|
| 90 |
asyncio.create_task(read_from_socket(websocket))
|
|
@@ -92,8 +92,30 @@ async def websocket_endpoint(websocket: WebSocket, version: str):
|
|
| 92 |
while True:
|
| 93 |
while True:
|
| 94 |
res = stockfish.read_line()
|
| 95 |
-
if res
|
| 96 |
await websocket.send_text(f"{res}")
|
| 97 |
else:
|
| 98 |
break
|
| 99 |
-
await asyncio.sleep(0.1)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 80 |
async def websocket_endpoint(websocket: WebSocket, version: str):
|
| 81 |
await websocket.accept()
|
| 82 |
|
| 83 |
+
stockfish = EngineChess(f"engines/stockfish/stockfish-{version}-uci")
|
| 84 |
|
| 85 |
async def read_from_socket(websocket: WebSocket):
|
| 86 |
async for data in websocket.iter_text():
|
| 87 |
+
print(f"Stockfish Client: {data}")
|
| 88 |
stockfish.put(data)
|
| 89 |
|
| 90 |
asyncio.create_task(read_from_socket(websocket))
|
|
|
|
| 92 |
while True:
|
| 93 |
while True:
|
| 94 |
res = stockfish.read_line()
|
| 95 |
+
if res:
|
| 96 |
await websocket.send_text(f"{res}")
|
| 97 |
else:
|
| 98 |
break
|
| 99 |
+
await asyncio.sleep(0.1)
|
| 100 |
+
|
| 101 |
+
@app.websocket("/maia-{elo}")
|
| 102 |
+
async def websocket_endpoint(websocket: WebSocket, version: str):
|
| 103 |
+
await websocket.accept()
|
| 104 |
+
|
| 105 |
+
stockfish = EngineChess(["./engines/maia/lc0", f"--weights=engines/maia-{elo}.pb.gz", "--backend=trivial"])
|
| 106 |
+
|
| 107 |
+
async def read_from_socket(websocket: WebSocket):
|
| 108 |
+
async for data in websocket.iter_text():
|
| 109 |
+
print(f"Maia Client: {data}")
|
| 110 |
+
stockfish.put(data)
|
| 111 |
+
|
| 112 |
+
asyncio.create_task(read_from_socket(websocket))
|
| 113 |
+
|
| 114 |
+
while True:
|
| 115 |
+
while True:
|
| 116 |
+
res = stockfish.read_line()
|
| 117 |
+
if res:
|
| 118 |
+
await websocket.send_text(f"{res}")
|
| 119 |
+
else:
|
| 120 |
+
break
|
| 121 |
+
await asyncio.sleep(0.1)
|