diff options
| author | 2025-01-04 22:38:23 +0800 | |
|---|---|---|
| committer | 2025-01-04 22:38:23 +0800 | |
| commit | c990518cb533a793399e44edbb4bc036342c7175 (patch) | |
| tree | 8e2bd0f833b803a73dea7d88e7c294cf3d078d4d /hrc/service/websocket | |
| parent | bc57c1410c08323ba37114082d0fe609fafc2c5d (diff) | |
| download | HydroRollCore-main.tar.gz HydroRollCore-main.zip | |
Diffstat (limited to 'hrc/service/websocket')
| -rw-r--r-- | hrc/service/websocket/__init__.py | 30 |
1 files changed, 0 insertions, 30 deletions
diff --git a/hrc/service/websocket/__init__.py b/hrc/service/websocket/__init__.py deleted file mode 100644 index 3a7f089..0000000 --- a/hrc/service/websocket/__init__.py +++ /dev/null @@ -1,30 +0,0 @@ -from typing import Any, Coroutine -from typing_extensions import override -from aiohttp import web, ClientWebSocketResponse - -from hrc.service.utils import WebSocketService -from hrc.event import Event -from hrc.log import logger - -from aiohttp import web - -class WebSocketTestEvent(Event["WebSocketTestEvent"]): - message: str - -class WebSocketTestService(WebSocketService[WebSocketTestEvent, None]): - name: str = "websocket_test_service" - service_type: str = "reverse-ws" - host: str = "127.0.0.1" - port: int = 8765 - url: str = "/" - - @override - async def handle_reverse_ws_response(self, request: web.Request) -> Coroutine[Any, Any, ClientWebSocketResponse]: - event = WebSocketTestEvent( - service=self, - type="message", - message=await request.text() - ) - logger.info(f"Receive {event}") - await self.handle_event(event) - return web.Response()
\ No newline at end of file |
