DaniilAlpha commited on
Commit
a8aa145
·
1 Parent(s): 81a216e

State checking replaced with try-except

Browse files
Files changed (1) hide show
  1. main.py +9 -15
main.py CHANGED
@@ -2,7 +2,7 @@ from asyncio import sleep
2
  from typing import Union
3
  from fastapi import FastAPI
4
  from fastapi.encoders import jsonable_encoder
5
- from fastapi.websockets import WebSocket, WebSocketDisconnect, WebSocketState
6
  from fastapi.responses import HTMLResponse, JSONResponse
7
 
8
  from accelerator import Accelerator
@@ -80,21 +80,15 @@ def map(query: Union[str, None], items: Union[list[str], None]):
80
  async def answer(ws: WebSocket):
81
  await ws.accept()
82
 
83
- try: input = await ws.receive_text()
84
- except WebSocketDisconnect: return
85
-
86
- if accelerator.connected():
87
- output = await accelerator.accelerate(input)
88
- if(ws.client_state == WebSocketState.CONNECTED):
89
  await ws.send_text(output)
90
- elif(ws.client_state == WebSocketState.DISCONNECTED):
91
- return
92
- else:
93
- output = answerer(input, 32)
94
- async for el in output:
95
- if(ws.client_state == WebSocketState.CONNECTED):
96
  await ws.send_text(el)
97
- elif(ws.client_state == WebSocketState.DISCONNECTED):
98
- return
99
 
100
  await ws.close()
 
2
  from typing import Union
3
  from fastapi import FastAPI
4
  from fastapi.encoders import jsonable_encoder
5
+ from fastapi.websockets import WebSocket, WebSocketDisconnect
6
  from fastapi.responses import HTMLResponse, JSONResponse
7
 
8
  from accelerator import Accelerator
 
80
  async def answer(ws: WebSocket):
81
  await ws.accept()
82
 
83
+ try:
84
+ input = await ws.receive_text()
85
+ if accelerator.connected():
86
+ output = await accelerator.accelerate(input)
 
 
87
  await ws.send_text(output)
88
+ else:
89
+ output = answerer(input, 32)
90
+ async for el in output:
 
 
 
91
  await ws.send_text(el)
92
+ except WebSocketDisconnect: return
 
93
 
94
  await ws.close()