diff options
author | Devaev Maxim <[email protected]> | 2020-09-10 09:31:05 +0300 |
---|---|---|
committer | Devaev Maxim <[email protected]> | 2020-09-10 09:31:05 +0300 |
commit | 9cb5582565aa2301a238ca382a32dc80106f6c15 (patch) | |
tree | b0e06d9cb15c88f72a8a42e0c02a97a7b0965663 /kvmd/apps | |
parent | 967afb2d9a0f4a94026ec612801b6291db5c6a72 (diff) |
only available gpio modes
Diffstat (limited to 'kvmd/apps')
-rw-r--r-- | kvmd/apps/__init__.py | 34 | ||||
-rw-r--r-- | kvmd/apps/cleanup/__init__.py | 6 | ||||
-rw-r--r-- | kvmd/apps/kvmd/api/export.py | 4 | ||||
-rw-r--r-- | kvmd/apps/kvmd/ugpio.py | 7 |
4 files changed, 31 insertions, 20 deletions
diff --git a/kvmd/apps/__init__.py b/kvmd/apps/__init__.py index c03fc48b..a1bdb916 100644 --- a/kvmd/apps/__init__.py +++ b/kvmd/apps/__init__.py @@ -22,6 +22,7 @@ import sys import os +import functools import argparse import logging import logging.config @@ -43,6 +44,8 @@ from ..plugins.auth import get_auth_service_class from ..plugins.hid import get_hid_class from ..plugins.atx import get_atx_class from ..plugins.msd import get_msd_class + +from ..plugins.ugpio import UserGpioModes from ..plugins.ugpio import get_ugpio_driver_class from ..yamlconf import ConfigError @@ -181,29 +184,40 @@ def _patch_dynamic( # pylint: disable=too-many-locals rebuild = True if load_gpio: - drivers: Set[str] = set() + driver: str + drivers: Dict[str, Set[str]] = {} # Name to modes for (driver, params) in { # type: ignore "__gpio__": {}, **tools.rget(raw_config, "kvmd", "gpio", "drivers"), }.items(): with manual_validated(driver, "kvmd", "gpio", "drivers", "<key>"): driver = valid_ugpio_driver(driver) + driver_type = valid_stripped_string_not_empty(params.get("type", "gpio")) + driver_class = get_ugpio_driver_class(driver_type) + drivers[driver] = driver_class.get_modes() scheme["kvmd"]["gpio"]["drivers"][driver] = { "type": Option(driver_type, type=valid_stripped_string_not_empty), - **get_ugpio_driver_class(driver_type).get_plugin_options() + **driver_class.get_plugin_options() } - drivers.add(driver) - for (channel, params) in tools.rget(raw_config, "kvmd", "gpio", "scheme").items(): - with manual_validated(channel, "kvmd", "gpio", "scheme", "<key>"): + path = ("kvmd", "gpio", "scheme") + for (channel, params) in tools.rget(raw_config, *path).items(): + with manual_validated(channel, *path, "<key>"): channel = valid_ugpio_channel(channel) - with manual_validated(params.get("mode", ""), "kvmd", "gpio", "scheme", channel, "mode"): - mode = valid_ugpio_mode(params.get("mode", "")) + + driver = params.get("driver", "__gpio__") + with manual_validated(driver, *path, channel, "driver"): + driver = valid_ugpio_driver(driver, set(drivers)) + + mode: str = params.get("mode", "") + with manual_validated(mode, *path, channel, "mode"): + mode = valid_ugpio_mode(mode, drivers[driver]) + scheme["kvmd"]["gpio"]["scheme"][channel] = { - "driver": Option("__gpio__", type=(lambda arg: valid_ugpio_driver(arg, drivers))), + "driver": Option("__gpio__", type=functools.partial(valid_ugpio_driver, variants=set(drivers))), "pin": Option(-1, type=valid_gpio_pin), - "mode": Option("", type=valid_ugpio_mode), + "mode": Option("", type=functools.partial(valid_ugpio_mode, variants=drivers[driver])), "inverted": Option(False, type=valid_bool), **({ "busy_delay": Option(0.2, type=valid_float_f01), @@ -214,7 +228,7 @@ def _patch_dynamic( # pylint: disable=too-many-locals "min_delay": Option(0.1, type=valid_float_f01), "max_delay": Option(0.1, type=valid_float_f01), }, - } if mode == "output" else {}) + } if mode == UserGpioModes.OUTPUT else {}) } rebuild = True diff --git a/kvmd/apps/cleanup/__init__.py b/kvmd/apps/cleanup/__init__.py index bb9b3b71..708e3399 100644 --- a/kvmd/apps/cleanup/__init__.py +++ b/kvmd/apps/cleanup/__init__.py @@ -60,12 +60,6 @@ def _clear_gpio(config: Section) -> None: ("streamer/cap", config.streamer.cap_pin), ("streamer/conv", config.streamer.conv_pin), - - # *([ - # (f"gpio/{channel}", params.pin) - # for (channel, params) in config.gpio.scheme.items() - # if params.mode == "output" - # ]), ]: if pin >= 0: logger.info("Writing 0 to GPIO pin=%d (%s)", pin, name) diff --git a/kvmd/apps/kvmd/api/export.py b/kvmd/apps/kvmd/api/export.py index b659b5fe..7b911828 100644 --- a/kvmd/apps/kvmd/api/export.py +++ b/kvmd/apps/kvmd/api/export.py @@ -32,6 +32,8 @@ from .... import tools from ....plugins.atx import BaseAtx +from ....plugins.ugpio import UserGpioModes + from ..info import InfoManager from ..ugpio import UserGpio @@ -59,7 +61,7 @@ class ExportApi: self.__append_prometheus_rows(rows, atx_state["enabled"], "pikvm_atx_enabled") self.__append_prometheus_rows(rows, atx_state["leds"]["power"], "pikvm_atx_power") - for mode in ["input", "output"]: + for mode in sorted(UserGpioModes.ALL): for (channel, ch_state) in gpio_state[f"{mode}s"].items(): for key in ["online", "state"]: self.__append_prometheus_rows(rows, ch_state["state"], f"pikvm_gpio_{mode}_{key}_{channel}") diff --git a/kvmd/apps/kvmd/ugpio.py b/kvmd/apps/kvmd/ugpio.py index 3f62d286..06c1a6e5 100644 --- a/kvmd/apps/kvmd/ugpio.py +++ b/kvmd/apps/kvmd/ugpio.py @@ -34,6 +34,7 @@ from ...logging import get_logger from ...plugins.ugpio import GpioError from ...plugins.ugpio import GpioOperationError from ...plugins.ugpio import GpioDriverOfflineError +from ...plugins.ugpio import UserGpioModes from ...plugins.ugpio import BaseUserGpioDriver from ...plugins.ugpio import get_ugpio_driver_class @@ -250,7 +251,7 @@ class UserGpio: for (channel, ch_config) in tools.sorted_kvs(config.scheme): driver = self.__drivers[ch_config.driver] - if ch_config.mode == "input": + if ch_config.mode == UserGpioModes.INPUT: self.__inputs[channel] = _GpioInput(channel, ch_config, driver) else: # output: self.__outputs[channel] = _GpioOutput(channel, ch_config, driver, self.__notifier) @@ -331,12 +332,12 @@ class UserGpio: if parts: if parts[0] in self.__inputs: items.append({ - "type": "input", + "type": UserGpioModes.INPUT, "channel": parts[0], }) elif parts[0] in self.__outputs: items.append({ - "type": "output", + "type": UserGpioModes.OUTPUT, "channel": parts[0], "text": (parts[1] if len(parts) > 1 else "Click"), }) |