[+] add websocket clients manager
This commit is contained in:
parent
25d5b34add
commit
612d807bc4
55
deps/test-task-2025-06-30-v1/python/online/fxreader/pr34/test_task_2025_06_30_v1/async_api/fastapi.py
vendored
55
deps/test-task-2025-06-30-v1/python/online/fxreader/pr34/test_task_2025_06_30_v1/async_api/fastapi.py
vendored
@ -1,4 +1,5 @@
|
|||||||
import fastapi
|
import fastapi
|
||||||
|
import functools
|
||||||
import logging
|
import logging
|
||||||
import copy
|
import copy
|
||||||
import uvicorn
|
import uvicorn
|
||||||
@ -7,18 +8,68 @@ import sys
|
|||||||
|
|
||||||
from .settings import Settings as APISettings
|
from .settings import Settings as APISettings
|
||||||
|
|
||||||
async def websocket_tickers(
|
from typing import (Any, Optional,)
|
||||||
websocket: fastapi.WebSocket,
|
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
class WebsocketAPI:
|
||||||
|
def __init__(
|
||||||
|
self,
|
||||||
|
) -> None:
|
||||||
|
self.connections : set[
|
||||||
|
fastapi.WebSocket,
|
||||||
|
] = set()
|
||||||
|
self.subscriptionss : dict[str, set[fastapi.WebSocket]] = dict()
|
||||||
|
|
||||||
|
async def connect(self, client: fastapi.WebSocket) -> None:
|
||||||
|
assert not client in self.connections
|
||||||
|
|
||||||
|
await client.accept()
|
||||||
|
|
||||||
|
self.connections.add(client)
|
||||||
|
|
||||||
|
async def on_message(
|
||||||
|
self,
|
||||||
|
client: fastapi.WebSocket,
|
||||||
|
msg: Any
|
||||||
) -> None:
|
) -> None:
|
||||||
raise NotImplementedError
|
raise NotImplementedError
|
||||||
|
|
||||||
|
async def disconnect(self, client: fastapi.WebSocket) -> None:
|
||||||
|
assert client in self.connections
|
||||||
|
|
||||||
|
self.connections.remove(client)
|
||||||
|
|
||||||
|
async def websocket_tickers(
|
||||||
|
websocket: fastapi.WebSocket,
|
||||||
|
websocket_api: WebsocketAPI,
|
||||||
|
) -> None:
|
||||||
|
try:
|
||||||
|
await websocket_api.connect(websocket)
|
||||||
|
|
||||||
|
while True:
|
||||||
|
msg = await websocket.receive_text()
|
||||||
|
await websocket_api.on_message(websocket, msg)
|
||||||
|
except fastapi.WebSocketDisconnect:
|
||||||
|
pass
|
||||||
|
# websocket_api.disconnect(websocket)
|
||||||
|
except:
|
||||||
|
logger.exception('')
|
||||||
|
finally:
|
||||||
|
await websocket_api.disconnect(websocket)
|
||||||
|
|
||||||
def create_app() -> fastapi.FastAPI:
|
def create_app() -> fastapi.FastAPI:
|
||||||
|
websocket_api = WebsocketAPI()
|
||||||
|
|
||||||
app = fastapi.FastAPI()
|
app = fastapi.FastAPI()
|
||||||
|
|
||||||
app.websocket(
|
app.websocket(
|
||||||
'/tickers/',
|
'/tickers/',
|
||||||
)(
|
)(
|
||||||
|
functools.partial(
|
||||||
websocket_tickers,
|
websocket_tickers,
|
||||||
|
websocket_api=websocket_api,
|
||||||
|
)
|
||||||
)
|
)
|
||||||
|
|
||||||
return app
|
return app
|
||||||
|
Loading…
Reference in New Issue
Block a user