mirror of
https://github.com/PiBrewing/craftbeerpi4.git
synced 2024-11-14 11:08:15 +01:00
db39d82432
- command line cbpi plugins -> not interrupted if plugin has not been installed correctly - round power value submitted by mqtt plugin
69 lines
2.1 KiB
Python
69 lines
2.1 KiB
Python
# -*- coding: utf-8 -*-
|
|
import asyncio
|
|
import json
|
|
from cbpi.api import parameters, Property, CBPiActor
|
|
from cbpi.api import *
|
|
|
|
@parameters([Property.Text(label="Topic", configurable=True, description = "MQTT Topic")])
|
|
class MQTTActor(CBPiActor):
|
|
|
|
# Custom property which can be configured by the user
|
|
@action("Set Power", parameters=[Property.Number(label="Power", configurable=True,description="Power Setting [0-100]")])
|
|
async def setpower(self,Power = 100 ,**kwargs):
|
|
self.power=round(Power)
|
|
if self.power < 0:
|
|
self.power = 0
|
|
if self.power > 100:
|
|
self.power = 100
|
|
await self.set_power(self.power)
|
|
|
|
def __init__(self, cbpi, id, props):
|
|
super(MQTTActor, self).__init__(cbpi, id, props)
|
|
|
|
async def on_start(self):
|
|
self.topic = self.props.get("Topic", None)
|
|
self.power = 100
|
|
|
|
async def on(self, power=None):
|
|
if power is not None:
|
|
if power != self.power:
|
|
power = min(100, power)
|
|
power = max(0, power)
|
|
self.power = round(power)
|
|
await self.cbpi.satellite.publish(self.topic, json.dumps(
|
|
{"state": "on", "power": self.power}), True)
|
|
self.state = True
|
|
pass
|
|
|
|
async def off(self):
|
|
self.state = False
|
|
await self.cbpi.satellite.publish(self.topic, json.dumps(
|
|
{"state": "off", "power": self.power}), True)
|
|
pass
|
|
|
|
async def run(self):
|
|
while self.running:
|
|
await asyncio.sleep(1)
|
|
|
|
def get_state(self):
|
|
return self.state
|
|
|
|
async def set_power(self, power):
|
|
self.power = round(power)
|
|
if self.state == True:
|
|
await self.on(power)
|
|
else:
|
|
await self.off()
|
|
await self.cbpi.actor.actor_update(self.id,power)
|
|
pass
|
|
|
|
def setup(cbpi):
|
|
'''
|
|
This method is called by the server during startup
|
|
Here you need to register your plugins at the server
|
|
|
|
:param cbpi: the cbpi core
|
|
:return:
|
|
'''
|
|
if str(cbpi.static_config.get("mqtt", False)).lower() == "true":
|
|
cbpi.plugin.register("MQTTActor", MQTTActor)
|