Schrolli91/BOSWatch
1
0
Fork 0
mirror of https://github.com/Schrolli91/BOSWatch.git synced 2026-01-22 00:00:25 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

added possibility to configure login data for mqtt broker

Browse source
This commit is contained in:
Jonas Arnold 2022-03-14 08:52:09 +01:00
parent c75a807ad1
commit 14ab195061
2 changed files with 14 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
config/config.template.ini
View file

@ -596,6 +596,9 @@ commandPOC =
#Adress from MQTT-Broker
brokeraddress = 192.168.178.27
topic = alarm/data
# username and password for the broker. leave username empty to use anonymous login
brokerusername =
brokerpassword =
#####################
##### Not ready yet #

12
plugins/mqtt/mqtt.py
View file

@ -77,7 +77,11 @@ def run(typ,freq,data):
########## User Plugin CODE ##########
broker_address = globalVars.config.get("mqtt", "brokeraddress")
topic = globalVars.config.get("mqtt", "topic")
mqttClient = mqtt.Client()
broker_username = globalVars.config.get("mqtt", "brokerusername")
broker_password = globalVars.config.get("mqtt", "brokerpassword")
mqttClient = mqtt.Client()
if typ == "FMS":
x = {
@ -112,6 +116,12 @@ def run(typ,freq,data):
logging.warning("Invalid Typ: %s", typ)
y = json.dumps(x)
## only login if there is a username given
if( len(broker_username) > 0 ):
mqttClient.username_pw_set(broker_username, broker_password)
mqttClient.connect(broker_address)
mqttClient.publish(topic,y)
########## User Plugin CODE ##########