-
Notifications
You must be signed in to change notification settings - Fork 11
Expand file tree
/
Copy pathProgram.cs
More file actions
53 lines (39 loc) · 2.02 KB
/
Copy pathProgram.cs
File metadata and controls
53 lines (39 loc) · 2.02 KB
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
using System.Diagnostics.Metrics;
using Microsoft.Extensions.Options;
using OpenShock.Common;
using OpenShock.Common.Extensions;
using OpenShock.Common.Services;
using OpenShock.Common.Services.Device;
using OpenShock.Common.Services.Ota;
using OpenShock.Common.Swagger;
using OpenShock.LiveControlGateway;
using OpenShock.LiveControlGateway.LifetimeManager;
using OpenShock.LiveControlGateway.Options;
using OpenShock.LiveControlGateway.PubSub;
var builder = OpenShockApplication.CreateDefaultBuilder<Program>(args);
var redisOptions = builder.RegisterRedisOptions();
var databaseOptions = builder.RegisterDatabaseOptions();
builder.RegisterMetricsOptions();
var lcgOptions = builder.Configuration.GetRequiredSection(LcgOptions.SectionName).Get<LcgOptions>();
if (lcgOptions is null)
throw new InvalidOperationException($"Missing or invalid configuration for {LcgOptions.SectionName}.");
builder.Services.AddSingleton<IValidateOptions<LcgOptions>, LcgOptionsValidator>();
builder.Services.AddSingleton(lcgOptions);
builder.Services
.AddOpenShockMemDB(redisOptions)
.AddOpenShockDB(databaseOptions)
.AddOpenShockServices(configureMetrics: metricsBuilder => { metricsBuilder.AddMeter("OpenShock.Gateway"); })
.AddOpenShockSignalR(redisOptions);
builder.Services.AddScoped<IDeviceService, DeviceService>();
builder.Services.AddScoped<IControlSender, ControlSender>();
builder.Services.AddScoped<IOtaService, OtaService>();
builder.Services.AddKeyedSingleton("OpenShock.Gateway.Meter", new Meter("OpenShock.Gateway", "1.0.0", [new KeyValuePair<string, object?>("gateway_fqdn", lcgOptions.Fqdn)]));
builder.AddSwaggerExt<Program>();
//services.AddHealthChecks().AddCheck<DatabaseHealthCheck>("database");
builder.Services.AddHostedService<LcgKeepAlive>();
builder.Services.AddSingleton<HubLifetimeManager>();
builder.Services.AddSingleton<ApiTokenUpdateSubscriber>();
var app = builder.Build();
await app.UseCommonOpenShockMiddleware(lcgOptions.PublicPath);
await app.WaitForOpenShockSchemaReady(databaseOptions);
await app.RunAsync();