53 lines
1.4 KiB
C#
53 lines
1.4 KiB
C#
using Api;
|
|
using Api.DBAccess;
|
|
using Api.MQTTReciever;
|
|
using Microsoft.AspNetCore;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using Microsoft.Extensions.Configuration;
|
|
|
|
class Program
|
|
{
|
|
|
|
public static void Main(string[] args)
|
|
{
|
|
var app = CreateWebHostBuilder(args).Build();
|
|
|
|
|
|
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();
|
|
}
|
|
|
|
// Calls the startup class and creates the webinterface
|
|
public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>
|
|
WebHost.CreateDefaultBuilder(args)
|
|
.UseUrls("http://0.0.0.0:5000")
|
|
.UseStartup<Startup>();
|
|
|
|
public static async void RunMigrations(IWebHost app)
|
|
{
|
|
await using var scope = app.Services.CreateAsyncScope();
|
|
await using var db = scope.ServiceProvider.GetService<DBContext>();
|
|
|
|
if (db != null) {
|
|
await db.Database.MigrateAsync();
|
|
}
|
|
}
|
|
}
|
|
|
|
|