Add support for MQTT SSL (#140)

* Add support for MQTT SSL * Fixed format
teslamate-org · Sep 8, 2019 · b1ffa97 · b1ffa97 · virtualm2000 · Sep 8, 2019
1 parent 9c61150
commit b1ffa97
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 8 deletions.
diff --git a/config/releases.exs b/config/releases.exs
@@ -36,7 +36,8 @@ if System.get_env("DISABLE_MQTT") != "true" do
   config :teslamate, :mqtt,
     host: System.fetch_env!("MQTT_HOST"),
     username: System.get_env("MQTT_USERNAME"),
-    password: System.get_env("MQTT_PASSWORD")
+    password: System.get_env("MQTT_PASSWORD"),
+    ssl: System.get_env("MQTT_SSL")
 end
 
 config :logger,

diff --git a/lib/teslamate/mqtt/mqtt.ex b/lib/teslamate/mqtt/mqtt.ex
@@ -27,13 +27,25 @@ defmodule TeslaMate.Mqtt do
   defp config do
     auth = Application.get_env(:teslamate, :mqtt)
 
-    [
-      user_name: Keyword.get(auth, :username),
-      password: Keyword.get(auth, :password),
-      server: {Tortoise.Transport.Tcp, host: Keyword.get(auth, :host), port: 1883},
-      handler: {Tortoise.Handler.Logger, []},
-      subscriptions: []
-    ]
+    if(Keyword.get(auth, :ssl) == "false") do
+      [
+        user_name: Keyword.get(auth, :username),
+        password: Keyword.get(auth, :password),
+        server: {Tortoise.Transport.Tcp, host: Keyword.get(auth, :host), port: 1883},
+        handler: {Tortoise.Handler.Logger, []},
+        subscriptions: []
+      ]
+    else
+      [
+        user_name: Keyword.get(auth, :username),
+        password: Keyword.get(auth, :password),
+        server:
+          {Tortoise.Transport.SSL,
+           host: Keyword.get(auth, :host), port: 8883, verify: :verify_none},
+        handler: {Tortoise.Handler.Logger, []},
+        subscriptions: []
+      ]
+    end
   end
 
   defp generate_client_id do