Merge pull request #17 from zivillian/tls

add TLS support

ora2mqtt/ConfigureCommand.cs

@@ -7,8 +7,6 @@
 using Sharprompt;
 using Sharprompt.Fluent;
 using YamlDotNet.Serialization;
-using System.Runtime.InteropServices;
-using System.Security.Cryptography.X509Certificates;
 
 namespace ora2mqtt
 {
@@ -151,6 +149,8 @@ private void ConfigureMqttAsync(Ora2MqttOptions oraOptions)
                 options.Username = Prompt.Input<string>("Please enter your mqtt username", defaultValue: options.Username);
                 options.Password = Prompt.Password("Please enter your mqtt password");
             }
+
+            options.UseTls = Prompt.Confirm("Do you want to use TLS on port 8883?");
         }
 
         private async Task<bool> TestMqttAsync(Ora2MqttOptions oraOptions, CancellationToken cancellationToken)
@@ -163,7 +163,8 @@ private async Task<bool> TestMqttAsync(Ora2MqttOptions oraOptions, CancellationT
                 var factory = new MqttFactory();
                 using var client = factory.CreateMqttClient();
                 var builder = new MqttClientOptionsBuilder()
-                    .WithTcpServer(options.Host);
+                    .WithTcpServer(options.Host)
+                    .WithTlsOptions(new MqttClientTlsOptions { UseTls = options.UseTls });
                 if (!String.IsNullOrEmpty(options.Username) && !String.IsNullOrEmpty(options.Password))
                 {
                     builder = builder.WithCredentials(options.Username, options.Password);

ora2mqtt/Ora2MqttOptions.cs

@@ -29,4 +29,6 @@ public class Ora2MqttMqttOptions
     public string Username { get; set; }
 
     public string Password { get; set; }
+
+    public bool UseTls { get; set; }
 }

ora2mqtt/RunCommand.cs

@@ -55,7 +55,8 @@ private async Task<IMqttClient> ConnectMqttAsync(Ora2MqttMqttOptions options,Can
         var factory = new MqttFactory();
         var client = factory.CreateMqttClient();
         var builder = new MqttClientOptionsBuilder()
-            .WithTcpServer(options.Host);
+            .WithTcpServer(options.Host)
+            .WithTlsOptions(new MqttClientTlsOptions { UseTls = options.UseTls });
         if (!String.IsNullOrEmpty(options.Username) && !String.IsNullOrEmpty(options.Password))
         {
             builder = builder.WithCredentials(options.Username, options.Password);