Start using readonly memory

Separate the topic template samples from the other samples

MQTTnet.sln

@@ -33,8 +33,6 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "MQTTnet.Extensions.TopicTem
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MQTTnet.Server", "Source\MQTTnet.Server\MQTTnet.Server.csproj", "{C876EFFD-C5AD-4E26-BD9F-4C48252C02BC}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "MQTTnet.PowerShell", "Source\MQTTnet.PowerShell\MQTTnet.PowerShell.csproj", "{37B129C5-0231-4EB5-AF13-77959068911C}"
-EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -81,10 +79,6 @@ Global
 		{C876EFFD-C5AD-4E26-BD9F-4C48252C02BC}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{C876EFFD-C5AD-4E26-BD9F-4C48252C02BC}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{C876EFFD-C5AD-4E26-BD9F-4C48252C02BC}.Release|Any CPU.Build.0 = Release|Any CPU
-		{37B129C5-0231-4EB5-AF13-77959068911C}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{37B129C5-0231-4EB5-AF13-77959068911C}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{37B129C5-0231-4EB5-AF13-77959068911C}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{37B129C5-0231-4EB5-AF13-77959068911C}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

Samples/Client/Client_Subscribe_Samples.cs

@@ -7,7 +7,6 @@
 // ReSharper disable InconsistentNaming
 // ReSharper disable UnusedMember.Local
 
-using MQTTnet.Extensions.TopicTemplate;
 using MQTTnet.Packets;
 using MQTTnet.Protocol;
 using MQTTnet.Samples.Helpers;
