From 87cb265faf90957ab83fa26a084d3cedf703950b Mon Sep 17 00:00:00 2001
From: jens <jens.ahrensfeld@gmx.de>
Date: Thu, 17 Dec 2020 16:58:03 +0100
Subject: [PATCH] - reduce debug log - wired stirrer to emit messages

---
 tasks/heater.py     |  1 -
 tasks/pot.py        |  4 +---
 tasks/stirrer.py    | 11 +++++++++--
 tasks/tempsensor.py |  2 +-
 4 files changed, 11 insertions(+), 7 deletions(-)

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)