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

added possibility to login to mqtt broker (anonymous login does not work for every broker)

Browse source
This commit is contained in:
Jonas Arnold 2022-03-07 13:58:54 +01:00
parent 5ebbaba6f1
commit 54bccf3d68
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

@ -555,6 +555,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 ##########