- reduce debug log

- wired stirrer to emit messages
This commit is contained in:
jens
2020-12-17 16:58:03 +01:00
parent 87d394ca17
commit 87cb265faf
4 changed files with 11 additions and 7 deletions
+9 -2
View File
@@ -25,7 +25,11 @@ class StirrerTask(ATask):
asyncio.create_task(self.send({'Activate': int(is_activated)}))
async def recv(self, data):
print(data)
for pair in data.items():
if 'Speed' in pair[0]:
self.device.set_speed(pair[1])
if 'Activate' in pair[0]:
self.device.activate(bool(pair[1]))
async def send(self, data):
await self.msg_handler.send(data)
@@ -35,9 +39,12 @@ class StirrerTask(ATask):
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("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)
self.device.set_speed(10.0)
self.device.set_cycle_time(10.0)
self.device.set_duty_cycle(100)
while True:
self.device.process()
await asyncio.sleep(self.interval)