feat: Сохранение серверного подключения
This commit is contained in:
@@ -11,6 +11,7 @@ class Server:
|
|||||||
self._server_username = server_username
|
self._server_username = server_username
|
||||||
self._server_password = server_password
|
self._server_password = server_password
|
||||||
self._client_password = client_password
|
self._client_password = client_password
|
||||||
|
|
||||||
self._server_connection: WebSocket | None = None
|
self._server_connection: WebSocket | None = None
|
||||||
self._register_routes(app)
|
self._register_routes(app)
|
||||||
|
|
||||||
@@ -63,14 +64,16 @@ class Server:
|
|||||||
uuid = headers.get('Authorization')
|
uuid = headers.get('Authorization')
|
||||||
|
|
||||||
if uuid != self._server_token:
|
if uuid != self._server_token:
|
||||||
|
# Закрытие до принятия подключения выбрасывает 403 (Forbidden) код, так что не нужны доп сообщения
|
||||||
await websocket.close()
|
await websocket.close()
|
||||||
return
|
return
|
||||||
|
|
||||||
if self._server_connection is not None:
|
if self._server_connection is not None:
|
||||||
await self._server_connection.close()
|
await self._server_connection.close()
|
||||||
self._server_connection = None
|
|
||||||
|
|
||||||
await websocket.accept()
|
await websocket.accept()
|
||||||
|
self._server_connection = websocket
|
||||||
|
|
||||||
#TODO: Заменить принты на логирование
|
#TODO: Заменить принты на логирование
|
||||||
try:
|
try:
|
||||||
while True:
|
while True:
|
||||||
|
|||||||
Reference in New Issue
Block a user