From 13762eedd44c0f31ac5b8535a20cd03c76671e19 Mon Sep 17 00:00:00 2001
From: Christian <6939810+chkr1011@users.noreply.github.com>
Date: Tue, 19 Jul 2022 17:33:01 +0200
Subject: [PATCH] Update Server_Asp_Net_Samples.cs

---
 Samples/Server/Server_Asp_Net_Samples.cs | 43 +++++++++++++++++-------
 1 file changed, 30 insertions(+), 13 deletions(-)

diff --git a/Samples/Server/Server_Asp_Net_Samples.cs b/Samples/Server/Server_Asp_Net_Samples.cs
index a343159e..d085196d 100644
--- a/Samples/Server/Server_Asp_Net_Samples.cs
+++ b/Samples/Server/Server_Asp_Net_Samples.cs
@@ -5,12 +5,15 @@
 // ReSharper disable UnusedType.Global
 // ReSharper disable UnusedMember.Global
 // ReSharper disable InconsistentNaming
+// ReSharper disable EmptyConstructor
+// ReSharper disable MemberCanBeMadeStatic.Local
 
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using MQTTnet.AspNetCore;
+using MQTTnet.Server;
 
 namespace MQTTnet.Samples.Server;
 
@@ -30,7 +33,7 @@ public static class Server_Asp_Net_Samples
                         {
                             // This will allow MQTT connections based on TCP port 1883.
                             o.ListenAnyIP(1883, l => l.UseMqtt());
-                            
+
                             // This will allow MQTT connections based on HTTP WebSockets with URI "localhost:5000/mqtt"
                             // See code below for URI configuration.
                             o.ListenAnyIP(5000); // Default HTTP pipeline
@@ -42,9 +45,30 @@ public static class Server_Asp_Net_Samples
         return host.RunConsoleAsync();
     }
 
+    sealed class MqttController
+    {
+        public MqttController()
+        {
+            // Inject other services via constructor.
+        }
+        
+        public Task OnClientConnected(ClientConnectedEventArgs eventArgs)
+        {
+            Console.WriteLine($"Client '{eventArgs.ClientId}' connected.");
+            return Task.CompletedTask;
+        }
+
+
+        public Task ValidateConnection(ValidatingConnectionEventArgs eventArgs)
+        {
+            Console.WriteLine($"Client '{eventArgs.ClientId}' wants to connect. Accepting!");
+            return Task.CompletedTask;
+        }
+    }
+
     sealed class Startup
     {
-        public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
+        public void Configure(IApplicationBuilder app, IWebHostEnvironment environment, MqttController mqttController)
         {
             app.UseRouting();
 
@@ -64,17 +88,8 @@ public static class Server_Asp_Net_Samples
                      * Attach event handlers etc. if required.
                      */
 
-                    server.ValidatingConnectionAsync += e =>
-                    {
-                        Console.WriteLine($"Client '{e.ClientId}' wants to connect. Accepting!");
-                        return Task.CompletedTask;
-                    };
-
-                    server.ClientConnectedAsync += e =>
-                    {
-                        Console.WriteLine($"Client '{e.ClientId}' connected.");
-                        return Task.CompletedTask;
-                    };
+                    server.ValidatingConnectionAsync += mqttController.ValidateConnection;
+                    server.ClientConnectedAsync += mqttController.OnClientConnected;
                 });
         }
 
@@ -88,6 +103,8 @@ public static class Server_Asp_Net_Samples
 
             services.AddMqttConnectionHandler();
             services.AddConnections();
+
+            services.AddSingleton<MqttController>();
         }
     }
 }
\ No newline at end of file
-- 
GitLab