backend/Api/Api.csproj

@@ -22,7 +22,6 @@
       <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,6 +1,7 @@
 using Api.DBAccess;
 using Api.Models;
 using MQTTnet;
+using MQTTnet.Extensions.TopicTemplate;
 using System.Text;
 using System.Text.Json;
 
@@ -52,8 +53,6 @@ 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;

backend/Api/Program.cs

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