Added MQTT integration including homeassistant auto-discovery information

app.py

@@ -1600,6 +1600,29 @@ def settings_page(action=None):
 		if 'influxdb_bucket' in response:
 			settings['notify_services']['influxdb']['bucket'] = response['influxdb_bucket']
 
+		if _is_checked(response, 'mqtt_enabled'):
+			settings['notify_services']['mqtt']['enabled'] = True
+		else:
+			settings['notify_services']['mqtt']['enabled'] = False
+		#if _is_checked(response, 'mqtt_control'):
+		#	settings['notify_services']['mqtt']['control'] = True
+		#else:
+		#	settings['notify_services']['mqtt']['control'] = False
+		if 'mqtt_id' in response:
+			settings['notify_services']['mqtt']['id'] = response['mqtt_id']
+		if 'mqtt_broker' in response:
+			settings['notify_services']['mqtt']['broker'] = response['mqtt_broker']
+		if 'mqtt_port' in response:
+			settings['notify_services']['mqtt']['port'] = response['mqtt_port']
+		if 'mqtt_user' in response:
+			settings['notify_services']['mqtt']['username'] = response['mqtt_user']
+		if 'mqtt_pw' in response:
+			settings['notify_services']['mqtt']['password'] = response['mqtt_pw']
+		if 'mqtt_auto_d' in response:
+			settings['notify_services']['mqtt']['homeassistant_autodiscovery_topic'] = response['mqtt_auto_d']
+		if 'mqtt_freq' in response:
+			settings['notify_services']['mqtt']['update_sec'] = response['mqtt_freq']
+
 		if 'delete_device' in response:
 			DeviceID = response['delete_device']
 			settings['notify_services']['onesignal']['devices'].pop(DeviceID)

auto-install/install.sh

@@ -128,6 +128,7 @@ python -m pip install scikit-fuzzy
 python -m pip install scikit-learn
 python -m pip install ratelimitingfilter
 python -m pip install "pillow>=9.2.0"
+python -m pip install paho-mqtt
 
 # Setup config.txt to enable busses 
 clear

common/common.py

@@ -403,6 +403,18 @@ def default_notify_services():
 		'org': '',
 		'bucket': ''
 	}
+
+	services['mqtt'] = {
+      "broker": "homeassistant.local",
+      #"control": False,
+      "enabled": False,
+      "homeassistant_autodiscovery_topic": "homeassistant",
+      "id": "PiFire",
+      "password": "",
+      "port": "1883",
+      "update_sec": "30",
+      "username": ""
+    }
 
 	return services
 

control.py

@@ -1241,6 +1241,8 @@ def _recipe_mode(grill_platform, probe_complex, display_device, dist_device, sta
 			write_control(control, direct_write=True, origin='control')
 			_work_cycle('Reignite', grill_platform, probe_complex, display_device, dist_device)
 			_next_mode(control['next_mode'], setpoint=setpoint)
+
+	check_notify(settings, control, pelletdb=pelletdb)
 
 	time.sleep(0.1)
 # ===================