Mqtt works at the same time as api

backend/Api/Api.csproj

@@ -22,6 +22,7 @@
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageReference>
     <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.19.6" />
+    <PackageReference Include="MQTTnet" Version="5.0.1.1416" />
     <PackageReference Include="Swashbuckle.AspNetCore" Version="6.4.0" />
   </ItemGroup>
 

backend/Api/MQTTReciever/MQTTReciever.cs

@@ -1,7 +1,6 @@
 using Api.DBAccess;
 using Api.Models;
 using MQTTnet;
-using MQTTnet.Extensions.TopicTemplate;
 using System.Text;
 using System.Text.Json;
 
@@ -53,9 +52,11 @@ namespace Api.MQTTReciever
                     string refernceId = mqttMessageReceive.device_id;
                     var device = _dbAccess.ReadDevice(refernceId);
 
+                    if (device == null) { return Task.CompletedTask; }
+
                     newLog.Temperature = mqttMessageReceive.temperature;
                     newLog.Date = DateTimeOffset.FromUnixTimeSeconds(mqttMessageReceive.timestamp).DateTime;
-                    newLog.TempHigh= device.TempHigh;
+                    newLog.TempHigh = device.TempHigh;
                     newLog.TempLow = device.TempLow;
 
                     _dbAccess.CreateLog(newLog, refernceId);

backend/Api/Program.cs

@@ -10,19 +10,22 @@ class Program
     {
         var app = CreateWebHostBuilder(args).Build();
 
-
-        using (var scope = app.Services.CreateScope())
-        {
-            var services = scope.ServiceProvider;
-            var configuration = services.GetRequiredService<IConfiguration>();
-            var dbAccess = services.GetRequiredService<DbAccess>();
-
-            MQTTReciever mqtt = new MQTTReciever(configuration, dbAccess);
-            mqtt.Handle_Received_Application_Message();
-        }
-
         RunMigrations(app);
 
+        Task.Run(() =>
+        {
+            using (var scope = app.Services.CreateScope())
+            {
+                var services = scope.ServiceProvider;
+                var configuration = services.GetRequiredService<IConfiguration>();
+                var dbAccess = services.GetRequiredService<DbAccess>();
+
+                MQTTReciever mqtt = new MQTTReciever(configuration, dbAccess);
+                mqtt.Handle_Received_Application_Message().Wait();
+            }
+        });
+
+
         app.Run();
     }