diff --git a/tasks/heater.py b/tasks/heater.py index 8334ea2..21b44be 100644 --- a/tasks/heater.py +++ b/tasks/heater.py @@ -26,7 +26,6 @@ class HeaterTask(ATask): asyncio.create_task(self.send({'Power': power})) async def recv(self, data): - print(data) for pair in data.items(): if 'Power' in pair[0]: self.power_soll = pair[1] diff --git a/tasks/pot.py b/tasks/pot.py index 354ece5..f0c1178 100644 --- a/tasks/pot.py +++ b/tasks/pot.py @@ -20,9 +20,7 @@ class PotTask(ATask): asyncio.create_task(self.send({'Temp': value})) async def recv(self, data): - print(data) - for key in data: - print(key) + pass async def send(self, data): await self.msg_handler.send(data) diff --git a/tasks/stirrer.py b/tasks/stirrer.py index 5d6aafd..78082d9 100644 --- a/tasks/stirrer.py +++ b/tasks/stirrer.py @@ -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) diff --git a/tasks/tempsensor.py b/tasks/tempsensor.py index ce34276..5983f53 100644 --- a/tasks/tempsensor.py +++ b/tasks/tempsensor.py @@ -17,7 +17,7 @@ class TempSensorTask(ATask): asyncio.create_task(self.send({'Temp': value})) async def recv(self, data): - print(data) + pass async def send(self, data): await self.msg_handler.send(data)