Merge pull request #108 from LTruijens/MQTTnet-update

Upgrade MQTTnet to latest version

Author: thebentern

Directory.Packages.props

@@ -18,7 +18,7 @@
     <PackageVersion Include="NUnit" Version="4.3.2" />
     <PackageVersion Include="NUnit3TestAdapter" Version="5.0.0" />
     <PackageVersion Include="NUnit.Analyzers" Version="4.6.0" />
-    <PackageVersion Include="MQTTnet" Version="4.3.7.1207" />
+    <PackageVersion Include="MQTTnet" Version="5.0.1.1416" />
     <PackageVersion Include="QRCoder" Version="1.6.0" />
     <PackageVersion Include="SimpleExec" Version="12.0.0" />
     <PackageVersion Include="Spectre.Console" Version="0.49.1" />

Meshtastic.Cli/CommandHandlers/MqttProxyCommandHandler.cs

@@ -2,8 +2,8 @@
 using Meshtastic.Data.MessageFactories;
 using MQTTnet;
 using Meshtastic.Protobufs;
-using MQTTnet.Client;
 using Microsoft.Extensions.Logging;
+using System.Buffers;
 
 namespace Meshtastic.Cli.CommandHandlers;
 
@@ -22,7 +22,7 @@ public async Task<DeviceStateContainer> Handle()
     public override async Task OnCompleted(FromRadio packet, DeviceStateContainer container)
     {
         // connect to mqtt server with mqttnet
-        var factory = new MqttFactory();
+        var factory = new MqttClientFactory();
         using var mqttClient = factory.CreateMqttClient();
         MqttClientOptions options = GetMqttClientOptions(container);
         await mqttClient.ConnectAsync(options, CancellationToken.None);
@@ -45,7 +45,7 @@ await mqttClient.SubscribeAsync(new MqttTopicFilterBuilder()
 
             // Get bytes from utf8 string
             var toRadio = new ToRadioMessageFactory()
-                .CreateMqttClientProxyMessage(e.ApplicationMessage.Topic, e.ApplicationMessage.PayloadSegment.ToArray(), e.ApplicationMessage.Retain);
+                .CreateMqttClientProxyMessage(e.ApplicationMessage.Topic, e.ApplicationMessage.Payload.ToArray(), e.ApplicationMessage.Retain);
             Logger.LogDebug(toRadio.ToString());
             await Connection.WriteToRadio(toRadio);
         };