- added listener for 'activate'

This commit is contained in:
jens
2020-12-17 16:35:30 +01:00
parent ddf8003f5c
commit 87d394ca17
+7
View File
@@ -2,6 +2,7 @@ import asyncio
from tasks import ATask from tasks import ATask
from ws.message import MsgIo from ws.message import MsgIo
from components import AStirrer from components import AStirrer
from utils.value import ChangedInteger
class StirrerTask(ATask): class StirrerTask(ATask):
@@ -20,6 +21,9 @@ class StirrerTask(ATask):
def on_cycletime_changed(self, value): def on_cycletime_changed(self, value):
asyncio.create_task(self.send({'CycleTime': value})) asyncio.create_task(self.send({'CycleTime': value}))
def on_changed_active(self, is_activated):
asyncio.create_task(self.send({'Activate': int(is_activated)}))
async def recv(self, data): async def recv(self, data):
print(data) print(data)
@@ -31,6 +35,9 @@ class StirrerTask(ATask):
self.device.set_on_changed("speed", self.on_speed_changed) self.device.set_on_changed("speed", self.on_speed_changed)
self.device.set_on_changed("dutyCycle", self.on_dutycycle_changed) self.device.set_on_changed("dutyCycle", self.on_dutycycle_changed)
self.device.set_on_changed("cycleTime", self.on_cycletime_changed) self.device.set_on_changed("cycleTime", self.on_cycletime_changed)
self.device.set_on_changed("cycleTime", self.on_cycletime_changed)
self.device.set_on_changed('is_active', ChangedInteger(self.on_changed_active).set)
while True: while True:
self.device.process() self.device.process()
await asyncio.sleep(self.interval) await asyncio.sleep(self.interval)