AdamAnt/mqtt-dash
1
0
Fork 0
mirror of https://github.com/Adam-Ant/mqtt-dash synced 2025-10-31 10:17:17 +00:00
Code Issues Releases Wiki Activity

Add SSL support as a configuration option

Browse Source
This commit is contained in:
CyclingEngineer
2017-07-22 16:37:29 +01:00
parent 39564cbf35
commit 1ce2d727cc
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
main.py
View File

@@ -4,6 +4,7 @@ import paho.mqtt.client as mqtt
import logging import logging
import argparse import argparse
from time import sleep from time import sleep
import ssl
logging.getLogger("scapy.runtime").setLevel(logging.ERROR) logging.getLogger("scapy.runtime").setLevel(logging.ERROR)
from scapy.all import * from scapy.all import *
@@ -21,6 +22,12 @@ host =
#user = #user =
# Password (if required) # Password (if required)
#pass = #pass =
# SSL required? (Default: False)
# Uses TLSv1.2
#ssl = True
# CA Cert location (Default: /etc/ssl/certs/ca-certificates.crt)
# This is sufficient for brokers using LetsEncrypt
#certpath =
[Buttons] [Buttons]
# For every line, list the MAC of the button, and the MQTT topic to publish to. # For every line, list the MAC of the button, and the MQTT topic to publish to.
@@ -69,6 +76,8 @@ if __name__ == '__main__':
hostname = config['MQTT'].get('host') hostname = config['MQTT'].get('host')
port = config['MQTT'].get('port') port = config['MQTT'].get('port')
authrequired = config['MQTT'].getboolean('auth', False) authrequired = config['MQTT'].getboolean('auth', False)
sslrequired = config['MQTT'].getboolean('ssl', False)
ca_certs = config['MQTT'].get('certpath', "/etc/ssl/certs/ca-certificates.crt")
if (authrequired): if (authrequired):
username = config['MQTT'].get('user') username = config['MQTT'].get('user')
password = config['MQTT'].get('pass') password = config['MQTT'].get('pass')
@@ -82,6 +91,8 @@ if __name__ == '__main__':
if (authrequired): if (authrequired):
mqttc.username_pw_set(username,password=password) mqttc.username_pw_set(username,password=password)
if (sslrequired):
mqttc.tls_set( ca_certs, tls_version=ssl.PROTOCOL_TLSv1_2 )
mqttc.connect(hostname) mqttc.connect(hostname)
mqttc.loop_start() mqttc.loop_start()
sniff(prn=arp_display, filter="arp", store=0, count=0) sniff(prn=arp_display, filter="arp", store=0, count=0)