add redis test

This commit is contained in:
Stanley Dimant
2022-09-08 20:28:26 +02:00
parent 2192ea1fa0
commit 7672df275a
3 changed files with 23 additions and 13 deletions

View File

@@ -28,6 +28,7 @@
<PackageReference Include="lz4net" Version="1.0.15.93" /> <PackageReference Include="lz4net" Version="1.0.15.93" />
<PackageReference Include="Microsoft.AspNetCore.Diagnostics.EntityFrameworkCore" Version="6.0.8" /> <PackageReference Include="Microsoft.AspNetCore.Diagnostics.EntityFrameworkCore" Version="6.0.8" />
<PackageReference Include="Microsoft.AspNetCore.Identity.EntityFrameworkCore" Version="6.0.8" /> <PackageReference Include="Microsoft.AspNetCore.Identity.EntityFrameworkCore" Version="6.0.8" />
<PackageReference Include="Microsoft.AspNetCore.SignalR.StackExchangeRedis" Version="6.0.8" />
<PackageReference Include="Microsoft.Extensions.Hosting.Systemd" Version="6.0.0" /> <PackageReference Include="Microsoft.Extensions.Hosting.Systemd" Version="6.0.0" />
<PackageReference Include="prometheus-net.AspNetCore" Version="6.0.0" /> <PackageReference Include="prometheus-net.AspNetCore" Version="6.0.0" />
</ItemGroup> </ItemGroup>

View File

@@ -17,25 +17,29 @@ namespace MareSynchronosServer
{ {
var hostBuilder = CreateHostBuilder(args); var hostBuilder = CreateHostBuilder(args);
var host = hostBuilder.Build(); var host = hostBuilder.Build();
using (var scope = host.Services.CreateScope()) using (var scope = host.Services.CreateScope())
{ {
var services = scope.ServiceProvider; var services = scope.ServiceProvider;
using var context = services.GetRequiredService<MareDbContext>(); using var context = services.GetRequiredService<MareDbContext>();
context.Database.Migrate();
context.SaveChanges();
// clean up residuals var noDbActions = Environment.GetEnvironmentVariable("NODBACTIONS");
var users = context.Users; if (string.IsNullOrEmpty(noDbActions) || noDbActions == "0")
foreach (var user in users)
{ {
user.CharacterIdentification = null; context.Database.Migrate();
context.SaveChanges();
// clean up residuals
var users = context.Users;
foreach (var user in users)
{
user.CharacterIdentification = null;
}
var looseFiles = context.Files.Where(f => f.Uploaded == false);
var unfinishedRegistrations = context.LodeStoneAuth.Where(c => c.StartedAt != null);
context.RemoveRange(unfinishedRegistrations);
context.RemoveRange(looseFiles);
context.SaveChanges();
} }
var looseFiles = context.Files.Where(f => f.Uploaded == false);
var unfinishedRegistrations = context.LodeStoneAuth.Where(c => c.StartedAt != null);
context.RemoveRange(unfinishedRegistrations);
context.RemoveRange(looseFiles);
context.SaveChanges();
var metrics = services.GetRequiredService<MareMetrics>(); var metrics = services.GetRequiredService<MareMetrics>();

View File

@@ -112,7 +112,7 @@ namespace MareSynchronosServer
services.AddSingleton<IRateLimitConfiguration, RateLimitConfiguration>(); services.AddSingleton<IRateLimitConfiguration, RateLimitConfiguration>();
services.AddSignalR(hubOptions => var signalRserviceBuilder = services.AddSignalR(hubOptions =>
{ {
hubOptions.MaximumReceiveMessageSize = long.MaxValue; hubOptions.MaximumReceiveMessageSize = long.MaxValue;
hubOptions.EnableDetailedErrors = true; hubOptions.EnableDetailedErrors = true;
@@ -120,6 +120,11 @@ namespace MareSynchronosServer
hubOptions.StreamBufferCapacity = 200; hubOptions.StreamBufferCapacity = 200;
hubOptions.AddFilter<SignalRLimitFilter>(); hubOptions.AddFilter<SignalRLimitFilter>();
}); });
var redis = mareConfig.GetValue<string>("RedisConnectionString", string.Empty);
if (!string.IsNullOrEmpty(redis))
{
signalRserviceBuilder.AddStackExchangeRedis(redis);
}
} }
public void Configure(IApplicationBuilder app, IWebHostEnvironment env) public void Configure(IApplicationBuilder app, IWebHostEnvironment env)