Easy home automation with MQTT and/or openHAB

spacemanspiff2007, updated 🕥 2023-02-09 12:59:44

HABApp

Tests Status Documentation Status Updates PyPI - Python Version

PyPI Downloads Docker Image Version (latest by date) Docker Pulls

Easy automation with MQTT and/or openHAB

HABApp is a asyncio/multithread application that connects to an openHAB instance and/or a MQTT broker. It is possible to create rules that listen to events from these instances and then react accordingly.

Goals

The goal of this application is to provide a simple way to create home automation rules in python. With full syntax highlighting and descriptive names it should almost never be required to look something up in the documentation

Documentation

The documentation can be found at here

Examples

MQTT Rule example

```python import datetime import random

import HABApp from HABApp.mqtt.items import MqttItem from HABApp.core.events import ValueChangeEvent, ValueChangeEventFilter, ValueUpdateEvent, ValueUpdateEventFilter

class ExampleMqttTestRule(HABApp.Rule): def init(self): super().init()

    self.run.every(
        start_time=datetime.timedelta(seconds=60),
        interval=datetime.timedelta(seconds=30),
        callback=self.publish_rand_value
    )

    # this will trigger every time a message is received under "test/test"
    self.listen_event('test/test', self.topic_updated, ValueUpdateEventFilter())

    # This will create an item which will store the payload of the topic so it can be accessed later.
    self.item = MqttItem.get_create_item('test/value_stored')
    # Since the payload is now stored we can trigger only if the value has changed
    self.item.listen_event(self.item_topic_updated, ValueChangeEventFilter())

def publish_rand_value(self):
    print('test mqtt_publish')
    self.mqtt.publish('test/test', str(random.randint(0, 1000)))

def topic_updated(self, event: ValueUpdateEvent):
    assert isinstance(event, ValueUpdateEvent), type(event)
    print( f'mqtt topic "test/test" updated to {event.value}')

def item_topic_updated(self, event: ValueChangeEvent):
    print(self.item.value)  # will output the current item value
    print( f'mqtt topic "test/value_stored" changed from {event.old_value} to {event.value}')

ExampleMqttTestRule() ```

openHAB rule example

```python import HABApp from HABApp.core.events import ValueUpdateEvent, ValueChangeEvent, ValueChangeEventFilter, ValueUpdateEventFilter from HABApp.openhab.events import ItemCommandEvent, ItemStateEventFilter, ItemCommandEventFilter, \ ItemStateChangedEventFilter

class MyOpenhabRule(HABApp.Rule):

def init(self): super().init()

# Trigger on item updates
self.listen_event('TestContact', self.item_state_update, ItemStateEventFilter())
self.listen_event('TestDateTime', self.item_state_update, ValueUpdateEventFilter())

# Trigger on item changes
self.listen_event('TestDateTime', self.item_state_change, ItemStateChangedEventFilter())
self.listen_event('TestSwitch', self.item_state_change, ValueChangeEventFilter())

# Trigger on item commands
self.listen_event('TestSwitch', self.item_command, ItemCommandEventFilter())

def item_state_update(self, event: ValueUpdateEvent): assert isinstance(event, ValueUpdateEvent) print(f'{event}')

def item_state_change(self, event: ValueChangeEvent): assert isinstance(event, ValueChangeEvent) print(f'{event}')

# interaction is available through self.openHAB or self.oh
self.openhab.send_command('TestItemCommand', 'ON')

def item_command(self, event: ItemCommandEvent): assert isinstance(event, ItemCommandEvent) print(f'{event}')

# interaction is available through self.openhab or self.oh
self.oh.post_update('TestItemUpdate', 123)

MyOpenhabRule() ```

Changelog

1.0.8 (2023-02-09)

  • Fixed an issue when using token based authentication with openHAB
  • Fixed an issue with the asyncio event loop under Python < 3.10

1.0.7 (2023-02-09)

  • ContactItem has open()/closed() methods
  • Setting persistence values now works for some persistence services
  • Don't connect when user/password is missing for openHAB

1.0.6 (2022-11-08)

  • Added log message if item for ping does not exist
  • Added execute_python and reworked execute_subprocess: HABApp will now by default pass only the captured output as a str into the callback.
  • Reworked Thing handling

1.0.5 (2022-10-20)

  • Added new item function post_value_if and oh_post_update_if to conditionally update an item
  • Added support for new alive event with openHAB 3.4
  • Reworked file writer for textual thing config
  • Added support for ThingConfigStatusInfoEvent
  • MultiModeValue returns True/False if item value was changed
  • Updated dependencies

