ModuleAPI/ModuleAPI.cs at master · ModularSmartHome/ModuleAPI · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
usingMicrosoft.EntityFrameworkCore;
usingModuleAPI.Utility;
usingModuleAPI.Models;
usingModuleAPI.Shared;

namespaceModuleAPI;

publicclassModuleAPI
{
privateWebApplicationBuilderWebAppBuilder;

publicModuleAPI(string[]args)
{
WebAppBuilder=WebApplication.CreateBuilder(args);
WebAppBuilder.Services.AddControllers();
WebAppBuilder.Services.AddRazorPages();
WebAppBuilder.Services.AddEndpointsApiExplorer();
WebAppBuilder.Services.AddSingleton<ArgumentListener>(sp =>newArgumentListener(args));
}

publicstaticvoidMain(string[]args)
{
Console.WriteLine("Started app");
}

publicModuleAPISetActionHandler(IActionHandleractionHandler)
{
WebAppBuilder.Services.AddSingleton<IActionHandler>(sp =>actionHandler);
returnthis;
}

publicModuleAPISetModuleInfo(ModuleInfoinfo)
{
WebAppBuilder.Services.AddSingleton<ModuleInfo>(sp =>info);
returnthis;
}

publicModuleAPISetDatabaseContext<T>()whereT:AbstractDatabaseContext
{
WebAppBuilder.Services.AddDbContext<T>();
returnthis;
}

publicvoidRunServer()
{
varapplicationUrl=DefineApplicationPort();
varapp=WebAppBuilder.Build();
CheckDatabaseConnection(app);
MigrateDatabase(app);
SetModuleHost(app,applicationUrl).Wait();
app.MapControllers();
app.MapRazorPages();
app.Run();
}

privatestringDefineApplicationPort()
{
vartcpLookup=newTcpPortLookup();
varfreePort=tcpLookup.GetUnusedPort();
varhostUrl="http://localhost:"+freePort;
WebAppBuilder.WebHost.UseUrls(hostUrl);
Console.WriteLine("Starting application on: "+hostUrl);
returnhostUrl;
}

privateasyncTaskSetModuleHost(WebApplicationapp,stringhost)
{
using(varscope=app.Services.CreateScope())
{
varlistener=scope.ServiceProvider.GetService<ArgumentListener>()!;
awaitnewRestClient(listener).SetModuleHost(host);
}
}

privatevoidMigrateDatabase(WebApplicationapp)
{
using(varscope=app.Services.CreateScope())
using(vardb=scope.ServiceProvider.GetService<AbstractDatabaseContext>()!)
{
try
{
db.Database.Migrate();
}
catch
{
Console.WriteLine("Already migrated");
}
}
}

privatevoidCheckDatabaseConnection(WebApplicationapp)
{
using(varscope=app.Services.CreateScope())
using(vardb=scope.ServiceProvider.GetService<AbstractDatabaseContext>()!)
{
if(db.Database.CanConnect())
{
Console.WriteLine("Able to connect to database");
}
else
{
Console.WriteLine("Unable to connect to database");
}
}
}


}