From 616e889e9406dfb93db46ff78190235e46fba956 Mon Sep 17 00:00:00 2001 From: ngt-github Date: Sat, 13 Aug 2022 23:36:39 +0200 Subject: [PATCH] Added options for TLS usage for MQTT client and insecure certificate handling --- tools/rpi/ahoy.yml.example | 2 ++ tools/rpi/hoymiles/__main__.py | 5 +++++ 2 files changed, 7 insertions(+) diff --git a/tools/rpi/ahoy.yml.example b/tools/rpi/ahoy.yml.example index 8438b9f7..15b2cd91 100644 --- a/tools/rpi/ahoy.yml.example +++ b/tools/rpi/ahoy.yml.example @@ -16,6 +16,8 @@ ahoy: port: 1883 user: 'username' password: 'password' + useTLS: False + insecureTLS: False #set True for e.g. self signed certificates. # Influx2 output influxdb: diff --git a/tools/rpi/hoymiles/__main__.py b/tools/rpi/hoymiles/__main__.py index 71b0fe13..f41dd7da 100644 --- a/tools/rpi/hoymiles/__main__.py +++ b/tools/rpi/hoymiles/__main__.py @@ -226,6 +226,11 @@ if __name__ == '__main__': mqtt_config = ahoy_config.get('mqtt', []) if not mqtt_config.get('disabled', False): mqtt_client = paho.mqtt.client.Client() + + if mqtt_config.get('useTLS',False): + mqtt_client.tls_set() + mqtt_client.tls_insecure_set(mqtt_config.get('insecureTLS',False)) + mqtt_client.username_pw_set(mqtt_config.get('user', None), mqtt_config.get('password', None)) mqtt_client.connect(mqtt_config.get('host', '127.0.0.1'), mqtt_config.get('port', 1883)) mqtt_client.loop_start()