1.0.4 (2022-08-25)

  • New RGB & HSB datatype for simpler color handling
  • Fixed Docker build
  • Bugfixes

1.0.3 (2022-08-09)

  • OpenHAB Thing can now be enabled/disabled with thing.set_enabled()
  • ClientID for MQTT should now be unique for every HABApp installation
  • Reworked MultiModeItem, now a default value is possible when no mode is active
  • Added some type hints and updated documentation

1.0.2 (2022-07-29)

  • Fixed setup issues
  • Fixed unnecessary long tracebacks

1.0.1 (2022-07-25)

  • Dockerfile is Python 3.10 and non slim

1.0.0 (2022-07-25)

  • OpenHAB >= 3.3 and Python >= 3.8 only!
  • Major internal refactoring
  • Startup issues are gone with a new and improved connection mechanism.
  • New configuration library: More settings can be configured in the configuration file. Config values are also described in the docs. Also better error messages (hopefully)
  • Improved event log performance (BufferEventFile no longer needed and should be removed)
  • Improved openhab performance (added some buffers)
  • Improved mqtt performance
  • Better tracebacks in case of error
  • EventFilters can be logically combined ("and", "or") so rules trigger only once
  • Label, Groups and Metadata is part of the OpenhabItem and can easily be accessed
  • Added possibility to run arbitrary user code before the HABApp configuration is loaded
  • Fixed setup issues
  • Fixed some known bugs and introduced new ones ;-)
  • Docker file changed to a multi stage build. Mount points changed to /habapp/config.

Migration to new version

self.listen_event now requires an instance of EventFilter.

Old: python from HABApp.core.events import ValueUpdateEvent ... self.my_sensor = Item.get_item('my_sensor') self.my_sensor.listen_event(self.movement, ValueUpdateEvent)

New: python from HABApp.core.events import ValueUpdateEventFilter ... self.my_sensor = Item.get_item('my_sensor') self.my_sensor.listen_event(self.movement, ValueUpdateEventFilter()) # <-- Instance of EventFilter

```text HABApp: ValueUpdateEvent -> ValueUpdateEventFilter() ValueChangeEvent -> ValueChangeEventFilter()

Openhab: ItemStateEvent -> ItemStateEventFilter() ItemStateChangedEvent -> ItemStateChangedEventFilter() ItemCommandEvent -> ItemCommandEventFilter()

MQTT: MqttValueUpdateEvent -> MqttValueUpdateEventFilter() MqttValueChangeEvent -> MqttValueChangeEventFilter() ```

Migration to new docker image - change the mount point of the config from /config to /habapp/config - The new image doesn't run as root. You can set USER_ID and GROUP_ID to the user you want habapp to run with. It's necessary to modify the permissions of the mounted folder accordingly.


0.31.2 (2021-12-17)

  • Added command line switch to display debug information
  • Display debug information on missing dependencies
  • Added a small splash screen when HABApp is started
  • May doc updates
  • Reworked EventListenerGroup

0.31.1 (2021-10-29)

  • Added support for item metadata
  • Added possibility to search for items by metadata
  • Added EventListenerGroup to subscribe/cancel multiple listeners at once

0.31.0 (2021-10-08)

  • added self.get_items to easily search for items in a rule
  • added full support for tags and groups on OpenhabItem
  • Application should now properly shut down when there is a PermissionError
  • Added DatetimeItem to docs
  • Label in commandOption is optional
  • Added message when file is removed
  • Examples in the docs get checked with a newly created sphinx extension
  • Reworked the openHAB tests

0.30.3 (2021-06-17)

  • add support for custom ca cert for MQTT
  • Scheduler runs only when the rule file has been loaded properly
  • Sync openHAB calls raise an error when called from an async context
  • Replaced thread check for asyncio with a contextvar (internal)

0.30.3 (2021-06-01)

  • Scheduler runs only when the rule file has been loaded properly
  • Replaced thread check for asyncio with a contextvar
  • Sync openHAB calls raise an error when called from an async context

0.30.2 (2021-05-26)

  • Item and Thing loading from openHAB is more robust and disconnects now properly if openHAB is only partly ready
  • Renamed command line argument "-s" to "-wos" or "--wait_os_uptime"
  • Updated dependencies

