Catch up with HA, cleanuip, remove setspeed

Author: dingusdk

.devcontainer/configuration.yaml

@@ -10,6 +10,10 @@ configurator:
 http:
 api:
 
-# debugpy:
+#debugpy:
 #  wait: true
 
+logger:
+  default: warning
+  logs:
+    custom_components.dukaone: debug

.devcontainer/devcontainer.json

@@ -1,6 +1,6 @@
 {
   "name": "DukaOne",
-  "image": "ludeeus/container:integration",
+  "image": "ghcr.io/ludeeus/devcontainer/integration:stable",
   "context": "..",
   "postCreateCommand": "",
   "runArgs": [],
@@ -25,15 +25,15 @@
     "ms-python.python",
     "github.vscode-pull-request-github",
     "ryanluker.vscode-coverage-gutters",
-    "ms-python.vscode-pylance"
+    "ms-python.vscode-pylance",
     // "eamodio.gitlens",
     // "dbaeumer.vscode-eslint",
-    // "esbenp.prettier-vscode",
+    "esbenp.prettier-vscode",
     // "bierner.lit-html",
     // "runem.lit-plugin",
     // "auchenberg.vscode-browser-preview",
-    // "davidanson.vscode-markdownlint",
-    // "redhat.vscode-yaml",
+    "davidanson.vscode-markdownlint",
+    "redhat.vscode-yaml",
     // "oderwat.indent-rainbow"
   ],
-}
+}

.vscode/settings.json

@@ -1,7 +1,18 @@
 {
-    "python.formatting.provider": "black",
-    "python.pythonPath": "/usr/bin/python3",
-    "files.associations": {
-        "*.yaml": "home-assistant"
-    }
-}
+  "editor.tabSize": 2,
+  "editor.insertSpaces": true,
+  "editor.formatOnSave": true,
+  "python.formatting.provider": "black",
+  "python.linting.flake8Enabled": false,
+  "python.linting.flake8Args": ["--max-line-length=120"],
+  "python.linting.enabled": true,
+  "python.linting.pydocstyleEnabled": false,
+  "python.linting.pydocstyleArgs": ["--max-line-length=120"],
+  "python.linting.pylintEnabled": true,
+  "python.linting.pycodestyleEnabled": false,
+  "python.linting.pycodestyleArgs": ["--max-line-length=120"],
+  "python.pythonPath": "/usr/bin/python3",
+  "files.associations": {
+    "*.yaml": "home-assistant"
+  }
+}

custom_components/dukaone/__init__.py

@@ -10,7 +10,7 @@
 from homeassistant.core import HomeAssistant
 from homeassistant.helpers.entity_component import EntityComponent
 
-from dukaonesdk.dukaclient import DukaClient
+from dukaonesdk.dukaclient import DukaClient, Device
 
 from .const import DOMAIN
 
@@ -54,14 +54,15 @@ async def async_unload_entry(hass: HomeAssistant, entry: ConfigEntry):
 
 
 class DukaEntityComponent(EntityComponent):
-    """ We only want to have one instance of the dukaclient."""
+    """We only want to have one instance of the dukaclient."""
 
     def __init__(self, hass):
         super(DukaEntityComponent, self).__init__(_LOGGER, DOMAIN, hass)
         self._the_client = None
 
     @property
     def the_client(self) -> DukaClient:
+        """Get the duka one client."""
         if self._the_client is None:
             self._the_client = DukaClient()
         return self._the_client

custom_components/dukaone/config_flow.py

@@ -28,7 +28,7 @@
 
 
 def dovalidate(hass: HomeAssistantType, user_input):
-
+    """Validate if we can connect to the device"""
     if DOMAIN not in hass.data:
         hass.data[DOMAIN] = DukaEntityComponent(hass)
     component: DukaEntityComponent = hass.data[DOMAIN]

custom_components/dukaone/dukaentity.py

@@ -0,0 +1,60 @@
+""" """
+import asyncio
+import logging
+import time
+from xmlrpc.client import boolean
+
+from dukaonesdk.device import Device
+from dukaonesdk.dukaclient import DukaClient
+
+from homeassistant.helpers.typing import HomeAssistantType
+
+from . import DukaEntityComponent
+from .const import DOMAIN
+
+_LOGGER = logging.getLogger(__name__)
+
+
+class DukaEntity:
+    """Implement the base of a duka entity with a reference to a device"""
+
+    def __init__(self, hass: HomeAssistantType, device_id):
+        self._device_id = device_id
+        self.device: Device = None
+        component: DukaEntityComponent = hass.data[DOMAIN]
+        self.the_client: DukaClient = component.the_client
+
+    def initialize_device(self, password: str, ip_address: str) -> None:
+        """Initialize the duka one device"""
+        self.device = self.the_client.add_device(
+            self._device_id,
+            password,
+            ip_address,
+            self.on_change,
+        )
+
+    async def wait_for_device_to_be_ready(self) -> boolean:
+        """Wait for the device to reponse to the initial get firmware version command."""
+        timeout = time.time() + 10
+        while self.device is None or self.device.firmware_version is None:
+            if time.time() > timeout:
+                return False
+            await asyncio.sleep(0.1)
+        return True
+
+    def on_change(self, device: Device):
+        """Callback whe dukaone has changes - must be implemented in derived class"""
+        raise NotImplementedError()
+
+    def dukaone_device_info(self):
+        """Return device information."""
+        if self.device is None:
+            return None
+        info = {
+            "name": "DukaOne",
+            "identifiers": {(DOMAIN, self._device_id)},
+            "manufacturer": "Duka Ventilation",
+            "model": f"Type {self.device.unit_type}",
+            "sw_version": f"{self.device.firmware_version} {self.device.firmware_date}",
+        }
+        return info