aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/hrc/service/websocket
diff options
context:
space:
mode:
authorHsiangNianian <i@jyunko.cn>2025-01-04 22:38:23 +0800
committerHsiangNianian <i@jyunko.cn>2025-01-04 22:38:23 +0800
commitc990518cb533a793399e44edbb4bc036342c7175 (patch)
tree8e2bd0f833b803a73dea7d88e7c294cf3d078d4d /hrc/service/websocket
parentbc57c1410c08323ba37114082d0fe609fafc2c5d (diff)
downloadHydroRollCore-main.tar.gz
HydroRollCore-main.zip
feat(core): Initialize core components and configuration modelsHEADmain
Diffstat (limited to 'hrc/service/websocket')
-rw-r--r--hrc/service/websocket/__init__.py30
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