rewrited #65

kvmd/apps/kvmd/api/ugpio.py

@@ -19,11 +19,9 @@
 #                                                                            #
 # ========================================================================== #
 
-from typing import Dict
 
 from aiohttp.web import Request
 from aiohttp.web import Response
-from aiohttp.web import WebSocketResponse
 
 from ....validators.basic import valid_bool
 from ....validators.basic import valid_float_f0
@@ -32,7 +30,6 @@ from ....validators.ugpio import valid_ugpio_channel
 from ..ugpio import UserGpio
 
 from ..http import exposed_http
-from ..http import exposed_ws
 from ..http import make_json_response
 
 
@@ -41,7 +38,7 @@ class UserGpioApi:
     def __init__(self, user_gpio: UserGpio) -> None:
         self.__user_gpio = user_gpio
 
-    # ===== Http
+    # =====
 
     @exposed_http("GET", "/gpio")
     async def __state_handler(self, _: Request) -> Response:
@@ -65,25 +62,3 @@ class UserGpioApi:
         wait = valid_bool(request.query.get("wait", "0"))
         await self.__user_gpio.pulse(channel, delay, wait)
         return make_json_response()
-
-    # ===== Websocket
-
-    @exposed_ws("gpio_switch")
-    async def __ws_gpio_switch_handler(self, _: WebSocketResponse, event: Dict) -> None:
-        try:
-            channel = valid_ugpio_channel(event["channel"])
-            state = valid_bool(event["state"])
-            wait = valid_bool(event["wait"])
-        except Exception:
-            return
-        await self.__user_gpio.switch(channel, state, wait)
-
-    @exposed_ws("gpio_pulse")
-    async def __ws_gpio_pulse_handler(self, _: WebSocketResponse, event: Dict) -> None:
-        try:
-            channel = valid_ugpio_channel(event["channel"])
-            delay = valid_float_f0(event["delay"])
-            wait = valid_bool(event["wait"])
-        except Exception:
-            return
-        await self.__user_gpio.pulse(channel, delay, wait)