small mqtt subscriber changes

Team-Wilhelm · Jun 5, 2024 · 6f9fa80 · 6f9fa80
1 parent 5e703f1
commit 6f9fa80
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/api/Core/Services/MqttSubscriberService.cs b/api/Core/Services/MqttSubscriberService.cs
@@ -54,5 +54,7 @@ public async Task SubscribeAsync()
                 f => { f.WithTopic(_options.Value.SubscribeTopic); }).Build();
 
         await mqttClient.SubscribeAsync(mqttSubscribeOptions, CancellationToken.None);
+
+        Console.ReadLine();
     }
 }
diff --git a/api/Program.cs b/api/Program.cs
@@ -82,6 +82,7 @@ public static async Task<WebApplication> StartApi(string[] args)
         var services = builder.FindAndInjectClientEventHandlers(Assembly.GetExecutingAssembly());
 
         var app = builder.Build();
+        await app.Services.GetRequiredService<MqttSubscriberService>().SubscribeAsync();
 
         // be careful with using --db-init on production, it will delete all data
         if (args.Contains("--db-init"))