0.30.1 (2021-05-07)

  • latitude is now set correctly for sunrise/sunset calculation (closes #217)
  • Added missing " for tags in textual thing configuration
  • Updated scheduler which fixes an overflow error(#216)
  • States of openHAB groups are now unpacked correctly

0.30.0 (2021-05-02)

Attention: - No more support for python 3.6! - Migration of rules is needed!

Changelog - Switched to Apache2.0 License - Fix DateTime string parsing for OH 3.1 (#214) - State of Groupitem gets set correctly - About ~50% performance increase for async calls in rules - Significantly less CPU usage when no functions are running - Completely reworked the file handling (loading and dependency resolution) - Completely reworked the Scheduler! - Has now subsecond accuracy (finally!) - Has a new .countdown() job which can simplify many rules. It is made for functions that do something after a certain period of time (e.g. switch a light off after movement) - Added hsb_to_rgb, rgb_to_hsb functions which can be used in rules - Better error message if configured foldes overlap with HABApp folders - Renamed HABAppError to HABAppException - Some Doc improvements

Migration of rules: - Search for self.run_ and replace with self.run. - Search for self.run.in and replace with self.run.at - Search for .get_next_call() and replace with .get_next_run() (But make sure it's a scheduled job) - Search for HABAppError and replace with HABAppException

0.20.2 (2021-04-07)

  • Added HABApp.util.functions with min/max
  • Reworked small parts of the file watcher
  • Doc improvements
  • Dependency updates

Issues

Prevent adding rules after the file was loaded

opened on 2023-03-06 06:01:03 by spacemanspiff2007

Especially beginners try to dynamically create rules from other rules without being aware of the possible issues. Add a simple mode that prevents creating rules after the file has been loaded

Rework FileWatcher

opened on 2023-02-14 12:56:03 by spacemanspiff2007

Rework FileWatcher so the same file e.g. with different permissions/timestamp/newlines is not reloaded

Doc tweaks

opened on 2023-02-10 18:24:39 by Dantenz

I tried to push some changes for PR, but it seems the repo is locked down - so here's a ticket.

I ran into some major headaches when trying to use the set_metadata() function. The documentation for the namespace parameter currently says "namespace", which isn't very useful. I ended up searching the internet for some time trying to find out what an acceptable value would be and in the end figured it out by playing around with the OpenHAB UI. My recommendations for change are:

docs/interface_openhab.rst ``Function parameters ====================================== If referring to namespaces, a full list can be found in theopenHAB repo https://github.com/openhab/openhab-webui/blob/main/bundles/org.openhab.ui/web/src/assets/definitions/metadata/namespaces.js`_.

.. automodule:: HABApp.openhab.interface :members: :imported-members: ```

openhab/connection_handler/func_sync.py ```def set_metadata(item_name: str, namespace: str, value: str, config: dict): """ Add/set metadata to an item

:param item_name: name of the item or item
:param namespace: namespace, e.g. stateDescription
:param value: value
:param config: configuration, e.g. {"options": "A,B,C"}
:return: True if metadata was successfully created/updated
"""

Reloading logging config does not restart the logging thread

opened on 2023-01-29 08:59:49 by spacemanspiff2007

[ HABApp.logging] DEBUG | LogBufferEventFile thread stopped

New StrEnumItem

opened on 2023-01-15 09:40:48 by spacemanspiff2007

It would be nice if there is an item that only accepts StrEnum values. Make it in a way that the IDE can provide auto-complete and checks.

Thing action support

opened on 2023-01-02 04:45:01 by spacemanspiff2007

Thing actions are now available through #926. Add support.

Releases

v1.0.8 2023-02-09 12:58:54

  • Fixed an issue when using token based authentication with openHAB
  • Fixed an issue with the asyncio event loop under Python < 3.10

v1.0.7.release 2023-02-09 08:09:20

v1.0.7 2023-02-09 07:38:38

  • ContactItem has open()/closed() methods
  • Setting persistence values now works for some persistence services
  • Don't connect when user/password is missing for openHAB

v1.0.6 2022-11-08 05:18:48

  • Added log message if item for ping does not exist
  • File writer for Thing config doesn't create empty files
  • Fixed thing table for textual thing config
  • Added execute_python to rule and reworked execute_subprocess
  • Added item_registry to ignored exception paths

v1.0.5 2022-10-20 12:20:08

  • Added new item function post_value_if and oh_post_update_if to conditionally update an item
  • Added support for new alive event with openHAB 3.4
  • Reworked file writer for textual thing config
  • Added support for ThingConfigStatusInfoEvent
  • MultiModeValue returns True/False if item value was changed
  • Updated dependencies

v1.0.4 2022-08-25 04:34:09

  • New RGB & HSB datatype for simpler color handling
  • Fixed Docker build
  • Bugfixes
spacemanspiff2007
GitHub Repository

python openhab mqtt pypi home-automation