@@ -16,8 +15,6 @@ namespace MQTTnet.Samples.Client;
 
 public static class Client_Subscribe_Samples
 {
-    static readonly MqttTopicTemplate sampleTemplate = new("mqttnet/samples/topic/{id}");
-
     public static async Task Handle_Received_Application_Message()
     {
         /*
@@ -42,7 +39,7 @@ public static class Client_Subscribe_Samples
 
         await mqttClient.ConnectAsync(mqttClientOptions, CancellationToken.None);
 
-        var mqttSubscribeOptions = mqttFactory.CreateSubscribeOptionsBuilder().WithTopicTemplate(sampleTemplate.WithParameter("id", "2")).Build();
+        var mqttSubscribeOptions = mqttFactory.CreateSubscribeOptionsBuilder().WithTopicFilter("mqttnet/samples/topic/2").Build();
 
         await mqttClient.SubscribeAsync(mqttSubscribeOptions, CancellationToken.None);
 
@@ -55,7 +52,7 @@ public static class Client_Subscribe_Samples
     public static async Task Send_Responses()
     {
         /*
-         * This sample subscribes to a topic and sends a response to the broker. This requires at least QoS level 1 to work!
+         * This sample subscribes to a topic and sends a detailed response to the client. This requires at least QoS level 1 to work!
          */
 
         var mqttFactory = new MqttClientFactory();
@@ -80,7 +77,7 @@ public static class Client_Subscribe_Samples
 
         await mqttClient.ConnectAsync(mqttClientOptions, CancellationToken.None);
 
-        var mqttSubscribeOptions = mqttFactory.CreateSubscribeOptionsBuilder().WithTopicTemplate(sampleTemplate.WithParameter("id", "1")).Build();
+        var mqttSubscribeOptions = mqttFactory.CreateSubscribeOptionsBuilder().WithTopicFilter("topic/test").Build();
 
         var response = await mqttClient.SubscribeAsync(mqttSubscribeOptions, CancellationToken.None);
 
@@ -106,9 +103,10 @@ public static class Client_Subscribe_Samples
         // Create the subscribe options including several topics with different options.
         // It is also possible to all of these topics using a dedicated call of _SubscribeAsync_ per topic.
         var mqttSubscribeOptions = mqttFactory.CreateSubscribeOptionsBuilder()
-            .WithTopicTemplate(sampleTemplate.WithParameter("id", "1"))
+            .WithTopicFilter(t => t.WithTopic("topic/1").WithAtLeastOnceQoS())
-            .WithTopicTemplate(sampleTemplate.WithParameter("id", "2"), noLocal: true)
+            .WithTopicFilter(t => t.WithTopic("topic/2").WithAtMostOnceQoS())
-            .WithTopicTemplate(sampleTemplate.WithParameter("id", "3"), retainHandling: MqttRetainHandling.SendAtSubscribe)
+            .WithTopicFilter(t => t.WithTopic("topic/3").WithNoLocal())
+            .WithTopicFilter(t => t.WithRetainHandling(MqttRetainHandling.SendAtSubscribe))
             .Build();
 
         var response = await mqttClient.SubscribeAsync(mqttSubscribeOptions, CancellationToken.None);
@@ -132,7 +130,9 @@ public static class Client_Subscribe_Samples
 
         await mqttClient.ConnectAsync(mqttClientOptions, CancellationToken.None);
 
-        var mqttSubscribeOptions = mqttFactory.CreateSubscribeOptionsBuilder().WithTopicTemplate(sampleTemplate.WithParameter("id", "1")).Build();
+        var topicFilter = mqttFactory.CreateTopicFilterBuilder().WithTopic("mqttnet/samples/topic/2").WithAtLeastOnceQoS();
+
+        var mqttSubscribeOptions = mqttFactory.CreateSubscribeOptionsBuilder().WithTopicFilter(topicFilter).Build();
 
         var response = await mqttClient.SubscribeAsync(mqttSubscribeOptions, CancellationToken.None);
 

Samples/Client/Client_Subscribe_TopicTemplate_Samples.cs

@@ -0,0 +1,75 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+// See the LICENSE file in the project root for more information.
+
+using MQTTnet.Extensions.TopicTemplate;
+using MQTTnet.Protocol;
+using MQTTnet.Samples.Helpers;
+
+// ReSharper disable UnusedType.Global
+// ReSharper disable UnusedMember.Global
+// ReSharper disable InconsistentNaming
+// ReSharper disable UnusedMember.Local
+
+namespace MQTTnet.Samples.Client;
+
+public static class Client_Subscribe_TopicTemplate_Samples
+{
+    static readonly MqttTopicTemplate SampleTemplate = new("mqttnet/samples/topic/{id}");
+
+    public static async Task Subscribe_Multiple_Topics_With_Template()
+    {
+        /*
+         * This sample subscribes to several topics in a single request.
+         *
+         * This sample requires the nuget 'MQTTnet.Extensions.TopicTemplate'.
+         */
+
+        var mqttFactory = new MqttClientFactory();
+
+        using var mqttClient = mqttFactory.CreateMqttClient();
+        var mqttClientOptions = new MqttClientOptionsBuilder().WithTcpServer("broker.hivemq.com").Build();
+
+        await mqttClient.ConnectAsync(mqttClientOptions, CancellationToken.None);
+
+        // Create the subscribe options including several topics with different options.
+        // It is also possible to all of these topics using a dedicated call of _SubscribeAsync_ per topic.
+        var mqttSubscribeOptions = mqttFactory.CreateSubscribeOptionsBuilder()
+            .WithTopicTemplate(SampleTemplate.WithParameter("id", "1"))
+            .WithTopicTemplate(SampleTemplate.WithParameter("id", "2"), noLocal: true)
+            .WithTopicTemplate(SampleTemplate.WithParameter("id", "3"), retainHandling: MqttRetainHandling.SendAtSubscribe)
+            .Build();
+
+        var response = await mqttClient.SubscribeAsync(mqttSubscribeOptions, CancellationToken.None);
+
+        Console.WriteLine("MQTT client subscribed to topics.");
+
+        // The response contains additional data sent by the server after subscribing.
+        response.DumpToConsole();
+    }
+
+    public static async Task Subscribe_Topic_With_Template()
+    {
+        /*
+         * This sample subscribes to a topic.
+         *
+         * This sample requires the nuget 'MQTTnet.Extensions.TopicTemplate'.
+         */
+
+        var mqttFactory = new MqttClientFactory();
+
+        using var mqttClient = mqttFactory.CreateMqttClient();
+        var mqttClientOptions = new MqttClientOptionsBuilder().WithTcpServer("broker.hivemq.com").Build();
+
+        await mqttClient.ConnectAsync(mqttClientOptions, CancellationToken.None);
+
+        var mqttSubscribeOptions = mqttFactory.CreateSubscribeOptionsBuilder().WithTopicTemplate(SampleTemplate.WithParameter("id", "1")).Build();
+
+        var response = await mqttClient.SubscribeAsync(mqttSubscribeOptions, CancellationToken.None);
+
+        Console.WriteLine("MQTT client subscribed to topic.");
+
+        // The response contains additional data sent by the server after subscribing.
+        response.DumpToConsole();
+    }
+}

Source/MQTTnet.AspnetCore/ApplicationBuilderExtensions.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.Extensions.DependencyInjection;
 using MQTTnet.Server;

Source/MQTTnet.AspnetCore/AspNetMqttServerOptionsBuilder.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using MQTTnet.Server;
 
 namespace MQTTnet.AspNetCore;

Source/MQTTnet.AspnetCore/BufferExtensions.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Runtime.InteropServices;
 
 namespace MQTTnet.AspNetCore;

Source/MQTTnet.AspnetCore/EndpointRouterExtensions.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Routing;
 

Source/MQTTnet.AspnetCore/MqttClientConnectionContextFactory.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using MQTTnet.Adapter;
 using MQTTnet.Diagnostics.Logger;
 using MQTTnet.Formatter;

Source/MQTTnet.AspnetCore/MqttConnectionContext.cs

@@ -2,13 +2,10 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Buffers;
 using System.IO.Pipelines;
 using System.Net;
 using System.Security.Cryptography.X509Certificates;
-using System.Threading;
-using System.Threading.Tasks;
 using Microsoft.AspNetCore.Connections;
 using Microsoft.AspNetCore.Http.Connections.Features;
 using Microsoft.AspNetCore.Http.Features;

Source/MQTTnet.AspnetCore/MqttConnectionHandler.cs

@@ -2,8 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Threading.Tasks;
 using Microsoft.AspNetCore.Connections;
 using Microsoft.AspNetCore.Connections.Features;
 using MQTTnet.Adapter;

Source/MQTTnet.AspnetCore/MqttHostedServer.cs

@@ -2,10 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Collections.Generic;
-using System.Threading;
-using System.Threading.Tasks;
 using Microsoft.Extensions.Hosting;
 using MQTTnet.Diagnostics.Logger;
 using MQTTnet.Server;

Source/MQTTnet.AspnetCore/MqttSubProtocolSelector.cs

@@ -2,9 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Collections.Generic;
-using System.Linq;
 using Microsoft.AspNetCore.Http;
 
 namespace MQTTnet.AspNetCore;

Source/MQTTnet.AspnetCore/MqttWebSocketServerAdapter.cs

@@ -2,10 +2,8 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Net;
 using System.Net.WebSockets;
-using System.Threading.Tasks;
 using Microsoft.AspNetCore.Http;
 using MQTTnet.Adapter;
 using MQTTnet.Diagnostics.Logger;

Source/MQTTnet.AspnetCore/ReaderExtensions.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Buffers;
 using System.Runtime.InteropServices;
 using MQTTnet.Adapter;

Source/MQTTnet.AspnetCore/ServiceCollectionExtensions.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.DependencyInjection.Extensions;
 using Microsoft.Extensions.Hosting;

Source/MQTTnet.AspnetCore/SocketAwaitable.cs

@@ -2,13 +2,10 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Diagnostics;
 using System.IO.Pipelines;
 using System.Net.Sockets;
 using System.Runtime.CompilerServices;
-using System.Threading;
-using System.Threading.Tasks;
 
 namespace MQTTnet.AspNetCore;
 

Source/MQTTnet.AspnetCore/SocketConnection.cs

@@ -2,13 +2,9 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Collections.Generic;
-using System.IO;
 using System.IO.Pipelines;
 using System.Net;
 using System.Net.Sockets;
-using System.Threading.Tasks;
 using Microsoft.AspNetCore.Connections;
 using Microsoft.AspNetCore.Http.Features;
 using MQTTnet.Exceptions;

Source/MQTTnet.AspnetCore/SocketReceiver.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.IO.Pipelines;
 using System.Net.Sockets;
 

Source/MQTTnet.AspnetCore/SocketSender.cs

@@ -2,9 +2,7 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Buffers;
-using System.Collections.Generic;
 using System.Diagnostics;
 using System.IO.Pipelines;
 using System.Net.Sockets;

Source/MQTTnet.Benchmarks/AssemblyInfo.cs

@@ -1,3 +1 @@
-using Microsoft.VisualStudio.TestTools.UnitTesting;
-
 [assembly: DoNotParallelize]

Source/MQTTnet.Benchmarks/AsyncLockBenchmark.cs

@@ -2,9 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Threading;
-using System.Threading.Tasks;
 using BenchmarkDotNet.Attributes;
 using BenchmarkDotNet.Jobs;
 using MQTTnet.Internal;

Source/MQTTnet.Benchmarks/ChannelAdapterBenchmark.cs

@@ -2,9 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.IO;
-using System.Threading;
 using BenchmarkDotNet.Attributes;
 using MQTTnet.Adapter;
 using MQTTnet.Diagnostics.Logger;

Source/MQTTnet.Benchmarks/MemoryCopyBenchmark.cs

@@ -1,6 +1,5 @@
 using BenchmarkDotNet.Attributes;
 using BenchmarkDotNet.Jobs;
-using System;
 
 
 namespace MQTTnet.Benchmarks;

Source/MQTTnet.Benchmarks/MqttBufferReaderBenchmark.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Text;
 using BenchmarkDotNet.Attributes;
 using BenchmarkDotNet.Jobs;

Source/MQTTnet.Benchmarks/MqttPacketReaderWriterBenchmark.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using BenchmarkDotNet.Attributes;
 using BenchmarkDotNet.Jobs;
 using MQTTnet.Formatter;

Source/MQTTnet.Benchmarks/Program.cs

@@ -2,9 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Collections.Generic;
-using System.Linq;
 using BenchmarkDotNet.Running;
 
 namespace MQTTnet.Benchmarks;

Source/MQTTnet.Benchmarks/ReaderExtensionsBenchmark.cs

@@ -4,9 +4,7 @@ using MQTTnet.AspNetCore;
 using MQTTnet.Exceptions;
 using MQTTnet.Formatter;
 using System.Buffers;
-using System.IO;
 using System.IO.Pipelines;
-using System.Threading.Tasks;
 
 namespace MQTTnet.Benchmarks;
 

Source/MQTTnet.Benchmarks/RoundtripProcessingBenchmark.cs

@@ -1,7 +1,6 @@
 using BenchmarkDotNet.Attributes;
 using BenchmarkDotNet.Jobs;
 using MQTTnet.Tests.Mockups;
-using MQTTnet.Tests.Server;
 
 namespace MQTTnet.Benchmarks;
 

Source/MQTTnet.Benchmarks/SerializerBenchmark.cs

@@ -4,10 +4,7 @@
 
 using BenchmarkDotNet.Attributes;
 using MQTTnet.Packets;
-using System;
 using System.Security.Cryptography.X509Certificates;
-using System.Threading;
-using System.Threading.Tasks;
 using MQTTnet.Adapter;
 using MQTTnet.Channel;
 using MQTTnet.Formatter;

Source/MQTTnet.Benchmarks/ServerProcessingBenchmark.cs

@@ -5,7 +5,6 @@
 using BenchmarkDotNet.Attributes;
 using BenchmarkDotNet.Jobs;
 using MQTTnet.Tests.Mockups;
-using MQTTnet.Tests.Server;
 
 namespace MQTTnet.Benchmarks;
 

Source/MQTTnet.Benchmarks/SubscribeBenchmark.cs

@@ -2,8 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System.Collections.Generic;
-using System.Linq;
 using BenchmarkDotNet.Attributes;
 using MQTTnet.Server;
 

Source/MQTTnet.Benchmarks/TcpPipesBenchmark.cs

@@ -5,8 +5,6 @@
 using System.IO.Pipelines;
 using System.Net;
 using System.Net.Sockets;
-using System.Threading;
-using System.Threading.Tasks;
 using BenchmarkDotNet.Attributes;
 using BenchmarkDotNet.Jobs;
 using MQTTnet.AspNetCore;

Source/MQTTnet.Benchmarks/TopicGenerator.cs

@@ -1,6 +1,3 @@
-using System;
-using System.Collections.Generic;
-
 namespace MQTTnet.Benchmarks;
 
 public class TopicGenerator

Source/MQTTnet.Benchmarks/UnsubscribeBenchmark.cs

@@ -2,8 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System.Collections.Generic;
-using System.Linq;
 using BenchmarkDotNet.Attributes;
 using MQTTnet.Server;
 

Source/MQTTnet.Extensions.Rpc/DefaultMqttRpcClientTopicGenerationStrategy.cs

@@ -2,8 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-
 namespace MQTTnet.Extensions.Rpc;
 
 public sealed class DefaultMqttRpcClientTopicGenerationStrategy : IMqttRpcClientTopicGenerationStrategy

Source/MQTTnet.Extensions.Rpc/IMqttRpcClient.cs

@@ -2,10 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Collections.Generic;
-using System.Threading;
-using System.Threading.Tasks;
 using MQTTnet.Protocol;
 
 namespace MQTTnet.Extensions.Rpc;

Source/MQTTnet.Extensions.Rpc/MqttFactoryExtensions.cs

@@ -2,8 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-
 namespace MQTTnet.Extensions.Rpc;
 
 public static class MqttFactoryExtensions

Source/MQTTnet.Extensions.Rpc/MqttRpcClient.cs

@@ -2,12 +2,8 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Buffers;
 using System.Collections.Concurrent;
-using System.Collections.Generic;
-using System.Threading;
-using System.Threading.Tasks;
 using MQTTnet.Exceptions;
 using MQTTnet.Formatter;
 using MQTTnet.Internal;

Source/MQTTnet.Extensions.Rpc/MqttRpcClientExtensions.cs

@@ -2,10 +2,7 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Collections.Generic;
 using System.Text;
-using System.Threading.Tasks;
 using MQTTnet.Protocol;
 
 namespace MQTTnet.Extensions.Rpc;

Source/MQTTnet.Extensions.Rpc/MqttRpcClientOptionsBuilder.cs

@@ -2,8 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-
 namespace MQTTnet.Extensions.Rpc;
 
 public sealed class MqttRpcClientOptionsBuilder

Source/MQTTnet.Extensions.Rpc/TopicGenerationContext.cs

@@ -2,8 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Collections.Generic;
 using MQTTnet.Protocol;
 
 namespace MQTTnet.Extensions.Rpc;

Source/MQTTnet.Extensions.TopicTemplate/MqttTopicTemplate.cs

@@ -2,11 +2,7 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Collections.Generic;
-using System.Linq;
 using System.Text.RegularExpressions;
-using System.Threading;
 using MQTTnet.Protocol;
 
 namespace MQTTnet.Extensions.TopicTemplate;

Source/MQTTnet.Extensions.TopicTemplate/TopicTemplateExtensions.cs

@@ -2,8 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Linq;
 using MQTTnet.Packets;
 using MQTTnet.Protocol;
 

Source/MQTTnet.PowerShell/Cmdlets/ConnectMqttSessionCmdlet.cs

@@ -1,120 +0,0 @@
-using System.Management.Automation;
-
-namespace MQTTnet.PowerShell.Cmdlets;
-
-[Cmdlet(VerbsCommunications.Connect, "MqttSession")]
-[OutputType(typeof(MqttClientConnectResult))]
-public class ConnectMqttSessionCmdlet : PSCmdlet
-{
-    [Parameter]
-    public SwitchParameter CleanSession { get; set; } = true;
-
-    [Parameter]
-    public string? ClientId { get; set; } = Guid.NewGuid().ToString();
-
-    [Parameter(Mandatory = true, ParameterSetName = "Tcp")]
-    [Parameter(Mandatory = true, ParameterSetName = "TcpWithTls")]
-    public new string? Host { get; set; }
-
-    [Parameter]
-    public string? Password { get; set; }
-
-    [Parameter(ParameterSetName = "Tcp")]
-    [Parameter(ParameterSetName = "TcpWithTls")]
-    public int Port { get; set; } = 1883;
-
-    [Parameter(Mandatory = true, ValueFromPipeline = true)]
-    public required PsMqttSession Session { get; set; }
-
-    [Parameter]
-    public string? Username { get; set; }
-
-    [Parameter(ParameterSetName = "TcpWithTls")]
-    public SwitchParameter UseTls { get; set; }
-
-    [Parameter(ParameterSetName = "TcpWithTls")]
-    public SwitchParameter AllowUntrustedCertificates { get; set; }
-
-    [Parameter(Mandatory = true, ParameterSetName = "WebSocket")]
-    public string? WebSocketUri { get; set; }
-
-    [Parameter]
-    public int KeepAlivePeriod { get; set; } = 15;
-
-    [Parameter]
-    public int Timeout { get; set; } = 10;
-
-    [Parameter]
-    public string? WillTopic { get; set; }
-
-    [Parameter]
-    public string? WillPayload { get; set; }
-
-    [Parameter]
-    public int WillQoS { get; set; } = 0;
-
-    [Parameter]
-    public SwitchParameter WillRetain { get; set; }
-
-    protected override void ProcessRecord()
-    {
-        var clientOptionsBuilder = new MqttClientOptionsBuilder();
-        
-        // Configure transport
-        if (ParameterSetName == "WebSocket")
-        {
-            clientOptionsBuilder.WithWebSocketServer(o => o.WithUri(WebSocketUri!));
-        }
-        else
-        {
-            clientOptionsBuilder.WithTcpServer(Host!, Port);
-            
-            if (UseTls)
-            {
-                clientOptionsBuilder.WithTlsOptions(o =>
-                {
-                    if (AllowUntrustedCertificates)
-                    {
-                        o.WithCertificateValidationHandler(_ => true);
-                    }
-                });
-            }
-        }
-
-        // Configure authentication
-        if (Username != null)
-        {
-            clientOptionsBuilder.WithCredentials(Username, Password);
-        }
-
-        // Configure session
-        clientOptionsBuilder.WithCleanSession(CleanSession);
-        
-        if (!string.IsNullOrEmpty(ClientId))
-        {
-            clientOptionsBuilder.WithClientId(ClientId);
-        }
-
-        // Configure keep alive
-        clientOptionsBuilder.WithKeepAlivePeriod(TimeSpan.FromSeconds(KeepAlivePeriod));
-        clientOptionsBuilder.WithTimeout(TimeSpan.FromSeconds(Timeout));
-
-        // Configure Will message
-        if (!string.IsNullOrEmpty(WillTopic))
-        {
-            clientOptionsBuilder.WithWillTopic(WillTopic);
-            
-            if (!string.IsNullOrEmpty(WillPayload))
-            {
-                clientOptionsBuilder.WithWillPayload(System.Text.Encoding.UTF8.GetBytes(WillPayload));
-            }
-            
-            clientOptionsBuilder.WithWillQualityOfServiceLevel((Protocol.MqttQualityOfServiceLevel)WillQoS);
-            clientOptionsBuilder.WithWillRetain(WillRetain);
-        }
-
-        var response = Session.GetClient().ConnectAsync(clientOptionsBuilder.Build()).GetAwaiter().GetResult();
-
-        WriteObject(response);
-    }
-}

Source/MQTTnet.PowerShell/Cmdlets/DisconnectMqttSessionCmdlet.cs

@@ -1,31 +0,0 @@
-using System.Management.Automation;
-
-namespace MQTTnet.PowerShell.Cmdlets;
-
-[Cmdlet(VerbsCommunications.Disconnect, "MqttSession")]
-public class DisconnectMqttSessionCmdlet : PSCmdlet
-{
-    [Parameter]
-    public MqttClientDisconnectOptionsReason Reason { get; set; } = MqttClientDisconnectOptionsReason.NormalDisconnection;
-
-    [Parameter]
-    public string? ReasonString { get; set; }
-
-    [Parameter(Mandatory = true, ValueFromPipeline = true)]
-    public required PsMqttSession Session { get; set; }
-
-    [Parameter]
-    public uint SessionExpiryInterval { get; set; }
-
-    protected override void ProcessRecord()
-    {
-        if (Session.GetClient().IsConnected)
-        {
-            var options = new MqttClientDisconnectOptionsBuilder().WithSessionExpiryInterval(SessionExpiryInterval).WithReason(Reason).WithReasonString(ReasonString).Build();
-
-            Session.GetClient().DisconnectAsync(options).GetAwaiter().GetResult();
-        }
-
-        WriteObject("Disconnected.");
-    }
-}

Source/MQTTnet.PowerShell/Cmdlets/GetMqttSessionStatusCmdlet.cs

@@ -1,27 +0,0 @@
-// Licensed to the .NET Foundation under one or more agreements.
-// The .NET Foundation licenses this file to you under the MIT license.
-// See the LICENSE file in the project root for more information.
-
-using System.Management.Automation;
-
-namespace MQTTnet.PowerShell.Cmdlets;
-
-[Cmdlet(VerbsCommon.Get, "MqttSessionStatus")]
-[OutputType(typeof(MqttClientConnectionStatus))]
-public class GetMqttSessionStatusCmdlet : PSCmdlet
-{
-    [Parameter(Mandatory = true, ValueFromPipeline = true)]
-    public required PsMqttSession Session { get; set; }
-
-    protected override void ProcessRecord()
-    {
-        var client = Session.GetClient();
-        var status = new
-        {
-            IsConnected = client.IsConnected,
-            Options = client.Options
-        };
-
-        WriteObject(status);
-    }
-}

Source/MQTTnet.PowerShell/Cmdlets/NewMqttSessionCmdlet.cs

@@ -1,13 +0,0 @@
-using System.Management.Automation;
-
-namespace MQTTnet.PowerShell.Cmdlets;
-
-[Cmdlet(VerbsCommon.New, "MqttSession")]
-[OutputType(typeof(PsMqttSession))]
-public class NewMqttSessionCmdlet : PSCmdlet
-{
-    protected override void ProcessRecord()
-    {
-        WriteObject(new PsMqttSession());
-    }
-}

Source/MQTTnet.PowerShell/Cmdlets/PublishMqttMessageCmdlet.cs

@@ -1,69 +0,0 @@
-using System.Collections;
-using System.Management.Automation;
-using System.Text;
-using MQTTnet.Protocol;
-using MQTTnet.Packets;
-
-namespace MQTTnet.PowerShell.Cmdlets;
-
-[Cmdlet(VerbsData.Publish, "MqttMessage")]
-public class PublishMqttMessageCmdlet : PSCmdlet
-{
-    [Parameter(Mandatory = true)]
-    public string? Payload { get; set; }
-
-    [Parameter]
-    public int QoS { get; set; } = 0;
-
-    [Parameter]
-    public SwitchParameter Retain { get; set; }
-
-    [Parameter(Mandatory = true, ValueFromPipeline = true)]
-    public required PsMqttSession Session { get; set; }
-
-    [Parameter(Mandatory = true)]
-    public required string Topic { get; set; }
-
-    [Parameter]
-    public string? ContentType { get; set; }
-
-    [Parameter]
-    public string? ResponseTopic { get; set; }
-
-    [Parameter]
-    public ushort TopicAlias { get; set; }
-
-    [Parameter]
-    public uint MessageExpiryInterval { get; set; }
-
-    [Parameter]
-    public Hashtable? UserProperties { get; set; }
-
-    protected override void ProcessRecord()
-    {
-        var msgBuilder = new MqttApplicationMessageBuilder()
-            .WithTopic(Topic)
-            .WithPayload(Encoding.UTF8.GetBytes(Payload ?? string.Empty))
-            .WithQualityOfServiceLevel((MqttQualityOfServiceLevel)QoS)
-            .WithRetainFlag(Retain)
-            .WithContentType(ContentType)
-            .WithResponseTopic(ResponseTopic)
-            .WithTopicAlias(TopicAlias)
-            .WithMessageExpiryInterval(MessageExpiryInterval);
-
-        // Add user properties if provided
-        if (UserProperties != null && UserProperties.Count > 0)
-        {
-            foreach (var key in UserProperties.Keys)
-            {
-                var value = UserProperties[key]?.ToString() ?? string.Empty;
-                msgBuilder.WithUserProperty(key.ToString(), value);
-            }
-        }
-
-        var msg = msgBuilder.Build();
-        var response = Session.GetClient().PublishAsync(msg).GetAwaiter().GetResult();
-
-        WriteObject(response);
-    }
-}

Source/MQTTnet.PowerShell/Cmdlets/ReceiveMqttMessageCmdlet.cs

@@ -1,74 +0,0 @@
-// Licensed to the .NET Foundation under one or more agreements.
-// The .NET Foundation licenses this file to you under the MIT license.
-// See the LICENSE file in the project root for more information.
-
-using System.Management.Automation;
-
-namespace MQTTnet.PowerShell.Cmdlets;
-
-[Cmdlet(VerbsCommunications.Receive, "MqttMessage")]
-[OutputType(typeof(PsMqttMessage))]
-public class ReceiveMqttMessageCmdlet : PSCmdlet
-{
-    [Parameter(Mandatory = true, ValueFromPipeline = true)]
-    public required PsMqttSession Session { get; set; }
-
-    [Parameter]
-    [ValidateRange(0, int.MaxValue)]
-    public int TimeoutSeconds { get; set; } = 0;
-
-    protected override void ProcessRecord()
-    {
-        var tcs = new TaskCompletionSource<PsMqttMessage>();
-        EventHandler<PsMqttMessage>? handler = null;
-        CancellationTokenSource? cts = null;
-
-        try
-        {
-            handler = (s, e) =>
-            {
-                if (!tcs.Task.IsCompleted)
-                {
-                    tcs.TrySetResult(e);
-                }
-            };
-
-            Session.MessageReceived += handler;
-
-            // Optionaler Timeout
-            if (TimeoutSeconds > 0)
-            {
-                cts = new CancellationTokenSource();
-                cts.CancelAfter(TimeSpan.FromSeconds(TimeoutSeconds));
-                cts.Token.Register(() =>
-                {
-                    if (!tcs.Task.IsCompleted)
-                    {
-                        tcs.TrySetCanceled();
-                    }
-                });
-            }
-
-            WriteVerbose("Waiting for next MQTT message...");
-
-            try
-            {
-                var message = tcs.Task.GetAwaiter().GetResult();
-                WriteObject(message);
-            }
-            catch (TaskCanceledException)
-            {
-                WriteWarning($"Timeout after {TimeoutSeconds} seconds — no message received.");
-            }
-        }
-        finally
-        {
-            if (handler != null)
-            {
-                Session.MessageReceived -= handler;
-            }
-
-            cts?.Dispose();
-        }
-    }
-}

Source/MQTTnet.PowerShell/Cmdlets/RegisterMqttMessageHandlerCmdlet.cs

@@ -1,59 +0,0 @@
-using System.Management.Automation;
-using System.Management.Automation.Runspaces;
-
-namespace MQTTnet.PowerShell.Cmdlets;
-
-[Cmdlet(VerbsLifecycle.Register, "MqttMessageHandler")]
-public class RegisterMqttMessageHandlerCmdlet : PSCmdlet
-{
-    [Parameter(Mandatory = true, ValueFromPipeline = true)]
-    public required PsMqttSession Session { get; set; }
-
-    [Parameter(Mandatory = true)]
-    public ScriptBlock? Action { get; set; }
-
-    protected override void ProcessRecord()
-    {
-        // Capture the ScriptBlock and current default runspace (available during cmdlet execution)
-        var scriptBlock = Action ?? throw new ArgumentNullException(nameof(Action));
-        var capturedRunspace = Runspace.DefaultRunspace ?? throw new InvalidOperationException("No default runspace available during cmdlet execution.");
-        var capturedHost = Host;
-
-        EventHandler<PsMqttMessage> handler = (sender, e) =>
-        {
-            // Run asynchronously to avoid blocking the event thread
-            Task.Run(() =>
-            {
-                // Temporarily set the default runspace for this thread
-                var originalRunspace = Runspace.DefaultRunspace;
-                Runspace.DefaultRunspace = capturedRunspace;
-
-                try
-                {
-                    // Invoke the ScriptBlock directly with arguments (returns Collection<PSObject>)
-                    var results = scriptBlock.Invoke(e.Topic, e.Payload, e); // Pass topic, payload, and full message
-
-                    // Handle output manually (e.g., write to host/console)
-                    foreach (var result in results)
-                    {
-                        capturedHost.UI.WriteLine(result?.ToString() ?? string.Empty);
-                    }
-                }
-                catch (Exception ex)
-                {
-                    // Handle errors by writing to host error stream
-                    capturedHost.UI.WriteErrorLine($"MQTT handler error: {ex.Message}");
-                    // Optionally: capturedHost.UI.WriteVerboseLine(ex.StackTrace); for more details
-                }
-                finally
-                {
-                    // Restore the original default runspace for this thread
-                    Runspace.DefaultRunspace = originalRunspace;
-                }
-            });
-        };
-
-        Session.MessageReceived += handler;
-        WriteObject($"Handler registered for MQTT messages on session.");
-    }
-}

Source/MQTTnet.PowerShell/Cmdlets/RemoveMqttSessionCmdlet.cs

@@ -1,16 +0,0 @@
-using System.Management.Automation;
-
-namespace MQTTnet.PowerShell.Cmdlets;
-
-[Cmdlet(VerbsCommon.Remove, "MqttSession")]
-public class RemoveMqttSessionCmdlet : PSCmdlet
-{
-    [Parameter(Mandatory = true, ValueFromPipeline = true)]
-    public required PsMqttSession Session { get; set; }
-
-    protected override void ProcessRecord()
-    {
-        Session.Dispose();
-        WriteObject("Session removed.");
-    }
-}

Source/MQTTnet.PowerShell/Cmdlets/ShowMqttExamplesCmdlet.cs

@@ -1,78 +0,0 @@
-// Licensed to the .NET Foundation under one or more agreements.
-// The .NET Foundation licenses this file to you under the MIT license.
-// See the LICENSE file in the project root for more information.
-
-using System.Management.Automation;
-
-namespace MQTTnet.PowerShell.Cmdlets;
-
-[Cmdlet(VerbsCommon.Show, "MqttExamples")]
-public class ShowMqttExamplesCmdlet : PSCmdlet
-{
-    protected override void ProcessRecord()
-    {
-        var examples = @"
-MQTTnet PowerShell Module - Quick Examples
-==========================================
-
-1. Basic Connection and Publish:
-   $session = New-MqttSession
-   Connect-MqttSession -Session $session -Host 'broker.hivemq.com'
-   Publish-MqttMessage -Session $session -Topic 'test/topic' -Payload 'Hello'
-   Disconnect-MqttSession -Session $session
-   Remove-MqttSession -Session $session
-
-2. Subscribe and Receive Messages:
-   $session = New-MqttSession
-   Connect-MqttSession -Session $session -Host 'broker.hivemq.com'
-   Subscribe-MqttTopic -Session $session -Topic 'test/demo'
-   $msg = Receive-MqttMessage -Session $session -TimeoutSeconds 30
-   Write-Host ""Received: $($msg.Payload)""
-
-3. WebSocket Connection:
-   $session = New-MqttSession
-   Connect-MqttSession -Session $session -WebSocketUri 'ws://broker.hivemq.com:8000/mqtt'
-   Publish-MqttMessage -Session $session -Topic 'test/ws' -Payload 'Hello WS'
-
-4. TLS/SSL Connection:
-   $session = New-MqttSession
-   Connect-MqttSession -Session $session -Host 'broker.hivemq.com' -Port 8883 `
-       -UseTls -AllowUntrustedCertificates
-
-5. Async Message Handler:
-   $session = New-MqttSession
-   Connect-MqttSession -Session $session -Host 'broker.hivemq.com'
-   Subscribe-MqttTopic -Session $session -Topic 'test/#'
-   Register-MqttMessageHandler -Session $session -Action {
-       param($topic, $payload, $message)
-       Write-Host ""Message on $topic : $payload""
-   }
-
-6. Last Will and Testament:
-   $session = New-MqttSession
-   Connect-MqttSession -Session $session -Host 'broker.hivemq.com' `
-       -WillTopic 'status/client' -WillPayload 'Offline' -WillQoS 1 -WillRetain
-
-7. Publish with User Properties:
-   $props = @{ 'source' = 'PowerShell'; 'version' = '1.0' }
-   Publish-MqttMessage -Session $session -Topic 'test/props' `
-       -Payload 'Data' -UserProperties $props
-
-8. High QoS Publishing:
-   Publish-MqttMessage -Session $session -Topic 'critical/data' `
-       -Payload 'Important' -QoS 2
-
-9. Test Connection:
-   $isAlive = Test-MqttConnection -Session $session
-   Write-Host ""Connection alive: $isAlive""
-
-10. Get Session Status:
-    $status = Get-MqttSessionStatus -Session $session
-    Write-Host ""Connected: $($status.IsConnected)""
-
-For more details, see: Source/MQTTnet.PowerShell/README.md
-";
-        
-        WriteObject(examples);
-    }
-}

Source/MQTTnet.PowerShell/Cmdlets/SubscribeMqttTopicCmdlet.cs

@@ -1,55 +0,0 @@
-// Licensed to the .NET Foundation under one or more agreements.
-// The .NET Foundation licenses this file to you under the MIT license.
-// See the LICENSE file in the project root for more information.
-
-using System.Management.Automation;
-using MQTTnet.Protocol;
-
-namespace MQTTnet.PowerShell.Cmdlets;
-
-[Cmdlet("Subscribe", "MqttTopic")]
-[OutputType(typeof(MqttClientSubscribeResult))]
-public class SubscribeMqttTopicCmdlet : PSCmdlet
-{
-    [Parameter]
-    public bool NoLocal { get; set; }
-
-    [Parameter]
-    public int QoS { get; set; } = 0;
-
-    [Parameter]
-    public bool RetainAsPublished { get; set; }
-
-    [Parameter]
-    public MqttRetainHandling RetainHandling { get; set; } = MqttRetainHandling.SendAtSubscribe;
-
-    [Parameter(Mandatory = true, ValueFromPipeline = true)]
-    public required PsMqttSession Session { get; set; }
-
-    [Parameter]
-    public uint SubscriptionIdentifier { get; set; }
-
-    [Parameter(Mandatory = true)]
-    public required string Topic { get; set; }
-
-    protected override void ProcessRecord()
-    {
-        var topicFilter = new MqttTopicFilterBuilder().WithTopic(Topic)
-            .WithQualityOfServiceLevel((MqttQualityOfServiceLevel)QoS)
-            .WithNoLocal(NoLocal)
-            .WithRetainAsPublished(RetainAsPublished)
-            .WithRetainHandling(RetainHandling)
-            .Build();
-
-        var options = new MqttClientSubscribeOptionsBuilder().WithTopicFilter(topicFilter);
-
-        if (SubscriptionIdentifier > 0)
-        {
-            options.WithSubscriptionIdentifier(SubscriptionIdentifier);
-        }
-
-        var response = Session.GetClient().SubscribeAsync(options.Build()).GetAwaiter().GetResult();
-
-        WriteObject(response);
-    }
-}

Source/MQTTnet.PowerShell/Cmdlets/TestMqttConnectionCmdlet.cs

@@ -1,41 +0,0 @@
-// Licensed to the .NET Foundation under one or more agreements.
-// The .NET Foundation licenses this file to you under the MIT license.
-// See the LICENSE file in the project root for more information.
-
-using System.Management.Automation;
-
-namespace MQTTnet.PowerShell.Cmdlets;
-
-[Cmdlet(VerbsDiagnostic.Test, "MqttConnection")]
-[OutputType(typeof(bool))]
-public class TestMqttConnectionCmdlet : PSCmdlet
-{
-    [Parameter(Mandatory = true, ValueFromPipeline = true)]
-    public required PsMqttSession Session { get; set; }
-
-    [Parameter]
-    public int TimeoutSeconds { get; set; } = 5;
-
-    protected override void ProcessRecord()
-    {
-        try
-        {
-            var client = Session.GetClient();
-            
-            if (!client.IsConnected)
-            {
-                WriteObject(false);
-                return;
-            }
-
-            var cts = new CancellationTokenSource(TimeSpan.FromSeconds(TimeoutSeconds));
-            client.PingAsync(cts.Token).GetAwaiter().GetResult();
-            
-            WriteObject(true);
-        }
-        catch
-        {
-            WriteObject(false);
-        }
-    }
-}

Source/MQTTnet.PowerShell/Cmdlets/UnregisterMqttMessageHandlerCmdlet.cs

@@ -1,21 +0,0 @@
-// Licensed to the .NET Foundation under one or more agreements.
-// The .NET Foundation licenses this file to you under the MIT license.
-// See the LICENSE file in the project root for more information.
-
-using System.Management.Automation;
-
-namespace MQTTnet.PowerShell.Cmdlets;
-
-[Cmdlet(VerbsLifecycle.Unregister, "MqttMessageHandler")]
-public class UnregisterMqttMessageHandlerCmdlet : PSCmdlet
-{
-    [Parameter(Mandatory = true, ValueFromPipeline = true)]
-    public required PsMqttSession Session { get; set; }
-
-    protected override void ProcessRecord()
-    {
-        // Clear all event handlers
-        Session.ClearMessageHandlers();
-        WriteObject($"All message handlers cleared for MQTT session.");
-    }
-}

Source/MQTTnet.PowerShell/Cmdlets/UnsubscribeMqttTopicCmdlet.cs

@@ -1,23 +0,0 @@
-using System.Management.Automation;
-
-namespace MQTTnet.PowerShell.Cmdlets;
-
-[Cmdlet("Unsubscribe", "MqttTopic")]
-[OutputType(typeof(MqttClientUnsubscribeResult))]
-public class UnsubscribeMqttTopicCmdlet : PSCmdlet
-{
-    [Parameter(Mandatory = true, ValueFromPipeline = true)]
-    public required PsMqttSession Session { get; set; }
-
-    [Parameter(Mandatory = true)]
-    public required string Topic { get; set; }
-
-    protected override void ProcessRecord()
-    {
-        var options = new MqttClientUnsubscribeOptionsBuilder().WithTopicFilter(Topic).Build();
-
-        var response = Session.GetClient().UnsubscribeAsync(options).GetAwaiter().GetResult();
-
-        WriteObject(response);
-    }
-}

Source/MQTTnet.PowerShell/IMPLEMENTATION.md

@@ -1,197 +0,0 @@
-# PowerShell Module Extension - Implementation Summary
-
-## Overview
-This implementation extends the PowerShell support for the MQTTnet library as requested in issue #2215, implementing the proposal described in the ticket comments and exposing additional features of the library as PowerShell cmdlets.
-
-## Changes Implemented
-
-### 1. Enhanced RegisterMqttMessageHandler (Primary Requirement from #2215)
-**File**: `Source/MQTTnet.PowerShell/Cmdlets/RegisterMqttMessageHandlerCmdlet.cs`
-
-Implemented the proposal from the issue comment by @ArakniD:
-- Proper ScriptBlock execution in the correct runspace
-- Asynchronous message handling using Task.Run to avoid blocking
-- Passes three parameters to the handler: topic (string), payload (string), and full message object
-- Proper error handling with try-catch and error output to host
-- Captures the runspace during cmdlet execution and restores it during handler execution
-
-**Usage Example:**
-```powershell
-Register-MqttMessageHandler -Session $session -Action {
-    param($topic, $payload, $message)
-    Write-Host "Received on $topic: $payload"
-    # Can access $message.QoS, $message.Retain, etc.
-}
-```
-
-### 2. Enhanced Connection Options
-**File**: `Source/MQTTnet.PowerShell/Cmdlets/ConnectMqttSessionCmdlet.cs`
-
-Extended Connect-MqttSession with:
-- **WebSocket Support**: New `-WebSocketUri` parameter for WebSocket connections
-- **TLS/SSL Support**: New `-UseTls` and `-AllowUntrustedCertificates` parameters
-- **Last Will and Testament**: Parameters for `-WillTopic`, `-WillPayload`, `-WillQoS`, `-WillRetain`
-- **Connection Tuning**: Parameters for `-KeepAlivePeriod` and `-Timeout`
-- **Parameter Sets**: Organized into TCP, TcpWithTls, and WebSocket parameter sets
-
-**Usage Examples:**
-```powershell
-# TCP with TLS
-Connect-MqttSession -Session $session -Host "broker.com" -Port 8883 -UseTls
-
-# WebSocket
-Connect-MqttSession -Session $session -WebSocketUri "ws://broker.com:8000/mqtt"
-
-# With Last Will
-Connect-MqttSession -Session $session -Host "broker.com" `
-    -WillTopic "status" -WillPayload "Offline" -WillRetain
-```
-
-### 3. Enhanced Publishing
-**File**: `Source/MQTTnet.PowerShell/Cmdlets/PublishMqttMessageCmdlet.cs`
-
-Added support for:
-- **User Properties**: New `-UserProperties` parameter accepting a Hashtable
-- MQTT 5 features already supported: ContentType, ResponseTopic, TopicAlias, MessageExpiryInterval
-
-**Usage Example:**
-```powershell
-$props = @{ "source" = "PowerShell"; "version" = "1.0" }
-Publish-MqttMessage -Session $session -Topic "data" -Payload "test" -UserProperties $props
-```
-
-### 4. New Utility Cmdlets
-
-#### Get-MqttSessionStatus
-**File**: `Source/MQTTnet.PowerShell/Cmdlets/GetMqttSessionStatusCmdlet.cs`
-
-Returns connection status information.
-
-```powershell
-$status = Get-MqttSessionStatus -Session $session
-Write-Host "Connected: $($status.IsConnected)"
-```
-
-#### Test-MqttConnection
-**File**: `Source/MQTTnet.PowerShell/Cmdlets/TestMqttConnectionCmdlet.cs`
-
-Pings the broker to verify connectivity.
-
-```powershell
-$isAlive = Test-MqttConnection -Session $session -TimeoutSeconds 5
-```
-
-#### Unregister-MqttMessageHandler
-**File**: `Source/MQTTnet.PowerShell/Cmdlets/UnregisterMqttMessageHandlerCmdlet.cs`
-
-Clears all registered message handlers.
-
-```powershell
-Unregister-MqttMessageHandler -Session $session
-```
-
-#### Show-MqttExamples
-**File**: `Source/MQTTnet.PowerShell/Cmdlets/ShowMqttExamplesCmdlet.cs`
-
-Displays quick reference examples for common MQTT tasks.
-
-```powershell
-Show-MqttExamples
-```
-
-### 5. Enhanced PsMqttSession Class
-**File**: `Source/MQTTnet.PowerShell/PsMqttSession.cs`
-
-Added:
-- `ClearMessageHandlers()` method to remove all event handlers
-- Improved event handling infrastructure
-
-### 6. Documentation
-**Files**: 
-- `Source/MQTTnet.PowerShell/README.md` (new)
-- `Source/MQTTnet.PowerShell/Test.ps1` (updated)
-- `Source/MQTTnet.PowerShell/SmokeTest.ps1` (new)
-
-Created comprehensive documentation including:
-- Quick start guide
-- Detailed cmdlet documentation
-- Parameter descriptions
-- Usage examples for all features
-- Advanced scenarios (request-response, error handling)
-- Tips and best practices
-- Smoke tests for validation
-
-## Complete Cmdlet List (13 Total)
-
-1. **New-MqttSession** - Create MQTT session
-2. **Connect-MqttSession** - Connect with TCP/WebSocket/TLS support
-3. **Disconnect-MqttSession** - Clean disconnect
-4. **Remove-MqttSession** - Cleanup resources
-5. **Get-MqttSessionStatus** - Check connection status
-6. **Test-MqttConnection** - Ping broker
-7. **Publish-MqttMessage** - Publish with advanced features
-8. **Subscribe-MqttTopic** - Subscribe to topics
-9. **Unsubscribe-MqttTopic** - Unsubscribe from topics
-10. **Receive-MqttMessage** - Synchronous message receive
-11. **Register-MqttMessageHandler** - Async message handling ⭐ (Primary requirement)
-12. **Unregister-MqttMessageHandler** - Clear handlers
-13. **Show-MqttExamples** - Quick reference examples
-
-## Testing
-
-### Build Status
-✅ PowerShell module builds successfully
-✅ No compilation errors or warnings
-✅ Code passes CodeQL security analysis (0 alerts)
-
-### Smoke Tests
-✅ All 13 cmdlets load correctly
-✅ Session creation and disposal works
-✅ Show-MqttExamples returns help text
-✅ No runtime errors during basic operations
-
-### Test Files
-- `SmokeTest.ps1`: Quick validation of module loading and basic operations
-- `Test.ps1`: Comprehensive examples demonstrating all features
-
-## Features Not Implemented (Out of Scope)
-
-The following were considered but determined to be out of scope for this task:
-- MQTT broker/server cmdlets (only client features were requested)
-- Managed MQTT client wrapper (existing client is sufficient)
-- RPC extension support (specialized use case)
-- File-based certificate handling cmdlets (can be done with existing .NET capabilities)
-
-## Compatibility
-
-- Requires .NET 8.0 or later
-- Requires PowerShell 7.0 or later
-- Works on Windows, Linux, and macOS
-- Compatible with MQTT 3.1.1 and MQTT 5.0 protocols
-
-## Breaking Changes
-
-None. This is a new feature addition that doesn't modify existing code outside the PowerShell module.
-
-## Migration Guide
-
-For users who were using the initial implementation from PR #2215:
-- The RegisterMqttMessageHandler now actually works! Update your scripts to use the handler.
-- Connect-MqttSession now requires explicit parameter sets (-Host for TCP, -WebSocketUri for WebSocket)
-- No other breaking changes
-
-## Future Enhancements
-
-Potential future improvements that could be added:
-1. Pipeline support for batch publishing
-2. Managed client wrapper for automatic reconnection
-3. Certificate-based authentication helpers
-4. MQTT broker cmdlets for running local brokers
-5. Performance counters and statistics cmdlets
-6. Async/await support for better PowerShell integration
-
-## References
-
-- Issue #2215: https://github.com/dotnet/MQTTnet/pull/2215
-- Proposal comment by @ArakniD: https://github.com/dotnet/MQTTnet/pull/2215#issuecomment-3594492551
-- MQTTnet Documentation: https://github.com/dotnet/MQTTnet

Source/MQTTnet.PowerShell/MQTTnet.PowerShell.csproj

@@ -1,19 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-
-  <PropertyGroup>
-    <AssemblyName>MQTTnet.PowerShell</AssemblyName>
-    <LangVersion>default</LangVersion>
-    <Nullable>enable</Nullable>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="PowerShellStandard.Library" Version="5.1.1">
-      <PrivateAssets>All</PrivateAssets>
-    </PackageReference>
-  </ItemGroup>
-
-  <ItemGroup>
-    <ProjectReference Include="..\MQTTnet\MQTTnet.csproj" />
-  </ItemGroup>
-
-</Project>

Source/MQTTnet.PowerShell/PsMqttMessage.cs

@@ -1,30 +0,0 @@
-// Licensed to the .NET Foundation under one or more agreements.
-// The .NET Foundation licenses this file to you under the MIT license.
-// See the LICENSE file in the project root for more information.
-
-using System.Management.Automation;
-using MQTTnet.Packets;
-
-namespace MQTTnet.PowerShell;
-
-public class PsMqttPublishResult
-{
-
-}
-
-public class PsMqttConnectResult
-{
-
-}
-
-public class PsMqttMessage
-{
-    public required string? ContentType { get; init; }
-    public required string Payload { get; init; }
-    public int QoS { get; init; }
-    public required byte[] RawPayload { get; init; }
-    public string? ResponseTopic { get; init; }
-    public bool Retain { get; init; }
-    public required string Topic { get; init; }
-    public required List<MqttUserProperty>? UserProperties { get; init; }
-}

Source/MQTTnet.PowerShell/PsMqttSession.cs

@@ -1,62 +0,0 @@
-// Licensed to the .NET Foundation under one or more agreements.
-// The .NET Foundation licenses this file to you under the MIT license.
-// See the LICENSE file in the project root for more information.
-
-using System.Buffers;
-using System.Text;
-
-namespace MQTTnet.PowerShell;
-
-public sealed class PsMqttSession : IDisposable
-{
-    readonly IMqttClient _client;
-
-    public PsMqttSession()
-    {
-        var factory = new MqttClientFactory();
-        _client = factory.CreateMqttClient();
-
-        _client.ApplicationMessageReceivedAsync += e =>
-        {
-            MessageReceived?.Invoke(
-                this,
-                new PsMqttMessage
-                {
-                    Topic = e.ApplicationMessage.Topic,
-                    Payload = Encoding.UTF8.GetString(e.ApplicationMessage.Payload),
-                    RawPayload = e.ApplicationMessage.Payload.ToArray(),
-                    UserProperties = e.ApplicationMessage.UserProperties,
-                    QoS = (int)e.ApplicationMessage.QualityOfServiceLevel,
-                    ContentType = e.ApplicationMessage.ContentType,
-                    Retain = e.ApplicationMessage.Retain,
-                    ResponseTopic = e.ApplicationMessage.ResponseTopic
-                });
-
-            return Task.CompletedTask;
-        };
-    }
-
-    public event EventHandler<PsMqttMessage>? MessageReceived;
-
-    public void ClearMessageHandlers()
-    {
-        // Remove all event subscribers
-        if (MessageReceived != null)
-        {
-            foreach (var handler in MessageReceived.GetInvocationList())
-            {
-                MessageReceived -= (EventHandler<PsMqttMessage>)handler;
-            }
-        }
-    }
-
-    public void Dispose()
-    {
-        _client.Dispose();
-    }
-
-    public IMqttClient GetClient()
-    {
-        return _client;
-    }
-}

Source/MQTTnet.PowerShell/README.md

@@ -1,396 +0,0 @@
-# MQTTnet PowerShell Module
-
-A PowerShell module for MQTTnet that provides cmdlets for MQTT communication in PowerShell.
-
-## Features
-
-- **Full MQTT Protocol Support**: Connect, subscribe, publish, and manage MQTT connections
-- **TCP and WebSocket Transports**: Support for both TCP and WebSocket connections
-- **TLS/SSL Support**: Secure connections with TLS encryption
-- **Async Message Handling**: Register PowerShell ScriptBlocks as message handlers
-- **Advanced MQTT Features**: 
-  - Quality of Service (QoS) levels 0, 1, and 2
-  - Retained messages
-  - Last Will and Testament (LWT)
-  - User properties
-  - Message expiry intervals
-  - Response topics
-
-## Installation
-
-1. Build the MQTTnet.PowerShell project:
-   ```powershell
-   dotnet build Source/MQTTnet.PowerShell/MQTTnet.PowerShell.csproj
-   ```
-
-2. Import the module:
-   ```powershell
-   Import-Module ./Source/MQTTnet.PowerShell/bin/Debug/net8.0/MQTTnet.PowerShell.dll
-   ```
-
-## Quick Start
-
-### Basic Connection and Publish
-
-```powershell
-# Create a new MQTT session
-$session = New-MqttSession
-
-# Connect to a broker
-Connect-MqttSession -Session $session -Host "broker.hivemq.com" -Port 1883
-
-# Publish a message
-Publish-MqttMessage -Session $session -Topic "test/topic" -Payload "Hello MQTT!"
-
-# Disconnect and cleanup
-Disconnect-MqttSession -Session $session
-Remove-MqttSession -Session $session
-```
-
-### Subscribe and Receive Messages
-
-```powershell
-$session = New-MqttSession
-Connect-MqttSession -Session $session -Host "broker.hivemq.com"
-
-# Subscribe to a topic
-Subscribe-MqttTopic -Session $session -Topic "test/demo"
-
-# Wait for a message (with timeout)
-$message = Receive-MqttMessage -Session $session -TimeoutSeconds 30
-Write-Host "Received: $($message.Payload)"
-
-Disconnect-MqttSession -Session $session
-Remove-MqttSession -Session $session
-```
-
-### Async Message Handler
-
-```powershell
-$session = New-MqttSession
-Connect-MqttSession -Session $session -Host "broker.hivemq.com"
-
-Subscribe-MqttTopic -Session $session -Topic "test/#"
-
-# Register a message handler
-Register-MqttMessageHandler -Session $session -Action {
-    param($topic, $payload, $message)
-    Write-Host "Message on $topic : $payload"
-    Write-Host "QoS: $($message.QoS), Retain: $($message.Retain)"
-}
-
-# Messages will be handled asynchronously
-Start-Sleep -Seconds 60
-
-Disconnect-MqttSession -Session $session
-Remove-MqttSession -Session $session
-```
-
-## Available Cmdlets
-
-### Help and Examples
-
-#### Show-MqttExamples
-Displays quick examples for common MQTT tasks.
-
-```powershell
-Show-MqttExamples
-```
-
-### Session Management
-
-#### New-MqttSession
-Creates a new MQTT session.
-
-```powershell
-$session = New-MqttSession
-```
-
-#### Connect-MqttSession
-Connects to an MQTT broker with various options.
-
-**TCP Connection:**
-```powershell
-Connect-MqttSession -Session $session -Host "broker.hivemq.com" -Port 1883
-```
-
-**TCP with TLS:**
-```powershell
-Connect-MqttSession -Session $session -Host "broker.hivemq.com" -Port 8883 `
-    -UseTls -AllowUntrustedCertificates
-```
-
-**WebSocket Connection:**
-```powershell
-Connect-MqttSession -Session $session -WebSocketUri "ws://broker.hivemq.com:8000/mqtt"
-```
-
-**With Authentication:**
-```powershell
-Connect-MqttSession -Session $session -Host "broker.hivemq.com" `
-    -Username "user" -Password "pass"
-```
-
-**With Last Will and Testament:**
-```powershell
-Connect-MqttSession -Session $session -Host "broker.hivemq.com" `
-    -WillTopic "status/client" -WillPayload "Offline" -WillQoS 1 -WillRetain
-```
-
-**Parameters:**
-- `Session`: The MQTT session (mandatory)
-- `Host`: Broker hostname (for TCP)
-- `Port`: Broker port (default: 1883)
-- `WebSocketUri`: WebSocket URI (for WebSocket connections)
-- `Username`: Username for authentication
-- `Password`: Password for authentication
-- `ClientId`: Client identifier (auto-generated if not specified)
-- `CleanSession`: Use clean session (default: true)
-- `UseTls`: Enable TLS encryption
-- `AllowUntrustedCertificates`: Allow untrusted certificates
-- `KeepAlivePeriod`: Keep-alive period in seconds (default: 15)
-- `Timeout`: Connection timeout in seconds (default: 10)
-- `WillTopic`: Last Will topic
-- `WillPayload`: Last Will payload
-- `WillQoS`: Last Will QoS level (0-2)
-- `WillRetain`: Retain Last Will message
-
-#### Get-MqttSessionStatus
-Gets the current status of the MQTT session.
-
-```powershell
-$status = Get-MqttSessionStatus -Session $session
-Write-Host "Connected: $($status.IsConnected)"
-```
-
-#### Disconnect-MqttSession
-Disconnects from the MQTT broker.
-
-```powershell
-Disconnect-MqttSession -Session $session
-```
-
-**Parameters:**
-- `Session`: The MQTT session (mandatory)
-- `Reason`: Disconnect reason code
-- `ReasonString`: Human-readable reason
-- `SessionExpiryInterval`: Session expiry interval
-
-#### Remove-MqttSession
-Disposes the MQTT session and releases resources.
-
-```powershell
-Remove-MqttSession -Session $session
-```
-
-#### Test-MqttConnection
-Tests if the MQTT connection is alive by sending a PING packet.
-
-```powershell
-$isAlive = Test-MqttConnection -Session $session -TimeoutSeconds 5
-Write-Host "Connection is alive: $isAlive"
-```
-
-**Parameters:**
-- `Session`: The MQTT session (mandatory)
-- `TimeoutSeconds`: Timeout for the ping operation (default: 5)
-
-### Publishing
-
-#### Publish-MqttMessage
-Publishes a message to a topic.
-
-**Basic:**
-```powershell
-Publish-MqttMessage -Session $session -Topic "test/topic" -Payload "Hello"
-```
-
-**With QoS and Retain:**
-```powershell
-Publish-MqttMessage -Session $session -Topic "test/topic" -Payload "Hello" `
-    -QoS 1 -Retain
-```
-
-**With User Properties:**
-```powershell
-$props = @{
-    "source" = "PowerShell"
-    "version" = "1.0"
-}
-Publish-MqttMessage -Session $session -Topic "test/topic" -Payload "Hello" `
-    -UserProperties $props
-```
-
-**Parameters:**
-- `Session`: The MQTT session (mandatory)
-- `Topic`: Topic to publish to (mandatory)
-- `Payload`: Message payload (mandatory)
-- `QoS`: Quality of Service level (0-2, default: 0)
-- `Retain`: Retain flag
-- `ContentType`: Content type of the payload
-- `ResponseTopic`: Response topic for request/response pattern
-- `UserProperties`: Hashtable of user properties
-- `TopicAlias`: Topic alias
-- `MessageExpiryInterval`: Message expiry interval in seconds
-
-### Subscribing
-
-#### Subscribe-MqttTopic
-Subscribes to a topic.
-
-```powershell
-Subscribe-MqttTopic -Session $session -Topic "test/demo" -QoS 1
-```
-
-**Parameters:**
-- `Session`: The MQTT session (mandatory)
-- `Topic`: Topic filter to subscribe to (mandatory)
-- `QoS`: Quality of Service level (0-2, default: 0)
-- `NoLocal`: No local flag
-- `RetainAsPublished`: Retain as published flag
-- `RetainHandling`: Retain handling option
-- `SubscriptionIdentifier`: Subscription identifier
-
-#### Unsubscribe-MqttTopic
-Unsubscribes from a topic.
-
-```powershell
-Unsubscribe-MqttTopic -Session $session -Topic "test/demo"
-```
-
-### Message Handling
-
-#### Receive-MqttMessage
-Waits for and receives a single message.
-
-```powershell
-# Wait indefinitely
-$message = Receive-MqttMessage -Session $session
-
-# Wait with timeout
-$message = Receive-MqttMessage -Session $session -TimeoutSeconds 30
-```
-
-**Parameters:**
-- `Session`: The MQTT session (mandatory)
-- `TimeoutSeconds`: Timeout in seconds (0 = no timeout)
-
-#### Register-MqttMessageHandler
-Registers an asynchronous message handler using a PowerShell ScriptBlock.
-
-```powershell
-Register-MqttMessageHandler -Session $session -Action {
-    param($topic, $payload, $message)
-    
-    Write-Host "Topic: $topic"
-    Write-Host "Payload: $payload"
-    Write-Host "QoS: $($message.QoS)"
-    
-    # Access full message properties
-    if ($message.UserProperties) {
-        foreach ($prop in $message.UserProperties) {
-            Write-Host "Property: $($prop.Name) = $($prop.Value)"
-        }
-    }
-}
-```
-
-The ScriptBlock receives three parameters:
-1. `$topic`: The message topic (string)
-2. `$payload`: The message payload as UTF-8 string
-3. `$message`: The full message object with properties:
-   - `Topic`: Message topic
-   - `Payload`: Payload as string
-   - `RawPayload`: Payload as byte array
-   - `QoS`: Quality of Service level
-   - `Retain`: Retain flag
-   - `ContentType`: Content type
-   - `ResponseTopic`: Response topic
-   - `UserProperties`: List of user properties
-
-**Parameters:**
-- `Session`: The MQTT session (mandatory)
-- `Action`: ScriptBlock to execute for each message (mandatory)
-
-#### Unregister-MqttMessageHandler
-Removes all registered message handlers.
-
-```powershell
-Unregister-MqttMessageHandler -Session $session
-```
-
-## Advanced Examples
-
-### Request-Response Pattern
-
-```powershell
-$session = New-MqttSession
-Connect-MqttSession -Session $session -Host "broker.hivemq.com"
-
-# Responder
-Subscribe-MqttTopic -Session $session -Topic "request/topic"
-Register-MqttMessageHandler -Session $session -Action {
-    param($topic, $payload, $message)
-    if ($message.ResponseTopic) {
-        $response = "Response to: $payload"
-        Publish-MqttMessage -Session $session -Topic $message.ResponseTopic `
-            -Payload $response
-    }
-}
-
-# Requestor (in another session)
-$responseSession = New-MqttSession
-Connect-MqttSession -Session $responseSession -Host "broker.hivemq.com"
-Subscribe-MqttTopic -Session $responseSession -Topic "response/topic"
-Publish-MqttMessage -Session $responseSession -Topic "request/topic" `
-    -Payload "Request data" -ResponseTopic "response/topic"
-
-# Wait for response
-$response = Receive-MqttMessage -Session $responseSession -TimeoutSeconds 10
-```
-
-### High QoS Publishing
-
-```powershell
-# Publish with QoS 2 (exactly once delivery)
-$result = Publish-MqttMessage -Session $session -Topic "critical/data" `
-    -Payload "Important data" -QoS 2
-
-Write-Host "Publish result: $($result.ReasonCode)"
-```
-
-### Error Handling in Message Handler
-
-```powershell
-Register-MqttMessageHandler -Session $session -Action {
-    param($topic, $payload, $message)
-    try {
-        # Process message
-        $data = ConvertFrom-Json $payload
-        # Do something with data
-    }
-    catch {
-        Write-Host "Error processing message: $_" -ForegroundColor Red
-    }
-}
-```
-
-## Tips and Best Practices
-
-1. **Always disconnect cleanly**: Use `Disconnect-MqttSession` before `Remove-MqttSession`
-2. **Use appropriate QoS levels**: QoS 0 for best performance, QoS 1 for reliability, QoS 2 for critical data
-3. **Handle errors in message handlers**: Wrap handler code in try-catch blocks
-4. **Use meaningful client IDs**: Set custom client IDs for debugging
-5. **Secure connections**: Use TLS for production environments
-6. **Topic design**: Use hierarchical topic structures like `device/sensor/temperature`
-7. **Clean session**: Use `-CleanSession:$false` to maintain subscriptions across reconnects
-
-## Requirements
-
-- .NET 8.0 or later
-- PowerShell 7.0 or later
-- MQTTnet library
-
-## License
-
-This project is licensed under the MIT License - see the LICENSE file in the repository root for details.

Source/MQTTnet.PowerShell/SmokeTest.ps1

@@ -1,25 +0,0 @@
-# Quick smoke test for MQTTnet PowerShell Module
-Import-Module ./bin/Debug/net8.0/MQTTnet.PowerShell.dll -WarningAction SilentlyContinue
-
-Write-Host "Testing module load..." -ForegroundColor Yellow
-$commands = Get-Command -Module MQTTnet.PowerShell
-Write-Host "Found $($commands.Count) cmdlets:" -ForegroundColor Green
-$commands | ForEach-Object { Write-Host "  - $($_.Name)" -ForegroundColor Cyan }
-
-Write-Host "`nTesting session creation..." -ForegroundColor Yellow
-$session = New-MqttSession
-Write-Host "Session created successfully!" -ForegroundColor Green
-
-Write-Host "`nTesting Show-MqttExamples..." -ForegroundColor Yellow
-$examples = Show-MqttExamples
-if ($examples) {
-    Write-Host "Examples retrieved successfully!" -ForegroundColor Green
-} else {
-    Write-Host "Failed to retrieve examples!" -ForegroundColor Red
-}
-
-Write-Host "`nTesting session cleanup..." -ForegroundColor Yellow
-Remove-MqttSession -Session $session
-Write-Host "Session removed successfully!" -ForegroundColor Green
-
-Write-Host "`n✓ All smoke tests passed!" -ForegroundColor Green

