craftbeerpi4-pione/cbpi/api/sensor.py

66 lines
1.4 KiB
Python
Raw Normal View History

2021-02-16 20:37:51 +01:00
import asyncio
2019-08-16 21:36:55 +02:00
import logging
2021-01-22 23:25:20 +01:00
from abc import abstractmethod, ABCMeta
2019-01-05 20:43:48 +01:00
from cbpi.api.extension import CBPiExtension
2021-02-16 20:37:51 +01:00
2021-02-10 07:38:55 +01:00
from cbpi.api.base import CBPiBase
2019-01-05 20:43:48 +01:00
2021-02-10 07:38:55 +01:00
class CBPiSensor(CBPiBase, metaclass=ABCMeta):
2021-01-22 23:25:20 +01:00
def __init__(self, cbpi, id, props):
self.cbpi = cbpi
self.id = id
self.props = props
self.logger = logging.getLogger(__file__)
self.data_logger = None
self.state = False
self.running = False
def init(self):
pass
def log_data(self, value):
self.cbpi.log.log_data(self.id, value)
def get_state(self):
pass
def get_value(self):
pass
def get_unit(self):
pass
2021-01-24 22:14:57 +01:00
def push_update(self, value):
try:
self.cbpi.ws.send(dict(topic="sensorstate", id=self.id, value=value))
2021-03-14 11:52:46 +01:00
self.cbpi.push_update("cbpi/sensor/{}/udpate".format(self.id), dict(id=self.id, value=value), retain=True)
2021-01-24 22:14:57 +01:00
except:
logging.error("Faild to push sensor update")
2021-01-22 23:25:20 +01:00
async def start(self):
2021-02-16 20:37:51 +01:00
pass
2021-01-22 23:25:20 +01:00
async def stop(self):
2021-02-16 20:37:51 +01:00
pass
async def on_start(self):
pass
async def on_stop(self):
pass
async def run(self):
pass
async def _run(self):
try:
await self.on_start()
self.cancel_reason = await self.run()
except asyncio.CancelledError as e:
pass
finally:
await self.on_stop()