Issue 338 limit regulation over valve to avoid drowning battery of the TRV (#356)

* With testus ok

* Clean TPI algo

* Commenet failed testu

* Documentation

---------

Co-authored-by: Jean-Marc Collin <jean-marc.collin-extern@renault.com>

.devcontainer/devcontainer.json

@@ -30,7 +30,8 @@
 				"waderyan.gitblame",
 				"keesschollaart.vscode-home-assistant",
 				"vscode.markdown-math",
-				"yzhang.markdown-all-in-one"
+				"yzhang.markdown-all-in-one",
+				"github.vscode-github-actions"
 			],
 			"settings": {
 				"files.eol": "\n",

.github/workflows/testus.yaml

@@ -0,0 +1,50 @@
+name: Run Tests
+
+on:
+  push:
+    branches:
+      - main
+  pull_request:
+
+jobs:
+  testu:
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Checkout Repository
+        uses: actions/checkout@v2
+
+      - name: Set up Python
+        uses: actions/setup-python@v2
+        with:
+          python-version: 3.11
+
+      - name: Install dependencies
+        run: |
+          python -m pip install --upgrade pip
+          pip3 install -r requirements_test.txt
+
+      - name: Run Tests
+        run: |
+          pytest \
+            -qq \
+            --timeout=9 \
+            --durations=10 \
+            -n auto \
+            -o console_output_style=count \
+            -p no:sugar \
+            tests
+
+      - name: Coverage
+        run: |
+          coverage run -m pytest tests/
+          coverage report
+
+      - name: Generate HTML Coverage Report
+        run: coverage html
+
+      - name: Deploy to GitHub Pages
+        uses: peaceiris/actions-gh-pages@v3
+        with:
+          github_token: ${{ secrets.GITHUB_TOKEN }}
+          publish_dir: ./htmlcov

.gitignore

@@ -110,3 +110,6 @@ __pycache__
 config/**
 custom_components/hacs
 custom_components/localtuya
+
+.coverage
+htmlcov

.vscode/tasks.json

@@ -13,6 +13,12 @@
             "command": "./container restart",
             "problemMatcher": []
         },
+        {
+            "label": "Start coverage",
+            "type": "shell",
+            "command": "./container coverage",
+            "problemMatcher": []
+        },
         {
             "label": "Home Assistant translations update",
             "type": "shell",

README-fr.md

@@ -84,14 +84,15 @@ Ce composant personnalisé pour Home Assistant est une mise à niveau et est une
 
 
 > ![Nouveau](https://github.com/jmcollin78/versatile_thermostat/blob/main/images/new-icon.png?raw=true) _*Nouveautés*_
+> * **Release 5.4** : Ajout du pas de température [#311](https://github.com/jmcollin78/versatile_thermostat/issues/311). Ajout de seuils de régulation pour les `over_valve` pour éviter de trop vider la batterie des TRV [#338](https://github.com/jmcollin78/versatile_thermostat/issues/338)
 > * **Release 5.3** : Ajout d'une fonction de pilotage d'une chaudière centrale [#234](https://github.com/jmcollin78/versatile_thermostat/issues/234) - plus d'infos ici: [Le contrôle d'une chaudière centrale](#le-contrôle-dune-chaudière-centrale). Ajout de la possibilité de désactiver le mode sécurité pour le thermomètre extérieur [#343](https://github.com/jmcollin78/versatile_thermostat/issues/343)
 > * **Release 5.2** : Ajout d'un `central_mode` permettant de piloter tous les VTherms de façon centralisée [#158](https://github.com/jmcollin78/versatile_thermostat/issues/158).
 > * **Release 5.1** : Limitation des valeurs envoyées aux valves et au température envoyées au climate sous-jacent.
 > * **Release 5.0** : Ajout d'une configuration centrale permettant de mettre en commun les attributs qui peuvent l'être [#239](https://github.com/jmcollin78/versatile_thermostat/issues/239).
-> * **Release 4.3** : Ajout d'un mode auto-fan pour le type `over_climate` permettant d'activer la ventilation si l'écart de température est important [#223](https://github.com/jmcollin78/versatile_thermostat/issues/223).
 <details>
 <summary>Autres versions</summary>
 
+> * **Release 4.3** : Ajout d'un mode auto-fan pour le type `over_climate` permettant d'activer la ventilation si l'écart de température est important [#223](https://github.com/jmcollin78/versatile_thermostat/issues/223).
 > * **Release 4.2** : Le calcul de la pente de la courbe de température se fait maintenant en °/heure et non plus en °/min [#242](https://github.com/jmcollin78/versatile_thermostat/issues/242). Correction de la détection automatique des ouvertures par l'ajout d'un lissage de la courbe de température .
 > * **Release 4.1** : Ajout d'un mode de régulation **Expert** dans lequel l'utilisateur peut spécifier ses propres paramètres d'auto-régulation au lieu d'utiliser les pre-programmés [#194](https://github.com/jmcollin78/versatile_thermostat/issues/194).
 > * **Release 4.0** : Ajout de la prise en charge de la **Versatile Thermostat UI Card**. Voir [Versatile Thermostat UI Card](https://github.com/jmcollin78/versatile-thermostat-ui-card). Ajout d'un mode de régulation **Slow** pour les appareils de chauffage à latence lente [#168](https://github.com/jmcollin78/versatile_thermostat/issues/168). Changement de la façon dont **la puissance est calculée** dans le cas de VTherm avec des équipements multi-sous-jacents [#146](https://github.com/jmcollin78/versatile_thermostat/issues/146). Ajout de la prise en charge de AC et Heat pour VTherm via un interrupteur également [#144](https://github.com/jmcollin78/versatile_thermostat/pull/144)
@@ -127,7 +128,7 @@ En conséquence toute la phase de paramètrage d'un VTherm a été profondemment
 **Note :** les copies d'écran de la configuration d'un VTherm n'ont pas été mises à jour.
 
 # Merci pour la bière [buymecoffee](https://www.buymeacoffee.com/jmcollin78)
-Un grand merci à @salabur, @pvince83, @bergoglio, @EPicLURcher, @ecolorado66, @Kriss1670, @maia, @f.maymil, @moutte69, @Jerome, @Gunnar M, @Greg.o, @John Burgess, @abyssmal, @capinfo26, @Helge, @MattG @Mexx62, @Someone, @Lajull pour les bières. Ca fait très plaisir et ça m'encourage à continuer !
+Un grand merci à @salabur, @pvince83, @bergoglio, @EPicLURcher, @ecolorado66, @Kriss1670, @maia, @f.maymil, @moutte69, @Jerome, @Gunnar M, @Greg.o, @John Burgess, @abyssmal, @capinfo26, @Helge, @MattG @Mexx62, @Someone, @Lajull, @giopeco pour les bières. Ca fait très plaisir et ça m'encourage à continuer !
 
 
 # Quand l'utiliser et ne pas l'utiliser
@@ -544,7 +545,7 @@ Par défaut, le thermomètre extérieur peut déclencher une mise en sécurité
 
 Voir [exemple de réglages](#examples-tuning) pour avoir des exemples de réglage communs
 
-> ![Astuce](https://github.com/jmcollin78/versatile_thermostat/blob/main/images/tips.png?raw=true) _*Notes*_
+> ![Astuce](/images/tips.png?raw=true) _*Notes*_
 > 1. Lorsque le capteur de température viendra à la vie et renverra les températures, le préréglage sera restauré à sa valeur précédente,
 > 2. Attention, deux températures sont nécessaires : la température interne et la température externe et chacune doit donner la température, sinon le thermostat sera en préréglage "security",
 > 3. Un service est disponible qui permet de régler les 3 paramètres de sécurité. Ca peut servir à adapter la fonction de sécurité à votre usage,
@@ -571,12 +572,18 @@ Depuis la release 5.3, vous avez la possibilité de contrôler une chaudière ce
 
 Le principe mis en place est globalement le suivant :
 1. une nouvelle entité de type `binary_sensor` et nommée par défaut `binary_sensor.central_boiler` est ajoutée,
-2. dans la configuration des VTherms vous indiqué si le VTherm doit contrôler la chaudière. En effet, dans une installation hétérogène, certains VTherm doivent commander la chaudière et d'autres non. Vous devez donc indiqué dans chaque configuration de VTherm si il contrôle la chaudière ou pas,
-3. le `binary_sensor.central_boiler` écoute les changements d'états des VTherm marqués comme contrôlant la chaudière,
-4. si l'un des VTherm écoutés demande du chauffage (ie son `hvac_action` passe à `Heating`), alors le `binary_sensor.central_boiler` passe à `on` et si un service d'activation a été configuré, alors ce service est appelé,
-5. si plus aucun VTherm écoutés ne demande du chauffage (ie aucun `hvac_action` n'est `Heating`), alors le `binary_sensor.central_boiler` passe à `off` et si un service de désactivation a été configuré, alors ce service est appelé.
+2. dans la configuration des VTherms vous indiquez si le VTherm doit contrôler la chaudière. En effet, dans une installation hétérogène, certains VTherm doivent commander la chaudière et d'autres non. Vous devez donc indiquer dans chaque configuration de VTherm si il contrôle la chaudière ou pas,
+3. le `binary_sensor.central_boiler` écoute les changements d'états des équipements des VTherm marqués comme contrôlant la chaudière,
+4. dès que le nombre d'équipements pilotés par le VTherm demandant du chauffage (ie son `hvac_action` passe à `Heating`) dépasse un seuil paramétrable, alors le `binary_sensor.central_boiler` passe à `on` et **si un service d'activation a été configuré, alors ce service est appelé**,
+5. si le nombre d'équipements nécessitant du chauffage repasse en dessous du seuil, alors le `binary_sensor.central_boiler` passe à `off` et si **un service de désactivation a été configuré, alors ce service est appelé**,
+6. vous avez accès à deux entités :
+   - une de type `number` nommé par défaut `number.boiler_activation_threshold`, donne le seuil de déclenchement. Ce seuil est en nombre d'équipements (radiateurs) qui demande du chauffage.
+   - une de type `sensor` nommé par défaut `sensor.nb_device_active_for_boiler`, donne le nombre d'équipements qui demande du chauffage. Par exemple, un VTherm ayant 4 vannes dont 3 demandes du chauffage fera passé ce capteur à 3. Seuls les équipements des VTherms qui sont marqués pour contrôler la chaudière centrale sont comptabilisés.
 
-Vous avez donc en permanence, un indicateur qui donne l'info que au moins un des radiateurs est à besoin de chauffer.
+Vous avez donc en permanence, les informations qui permettent de piloter et régler le déclenchement de la chaudière.
+
+Toutes ces entités sont rattachés au service de configuration centrale :
+![Les entités pilotant la chaudière](/images/entitites-central-boiler.png?raw=true)
 
 ### Configuration
 Pour configurer cette fonction, vous devez avoir une configuration centralisée (cf. [Configuration](#configuration)) et cochez la case 'Ajouter une chuadière centrale' :

README.md

@@ -84,14 +84,15 @@
 This custom component for Home Assistant is an upgrade and is a complete rewrite of the component "Awesome thermostat" (see [Github](https://github.com/dadge/awesome_thermostat)) with addition of features.
 
 >![New](https://github.com/jmcollin78/versatile_thermostat/blob/main/images/new-icon.png?raw=true) _*News*_
+> * **Release 5.4**: Added a temperature step [#311](https://github.com/jmcollin78/versatile_thermostat/issues/311). Added some regulation thresholdfor `over_valve` VTherm in order to avoid drowing the battery of TRV devices [#338](https://github.com/jmcollin78/versatile_thermostat/issues/338).
 > * **Release 5.3**: Added a central boiler control function [#234](https://github.com/jmcollin78/versatile_thermostat/issues/234) - more information here: [Controlling a central boiler](#controlling-a-central-boiler). Added the ability to disable security mode for outdoor thermometer [#343](https://github.com/jmcollin78/versatile_thermostat/issues/343)
 > * **Release 5.2**: Added a `central_mode` allowing all VTherms to be controlled centrally [#158](https://github.com/jmcollin78/versatile_thermostat/issues/158).
 > * **Release 5.1**: Limitation of the values sent to the valves and the temperature sent to the underlying climate.
 > * **Release 5.0**: Added a central configuration allowing the sharing of attributes that can be shared [#239](https://github.com/jmcollin78/versatile_thermostat/issues/239).
-> * **Release 4.3**: Added an auto-fan mode for the `over_climate` type allowing ventilation to be activated if the temperature difference is significant [#223](https://github.com/jmcollin78/versatile_thermostat/issues/223).
 <details>
 <summary>Others releases</summary>
 
+> * **Release 4.3**: Added an auto-fan mode for the `over_climate` type allowing ventilation to be activated if the temperature difference is significant [#223](https://github.com/jmcollin78/versatile_thermostat/issues/223).
 > * **Release 4.2**: The calculation of the slope of the temperature curve is now done in °/hour and no longer in °/min [#242](https://github.com/jmcollin78/versatile_thermostat/issues/242). Correction of automatic detection of openings by adding smoothing of the temperature curve.
 > * **Release 4.1**: Added an **Expert** regulation mode in which the user can specify their own auto-regulation parameters instead of using the pre-programmed ones [#194]( https://github.com/jmcollin78/versatile_thermostat/issues/194).
 > * **Release 4.0**: Added the support of **Versatile Thermostat UI Card**. See [Versatile Thermostat UI Card](https://github.com/jmcollin78/versatile-thermostat-ui-card). Added a **Slow** regulation mode for slow latency heating devices [#168](https://github.com/jmcollin78/versatile_thermostat/issues/168). Change the way **the power is calculated** in case of VTherm with multi-underlying equipements [#146](https://github.com/jmcollin78/versatile_thermostat/issues/146). Added the support of AC and Heat for VTherm over switch alse [#144](https://github.com/jmcollin78/versatile_thermostat/pull/144)
@@ -127,7 +128,7 @@ Consequently, the entire configuration phase of a VTherm has been profoundly mod
 **Note:** the VTherm configuration screenshots have not been updated.
 
 # Thanks for the beer [buymecoffee](https://www.buymeacoffee.com/jmcollin78)
-Many thanks to @salabur, @pvince83, @bergoglio, @EPicLURcher, @ecolorado66, @Kriss1670, @maia, @f.maymil, @moutte69, @Jerome, @Gunnar M, @Greg.o, @John Burgess, @abyssmal, @capinfo26, @Helge, @MattG, @MattG, @Mexx62, @Someone, @Lajull for the beers. It's very nice and encourages me to continue!
+Many thanks to @salabur, @pvince83, @bergoglio, @EPicLURcher, @ecolorado66, @Kriss1670, @maia, @f.maymil, @moutte69, @Jerome, @Gunnar M, @Greg.o, @John Burgess, @abyssmal, @capinfo26, @Helge, @MattG, @MattG, @Mexx62, @Someone, @Lajull, @giopeco for the beers. It's very nice and encourages me to continue!
 
 # When to use / not use
 This thermostat can control 3 types of equipment:
@@ -558,11 +559,17 @@ Since release 5.3, you have the possibility of controlling a centralized boiler.
 The principle put in place is generally as follows:
 1. a new entity of type `binary_sensor` and named by default `binary_sensor.central_boiler` is added,
 2. in the VTherms configuration you indicate whether the VTherm should control the boiler. Indeed, in a heterogeneous installation, some VTherm must control the boiler and others not. You must therefore indicate in each VTherm configuration whether it controls the boiler or not,
-3. the `binary_sensor.central_boiler` listens for changes in state of the VTherms marked as controlling the boiler,
-4. if one of the listened VTherms requests heating (ie its `hvac_action` changes to `Heating`), then the `binary_sensor.central_boiler` changes to `on` and if an activation service has been configured, then this service is called,
-5. if no more listened VTherm requests heating (ie no `hvac_action` is `Heating`), then the `binary_sensor.central_boiler` goes to `off` and if a deactivation service has been configured, then this service is called.
+3. the `binary_sensor.central_boiler` listens for changes in state of VTherm equipment marked as controlling the boiler,
+4. as soon as the number of devices controlled by the VTherm requesting heating (ie its `hvac_action` goes to `Heating`) exceeds a configurable threshold, then the `binary_sensor.central_boiler` goes to `on` and **if a activation service has been configured, then this service is called**,
+5. if the number of devices requiring heating falls below the threshold again, then the `binary_sensor.central_boiler` goes to `off` and if **a deactivation service has been configured, then this service is called**,
+6. you have access to two entities:
+    - one of type `number` named by default `number.boiler_activation_threshold`, gives the trigger threshold. This threshold is in number of equipment (radiators) which requires heating.
+    - one of type `sensor` named by default `sensor.nb_device_active_for_boiler`, gives the number of devices requiring heating. For example, a VTherm having 4 valves including 3 heating requests will increase this sensor to 3. Only VTherm equipment that is marked to control the central boiler is counted.
 
-You therefore always have an indicator which gives information that at least one of the radiators needs to be heated.
+You therefore always have the information which allows you to control and adjust the activation of the boiler.
+
+All these entities are attached to the central configuration service:
+![The entities controlling the boiler](/images/entitites-central-boiler.png?raw=true)
 
 ### Setup
 To configure this function, you must have a centralized configuration (see [Configuration](#configuration)) and check the 'Add a central boiler' box:

container

@@ -43,4 +43,13 @@ case $1 in
         pwd
         ./scripts/starts_ha.sh
     ;;
+    coverage)
+        rm -rf htmlcov/*
+        echo "Starting coverage tests"
+        coverage run -m pytest tests/
+        echo "Starting coverage report"
+        coverage report
+        echo "Starting coverage html"
+        coverage html
+    ;;
 esac

custom_components/versatile_thermostat/__init__.py

@@ -133,6 +133,8 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
 
     await hass.config_entries.async_forward_entry_setups(entry, PLATFORMS)
 
+    await api.reload_central_boiler_entities_list()
+
     return True
 
 

custom_components/versatile_thermostat/base_thermostat.py

@@ -145,20 +145,6 @@ def get_tz(hass: HomeAssistant):
 class BaseThermostat(ClimateEntity, RestoreEntity):
     """Representation of a base class for all Versatile Thermostat device."""
 
-    # The list of VersatileThermostat entities
-    _hass: HomeAssistant
-    _last_temperature_measure: datetime
-    _last_ext_temperature_measure: datetime
-    _total_energy: float
-    _overpowering_state: bool
-    _window_state: bool
-    _motion_state: bool
-    _presence_state: bool
-    _window_auto_state: bool
-    _window_bypass_state: bool
-    _underlyings: list[UnderlyingEntity]
-    _last_change_time: datetime
-
     _entity_component_unrecorded_attributes = (
         ClimateEntity._entity_component_unrecorded_attributes.union(
             frozenset(
@@ -355,6 +341,8 @@ class BaseThermostat(ClimateEntity, RestoreEntity):
         self._ac_mode = entry_infos.get(CONF_AC_MODE) is True
         self._attr_max_temp = entry_infos.get(CONF_TEMP_MAX)
         self._attr_min_temp = entry_infos.get(CONF_TEMP_MIN)
+        if (step := entry_infos.get(CONF_STEP_TEMPERATURE)) is not None:
+            self._attr_target_temperature_step = step
 
         # convert entry_infos into usable attributes
         presets = {}
@@ -400,8 +388,6 @@ class BaseThermostat(ClimateEntity, RestoreEntity):
         self._proportional_function = entry_infos.get(CONF_PROP_FUNCTION)
         self._temp_sensor_entity_id = entry_infos.get(CONF_TEMP_SENSOR)
         self._ext_temp_sensor_entity_id = entry_infos.get(CONF_EXTERNAL_TEMP_SENSOR)
-        # Default value not configurable
-        self._attr_target_temperature_step = 0.1
         self._power_sensor_entity_id = entry_infos.get(CONF_POWER_SENSOR)
         self._max_power_sensor_entity_id = entry_infos.get(CONF_MAX_POWER_SENSOR)
         self._window_sensor_entity_id = entry_infos.get(CONF_WINDOW_SENSOR)
@@ -477,7 +463,7 @@ class BaseThermostat(ClimateEntity, RestoreEntity):
         self._saved_preset_mode = PRESET_NONE
 
         # Power management
-        self._device_power = entry_infos.get(CONF_DEVICE_POWER)
+        self._device_power = entry_infos.get(CONF_DEVICE_POWER) or 0
         self._pmax_on = False
         self._current_power = None
         self._current_power_max = None

custom_components/versatile_thermostat/binary_sensor.py

@@ -383,13 +383,12 @@ class CentralBoilerBinarySensor(BinarySensorEntity):
     async def async_added_to_hass(self) -> None:
         await super().async_added_to_hass()
 
+        api: VersatileThermostatAPI = VersatileThermostatAPI.get_vtherm_api(self._hass)
+        api.register_central_boiler(self)
+
         @callback
         async def _async_startup_internal(*_):
             _LOGGER.debug("%s - Calling async_startup_internal", self)
-            api: VersatileThermostatAPI = VersatileThermostatAPI.get_vtherm_api(
-                self._hass
-            )
-            api.register_central_boiler(self)
             await self.listen_nb_active_vtherm_entity()
 
         if self.hass.state == CoreState.running:
@@ -406,13 +405,13 @@ class CentralBoilerBinarySensor(BinarySensorEntity):
         api: VersatileThermostatAPI = VersatileThermostatAPI.get_vtherm_api(self._hass)
 
         if (
-            api.nb_active_vtherm_for_boiler_entity
+            api.nb_active_device_for_boiler_entity
             and api.nb_active_device_for_boiler_threshold_entity
         ):
             listener_cancel = async_track_state_change_event(
                 self._hass,
                 [
-                    api.nb_active_vtherm_for_boiler_entity.entity_id,
+                    api.nb_active_device_for_boiler_entity.entity_id,
                     api.nb_active_device_for_boiler_threshold_entity.entity_id,
                 ],
                 self.calculate_central_boiler_state,
@@ -420,7 +419,7 @@ class CentralBoilerBinarySensor(BinarySensorEntity):
             _LOGGER.debug(
                 "%s - entity to get the nb of active VTherm is %s",
                 self,
-                api.nb_active_vtherm_for_boiler_entity.entity_id,
+                api.nb_active_device_for_boiler_entity.entity_id,
             )
             self.async_on_remove(listener_cancel)
         else:
@@ -435,7 +434,7 @@ class CentralBoilerBinarySensor(BinarySensorEntity):
         _LOGGER.debug("%s - calculating the new central boiler state", self)
         api: VersatileThermostatAPI = VersatileThermostatAPI.get_vtherm_api(self._hass)
         if (
-            api.nb_active_vtherm_for_boiler is None
+            api.nb_active_device_for_boiler is None
             or api.nb_active_device_for_boiler_threshold is None
         ):
             _LOGGER.warning(
@@ -445,7 +444,7 @@ class CentralBoilerBinarySensor(BinarySensorEntity):
             return False
 
         active = (
-            api.nb_active_vtherm_for_boiler >= api.nb_active_device_for_boiler_threshold
+            api.nb_active_device_for_boiler >= api.nb_active_device_for_boiler_threshold
         )
 
         if self._attr_is_on != active:

custom_components/versatile_thermostat/config_schema.py

@@ -61,6 +61,7 @@ STEP_CENTRAL_MAIN_DATA_SCHEMA = vol.Schema(  # pylint: disable=invalid-name
         ),
         vol.Required(CONF_TEMP_MIN, default=7): vol.Coerce(float),
         vol.Required(CONF_TEMP_MAX, default=35): vol.Coerce(float),
+        vol.Required(CONF_STEP_TEMPERATURE, default=0.1): vol.Coerce(float),
         vol.Required(CONF_ADD_CENTRAL_BOILER_CONTROL, default=False): cv.boolean,
     }
 )
@@ -72,6 +73,7 @@ STEP_CENTRAL_SPEC_MAIN_DATA_SCHEMA = vol.Schema(  # pylint: disable=invalid-name
         ),
         vol.Required(CONF_TEMP_MIN, default=7): vol.Coerce(float),
         vol.Required(CONF_TEMP_MAX, default=35): vol.Coerce(float),
+        vol.Required(CONF_STEP_TEMPERATURE, default=0.1): vol.Coerce(float),
     }
 )
 
@@ -164,6 +166,8 @@ STEP_THERMOSTAT_VALVE = vol.Schema(  # pylint: disable=invalid-name
             ]
         ),
         vol.Optional(CONF_AC_MODE, default=False): cv.boolean,
+        vol.Optional(CONF_AUTO_REGULATION_DTEMP, default=0.5): vol.Coerce(float),
+        vol.Optional(CONF_AUTO_REGULATION_PERIOD_MIN, default=5): cv.positive_int,
     }
 )
 

custom_components/versatile_thermostat/const.py

@@ -40,11 +40,11 @@ HIDDEN_PRESETS = [PRESET_POWER, PRESET_SECURITY]
 DOMAIN = "versatile_thermostat"
 
 PLATFORMS: list[Platform] = [
-    Platform.CLIMATE,
-    Platform.BINARY_SENSOR,
-    Platform.SENSOR,
-    Platform.SELECT,
     Platform.NUMBER,
+    Platform.SELECT,
+    Platform.CLIMATE,
+    Platform.SENSOR,
+    Platform.BINARY_SENSOR,
 ]
 
 CONF_HEATER = "heater_entity_id"
@@ -112,6 +112,7 @@ CONF_AUTO_FAN_LOW = "auto_fan_low"
 CONF_AUTO_FAN_MEDIUM = "auto_fan_medium"
 CONF_AUTO_FAN_HIGH = "auto_fan_high"
 CONF_AUTO_FAN_TURBO = "auto_fan_turbo"
+CONF_STEP_TEMPERATURE = "step_temperature"
 
 # Global params into configuration.yaml
 CONF_SHORT_EMA_PARAMS = "short_ema_params"
@@ -270,6 +271,7 @@ ALL_CONF = (
         CONF_CENTRAL_BOILER_ACTIVATION_SRV,
         CONF_CENTRAL_BOILER_DEACTIVATION_SRV,
         CONF_WINDOW_ACTION,
+        CONF_STEP_TEMPERATURE,
     ]
     + CONF_PRESETS_VALUES
     + CONF_PRESETS_AWAY_VALUES

custom_components/versatile_thermostat/manifest.json

@@ -14,6 +14,6 @@
   "quality_scale": "silver",
   "requirements": [],
   "ssdp": [],
-  "version": "5.3.0",
+  "version": "5.4.0",
   "zeroconf": []
 }

custom_components/versatile_thermostat/number.py

@@ -51,9 +51,6 @@ async def async_setup_entry(
 
     async_add_entities(entities, True)
 
-    api: VersatileThermostatAPI = VersatileThermostatAPI.get_vtherm_api(hass)
-    api.register_central_boiler_activation_number_threshold(entities[0])
-
 
 class ActivateBoilerThresholdNumber(NumberEntity, RestoreEntity):
     """Representation of the threshold of the number of VTherm
@@ -95,6 +92,9 @@ class ActivateBoilerThresholdNumber(NumberEntity, RestoreEntity):
     async def async_added_to_hass(self) -> None:
         await super().async_added_to_hass()
 
+        api: VersatileThermostatAPI = VersatileThermostatAPI.get_vtherm_api(self._hass)
+        api.register_central_boiler_activation_number_threshold(self)
+
         old_state: CoreState = await self.async_get_last_state()
         _LOGGER.debug(
             "%s - Calling async_added_to_hass old_state is %s", self, old_state

custom_components/versatile_thermostat/sensor.py

@@ -49,6 +49,7 @@ from .const import (
     CONF_THERMOSTAT_CLIMATE,
     CONF_THERMOSTAT_TYPE,
     CONF_THERMOSTAT_CENTRAL_CONFIG,
+    CONF_ADD_CENTRAL_BOILER_CONTROL,
     overrides,
 )
 
@@ -74,9 +75,11 @@ async def async_setup_entry(
     entities = None
 
     if vt_type == CONF_THERMOSTAT_CENTRAL_CONFIG:
-        entities = [NbActiveDeviceForBoilerSensor(hass, unique_id, name, entry.data)]
-        api: VersatileThermostatAPI = VersatileThermostatAPI.get_vtherm_api(hass)
-        api.register_nb_vtherm_active_boiler(entities[0])
+        if entry.data.get(CONF_ADD_CENTRAL_BOILER_CONTROL):
+            entities = [
+                NbActiveDeviceForBoilerSensor(hass, unique_id, name, entry.data)
+            ]
+            async_add_entities(entities, True)
     else:
         entities = [
             LastTemperatureSensor(hass, unique_id, name, entry.data),
@@ -105,7 +108,7 @@ async def async_setup_entry(
                 RegulatedTemperatureSensor(hass, unique_id, name, entry.data)
             )
 
-    async_add_entities(entities, True)
+        async_add_entities(entities, True)
 
 
 class EnergySensor(VersatileThermostatBaseEntity, SensorEntity):
@@ -669,6 +672,9 @@ class NbActiveDeviceForBoilerSensor(SensorEntity):
     async def async_added_to_hass(self) -> None:
         await super().async_added_to_hass()
 
+        api: VersatileThermostatAPI = VersatileThermostatAPI.get_vtherm_api(self._hass)
+        api.register_nb_device_active_boiler(self)
+
         @callback
         async def _async_startup_internal(*_):
             _LOGGER.debug("%s - Calling async_startup_internal", self)
@@ -686,24 +692,25 @@ class NbActiveDeviceForBoilerSensor(SensorEntity):
 
         # Listen to all VTherm state change
         self._entities = []
-        entities_id = []
+        underlying_entities_id = []
 
         component: EntityComponent[ClimateEntity] = self.hass.data[CLIMATE_DOMAIN]
         for entity in component.entities:
             if isinstance(entity, BaseThermostat) and entity.is_used_by_central_boiler:
                 self._entities.append(entity)
-                entities_id.append(entity.entity_id)
-        if len(self._entities) > 0:
+                for under in entity.underlying_entities:
+                    underlying_entities_id.append(under.entity_id)
+        if len(underlying_entities_id) > 0:
             # Arme l'écoute de la première entité
             listener_cancel = async_track_state_change_event(
                 self._hass,
-                entities_id,
+                underlying_entities_id,
                 self.calculate_nb_active_devices,
             )
             _LOGGER.info(
-                "%s - VTherm that could controls the central boiler are %s",
+                "%s - the underlyings that could controls the central boiler are %s",
                 self,
-                entities_id,
+                underlying_entities_id,
             )
             self.async_on_remove(listener_cancel)
         else:

custom_components/versatile_thermostat/strings.json

@@ -23,6 +23,7 @@
           "cycle_min": "Cycle duration (minutes)",
           "temp_min": "Minimal temperature allowed",
           "temp_max": "Maximal temperature allowed",
+          "step_temperature": "Temperature step",
           "device_power": "Device power",
           "use_central_mode": "Enable the control by central entity (need central config). Check to enable the control of the VTherm with the select central_mode entities.",
           "use_window_feature": "Use window detection",
@@ -77,7 +78,7 @@
           "valve_entity3_id": "3rd valve number entity id",
           "valve_entity4_id": "4th valve number entity id",
           "auto_regulation_mode": "Auto adjustment of the target temperature",
-          "auto_regulation_dtemp": "The threshold in ° under which the temperature change will not be sent",
+          "auto_regulation_dtemp": "The threshold in ° (or % for valve) under which the temperature change will not be sent",
           "auto_regulation_periode_min": "Duration in minutes between two regulation update",
           "inverse_switch_command": "For switch with pilot wire and diode you may need to inverse the command",
           "auto_fan_mode": " Automatically activate fan when huge heating/cooling is necessary"
@@ -257,6 +258,7 @@
           "cycle_min": "Cycle duration (minutes)",
           "temp_min": "Minimal temperature allowed",
           "temp_max": "Maximal temperature allowed",
+          "step_temperature": "Temperature step",
           "device_power": "Device power",
           "use_central_mode": "Enable the control by central entity (need central config). Check to enable the control of the VTherm with the select central_mode entities.",
           "use_window_feature": "Use window detection",
@@ -311,7 +313,7 @@
           "valve_entity3_id": "3rd valve number entity id",
           "valve_entity4_id": "4th valve number entity id",
           "auto_regulation_mode": "Auto adjustment of the target temperature",
-          "auto_regulation_dtemp": "The threshold in ° under which the temperature change will not be sent",
+          "auto_regulation_dtemp": "The threshold in ° (or % for valve) under which the temperature change will not be sent",
           "auto_regulation_periode_min": "Duration in minutes between two regulation update",
           "inverse_switch_command": "For switch with pilot wire and diode you may need to invert the command",
           "auto_fan_mode": " Automatically activate fan when huge heating/cooling is necessary"

custom_components/versatile_thermostat/thermostat_climate.py

@@ -162,7 +162,6 @@ class ThermostatOverClimate(BaseThermostat):
             self._regulated_target_temp = self.target_temperature
 
         _LOGGER.info("%s - regulation calculation will be done", self)
-        self._last_regulation_change = now
 
         new_regulated_temp = round_to_nearest(
             self._regulation_algo.calculate_regulated_temperature(
@@ -188,6 +187,7 @@ class ThermostatOverClimate(BaseThermostat):
             new_regulated_temp,
         )
 
+        self._last_regulation_change = now
         for under in self._underlyings:
             await under.set_temperature(
                 self.regulated_target_temp, self._attr_max_temp, self._attr_min_temp
@@ -526,7 +526,11 @@ class ThermostatOverClimate(BaseThermostat):
             return
 
         added_energy = 0
-        if self.is_over_climate and self._underlying_climate_delta_t is not None:
+        if (
+            self.is_over_climate
+            and self._underlying_climate_delta_t is not None
+            and self._device_power
+        ):
             added_energy = self._device_power * self._underlying_climate_delta_t
 
         self._total_energy += added_energy
@@ -846,13 +850,14 @@ class ThermostatOverClimate(BaseThermostat):
 
         return self._support_flags
 
-    @property
-    def target_temperature_step(self) -> float | None:
-        """Return the supported step of target temperature."""
-        if self.underlying_entity(0):
-            return self.underlying_entity(0).target_temperature_step
-
-        return None
+    # We keep the step configured for the VTherm and not the step of the underlying
+    # @property
+    # def target_temperature_step(self) -> float | None:
+    #     """Return the supported step of target temperature."""
+    #     if self.underlying_entity(0):
+    #         return self.underlying_entity(0).target_temperature_step
+    #
+    #     return None
 
     @property
     def target_temperature_high(self) -> float | None:

custom_components/versatile_thermostat/thermostat_valve.py

@@ -1,13 +1,13 @@
 # pylint: disable=line-too-long
 """ A climate over switch classe """
 import logging
-from datetime import timedelta
+from datetime import timedelta, datetime
 
 from homeassistant.helpers.event import (
     async_track_state_change_event,
     async_track_time_interval,
 )
-from homeassistant.core import callback
+from homeassistant.core import HomeAssistant, callback
 from homeassistant.components.climate import HVACMode
 
 from .base_thermostat import BaseThermostat
@@ -18,6 +18,9 @@ from .const import (
     CONF_VALVE_2,
     CONF_VALVE_3,
     CONF_VALVE_4,
+    # This is not really self-regulation but regulation here
+    CONF_AUTO_REGULATION_DTEMP,
+    CONF_AUTO_REGULATION_PERIOD_MIN,
     overrides,
 )
 
@@ -44,15 +47,23 @@ class ThermostatOverValve(BaseThermostat):
                     "function",
                     "tpi_coef_int",
                     "tpi_coef_ext",
+                    "auto_regulation_dpercent",
+                    "auto_regulation_period_min",
+                    "last_calculation_timestamp",
                 }
             )
         )
     )
 
-    # Useless for now
-    # def __init__(self, hass: HomeAssistant, unique_id, name, config_entry) -> None:
-    #    """Initialize the thermostat over switch."""
-    #    super().__init__(hass, unique_id, name, config_entry)
+    def __init__(self, hass: HomeAssistant, unique_id, name, config_entry) -> None:
+        """Initialize the thermostat over switch."""
+        self._valve_open_percent: int = 0
+        self._last_calculation_timestamp: datetime = None
+        self._auto_regulation_dpercent: float = None
+        self._auto_regulation_period_min: int = None
+
+        # Call to super must be done after initialization because it calls post_init at the end
+        super().__init__(hass, unique_id, name, config_entry)
 
     @property
     def is_over_valve(self) -> bool:
@@ -65,13 +76,25 @@ class ThermostatOverValve(BaseThermostat):
         if self._hvac_mode == HVACMode.OFF:
             return 0
         else:
-            return round(max(0, min(self.proportional_algorithm.on_percent, 1)) * 100)
+            return self._valve_open_percent
 
     @overrides
     def post_init(self, config_entry):
         """Initialize the Thermostat"""
 
         super().post_init(config_entry)
+
+        self._auto_regulation_dpercent = (
+            config_entry.get(CONF_AUTO_REGULATION_DTEMP)
+            if config_entry.get(CONF_AUTO_REGULATION_DTEMP) is not None
+            else 0.0
+        )
+        self._auto_regulation_period_min = (
+            config_entry.get(CONF_AUTO_REGULATION_PERIOD_MIN)
+            if config_entry.get(CONF_AUTO_REGULATION_PERIOD_MIN) is not None
+            else 0
+        )
+
         self._prop_algorithm = PropAlgorithm(
             self._proportional_function,
             self._tpi_coef_int,
@@ -164,6 +187,17 @@ class ThermostatOverValve(BaseThermostat):
         self._attr_extra_state_attributes["function"] = self._proportional_function
         self._attr_extra_state_attributes["tpi_coef_int"] = self._tpi_coef_int
         self._attr_extra_state_attributes["tpi_coef_ext"] = self._tpi_coef_ext
+        self._attr_extra_state_attributes[
+            "auto_regulation_dpercent"
+        ] = self._auto_regulation_dpercent
+        self._attr_extra_state_attributes[
+            "auto_regulation_period_min"
+        ] = self._auto_regulation_period_min
+        self._attr_extra_state_attributes["last_calculation_timestamp"] = (
+            self._last_calculation_timestamp.astimezone(self._current_tz).isoformat()
+            if self._last_calculation_timestamp
+            else None
+        )
 
         self.async_write_ha_state()
         _LOGGER.debug(
@@ -177,7 +211,21 @@ class ThermostatOverValve(BaseThermostat):
         """A utility function to force the calculation of a the algo and
         update the custom attributes and write the state
         """
-        _LOGGER.debug("%s - recalculate all", self)
+        _LOGGER.debug("%s - recalculate the open percent", self)
+
+        # For testing purpose. Should call _set_now() before
+        now = self.now
+
+        if self._last_calculation_timestamp is not None:
+            period = (now - self._last_calculation_timestamp).total_seconds() / 60
+            if period < self._auto_regulation_period_min:
+                _LOGGER.info(
+                    "%s - do not calculate TPI because regulation_period (%d) is not exceeded",
+                    self,
+                    period,
+                )
+                return
+
         self._prop_algorithm.calculate(
             self._target_temp,
             self._cur_temp,
@@ -185,9 +233,34 @@ class ThermostatOverValve(BaseThermostat):
             self._hvac_mode == HVACMode.COOL,
         )
 
+        new_valve_percent = round(
+            max(0, min(self.proportional_algorithm.on_percent, 1)) * 100
+        )
+
+        dpercent = new_valve_percent - self.valve_open_percent
+        if (
+            dpercent >= -1 * self._auto_regulation_dpercent
+            and dpercent < self._auto_regulation_dpercent
+        ):
+            _LOGGER.debug(
+                "%s - do not calculate TPI because regulation_dpercent (%.1f) is not exceeded",
+                self,
+                dpercent,
+            )
+
+            return
+
+        if self._valve_open_percent == new_valve_percent:
+            _LOGGER.debug("%s - no change in valve_open_percent.", self)
+            return
+
+        self._valve_open_percent = new_valve_percent
+
         for under in self._underlyings:
             under.set_valve_open_percent()
 
+        self._last_calculation_timestamp = now
+
         self.update_custom_attributes()
         self.async_write_ha_state()
 

custom_components/versatile_thermostat/translations/en.json

@@ -23,6 +23,7 @@
           "cycle_min": "Cycle duration (minutes)",
           "temp_min": "Minimal temperature allowed",
           "temp_max": "Maximal temperature allowed",
+          "step_temperature": "Temperature step",
           "device_power": "Device power",
           "use_central_mode": "Enable the control by central entity (need central config). Check to enable the control of the VTherm with the select central_mode entities.",
           "use_window_feature": "Use window detection",
@@ -77,7 +78,7 @@
           "valve_entity3_id": "3rd valve number entity id",
           "valve_entity4_id": "4th valve number entity id",
           "auto_regulation_mode": "Auto adjustment of the target temperature",
-          "auto_regulation_dtemp": "The threshold in ° under which the temperature change will not be sent",
+          "auto_regulation_dtemp": "The threshold in ° (or % for valve) under which the temperature change will not be sent",
           "auto_regulation_periode_min": "Duration in minutes between two regulation update",
           "inverse_switch_command": "For switch with pilot wire and diode you may need to inverse the command",
           "auto_fan_mode": " Automatically activate fan when huge heating/cooling is necessary"
@@ -257,6 +258,7 @@
           "cycle_min": "Cycle duration (minutes)",
           "temp_min": "Minimal temperature allowed",
           "temp_max": "Maximal temperature allowed",
+          "step_temperature": "Temperature step",
           "device_power": "Device power",
           "use_central_mode": "Enable the control by central entity (need central config). Check to enable the control of the VTherm with the select central_mode entities.",
           "use_window_feature": "Use window detection",
@@ -311,7 +313,7 @@
           "valve_entity3_id": "3rd valve number entity id",
           "valve_entity4_id": "4th valve number entity id",
           "auto_regulation_mode": "Auto adjustment of the target temperature",
-          "auto_regulation_dtemp": "The threshold in ° under which the temperature change will not be sent",
+          "auto_regulation_dtemp": "The threshold in ° (or % for valve) under which the temperature change will not be sent",
           "auto_regulation_periode_min": "Duration in minutes between two regulation update",
           "inverse_switch_command": "For switch with pilot wire and diode you may need to invert the command",
           "auto_fan_mode": " Automatically activate fan when huge heating/cooling is necessary"

custom_components/versatile_thermostat/translations/fr.json

@@ -23,6 +23,7 @@
           "cycle_min": "Durée du cycle (minutes)",
           "temp_min": "Température minimale permise",
           "temp_max": "Température maximale permise",
+          "step_temperature": "Pas de température",
           "device_power": "Puissance de l'équipement",
           "use_central_mode": "Autoriser le controle par une entity centrale ('nécessite une config. centrale`). Cochez pour autoriser le contrôle du VTherm par la liste déroulante 'central_mode' de l'entité configuration centrale.",
           "use_window_feature": "Avec détection des ouvertures",
@@ -77,7 +78,7 @@
           "valve_entity3_id": "Entity id de la 3ème valve",
           "valve_entity4_id": "Entity id de la 4ème valve",
           "auto_regulation_mode": "Ajustement automatique de la température cible",
-          "auto_regulation_dtemp": "Le seuil en ° au-dessous duquel la régulation ne sera pas envoyée",
+          "auto_regulation_dtemp": "Le seuil en ° (ou % pour les valves) en-dessous duquel la régulation ne sera pas envoyée",
           "auto_regulation_periode_min": "La durée en minutes entre deux mise à jour faites par la régulation",
           "inverse_switch_command": "Inverse la commande du switch pour une installation avec fil pilote et diode",
           "auto_fan_mode": "Active la ventilation automatiquement en cas d'écart important"
@@ -269,6 +270,7 @@
           "cycle_min": "Durée du cycle (minutes)",
           "temp_min": "Température minimale permise",
           "temp_max": "Température maximale permise",
+          "step_temperature": "Pas de température",
           "device_power": "Puissance de l'équipement",
           "use_central_mode": "Autoriser le controle par une entity centrale ('nécessite une config. centrale`). Cochez pour autoriser le contrôle du VTherm par la liste déroulante 'central_mode' de l'entité configuration centrale.",
           "use_window_feature": "Avec détection des ouvertures",
@@ -323,7 +325,7 @@
           "valve_entity3_id": "Entity id de la 3ème valve",
           "valve_entity4_id": "Entity id de la 4ème valve",
           "auto_regulation_mode": "Ajustement automatique de la consigne",
-          "auto_regulation_dtemp": "Le seuil en ° au-dessous duquel la régulation ne sera pas envoyée",
+          "auto_regulation_dtemp": "Le seuil en ° (ou % pour les valves) en-dessous duquel la régulation ne sera pas envoyée",
           "auto_regulation_periode_min": "La durée en minutes entre deux mise à jour faites par la régulation",
           "inverse_switch_command": "Inverse la commande du switch pour une installation avec fil pilote et diode",
           "auto_fan_mode": "Active la ventilation automatiquement en cas d'écart important"

custom_components/versatile_thermostat/underlyings.py

@@ -765,7 +765,7 @@ class UnderlyingValve(UnderlyingEntity):
             await self.send_percent_open()
 
     async def turn_on(self):
-        """Nothing to do for Valve because it cannot be turned off"""
+        """Nothing to do for Valve because it cannot be turned on"""
         self.set_valve_open_percent()
 
     async def set_hvac_mode(self, hvac_mode: HVACMode) -> bool:

custom_components/versatile_thermostat/vtherm_api.py

@@ -1,6 +1,6 @@
 """ The API of Versatile Thermostat"""
 import logging
-from homeassistant.core import HomeAssistant, HassJob
+from homeassistant.core import HomeAssistant
 from homeassistant.config_entries import ConfigEntry
 
 from .const import (
@@ -107,15 +107,9 @@ class VersatileThermostatAPI(dict):
         """register the two number entities needed for boiler activation"""
         self._threshold_number_entity = threshold_number_entity
 
-    def register_nb_vtherm_active_boiler(self, nb_active_number_entity):
+    def register_nb_device_active_boiler(self, nb_active_number_entity):
         """register the two number entities needed for boiler activation"""
         self._nb_active_number_entity = nb_active_number_entity
-        if self._central_boiler_entity:
-            job = HassJob(
-                self._central_boiler_entity.listen_nb_active_vtherm_entity,
-                "init listen nb active VTherm",
-            )
-            self._hass.async_run_hass_job(job)
 
     async def reload_central_boiler_entities_list(self):
         """Reload the central boiler list of entities if a central boiler is used"""
@@ -138,7 +132,12 @@ class VersatileThermostatAPI(dict):
         return self._safety_mode
 
     @property
-    def nb_active_vtherm_for_boiler(self):
+    def central_boiler_entity(self):
+        """Get the central boiler binary_sensor entity"""
+        return self._central_boiler_entity
+
+    @property
+    def nb_active_device_for_boiler(self):
         """Returns the number of active VTherm which have an
         influence on boiler"""
         if self._nb_active_number_entity is None:
@@ -147,7 +146,7 @@ class VersatileThermostatAPI(dict):
             return self._nb_active_number_entity.native_value
 
     @property
-    def nb_active_vtherm_for_boiler_entity(self):
+    def nb_active_device_for_boiler_entity(self):
         """Returns the number of active VTherm entity which have an
         influence on boiler"""
         return self._nb_active_number_entity

requirements_test.txt

@@ -2,5 +2,7 @@
 -r requirements_dev.txt
 aiodiscover
 ulid_transform
+pytest
+coverage
 pytest-asyncio
 pytest-homeassistant-custom-component

tests/commons.py

@@ -19,6 +19,14 @@ from homeassistant.components.climate import (
     ClimateEntityFeature,
 )
 
+from homeassistant.components.switch import (
+    SwitchEntity,
+)
+
+from homeassistant.components.number import (
+    NumberEntity,
+)
+
 from pytest_homeassistant_custom_component.common import MockConfigEntry
 
 from custom_components.versatile_thermostat.base_thermostat import BaseThermostat
@@ -60,6 +68,7 @@ from .const import (  # pylint: disable=unused-import
     PRESET_NONE,
     PRESET_ECO,
     PRESET_ACTIVITY,
+    overrides,
 )
 
 
@@ -137,6 +146,7 @@ FULL_CENTRAL_CONFIG = {
     CONF_EXTERNAL_TEMP_SENSOR: "sensor.mock_ext_temp_sensor",
     CONF_TEMP_MIN: 15,
     CONF_TEMP_MAX: 30,
+    CONF_STEP_TEMPERATURE: 0.1,
     CONF_TPI_COEF_INT: 0.5,
     CONF_TPI_COEF_EXT: 0.02,
     "frost_temp": 10,
@@ -168,8 +178,53 @@ FULL_CENTRAL_CONFIG = {
     CONF_SECURITY_DELAY_MIN: 61,
     CONF_SECURITY_MIN_ON_PERCENT: 0.5,
     CONF_SECURITY_DEFAULT_ON_PERCENT: 0.2,
+    CONF_ADD_CENTRAL_BOILER_CONTROL: False,
 }
 
+FULL_CENTRAL_CONFIG_WITH_BOILER = {
+    CONF_NAME: CENTRAL_CONFIG_NAME,
+    CONF_THERMOSTAT_TYPE: CONF_THERMOSTAT_CENTRAL_CONFIG,
+    CONF_EXTERNAL_TEMP_SENSOR: "sensor.mock_ext_temp_sensor",
+    CONF_TEMP_MIN: 15,
+    CONF_TEMP_MAX: 30,
+    CONF_STEP_TEMPERATURE: 0.1,
+    CONF_TPI_COEF_INT: 0.5,
+    CONF_TPI_COEF_EXT: 0.02,
+    "frost_temp": 10,
+    "eco_temp": 17.1,
+    "comfort_temp": 0,
+    "boost_temp": 19.1,
+    "eco_ac_temp": 25.1,
+    "comfort_ac_temp": 23.1,
+    "boost_ac_temp": 21.1,
+    "frost_away_temp": 15.1,
+    "eco_away_temp": 15.2,
+    "comfort_away_temp": 0,
+    "boost_away_temp": 15.4,
+    "eco_ac_away_temp": 30.5,
+    "comfort_ac_away_temp": 0,
+    "boost_ac_away_temp": 30.7,
+    CONF_WINDOW_DELAY: 15,
+    CONF_WINDOW_AUTO_OPEN_THRESHOLD: 4,
+    CONF_WINDOW_AUTO_CLOSE_THRESHOLD: 1,
+    CONF_WINDOW_AUTO_MAX_DURATION: 31,
+    CONF_MOTION_DELAY: 31,
+    CONF_MOTION_OFF_DELAY: 301,
+    CONF_MOTION_PRESET: "boost",
+    CONF_NO_MOTION_PRESET: "frost",
+    CONF_POWER_SENSOR: "sensor.mock_power_sensor",
+    CONF_MAX_POWER_SENSOR: "sensor.mock_max_power_sensor",
+    CONF_PRESET_POWER: 14,
+    CONF_MINIMAL_ACTIVATION_DELAY: 11,
+    CONF_SECURITY_DELAY_MIN: 61,
+    CONF_SECURITY_MIN_ON_PERCENT: 0.5,
+    CONF_SECURITY_DEFAULT_ON_PERCENT: 0.2,
+    CONF_ADD_CENTRAL_BOILER_CONTROL: True,
+    CONF_CENTRAL_BOILER_ACTIVATION_SRV: "switch.pompe_chaudiere/switch.turn_on",
+    CONF_CENTRAL_BOILER_DEACTIVATION_SRV: "switch.pompe_chaudiere/switch.turn_off",
+}
+
+
 _LOGGER = logging.getLogger(__name__)
 
 
@@ -210,9 +265,15 @@ class MockClimate(ClimateEntity):
         self._attr_target_temperature = 20
         self._attr_current_temperature = 15
         self._attr_hvac_action = hvac_action
+        self._attr_target_temperature_step = 0.2
         self._fan_modes = fan_modes if fan_modes else None
         self._attr_fan_mode = None
 
+    @property
+    def name(self) -> str:
+        """The name"""
+        return self._name
+
     @property
     def hvac_action(self):
         """The hvac action of the mock climate"""
@@ -244,6 +305,10 @@ class MockClimate(ClimateEntity):
         """The hvac mode"""
         self._attr_hvac_mode = hvac_mode
 
+    def set_hvac_mode(self, hvac_mode):
+        """The hvac mode"""
+        self._attr_hvac_mode = hvac_mode
+
     def set_hvac_action(self, hvac_action: HVACAction):
         """Set the HVACaction"""
         self._attr_hvac_action = hvac_action
@@ -350,6 +415,66 @@ class MagicMockClimate(MagicMock):
         return 19
 
 
+class MockSwitch(SwitchEntity):
+    """A fake switch to be used instead real switch"""
+
+    def __init__(  # pylint: disable=unused-argument, dangerous-default-value
+        self, hass: HomeAssistant, unique_id, name, entry_infos={}
+    ):
+        """Init the switch"""
+        super().__init__()
+
+        self.hass = hass
+        self.platform = "switch"
+        self.entity_id = self.platform + "." + unique_id
+        self._name = name
+        self._attr_is_on = False
+
+    @property
+    def name(self) -> str:
+        """The name"""
+        return self._name
+
+    @overrides
+    def turn_on(self, **kwargs: Any):
+        """Turns the switch on and notify the state change"""
+        self._attr_is_on = True
+        # self.async_write_ha_state()
+
+    @overrides
+    def turn_off(self, **kwargs: Any):
+        """Turns the switch on and notify the state change"""
+        self._attr_is_on = False
+        # self.async_write_ha_state()
+
+
+class MockNumber(NumberEntity):
+    """A fake switch to be used instead real switch"""
+
+    def __init__(  # pylint: disable=unused-argument, dangerous-default-value
+        self, hass: HomeAssistant, unique_id, name, entry_infos={}
+    ):
+        """Init the switch"""
+        super().__init__()
+
+        self.hass = hass
+        self.platform = "number"
+        self.entity_id = self.platform + "." + unique_id
+        self._name = name
+        self._attr_native_value = 0
+        self._attr_native_min_value = 0
+
+    @property
+    def name(self) -> str:
+        """The name"""
+        return self._name
+
+    @overrides
+    def set_native_value(self, value: float):
+        """Change the value"""
+        self._attr_native_value = value
+
+
 async def create_thermostat(
     hass: HomeAssistant, entry: MockConfigEntry, entity_id: str
 ) -> BaseThermostat:
@@ -361,13 +486,6 @@ async def create_thermostat(
         await hass.config_entries.async_setup(entry.entry_id)
         assert entry.state is ConfigEntryState.LOADED
 
-        # def find_my_entity(entity_id) -> ClimateEntity:
-        #     """Find my new entity"""
-        #     component: EntityComponent[ClimateEntity] = hass.data[CLIMATE_DOMAIN]
-        #     for entity in component.entities:
-        #         if entity.entity_id == entity_id:
-        #             return entity
-
         return search_entity(hass, entity_id, CLIMATE_DOMAIN)
 
 

tests/conftest.py

@@ -29,7 +29,11 @@ from custom_components.versatile_thermostat.config_flow import (
 from custom_components.versatile_thermostat.vtherm_api import VersatileThermostatAPI
 from custom_components.versatile_thermostat.base_thermostat import BaseThermostat
 
-from .commons import create_central_config
+from .commons import (
+    create_central_config,
+    FULL_CENTRAL_CONFIG,
+    FULL_CENTRAL_CONFIG_WITH_BOILER,
+)
 
 pytest_plugins = "pytest_homeassistant_custom_component"  # pylint: disable=invalid-name
 
@@ -127,6 +131,16 @@ async def init_central_config_fixture(
     hass, init_vtherm_api
 ):  # pylint: disable=unused-argument
     """Initialize the VTherm API"""
-    await create_central_config(hass)
+    await create_central_config(hass, FULL_CENTRAL_CONFIG)
+
+    yield
+
+
+@pytest.fixture(name="init_central_config_with_boiler_fixture")
+async def init_central_config_with_boiler_fixture(
+    hass, init_vtherm_api
+):  # pylint: disable=unused-argument
+    """Initialize the VTherm API"""
+    await create_central_config(hass, FULL_CENTRAL_CONFIG_WITH_BOILER)
 
     yield

tests/const.py

@@ -33,6 +33,7 @@ MOCK_TH_OVER_4SWITCH_USER_CONFIG = {
     CONF_CYCLE_MIN: 8,
     CONF_TEMP_MIN: 15,
     CONF_TEMP_MAX: 30,
+    CONF_STEP_TEMPERATURE: 0.1,
     CONF_DEVICE_POWER: 1,
     CONF_USE_WINDOW_FEATURE: True,
     CONF_USE_MOTION_FEATURE: True,
@@ -59,6 +60,7 @@ MOCK_TH_OVER_CLIMATE_CENTRAL_MAIN_CONFIG = {
     CONF_EXTERNAL_TEMP_SENSOR: "sensor.mock_ext_temp_sensor",
     CONF_TEMP_MIN: 15,
     CONF_TEMP_MAX: 30,
+    CONF_STEP_TEMPERATURE: 0.1,
     # Keep default values which are False
 }
 
@@ -66,6 +68,7 @@ MOCK_TH_OVER_SWITCH_CENTRAL_MAIN_CONFIG = {
     CONF_EXTERNAL_TEMP_SENSOR: "sensor.mock_ext_temp_sensor",
     CONF_TEMP_MIN: 15,
     CONF_TEMP_MAX: 30,
+    CONF_STEP_TEMPERATURE: 0.1,
     # Keep default values which are False
 }
 

tests/test_bugs.py

@@ -591,6 +591,7 @@ async def test_bug_272(
         domain=DOMAIN,
         title="TheOverClimateMockName",
         unique_id="uniqueId",
+        # default value are min 15°, max 30°, step 0.1
         data=PARTIAL_CLIMATE_CONFIG,  # 5 minutes security delay
     )
 
@@ -623,6 +624,8 @@ async def test_bug_272(
         assert entity.name == "TheOverClimateMockName"
         assert entity.is_over_climate is True
         assert entity.hvac_mode is HVACMode.OFF
+        # The VTherm value and not the underlying value
+        assert entity.target_temperature_step == 0.1
         assert entity.target_temperature == entity.min_temp
         assert entity.is_regulated is True
 

tests/test_central_boiler.py

@@ -0,0 +1,838 @@
+# pylint: disable=wildcard-import, unused-wildcard-import, protected-access, unused-argument, line-too-long
+
+""" Test the central_configuration """
+import asyncio
+from datetime import datetime
+
+from unittest.mock import patch, call
+
+from homeassistant.core import HomeAssistant
+
+from homeassistant.config_entries import ConfigEntryState
+
+from pytest_homeassistant_custom_component.common import MockConfigEntry
+
+from custom_components.versatile_thermostat.thermostat_switch import (
+    ThermostatOverSwitch,
+)
+
+from custom_components.versatile_thermostat.thermostat_valve import (
+    ThermostatOverValve,
+)
+
+from custom_components.versatile_thermostat.thermostat_climate import (
+    ThermostatOverClimate,
+)
+
+from custom_components.versatile_thermostat.vtherm_api import VersatileThermostatAPI
+from custom_components.versatile_thermostat.binary_sensor import (
+    CentralBoilerBinarySensor,
+)
+
+from .commons import *  # pylint: disable=wildcard-import, unused-wildcard-import
+from .const import *  # pylint: disable=wildcard-import, unused-wildcard-import
+
+
+# @pytest.mark.parametrize("expected_lingering_tasks", [True])
+# @pytest.mark.parametrize("expected_lingering_timers", [True])
+async def test_add_a_central_config_with_boiler(
+    hass: HomeAssistant,
+    skip_hass_states_is_state,
+):
+    """Tests the clean_central_config_doubon of base_thermostat"""
+    central_config_entry = MockConfigEntry(
+        domain=DOMAIN,
+        title="TheCentralConfigMockName",
+        unique_id="centralConfigUniqueId",
+        data=FULL_CENTRAL_CONFIG_WITH_BOILER,
+    )
+
+    central_config_entry.add_to_hass(hass)
+    await hass.config_entries.async_setup(central_config_entry.entry_id)
+    assert central_config_entry.state is ConfigEntryState.LOADED
+
+    entity: ThermostatOverClimate = search_entity(
+        hass, "climate.thecentralconfigmockname", "climate"
+    )
+
+    assert entity is None
+
+    assert count_entities(hass, "climate.thecentralconfigmockname", "climate") == 0
+
+    # Test that VTherm API find the CentralConfig
+    api = VersatileThermostatAPI.get_vtherm_api(hass)
+    central_configuration = api.find_central_configuration()
+    assert central_configuration is not None
+
+    # Test that VTherm API have any central boiler entities
+    assert api.nb_active_device_for_boiler_entity is not None
+    assert api.nb_active_device_for_boiler == 0
+
+    assert api.nb_active_device_for_boiler_threshold_entity is not None
+    assert api.nb_active_device_for_boiler_threshold is 1  # the default value is 1
+
+
+async def test_update_central_boiler_state_simple(
+    hass: HomeAssistant,
+    # skip_hass_states_is_state,
+    init_central_config_with_boiler_fixture,
+):
+    """Test that the central boiler state behavoir"""
+
+    api = VersatileThermostatAPI.get_vtherm_api(hass)
+
+    switch1 = MockSwitch(hass, "switch1", "theSwitch1")
+
+    entry = MockConfigEntry(
+        domain=DOMAIN,
+        title="TheOverSwitchMockName",
+        unique_id="uniqueId",
+        data={
+            CONF_NAME: "TheOverSwitchMockName",
+            CONF_THERMOSTAT_TYPE: CONF_THERMOSTAT_SWITCH,
+            CONF_TEMP_SENSOR: "sensor.mock_temp_sensor",
+            CONF_EXTERNAL_TEMP_SENSOR: "sensor.mock_ext_temp_sensor",
+            CONF_CYCLE_MIN: 5,
+            CONF_TEMP_MIN: 8,
+            CONF_TEMP_MAX: 18,
+            "frost_temp": 10,
+            "eco_temp": 17,
+            "comfort_temp": 18,
+            "boost_temp": 21,
+            CONF_USE_WINDOW_FEATURE: False,
+            CONF_USE_MOTION_FEATURE: False,
+            CONF_USE_POWER_FEATURE: False,
+            CONF_USE_PRESENCE_FEATURE: False,
+            CONF_HEATER: switch1.entity_id,
+            CONF_PROP_FUNCTION: PROPORTIONAL_FUNCTION_TPI,
+            CONF_INVERSE_SWITCH: False,
+            CONF_TPI_COEF_INT: 0.3,
+            CONF_TPI_COEF_EXT: 0.01,
+            CONF_MINIMAL_ACTIVATION_DELAY: 30,
+            CONF_SECURITY_DELAY_MIN: 5,
+            CONF_SECURITY_MIN_ON_PERCENT: 0.3,
+            CONF_SECURITY_DEFAULT_ON_PERCENT: 0.1,
+            CONF_USE_MAIN_CENTRAL_CONFIG: True,
+            CONF_USE_TPI_CENTRAL_CONFIG: True,
+            CONF_USE_PRESETS_CENTRAL_CONFIG: True,
+            CONF_USE_ADVANCED_CENTRAL_CONFIG: True,
+            CONF_USED_BY_CENTRAL_BOILER: True,
+        },
+    )
+
+    entity: ThermostatOverSwitch = await create_thermostat(
+        hass, entry, "climate.theoverswitchmockname"
+    )
+    assert entity
+    assert entity.name == "TheOverSwitchMockName"
+    assert entity.is_over_switch
+    assert entity.underlying_entities[0].entity_id == "switch.switch1"
+
+    assert api.nb_active_device_for_boiler_threshold == 1
+    assert api.nb_active_device_for_boiler == 0
+
+    # Force the VTherm to heat
+    await entity.async_set_hvac_mode(HVACMode.HEAT)
+    await entity.async_set_preset_mode(PRESET_BOOST)
+
+    tz = get_tz(hass)  # pylint: disable=invalid-name
+    now: datetime = datetime.now(tz=tz)
+    await send_temperature_change_event(entity, 10, now)
+
+    assert entity.hvac_mode == HVACMode.HEAT
+
+    boiler_binary_sensor: CentralBoilerBinarySensor = search_entity(
+        hass, "binary_sensor.central_boiler", "binary_sensor"
+    )
+    assert boiler_binary_sensor is not None
+    assert boiler_binary_sensor.state == STATE_OFF
+
+    # 1. start a heater
+    with patch(
+        "homeassistant.core.ServiceRegistry.async_call"
+    ) as mock_service_call, patch(
+        "custom_components.versatile_thermostat.binary_sensor.send_vtherm_event"
+    ) as mock_send_event:
+        await switch1.async_turn_on()
+        switch1.async_write_ha_state()
+        # Wait for state event propagation
+        await asyncio.sleep(0.1)
+
+        assert entity.hvac_action == HVACAction.HEATING
+
+        assert mock_service_call.call_count >= 1
+
+        # Sometimes this test fails
+        # mock_service_call.assert_has_calls(
+        #     [
+        #         call.service_call(
+        #             "switch",
+        #             "turn_on",
+        #             service_data={},
+        #             target={"entity_id": "switch.pompe_chaudiere"},
+        #         ),
+        #     ]
+        # )
+
+        assert mock_send_event.call_count >= 1
+        mock_send_event.assert_has_calls(
+            [
+                call.send_vtherm_event(
+                    hass=hass,
+                    event_type=EventType.CENTRAL_BOILER_EVENT,
+                    entity=api.central_boiler_entity,
+                    data={"central_boiler": True},
+                )
+            ]
+        )
+
+        assert api.nb_active_device_for_boiler == 1
+        assert boiler_binary_sensor.state == STATE_ON
+
+    # 2. stop a heater
+    with patch(
+        "homeassistant.core.ServiceRegistry.async_call"
+    ) as mock_service_call, patch(
+        "custom_components.versatile_thermostat.binary_sensor.send_vtherm_event"
+    ) as mock_send_event:
+        await switch1.async_turn_off()
+        switch1.async_write_ha_state()
+        # Wait for state event propagation
+        await asyncio.sleep(0.1)
+
+        assert entity.hvac_action == HVACAction.IDLE
+
+        assert mock_service_call.call_count >= 1
+        mock_service_call.assert_has_calls(
+            [
+                call(
+                    "switch",
+                    "turn_off",
+                    service_data={},
+                    target={"entity_id": "switch.pompe_chaudiere"},
+                )
+            ]
+        )
+
+        assert mock_send_event.call_count >= 1
+        mock_send_event.assert_has_calls(
+            [
+                call.send_vtherm_event(
+                    hass=hass,
+                    event_type=EventType.CENTRAL_BOILER_EVENT,
+                    entity=api.central_boiler_entity,
+                    data={"central_boiler": False},
+                )
+            ]
+        )
+
+        assert api.nb_active_device_for_boiler == 0
+        assert boiler_binary_sensor.state == STATE_OFF
+
+    entity.remove_thermostat()
+
+
+async def test_update_central_boiler_state_multiple(
+    hass: HomeAssistant,
+    # skip_hass_states_is_state,
+    init_central_config_with_boiler_fixture,
+):
+    """Test that the central boiler state behavoir"""
+
+    api = VersatileThermostatAPI.get_vtherm_api(hass)
+
+    switch1 = MockSwitch(hass, "switch1", "theSwitch1")
+    switch2 = MockSwitch(hass, "switch2", "theSwitch2")
+    switch3 = MockSwitch(hass, "switch3", "theSwitch3")
+    switch4 = MockSwitch(hass, "switch4", "theSwitch4")
+
+    entry = MockConfigEntry(
+        domain=DOMAIN,
+        title="TheOverSwitchMockName",
+        unique_id="uniqueId",
+        data={
+            CONF_NAME: "TheOverSwitchMockName",
+            CONF_THERMOSTAT_TYPE: CONF_THERMOSTAT_SWITCH,
+            CONF_TEMP_SENSOR: "sensor.mock_temp_sensor",
+            CONF_EXTERNAL_TEMP_SENSOR: "sensor.mock_ext_temp_sensor",
+            CONF_CYCLE_MIN: 5,
+            CONF_TEMP_MIN: 8,
+            CONF_TEMP_MAX: 18,
+            "frost_temp": 10,
+            "eco_temp": 17,
+            "comfort_temp": 18,
+            "boost_temp": 21,
+            CONF_USE_WINDOW_FEATURE: False,
+            CONF_USE_MOTION_FEATURE: False,
+            CONF_USE_POWER_FEATURE: False,
+            CONF_USE_PRESENCE_FEATURE: False,
+            CONF_HEATER: switch1.entity_id,
+            CONF_HEATER_2: switch2.entity_id,
+            CONF_HEATER_3: switch3.entity_id,
+            CONF_HEATER_4: switch4.entity_id,
+            CONF_PROP_FUNCTION: PROPORTIONAL_FUNCTION_TPI,
+            CONF_INVERSE_SWITCH: False,
+            CONF_TPI_COEF_INT: 0.3,
+            CONF_TPI_COEF_EXT: 0.01,
+            CONF_MINIMAL_ACTIVATION_DELAY: 30,
+            CONF_SECURITY_DELAY_MIN: 5,
+            CONF_SECURITY_MIN_ON_PERCENT: 0.3,
+            CONF_SECURITY_DEFAULT_ON_PERCENT: 0.1,
+            CONF_USE_MAIN_CENTRAL_CONFIG: True,
+            CONF_USE_TPI_CENTRAL_CONFIG: True,
+            CONF_USE_PRESETS_CENTRAL_CONFIG: True,
+            CONF_USE_ADVANCED_CENTRAL_CONFIG: True,
+            CONF_USED_BY_CENTRAL_BOILER: True,
+        },
+    )
+
+    entity: ThermostatOverSwitch = await create_thermostat(
+        hass, entry, "climate.theoverswitchmockname"
+    )
+    assert entity
+    assert entity.name == "TheOverSwitchMockName"
+    assert entity.is_over_switch
+    assert entity.underlying_entities[0].entity_id == "switch.switch1"
+    assert entity.underlying_entities[1].entity_id == "switch.switch2"
+    assert entity.underlying_entities[2].entity_id == "switch.switch3"
+    assert entity.underlying_entities[3].entity_id == "switch.switch4"
+
+    assert api.nb_active_device_for_boiler_threshold == 1
+    assert api.nb_active_device_for_boiler == 0
+    # Force the VTherm to heat
+    await entity.async_set_hvac_mode(HVACMode.HEAT)
+    await entity.async_set_preset_mode(PRESET_BOOST)
+
+    tz = get_tz(hass)  # pylint: disable=invalid-name
+    now: datetime = datetime.now(tz=tz)
+    await send_temperature_change_event(entity, 10, now)
+
+    assert entity.hvac_mode == HVACMode.HEAT
+
+    # 0. set threshold to 3
+    api.nb_active_device_for_boiler_threshold_entity.set_native_value(3)
+    assert api.nb_active_device_for_boiler_threshold == 3
+
+    boiler_binary_sensor: CentralBoilerBinarySensor = search_entity(
+        hass, "binary_sensor.central_boiler", "binary_sensor"
+    )
+    assert boiler_binary_sensor is not None
+    assert boiler_binary_sensor.state == STATE_OFF
+
+    # 1. start a first heater
+    with patch(
+        "homeassistant.core.ServiceRegistry.async_call"
+    ) as mock_service_call, patch(
+        "custom_components.versatile_thermostat.binary_sensor.send_vtherm_event"
+    ) as mock_send_event:
+        await switch1.async_turn_on()
+        switch1.async_write_ha_state()
+        # Wait for state event propagation
+        await asyncio.sleep(0.1)
+
+        assert entity.hvac_action == HVACAction.HEATING
+
+        assert mock_service_call.call_count == 1
+        # No switch of the boiler
+        mock_service_call.assert_has_calls(
+            [
+                call.service_call(
+                    "switch",
+                    "turn_on",
+                    {"entity_id": "switch.switch1"},
+                ),
+            ]
+        )
+        assert mock_send_event.call_count == 0
+
+        assert api.nb_active_device_for_boiler == 1
+        assert boiler_binary_sensor.state == STATE_OFF
+
+    # 2. start a 2nd heater
+    with patch(
+        "homeassistant.core.ServiceRegistry.async_call"
+    ) as mock_service_call, patch(
+        "custom_components.versatile_thermostat.binary_sensor.send_vtherm_event"
+    ) as mock_send_event:
+        await switch2.async_turn_on()
+        switch2.async_write_ha_state()
+        # Wait for state event propagation
+        await asyncio.sleep(0.1)
+
+        assert entity.hvac_action == HVACAction.HEATING
+
+        # Only the first heater is started by the algo
+        assert mock_service_call.call_count == 1
+        # No switch of the boiler. Caution: each time a underlying heater state change itself,
+        # the cycle restarts. So it is always the first heater that is started
+        mock_service_call.assert_has_calls(
+            [
+                call.service_call(
+                    "switch",
+                    "turn_on",
+                    {"entity_id": "switch.switch1"},
+                ),
+            ]
+        )
+        assert mock_send_event.call_count == 0
+
+        assert api.nb_active_device_for_boiler == 2
+        assert boiler_binary_sensor.state == STATE_OFF
+
+    # 3. start a 3rd heater
+    with patch(
+        "homeassistant.core.ServiceRegistry.async_call"
+    ) as mock_service_call, patch(
+        "custom_components.versatile_thermostat.binary_sensor.send_vtherm_event"
+    ) as mock_send_event:
+        await switch3.async_turn_on()
+        switch3.async_write_ha_state()
+        # Wait for state event propagation
+        await asyncio.sleep(0.1)
+
+        assert entity.hvac_action == HVACAction.HEATING
+
+        # Only the first heater is started by the algo
+        assert mock_service_call.call_count == 2
+        # No switch of the boiler. Caution: each time a underlying heater state change itself,
+        # the cycle restarts. So it is always the first heater that is started
+        mock_service_call.assert_has_calls(
+            [
+                call.service_call(
+                    "switch",
+                    "turn_on",
+                    service_data={},
+                    target={"entity_id": "switch.pompe_chaudiere"},
+                ),
+                call.service_call(
+                    "switch",
+                    "turn_on",
+                    {"entity_id": "switch.switch1"},
+                ),
+            ],
+            any_order=True,
+        )
+        assert mock_send_event.call_count == 1
+        mock_send_event.assert_has_calls(
+            [
+                call.send_vtherm_event(
+                    hass=hass,
+                    event_type=EventType.CENTRAL_BOILER_EVENT,
+                    entity=api.central_boiler_entity,
+                    data={"central_boiler": True},
+                )
+            ]
+        )
+
+        assert api.nb_active_device_for_boiler == 3
+        assert boiler_binary_sensor.state == STATE_ON
+
+    # 4. start a 4th heater
+    with patch(
+        "homeassistant.core.ServiceRegistry.async_call"
+    ) as mock_service_call, patch(
+        "custom_components.versatile_thermostat.binary_sensor.send_vtherm_event"
+    ) as mock_send_event:
+        await switch4.async_turn_on()
+        switch4.async_write_ha_state()
+        # Wait for state event propagation
+        await asyncio.sleep(0.1)
+
+        assert entity.hvac_action == HVACAction.HEATING
+
+        # Only the first heater is started by the algo
+        assert mock_service_call.call_count == 1
+        # No switch of the boiler. Caution: each time a underlying heater state change itself,
+        # the cycle restarts. So it is always the first heater that is started
+        mock_service_call.assert_has_calls(
+            [
+                call.service_call(
+                    "switch",
+                    "turn_on",
+                    {"entity_id": "switch.switch1"},
+                ),
+            ]
+        )
+        assert mock_send_event.call_count == 0
+        assert api.nb_active_device_for_boiler == 4
+        assert boiler_binary_sensor.state == STATE_ON
+
+    # 5. stop a heater
+    with patch(
+        "homeassistant.core.ServiceRegistry.async_call"
+    ) as mock_service_call, patch(
+        "custom_components.versatile_thermostat.binary_sensor.send_vtherm_event"
+    ) as mock_send_event:
+        await switch1.async_turn_off()
+        switch1.async_write_ha_state()
+        # Wait for state event propagation
+        await asyncio.sleep(0.1)
+
+        assert entity.hvac_action == HVACAction.HEATING
+
+        assert mock_service_call.call_count == 0
+        assert mock_send_event.call_count == 0
+        assert api.nb_active_device_for_boiler == 3
+        assert boiler_binary_sensor.state == STATE_ON
+
+    # 6. stop a 2nd heater
+    with patch(
+        "homeassistant.core.ServiceRegistry.async_call"
+    ) as mock_service_call, patch(
+        "custom_components.versatile_thermostat.binary_sensor.send_vtherm_event"
+    ) as mock_send_event:
+        await switch4.async_turn_off()
+        switch4.async_write_ha_state()
+        # Wait for state event propagation
+        await asyncio.sleep(0.1)
+
+        assert entity.hvac_action == HVACAction.HEATING
+
+        assert mock_service_call.call_count >= 1
+        mock_service_call.assert_has_calls(
+            [
+                call(
+                    "switch",
+                    "turn_off",
+                    service_data={},
+                    target={"entity_id": "switch.pompe_chaudiere"},
+                )
+            ]
+        )
+
+        assert mock_send_event.call_count >= 1
+        mock_send_event.assert_has_calls(
+            [
+                call.send_vtherm_event(
+                    hass=hass,
+                    event_type=EventType.CENTRAL_BOILER_EVENT,
+                    entity=api.central_boiler_entity,
+                    data={"central_boiler": False},
+                )
+            ]
+        )
+
+        assert api.nb_active_device_for_boiler == 2
+        assert boiler_binary_sensor.state == STATE_OFF
+
+    entity.remove_thermostat()
+
+
+async def test_update_central_boiler_state_simple_valve(
+    hass: HomeAssistant,
+    # skip_hass_states_is_state,
+    init_central_config_with_boiler_fixture,
+):
+    """Test that the central boiler state behavoir"""
+
+    api = VersatileThermostatAPI.get_vtherm_api(hass)
+
+    valve1 = MockNumber(hass, "valve1", "theValve1")
+
+    entry = MockConfigEntry(
+        domain=DOMAIN,
+        title="TheOverValveMockName",
+        unique_id="uniqueId",
+        data={
+            CONF_NAME: "TheOverValveMockName",
+            CONF_THERMOSTAT_TYPE: CONF_THERMOSTAT_VALVE,
+            CONF_TEMP_SENSOR: "sensor.mock_temp_sensor",
+            CONF_EXTERNAL_TEMP_SENSOR: "sensor.mock_ext_temp_sensor",
+            CONF_CYCLE_MIN: 5,
+            CONF_TEMP_MIN: 8,
+            CONF_TEMP_MAX: 18,
+            "frost_temp": 10,
+            "eco_temp": 17,
+            "comfort_temp": 18,
+            "boost_temp": 21,
+            CONF_USE_WINDOW_FEATURE: False,
+            CONF_USE_MOTION_FEATURE: False,
+            CONF_USE_POWER_FEATURE: False,
+            CONF_USE_PRESENCE_FEATURE: False,
+            CONF_VALVE: valve1.entity_id,
+            CONF_PROP_FUNCTION: PROPORTIONAL_FUNCTION_TPI,
+            CONF_INVERSE_SWITCH: False,
+            CONF_TPI_COEF_INT: 0.3,
+            CONF_TPI_COEF_EXT: 0.01,
+            CONF_MINIMAL_ACTIVATION_DELAY: 30,
+            CONF_SECURITY_DELAY_MIN: 5,
+            CONF_SECURITY_MIN_ON_PERCENT: 0.3,
+            CONF_SECURITY_DEFAULT_ON_PERCENT: 0.1,
+            CONF_USE_MAIN_CENTRAL_CONFIG: True,
+            CONF_USE_TPI_CENTRAL_CONFIG: True,
+            CONF_USE_PRESETS_CENTRAL_CONFIG: True,
+            CONF_USE_ADVANCED_CENTRAL_CONFIG: True,
+            CONF_USED_BY_CENTRAL_BOILER: True,
+        },
+    )
+
+    entity: ThermostatOverValve = await create_thermostat(
+        hass, entry, "climate.theovervalvemockname"
+    )
+    assert entity
+    assert entity.name == "TheOverValveMockName"
+    assert entity.is_over_valve
+    assert entity.underlying_entities[0].entity_id == "number.valve1"
+
+    assert api.nb_active_device_for_boiler_threshold == 1
+    assert api.nb_active_device_for_boiler == 0
+
+    # Force the VTherm to heat
+    await entity.async_set_hvac_mode(HVACMode.HEAT)
+    await entity.async_set_preset_mode(PRESET_BOOST)
+
+    tz = get_tz(hass)  # pylint: disable=invalid-name
+    now: datetime = datetime.now(tz=tz)
+
+    assert entity.hvac_mode == HVACMode.HEAT
+
+    boiler_binary_sensor: CentralBoilerBinarySensor = search_entity(
+        hass, "binary_sensor.central_boiler", "binary_sensor"
+    )
+    assert boiler_binary_sensor is not None
+    assert boiler_binary_sensor.state == STATE_OFF
+
+    # 1. start a valve
+    with patch(
+        "homeassistant.core.ServiceRegistry.async_call"
+    ) as mock_service_call, patch(
+        "custom_components.versatile_thermostat.binary_sensor.send_vtherm_event"
+    ) as mock_send_event:
+        await send_temperature_change_event(entity, 10, now)
+        # we have to simulate the valve also else the test don't work
+        valve1.set_native_value(10)
+        valve1.async_write_ha_state()
+        # Wait for state event propagation
+        await asyncio.sleep(0.1)
+
+        assert entity.hvac_action == HVACAction.HEATING
+
+        assert mock_service_call.call_count >= 1
+        mock_service_call.assert_has_calls(
+            [
+                call.service_call(
+                    "switch",
+                    "turn_on",
+                    service_data={},
+                    target={"entity_id": "switch.pompe_chaudiere"},
+                ),
+            ]
+        )
+        assert mock_send_event.call_count >= 1
+        mock_send_event.assert_has_calls(
+            [
+                call.send_vtherm_event(
+                    hass=hass,
+                    event_type=EventType.CENTRAL_BOILER_EVENT,
+                    entity=api.central_boiler_entity,
+                    data={"central_boiler": True},
+                )
+            ]
+        )
+
+        assert api.nb_active_device_for_boiler == 1
+        assert boiler_binary_sensor.state == STATE_ON
+
+    # 2. stop a heater
+    with patch(
+        "homeassistant.core.ServiceRegistry.async_call"
+    ) as mock_service_call, patch(
+        "custom_components.versatile_thermostat.binary_sensor.send_vtherm_event"
+    ) as mock_send_event:
+        await send_temperature_change_event(entity, 25, now)
+        # Change the valve value to 0
+        valve1.set_native_value(0)
+        valve1.async_write_ha_state()
+        # Wait for state event propagation
+        await asyncio.sleep(0.1)
+
+        assert entity.hvac_action == HVACAction.IDLE
+
+        assert mock_service_call.call_count >= 1
+        mock_service_call.assert_has_calls(
+            [
+                call(
+                    "switch",
+                    "turn_off",
+                    service_data={},
+                    target={"entity_id": "switch.pompe_chaudiere"},
+                )
+            ]
+        )
+
+        assert mock_send_event.call_count >= 1
+        mock_send_event.assert_has_calls(
+            [
+                call.send_vtherm_event(
+                    hass=hass,
+                    event_type=EventType.CENTRAL_BOILER_EVENT,
+                    entity=api.central_boiler_entity,
+                    data={"central_boiler": False},
+                )
+            ]
+        )
+
+        assert api.nb_active_device_for_boiler == 0
+        assert boiler_binary_sensor.state == STATE_OFF
+
+    entity.remove_thermostat()
+
+
+async def test_update_central_boiler_state_simple_climate(
+    hass: HomeAssistant,
+    # skip_hass_states_is_state,
+    init_central_config_with_boiler_fixture,
+):
+    """Test that the central boiler state behavoir"""
+
+    api = VersatileThermostatAPI.get_vtherm_api(hass)
+
+    climate1 = MockClimate(hass, "climate1", "theClimate1")
+
+    entry = MockConfigEntry(
+        domain=DOMAIN,
+        title="TheOverClimateMockName",
+        unique_id="uniqueId",
+        data={
+            CONF_NAME: "TheOverClimateMockName",
+            CONF_THERMOSTAT_TYPE: CONF_THERMOSTAT_CLIMATE,
+            CONF_TEMP_SENSOR: "sensor.mock_temp_sensor",
+            CONF_EXTERNAL_TEMP_SENSOR: "sensor.mock_ext_temp_sensor",
+            CONF_CYCLE_MIN: 5,
+            CONF_TEMP_MIN: 8,
+            CONF_TEMP_MAX: 18,
+            "frost_temp": 10,
+            "eco_temp": 17,
+            "comfort_temp": 18,
+            "boost_temp": 21,
+            CONF_USE_WINDOW_FEATURE: False,
+            CONF_USE_MOTION_FEATURE: False,
+            CONF_USE_POWER_FEATURE: False,
+            CONF_USE_PRESENCE_FEATURE: False,
+            CONF_CLIMATE: climate1.entity_id,
+            CONF_MINIMAL_ACTIVATION_DELAY: 30,
+            CONF_SECURITY_DELAY_MIN: 5,
+            CONF_SECURITY_MIN_ON_PERCENT: 0.3,
+            CONF_SECURITY_DEFAULT_ON_PERCENT: 0.1,
+            CONF_USE_MAIN_CENTRAL_CONFIG: True,
+            CONF_USE_PRESETS_CENTRAL_CONFIG: True,
+            CONF_USE_ADVANCED_CENTRAL_CONFIG: True,
+            CONF_USED_BY_CENTRAL_BOILER: True,
+        },
+    )
+
+    with patch(
+        "custom_components.versatile_thermostat.underlyings.UnderlyingClimate.find_underlying_climate",
+        return_value=climate1,
+    ):
+        entity: ThermostatOverValve = await create_thermostat(
+            hass, entry, "climate.theoverclimatemockname"
+        )
+        assert entity
+        assert entity.name == "TheOverClimateMockName"
+        assert entity.is_over_climate
+        assert entity.underlying_entities[0].entity_id == "climate.climate1"
+
+    assert api.nb_active_device_for_boiler_threshold == 1
+    assert api.nb_active_device_for_boiler == 0
+
+    # Force the VTherm to heat
+    await entity.async_set_hvac_mode(HVACMode.HEAT)
+    await entity.async_set_preset_mode(PRESET_BOOST)
+
+    tz = get_tz(hass)  # pylint: disable=invalid-name
+    now: datetime = datetime.now(tz=tz)
+
+    assert entity.hvac_mode == HVACMode.HEAT
+
+    boiler_binary_sensor: CentralBoilerBinarySensor = search_entity(
+        hass, "binary_sensor.central_boiler", "binary_sensor"
+    )
+    assert boiler_binary_sensor is not None
+    assert boiler_binary_sensor.state == STATE_OFF
+
+    # 1. start a climate
+    with patch(
+        "homeassistant.core.ServiceRegistry.async_call"
+    ) as mock_service_call, patch(
+        "custom_components.versatile_thermostat.binary_sensor.send_vtherm_event"
+    ) as mock_send_event:
+        await send_temperature_change_event(entity, 10, now)
+        # we have to simulate the climate also else the test don't work
+        climate1.set_hvac_mode(HVACMode.HEAT)
+        climate1.set_hvac_action(HVACAction.HEATING)
+        climate1.async_write_ha_state()
+        # Wait for state event propagation
+        await asyncio.sleep(0.5)
+
+        assert entity.hvac_action == HVACAction.HEATING
+
+        assert mock_service_call.call_count >= 1
+        mock_service_call.assert_has_calls(
+            [
+                call.service_call(
+                    "switch",
+                    "turn_on",
+                    service_data={},
+                    target={"entity_id": "switch.pompe_chaudiere"},
+                ),
+            ]
+        )
+        assert mock_send_event.call_count >= 1
+        mock_send_event.assert_has_calls(
+            [
+                call.send_vtherm_event(
+                    hass=hass,
+                    event_type=EventType.CENTRAL_BOILER_EVENT,
+                    entity=api.central_boiler_entity,
+                    data={"central_boiler": True},
+                )
+            ]
+        )
+
+        assert api.nb_active_device_for_boiler == 1
+        assert boiler_binary_sensor.state == STATE_ON
+
+    # 2. stop a climate
+    with patch(
+        "homeassistant.core.ServiceRegistry.async_call"
+    ) as mock_service_call, patch(
+        "custom_components.versatile_thermostat.binary_sensor.send_vtherm_event"
+    ) as mock_send_event:
+        await send_temperature_change_event(entity, 25, now)
+        climate1.set_hvac_mode(HVACMode.HEAT)
+        climate1.set_hvac_action(HVACAction.IDLE)
+        climate1.async_write_ha_state()
+        # Wait for state event propagation
+        await asyncio.sleep(0.5)
+
+        assert entity.hvac_action == HVACAction.IDLE
+
+        assert mock_service_call.call_count >= 1
+        mock_service_call.assert_has_calls(
+            [
+                call(
+                    "switch",
+                    "turn_off",
+                    service_data={},
+                    target={"entity_id": "switch.pompe_chaudiere"},
+                )
+            ]
+        )
+
+        assert mock_send_event.call_count >= 1
+        mock_send_event.assert_has_calls(
+            [
+                call.send_vtherm_event(
+                    hass=hass,
+                    event_type=EventType.CENTRAL_BOILER_EVENT,
+                    entity=api.central_boiler_entity,
+                    data={"central_boiler": False},
+                )
+            ]
+        )
+
+        assert api.nb_active_device_for_boiler == 0
+        assert boiler_binary_sensor.state == STATE_OFF
+
+    entity.remove_thermostat()

tests/test_central_config.py

@@ -31,8 +31,8 @@ from .commons import *  # pylint: disable=wildcard-import, unused-wildcard-impor
 from .const import *  # pylint: disable=wildcard-import, unused-wildcard-import
 
 
-@pytest.mark.parametrize("expected_lingering_tasks", [True])
-@pytest.mark.parametrize("expected_lingering_timers", [True])
+# @pytest.mark.parametrize("expected_lingering_tasks", [True])
+# @pytest.mark.parametrize("expected_lingering_timers", [True])
 async def test_add_a_central_config(hass: HomeAssistant, skip_hass_states_is_state):
     """Tests the clean_central_config_doubon of base_thermostat"""
     central_config_entry = MockConfigEntry(
@@ -76,6 +76,7 @@ async def test_add_a_central_config(hass: HomeAssistant, skip_hass_states_is_sta
             CONF_SECURITY_DELAY_MIN: 61,
             CONF_SECURITY_MIN_ON_PERCENT: 0.5,
             CONF_SECURITY_DEFAULT_ON_PERCENT: 0.2,
+            CONF_ADD_CENTRAL_BOILER_CONTROL: False,
         },
     )
 
@@ -96,8 +97,15 @@ async def test_add_a_central_config(hass: HomeAssistant, skip_hass_states_is_sta
     central_configuration = api.find_central_configuration()
     assert central_configuration is not None
 
+    # Test that VTherm API doesn't have any central boiler entities
+    assert api.nb_active_device_for_boiler_entity is None
+    assert api.nb_active_device_for_boiler is None
 
-@pytest.mark.parametrize("expected_lingering_tasks", [True])
+    assert api.nb_active_device_for_boiler_threshold_entity is None
+    assert api.nb_active_device_for_boiler_threshold is None
+
+
+# @pytest.mark.parametrize("expected_lingering_tasks", [True])
 @pytest.mark.parametrize("expected_lingering_timers", [True])
 async def test_minimal_over_switch_wo_central_config(
     hass: HomeAssistant, skip_hass_states_is_state, init_vtherm_api
@@ -116,6 +124,7 @@ async def test_minimal_over_switch_wo_central_config(
             CONF_CYCLE_MIN: 5,
             CONF_TEMP_MIN: 8,
             CONF_TEMP_MAX: 18,
+            CONF_STEP_TEMPERATURE: 0.3,
             "frost_temp": 10,
             "eco_temp": 17,
             "comfort_temp": 18,
@@ -157,8 +166,9 @@ async def test_minimal_over_switch_wo_central_config(
         assert entity._temp_sensor_entity_id == "sensor.mock_temp_sensor"
         assert entity._ext_temp_sensor_entity_id == "sensor.mock_ext_temp_sensor"
         assert entity._cycle_min == 5
-        assert entity._attr_min_temp == 8
-        assert entity._attr_max_temp == 18
+        assert entity.min_temp == 8
+        assert entity.max_temp == 18
+        assert entity.target_temperature_step == 0.3
         assert entity.preset_modes == ["none", "frost", "eco", "comfort", "boost"]
         assert entity.is_window_auto_enabled is False
         assert entity.nb_underlying_entities == 1
@@ -172,9 +182,11 @@ async def test_minimal_over_switch_wo_central_config(
         assert entity._security_default_on_percent == 0.1
         assert entity.is_inversed
 
+    entity.remove_thermostat()
 
-@pytest.mark.parametrize("expected_lingering_tasks", [True])
-@pytest.mark.parametrize("expected_lingering_timers", [True])
+
+# @pytest.mark.parametrize("expected_lingering_tasks", [True])
+# @pytest.mark.parametrize("expected_lingering_timers", [True])
 async def test_full_over_switch_wo_central_config(
     hass: HomeAssistant, skip_hass_states_is_state, init_vtherm_api
 ):
@@ -192,6 +204,7 @@ async def test_full_over_switch_wo_central_config(
             CONF_CYCLE_MIN: 5,
             CONF_TEMP_MIN: 8,
             CONF_TEMP_MAX: 18,
+            CONF_STEP_TEMPERATURE: 0.3,
             "frost_temp": 10,
             "eco_temp": 17,
             "comfort_temp": 18,
@@ -247,8 +260,9 @@ async def test_full_over_switch_wo_central_config(
         assert entity._temp_sensor_entity_id == "sensor.mock_temp_sensor"
         assert entity._ext_temp_sensor_entity_id == "sensor.mock_ext_temp_sensor"
         assert entity._cycle_min == 5
-        assert entity._attr_min_temp == 8
-        assert entity._attr_max_temp == 18
+        assert entity.min_temp == 8
+        assert entity.max_temp == 18
+        assert entity.target_temperature_step == 0.3
         assert entity.preset_modes == [
             "none",
             "frost",
@@ -286,9 +300,11 @@ async def test_full_over_switch_wo_central_config(
 
         assert entity._presence_sensor_entity_id == "binary_sensor.mock_presence_sensor"
 
+    entity.remove_thermostat()
 
-@pytest.mark.parametrize("expected_lingering_tasks", [True])
-@pytest.mark.parametrize("expected_lingering_timers", [True])
+
+# @pytest.mark.parametrize("expected_lingering_tasks", [True])
+# @pytest.mark.parametrize("expected_lingering_timers", [True])
 async def test_full_over_switch_with_central_config(
     hass: HomeAssistant, skip_hass_states_is_state, init_central_config
 ):
@@ -306,6 +322,7 @@ async def test_full_over_switch_with_central_config(
             CONF_CYCLE_MIN: 5,
             CONF_TEMP_MIN: 8,
             CONF_TEMP_MAX: 18,
+            CONF_STEP_TEMPERATURE: 0.3,
             "frost_temp": 10,
             "eco_temp": 17,
             "comfort_temp": 18,
@@ -357,8 +374,9 @@ async def test_full_over_switch_with_central_config(
         assert entity._temp_sensor_entity_id == "sensor.mock_temp_sensor"
         assert entity._ext_temp_sensor_entity_id == "sensor.mock_ext_temp_sensor"
         assert entity._cycle_min == 5
-        assert entity._attr_min_temp == 15
-        assert entity._attr_max_temp == 30
+        assert entity.min_temp == 15
+        assert entity.max_temp == 30
+        assert entity.target_temperature_step == 0.1
         assert entity.preset_modes == [
             "none",
             "frost",
@@ -396,9 +414,11 @@ async def test_full_over_switch_with_central_config(
 
         assert entity._presence_sensor_entity_id == "binary_sensor.mock_presence_sensor"
 
+    entity.remove_thermostat()
 
-@pytest.mark.parametrize("expected_lingering_tasks", [True])
-@pytest.mark.parametrize("expected_lingering_timers", [True])
+
+# @pytest.mark.parametrize("expected_lingering_tasks", [True])
+# @pytest.mark.parametrize("expected_lingering_timers", [True])
 async def test_over_switch_with_central_config_but_no_central_config(
     hass: HomeAssistant, skip_hass_states_get, init_vtherm_api
 ):

tests/test_valve.py

@@ -1,4 +1,4 @@
-# pylint: disable=line-too-long
+# pylint: disable=line-too-long, disable=protected-access
 
 """ Test the normal start of a Switch AC Thermostat """
 from unittest.mock import patch, call
@@ -324,3 +324,232 @@ async def test_over_valve_full_start(
             assert entity.hvac_action is HVACAction.HEATING
             assert entity.target_temperature == 17.1  # eco
             assert entity.valve_open_percent == 10
+
+
+@pytest.mark.parametrize("expected_lingering_timers", [True])
+async def test_over_valve_regulation(
+    hass: HomeAssistant, skip_hass_states_is_state
+):  # pylint: disable=unused-argument
+    """Test the normal full start of a thermostat in thermostat_over_switch type"""
+
+    entry = MockConfigEntry(
+        domain=DOMAIN,
+        title="TheOverValveMockName",
+        unique_id="uniqueId",
+        data={
+            CONF_NAME: "TheOverValveMockName",
+            CONF_THERMOSTAT_TYPE: CONF_THERMOSTAT_VALVE,
+            CONF_TEMP_SENSOR: "sensor.mock_temp_sensor",
+            CONF_EXTERNAL_TEMP_SENSOR: "sensor.mock_ext_temp_sensor",
+            CONF_VALVE: "number.mock_valve",
+            CONF_CYCLE_MIN: 5,
+            CONF_TEMP_MIN: 15,
+            CONF_TEMP_MAX: 30,
+            PRESET_FROST_PROTECTION + "_temp": 7,
+            PRESET_ECO + "_temp": 17,
+            PRESET_COMFORT + "_temp": 19,
+            PRESET_BOOST + "_temp": 21,
+            CONF_USE_WINDOW_FEATURE: False,
+            CONF_USE_MOTION_FEATURE: False,
+            CONF_USE_POWER_FEATURE: False,
+            CONF_USE_PRESENCE_FEATURE: False,
+            CONF_PROP_FUNCTION: PROPORTIONAL_FUNCTION_TPI,
+            CONF_TPI_COEF_INT: 0.3,
+            CONF_TPI_COEF_EXT: 0.01,
+            CONF_MINIMAL_ACTIVATION_DELAY: 30,
+            CONF_SECURITY_DELAY_MIN: 60,
+            CONF_SECURITY_MIN_ON_PERCENT: 0.3,
+            # only send new valve open percent if dtemp is > 30%
+            CONF_AUTO_REGULATION_DTEMP: 5,
+            # only send new valve open percent last mesure was more than 5 min ago
+            CONF_AUTO_REGULATION_PERIOD_MIN: 5,
+        },
+    )
+
+    tz = get_tz(hass)  # pylint: disable=invalid-name
+    now: datetime = datetime.now(tz=tz)
+
+    # 1. prepare the Valve at now
+    with patch(
+        "custom_components.versatile_thermostat.base_thermostat.BaseThermostat.send_event"
+    ) as mock_send_event:
+        entity: ThermostatOverValve = await create_thermostat(
+            hass, entry, "climate.theovervalvemockname"
+        )
+        assert entity
+        assert isinstance(entity, ThermostatOverValve)
+
+        assert entity.name == "TheOverValveMockName"
+        assert entity.is_over_valve is True
+        assert entity._auto_regulation_dpercent == 5
+        assert entity._auto_regulation_period_min == 5
+        assert entity.target_temperature == entity.min_temp
+        assert entity._prop_algorithm is not None
+
+    # 2. Set the HVACMode to HEAT, with manual preset and target_temp to 18 before receiving temperature
+    # at now +1
+    with patch(
+        "custom_components.versatile_thermostat.base_thermostat.BaseThermostat.send_event"
+    ) as mock_send_event:
+        now = now + timedelta(minutes=1)
+        entity._set_now(now)
+
+        # Select a hvacmode, presence and preset
+        await entity.async_set_hvac_mode(HVACMode.HEAT)
+        assert entity.hvac_mode is HVACMode.HEAT
+        # No heating now
+        assert entity.valve_open_percent == 0
+        assert entity.hvac_action == HVACAction.IDLE
+        assert mock_send_event.call_count == 1
+        mock_send_event.assert_has_calls(
+            [
+                call.send_event(
+                    EventType.HVAC_MODE_EVENT,
+                    {"hvac_mode": HVACMode.HEAT},
+                ),
+            ]
+        )
+
+    # 3. Set the preset
+    # at now +1
+    with patch(
+        "custom_components.versatile_thermostat.base_thermostat.BaseThermostat.send_event"
+    ) as mock_send_event:
+        now = now + timedelta(minutes=1)
+        entity._set_now(now)
+
+        # set preset
+        await entity.async_set_preset_mode(PRESET_BOOST)
+        assert entity.preset_mode == PRESET_BOOST
+        assert entity.target_temperature == 21
+        # the preset have changed
+        assert mock_send_event.call_count == 1
+        mock_send_event.assert_has_calls(
+            [
+                call.send_event(
+                    EventType.PRESET_EVENT,
+                    {"preset": PRESET_BOOST},
+                ),
+            ]
+        )
+
+        await entity.async_set_hvac_mode(HVACMode.HEAT)
+        assert entity.hvac_mode is HVACMode.HEAT
+        # Still no heating because we don't have temperature
+        assert entity.valve_open_percent == 0
+        assert entity.hvac_action == HVACAction.IDLE
+
+    # 4. Set temperature and external temperature
+    # at now + 1 (but the _last_calculation_timestamp is still not send)
+    with patch(
+        "custom_components.versatile_thermostat.base_thermostat.BaseThermostat.send_event"
+    ) as mock_send_event, patch(
+        "homeassistant.core.ServiceRegistry.async_call"
+    ) as mock_service_call, patch(
+        "homeassistant.core.StateMachine.get",
+        return_value=State(entity_id="number.mock_valve", state="90"),
+    ):
+        # Change temperature
+        now = now + timedelta(minutes=1)
+        entity._set_now(now)
+
+        await send_temperature_change_event(entity, 18, now)
+        assert entity.valve_open_percent == 90
+
+        assert entity.is_device_active is True
+        assert entity.hvac_action == HVACAction.HEATING
+
+        assert mock_service_call.call_count == 1
+        mock_service_call.assert_has_calls(
+            [
+                call.async_call(
+                    "number",
+                    "set_value",
+                    {"entity_id": "number.mock_valve", "value": 90},
+                ),
+            ]
+        )
+
+        assert mock_send_event.call_count == 0
+
+    # 5. Set external temperature
+    # at now + 1
+    with patch(
+        "custom_components.versatile_thermostat.base_thermostat.BaseThermostat.send_event"
+    ) as mock_send_event, patch(
+        "homeassistant.core.ServiceRegistry.async_call"
+    ) as mock_service_call, patch(
+        "homeassistant.core.StateMachine.get",
+        return_value=State(entity_id="number.mock_valve", state="90"),
+    ):
+        # Change external temperature
+        now = now + timedelta(minutes=1)
+        entity._set_now(now)
+
+        await send_ext_temperature_change_event(entity, 10, now)
+
+        # Should not have change due to regulation (period_min !)
+        assert entity.valve_open_percent == 90
+        assert entity.is_device_active is True
+        assert entity.hvac_action == HVACAction.HEATING
+
+        assert mock_service_call.call_count == 0
+        assert mock_send_event.call_count == 0
+
+    # 6. Set temperature
+    # at now + 5 (to avoid the period_min threshold)
+    with patch(
+        "custom_components.versatile_thermostat.base_thermostat.BaseThermostat.send_event"
+    ) as mock_send_event, patch(
+        "homeassistant.core.ServiceRegistry.async_call"
+    ) as mock_service_call, patch(
+        "homeassistant.core.StateMachine.get",
+        return_value=State(entity_id="number.mock_valve", state="90"),
+    ):
+        # Change external temperature
+        now = now + timedelta(minutes=5)
+        entity._set_now(now)
+
+        await send_ext_temperature_change_event(entity, 15, now)
+
+        # Should have change this time to 96
+        assert entity.valve_open_percent == 96
+        assert entity.is_device_active is True
+        assert entity.hvac_action == HVACAction.HEATING
+
+        assert mock_service_call.call_count == 1
+        mock_service_call.assert_has_calls(
+            [
+                call.async_call(
+                    "number",
+                    "set_value",
+                    {"entity_id": "number.mock_valve", "value": 96},
+                ),
+            ]
+        )
+        assert mock_send_event.call_count == 0
+
+    # 7. Set small temperature update to test dtemp threshold
+    # at now + 5
+    with patch(
+        "custom_components.versatile_thermostat.base_thermostat.BaseThermostat.send_event"
+    ) as mock_send_event, patch(
+        "homeassistant.core.ServiceRegistry.async_call"
+    ) as mock_service_call, patch(
+        "homeassistant.core.StateMachine.get",
+        return_value=State(entity_id="number.mock_valve", state="96"),
+    ):
+        # Change external temperature
+        now = now + timedelta(minutes=5)
+        entity._set_now(now)
+
+        # this generate a delta percent of -3
+        await send_temperature_change_event(entity, 18.1, now)
+
+        # Should not have due to dtemp
+        assert entity.valve_open_percent == 96
+        assert entity.is_device_active is True
+        assert entity.hvac_action == HVACAction.HEATING
+
+        assert mock_service_call.call_count == 0
+        assert mock_send_event.call_count == 0