From 8cab633291f65020d84f92976d58193dd6ae7a96 Mon Sep 17 00:00:00 2001
From: avollkopf <43980694+avollkopf@users.noreply.github.com>
Date: Fri, 23 Feb 2024 06:47:17 +0100
Subject: [PATCH] fixed payload for last mqtt change

---
 cbpi/__init__.py                           |  2 +-
 cbpi/controller/fermentation_controller.py | 11 +++++++++--
 2 files changed, 10 insertions(+), 3 deletions(-)

diff --git a/cbpi/__init__.py b/cbpi/__init__.py
index 231f90e..5285c9f 100644
--- a/cbpi/__init__.py
+++ b/cbpi/__init__.py
@@ -1,3 +1,3 @@
-__version__ = "4.3.2.a9"
+__version__ = "4.3.2.a10"
 __codename__ = "Winter Storm"
 
diff --git a/cbpi/controller/fermentation_controller.py b/cbpi/controller/fermentation_controller.py
index 4b6a1f3..512a528 100644
--- a/cbpi/controller/fermentation_controller.py
+++ b/cbpi/controller/fermentation_controller.py
@@ -545,12 +545,19 @@ class FermentationController:
 
             # send mqtt update for active femrentersteps
             for fermenter in fermentersteps:
+                active = False
                 for step in fermenter['steps']:
                     if step['status'] == 'A':
+                        active=True
+                        active_step=step
 #                        self.cbpi.push_update("cbpi/{}/{}/{}".format(key,fermenter['id'],step['id']), step)
-                        self.cbpi.push_update("cbpi/{}/{}".format(key,fermenter['id']), step)
                     #else:
-                    #    self.cbpi.push_update("cbpi/{}/{}/{}".format(key,fermenter['id'],step['id']), "")
+                    #    self.cbpi.push_update("cbpi/{}/{}".format(key,fermenter['id']), "")
+                if active:
+                    self.cbpi.push_update("cbpi/{}/{}".format(key,fermenter['id']), active_step)
+                else:
+                    self.cbpi.push_update("cbpi/{}/{}".format(key,fermenter['id']), "")
+
                         
         
     async def call_action(self, id, action, parameter) -> None: