daed314585
* Added DSMR Reader platform - Added DSMR Reader platform - Updated codeowners for other components I added earlier * Move sensor definitions to new file * Sensor definitions in new file * Add energy prices from MQTT * lint fixes * Black formatted some files * Update .coveragerc * Support transform methods on definitions * Manifest mangled by Black, fixed * Visual studio code reformatting dictionary error * Fix issues with code, remove unrelated manifest changes * Update CODEOWNERS
87 lines
2.4 KiB
Python
Executable file
87 lines
2.4 KiB
Python
Executable file
"""Support for DSMR Reader through MQTT."""
|
|
import logging
|
|
|
|
from homeassistant.components import mqtt
|
|
from homeassistant.core import callback
|
|
from homeassistant.helpers.entity import Entity
|
|
from homeassistant.util import slugify
|
|
|
|
from .definitions import DEFINITIONS
|
|
|
|
_LOGGER = logging.getLogger(__name__)
|
|
|
|
DOMAIN = "dsmr_reader"
|
|
|
|
|
|
async def async_setup_platform(hass, config, async_add_entities, discovery_info=None):
|
|
"""Set up DSMR Reader sensors."""
|
|
|
|
sensors = []
|
|
for topic in DEFINITIONS:
|
|
sensors.append(DSMRSensor(topic))
|
|
|
|
async_add_entities(sensors)
|
|
|
|
|
|
class DSMRSensor(Entity):
|
|
"""Representation of a DSMR sensor that is updated via MQTT."""
|
|
|
|
def __init__(self, topic):
|
|
"""Initialize the sensor."""
|
|
|
|
self._definition = DEFINITIONS[topic]
|
|
|
|
self._entity_id = slugify(topic.replace("/", "_"))
|
|
self._topic = topic
|
|
|
|
self._name = self._definition["name"]
|
|
self._unit_of_measurement = (
|
|
self._definition["unit"] if "unit" in self._definition else ""
|
|
)
|
|
self._icon = self._definition["icon"] if "icon" in self._definition else None
|
|
self._transform = (
|
|
self._definition["transform"] if "transform" in self._definition else None
|
|
)
|
|
|
|
self._state = None
|
|
|
|
async def async_added_to_hass(self):
|
|
"""Subscribe to MQTT events."""
|
|
|
|
@callback
|
|
def message_received(message):
|
|
"""Handle new MQTT messages."""
|
|
|
|
if self._transform is not None:
|
|
self._state = self._transform(message.payload)
|
|
else:
|
|
self._state = message.payload
|
|
|
|
self.async_schedule_update_ha_state()
|
|
|
|
return await mqtt.async_subscribe(self.hass, self._topic, message_received, 1)
|
|
|
|
@property
|
|
def name(self):
|
|
"""Return the name of the sensor supplied in constructor."""
|
|
return self._name
|
|
|
|
@property
|
|
def entity_id(self):
|
|
"""Return the entity ID for this sensor."""
|
|
return f"sensor.{self._entity_id}"
|
|
|
|
@property
|
|
def state(self):
|
|
"""Return the current state of the entity."""
|
|
return self._state
|
|
|
|
@property
|
|
def unit_of_measurement(self):
|
|
"""Return the unit_of_measurement of this sensor."""
|
|
return self._unit_of_measurement
|
|
|
|
@property
|
|
def icon(self):
|
|
"""Return the icon of this sensor."""
|
|
return self._icon
|