From c04ff316f57e76dd817373f79eb6dbace202daa5 Mon Sep 17 00:00:00 2001
From: Oscar Gonzalez <oscgonfer@gmail.com>
Date: Thu, 6 Jul 2023 13:54:25 +0000
Subject: [PATCH] Add possibility to connect via ssl to broker

---
 env.example                    | 3 ++-
 lib/tasks/mqtt_subscriber.rake | 8 +++++++-
 2 files changed, 9 insertions(+), 2 deletions(-)

diff --git a/env.example b/env.example
index 8d09fe19..b3ef1acf 100644
--- a/env.example
+++ b/env.example
@@ -20,7 +20,8 @@ REDIS_STORE=redis://redis:6379/3
 MQTT_HOST=mqtt
 #MQTT_CLEAN_SESSION=true
 #MQTT_CLIENT_ID=some_id
-
+#MQTT_PORT=port
+#MQTT_SSL=false
 aws_secret_key=123
 
 # kairos Dockerized
diff --git a/lib/tasks/mqtt_subscriber.rake b/lib/tasks/mqtt_subscriber.rake
index 30f15c24..6b432a9b 100644
--- a/lib/tasks/mqtt_subscriber.rake
+++ b/lib/tasks/mqtt_subscriber.rake
@@ -7,17 +7,23 @@ namespace :mqtt do
     mqtt_clean_session = ENV.has_key?('MQTT_CLEAN_SESSION') ? ENV['MQTT_CLEAN_SESSION'] == "true" : true
     mqtt_client_id = ENV.has_key?('MQTT_CLIENT_ID') ? ENV['MQTT_CLIENT_ID'] : nil
     mqtt_host = ENV.has_key?('MQTT_HOST') ? ENV['MQTT_HOST'] : 'mqtt'
+    mqtt_port = ENV.has_key?('MQTT_PORT') ? ENV['MQTT_PORT'] : 1883
+    mqtt_ssl = ENV.has_key?('MQTT_SSL') ? ENV['MQTT_SSL'] : false
 
     mqtt_log.info('MQTT TASK STARTING')
     mqtt_log.info("clean_session: #{mqtt_clean_session}")
     mqtt_log.info("client_id: #{mqtt_client_id}")
     mqtt_log.info("host: #{mqtt_host}")
+    mqtt_log.info("port: #{mqtt_port}")
+    mqtt_log.info("ssl: #{mqtt_ssl}")
 
     begin
       MQTT::Client.connect(
         :host => mqtt_host,
+        :port => mqtt_port,
         :clean_session => mqtt_clean_session,
-        :client_id => mqtt_client_id
+        :client_id => mqtt_client_id,
+        :ssl => mqtt_ssl
       ) do |client|
 
         mqtt_log.info "Connected to #{client.host}"