Source/MQTTnet.PowerShell/Test.ps1

@@ -1,117 +0,0 @@
-# MQTTnet PowerShell Module Test Script
-# This script demonstrates the usage of the MQTTnet PowerShell module
-
-Import-Module ./bin/Debug/net8.0/MQTTnet.PowerShell.dll
-
-Write-Host "=== MQTTnet PowerShell Module Test ===" -ForegroundColor Cyan
-
-# Example 1: Basic TCP connection
-Write-Host "`n1. Testing basic TCP connection..." -ForegroundColor Yellow
-$session = New-MqttSession
-
-try {
-    Connect-MqttSession -Session $session -Host "broker.hivemq.com" -Port 1883
-    Write-Host "Connected successfully!" -ForegroundColor Green
-    
-    # Get session status
-    Write-Host "`n2. Getting session status..." -ForegroundColor Yellow
-    $status = Get-MqttSessionStatus -Session $session
-    Write-Host "IsConnected: $($status.IsConnected)" -ForegroundColor Green
-    
-    # Example 2: Publish a simple message
-    Write-Host "`n3. Publishing a simple message..." -ForegroundColor Yellow
-    Publish-MqttMessage -Session $session -Topic "test/powershell" -Payload "Hello from PowerShell!"
-    Write-Host "Message published!" -ForegroundColor Green
-    
-    # Example 3: Publish with user properties
-    Write-Host "`n4. Publishing with user properties..." -ForegroundColor Yellow
-    $properties = @{
-        "source" = "PowerShell"
-        "version" = "1.0"
-    }
-    Publish-MqttMessage -Session $session -Topic "test/powershell/advanced" -Payload "Advanced message" -UserProperties $properties -QoS 1
-    Write-Host "Message with properties published!" -ForegroundColor Green
-    
-    # Example 4: Subscribe and receive messages
-    Write-Host "`n5. Subscribing to topics..." -ForegroundColor Yellow
-    Subscribe-MqttTopic -Session $session -Topic "test/demo"
-    Write-Host "Subscribed to test/demo" -ForegroundColor Green
-    
-    # Example 5: Register a message handler
-    Write-Host "`n6. Registering message handler..." -ForegroundColor Yellow
-    Register-MqttMessageHandler -Session $session -Action {
-        param($topic, $payload, $message)
-        Write-Host "Received message on topic: $topic" -ForegroundColor Cyan
-        Write-Host "Payload: $payload" -ForegroundColor White
-        Write-Host "QoS: $($message.QoS)" -ForegroundColor White
-    }
-    Write-Host "Handler registered!" -ForegroundColor Green
-    
-    # Publish a test message that the handler will receive
-    Write-Host "`n7. Publishing test message for handler..." -ForegroundColor Yellow
-    Publish-MqttMessage -Session $session -Topic "test/demo" -Payload "Test message for handler"
-    Start-Sleep -Seconds 2
-    
-    # Example 6: Unsubscribe
-    Write-Host "`n8. Unsubscribing from topic..." -ForegroundColor Yellow
-    Unsubscribe-MqttTopic -Session $session -Topic "test/demo"
-    Write-Host "Unsubscribed!" -ForegroundColor Green
-    
-    # Example 7: Clean disconnect
-    Write-Host "`n9. Disconnecting..." -ForegroundColor Yellow
-    Disconnect-MqttSession -Session $session
-    Write-Host "Disconnected!" -ForegroundColor Green
-}
-catch {
-    Write-Host "Error: $_" -ForegroundColor Red
-}
-finally {
-    # Cleanup
-    Remove-MqttSession -Session $session
-    Write-Host "`nSession cleaned up!" -ForegroundColor Green
-}
-
-Write-Host "`n=== WebSocket Connection Example ===" -ForegroundColor Cyan
-
-# Example 8: WebSocket connection
-Write-Host "`nTesting WebSocket connection..." -ForegroundColor Yellow
-$wsSession = New-MqttSession
-
-try {
-    Connect-MqttSession -Session $wsSession -WebSocketUri "ws://broker.hivemq.com:8000/mqtt"
-    Write-Host "Connected via WebSocket!" -ForegroundColor Green
-    
-    Publish-MqttMessage -Session $wsSession -Topic "test/websocket" -Payload "Hello via WebSocket!"
-    Write-Host "Message published via WebSocket!" -ForegroundColor Green
-    
-    Disconnect-MqttSession -Session $wsSession
-}
-catch {
-    Write-Host "WebSocket Error: $_" -ForegroundColor Red
-}
-finally {
-    Remove-MqttSession -Session $wsSession
-}
-
-Write-Host "`n=== Connection with Will Message Example ===" -ForegroundColor Cyan
-
-# Example 9: Connection with Last Will Testament
-Write-Host "`nTesting connection with Will message..." -ForegroundColor Yellow
-$willSession = New-MqttSession
-
-try {
-    Connect-MqttSession -Session $willSession -Host "broker.hivemq.com" `
-        -WillTopic "test/will" -WillPayload "Client disconnected unexpectedly" -WillQoS 1 -WillRetain
-    Write-Host "Connected with Will message configured!" -ForegroundColor Green
-    
-    Disconnect-MqttSession -Session $willSession
-}
-catch {
-    Write-Host "Will Error: $_" -ForegroundColor Red
-}
-finally {
-    Remove-MqttSession -Session $willSession
-}
-
-Write-Host "`n=== All tests completed ===" -ForegroundColor Cyan
-

Source/MQTTnet.TestApp/AsyncLockTest.cs

@@ -2,9 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Threading;
-using System.Threading.Tasks;
 using MQTTnet.Exceptions;
 
 namespace MQTTnet.TestApp;

Source/MQTTnet.TestApp/ClientFlowTest.cs

@@ -2,8 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Threading.Tasks;
 using MQTTnet.Diagnostics.Logger;
 
 namespace MQTTnet.TestApp;

Source/MQTTnet.TestApp/ClientTest.cs

@@ -2,10 +2,8 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Net;
 using System.Text;
-using System.Threading.Tasks;
 using MQTTnet.Diagnostics.Logger;
 using MQTTnet.Internal;
 using MQTTnet.Protocol;

Source/MQTTnet.TestApp/MessageThroughputTest.cs

@@ -1,10 +1,5 @@
 using MQTTnet.Server;
-using System.Collections.Generic;
-using System;
 using System.Diagnostics;
-using System.Threading;
-using System.Threading.Tasks;
-using System.Linq;
 using MQTTnet.Internal;
 
 namespace MQTTnet.TestApp;

Source/MQTTnet.TestApp/MqttNetConsoleLogger.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Text;
 using MQTTnet.Diagnostics.Logger;
 

Source/MQTTnet.TestApp/PerformanceTest.cs

@@ -2,13 +2,9 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Diagnostics;
-using System.Linq;
 using System.Net;
 using System.Text;
-using System.Threading;
-using System.Threading.Tasks;
 using MQTTnet.Protocol;
 using MQTTnet.Server;
 

Source/MQTTnet.TestApp/Program.cs

@@ -2,10 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Threading;
-using System.Threading.Tasks;
-
 namespace MQTTnet.TestApp;
 
 public static class Program

Source/MQTTnet.TestApp/PublicBrokerTest.cs

@@ -2,10 +2,7 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Security.Authentication;
-using System.Threading;
-using System.Threading.Tasks;
 using MQTTnet.Formatter;
 using MQTTnet.Internal;
 using MQTTnet.Protocol;

Source/MQTTnet.TestApp/ServerAndClientTest.cs

@@ -2,8 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System.Threading;
-using System.Threading.Tasks;
 using MQTTnet.Diagnostics.Logger;
 using MQTTnet.Server;
 

Source/MQTTnet.TestApp/ServerTest.cs

@@ -2,11 +2,7 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Collections.Generic;
-using System.IO;
 using System.Text;
-using System.Threading.Tasks;
 using MQTTnet.Diagnostics.Logger;
 using MQTTnet.Internal;
 using MQTTnet.Protocol;

Source/MQTTnet.TestApp/TopicGenerator.cs

@@ -1,5 +1,3 @@
-using System;
-using System.Collections.Generic;
 using MQTTnet.Extensions.TopicTemplate;
 
 namespace MQTTnet.TestApp;

Source/MQTTnet.Tests/ASP/Mockups/ConnectionHandlerMockup.cs

@@ -2,8 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Threading.Tasks;
 using Microsoft.AspNetCore.Connections;
 using MQTTnet.Adapter;
 using MQTTnet.AspNetCore;

Source/MQTTnet.Tests/ASP/Mockups/MemoryOwner.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Buffers;
 
 namespace MQTTnet.Tests.ASP.Mockups;

Source/MQTTnet.Tests/ASP/MqttConnectionContextTest.cs

@@ -2,12 +2,8 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Threading;
-using System.Threading.Tasks;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Connections;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.AspNetCore;
 using MQTTnet.Exceptions;
 using MQTTnet.Formatter;

Source/MQTTnet.Tests/ASP/ReaderExtensionsTest.cs

@@ -3,7 +3,6 @@
 // See the LICENSE file in the project root for more information.
 
 using System.Buffers;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.AspNetCore;
 using MQTTnet.Formatter;
 using MQTTnet.Packets;

Source/MQTTnet.Tests/AssemblyInfo.cs

@@ -1,3 +1 @@
-using Microsoft.VisualStudio.TestTools.UnitTesting;
-
 [assembly: DoNotParallelize]

Source/MQTTnet.Tests/BaseTestClass.cs

@@ -2,9 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Threading.Tasks;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Formatter;
 using MQTTnet.Tests.Mockups;
 

Source/MQTTnet.Tests/Clients/LowLevelMqttClient/LowLevelMqttClient_Tests.cs

@@ -2,12 +2,8 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Net.Sockets;
 using System.Text;
-using System.Threading;
-using System.Threading.Tasks;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Exceptions;
 using MQTTnet.LowLevelClient;
 using MQTTnet.Packets;

Source/MQTTnet.Tests/Clients/MqttClient/MqttClient_Connection_Tests.cs

@@ -2,11 +2,7 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Text;
-using System.Threading;
-using System.Threading.Tasks;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Exceptions;
 using MQTTnet.Formatter;
 using MQTTnet.Internal;

Source/MQTTnet.Tests/Clients/MqttClient/MqttClient_Tests.cs

@@ -2,17 +2,11 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Buffers;
-using System.Collections.Generic;
 using System.Diagnostics;
 using System.Globalization;
-using System.Linq;
 using System.Net.Sockets;
 using System.Text;
-using System.Threading;
-using System.Threading.Tasks;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Exceptions;
 using MQTTnet.Formatter;
 using MQTTnet.Internal;

Source/MQTTnet.Tests/Clients/MqttClientOptionsBuilder_Tests.cs

@@ -2,9 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System.Linq;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
-
 namespace MQTTnet.Tests.Clients;
 
 // ReSharper disable InconsistentNaming

Source/MQTTnet.Tests/Diagnostics/Logger_Tests.cs

@@ -2,8 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Diagnostics.Logger;
 
 namespace MQTTnet.Tests.Diagnostics;

Source/MQTTnet.Tests/Diagnostics/PacketInspection_Tests.cs

@@ -2,11 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Collections.Generic;
-using System.Threading;
-using System.Threading.Tasks;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Formatter;
 using MQTTnet.Internal;
 

Source/MQTTnet.Tests/Diagnostics/SourceLogger_Tests.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Diagnostics.Logger;
 
 namespace MQTTnet.Tests.Diagnostics;

Source/MQTTnet.Tests/Exceptions/MqttProtocolViolationException_Tests.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Exceptions;
 
 namespace MQTTnet.Tests.Exceptions;

Source/MQTTnet.Tests/Extensions/MqttTopicTemplate_Tests.cs

@@ -2,9 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Linq;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Exceptions;
 using MQTTnet.Extensions.TopicTemplate;
 

Source/MQTTnet.Tests/Extensions/Rpc_Tests.cs

@@ -2,11 +2,7 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Collections.Generic;
 using System.Text;
-using System.Threading.Tasks;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Exceptions;
 using MQTTnet.Extensions.Rpc;
 using MQTTnet.Formatter;

Source/MQTTnet.Tests/Factory/MqttFactory_Tests.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Server;
 
 namespace MQTTnet.Tests.Factory;

Source/MQTTnet.Tests/Formatter/MqttBufferReader_Tests.cs

@@ -2,10 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Collections.Generic;
-using System.IO;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Exceptions;
 using MQTTnet.Formatter;
 

Source/MQTTnet.Tests/Formatter/MqttPacketSerialization_V3_Binary_Tests.cs

@@ -2,11 +2,7 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Buffers;
-using System.IO;
-using System.Threading;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Adapter;
 using MQTTnet.Diagnostics.Logger;
 using MQTTnet.Exceptions;

Source/MQTTnet.Tests/Formatter/MqttPacketSerialization_V3_Tests.cs

@@ -2,9 +2,7 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Buffers;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Exceptions;
 using MQTTnet.Formatter;
 using MQTTnet.Packets;

Source/MQTTnet.Tests/Formatter/MqttPacketSerialization_V5_Tests.cs

@@ -2,9 +2,7 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Buffers;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Formatter;
 using MQTTnet.Packets;
 using MQTTnet.Protocol;

Source/MQTTnet.Tests/Formatter/MqttPacketWriter_Tests.cs

@@ -1,5 +1,3 @@
-using System;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Exceptions;
 using MQTTnet.Formatter;
 

Source/MQTTnet.Tests/Helpers/MqttClientExtensions.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using MQTTnet.Tests.Mockups;
 
 namespace MQTTnet.Tests.Helpers;

Source/MQTTnet.Tests/Helpers/ReflectionExtensions.cs

@@ -2,7 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Reflection;
 
 namespace MQTTnet.Tests.Helpers;

Source/MQTTnet.Tests/Internal/AsyncEvent_Tests.cs

@@ -2,10 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Threading;
-using System.Threading.Tasks;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Internal;
 
 namespace MQTTnet.Tests.Internal;

Source/MQTTnet.Tests/Internal/AsyncLock_Tests.cs

@@ -2,11 +2,7 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
 using System.Diagnostics;
-using System.Threading;
-using System.Threading.Tasks;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using MQTTnet.Internal;
 
 namespace MQTTnet.Tests.Internal;