AS1024/GeoFeed
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Create various scopes - forgot that EF Core DBContexts don't work in a singleton service

Browse Source
This commit is contained in:
Jeff Leung
2024-01-08 10:08:28 -08:00
parent 37841db663
commit 9974bb5f0c
1 changed files with 19 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
AS1024.GeoFeed/GeoFeedLocalCache/GeoFeedCacheService.cs
View File

@@ -1,5 +1,6 @@
using AS1024.GeoFeed.Interfaces; using AS1024.GeoFeed.Interfaces;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
using System.Runtime.CompilerServices;
namespace AS1024.GeoFeed.GeoFeedLocalCache namespace AS1024.GeoFeed.GeoFeedLocalCache
{ {
@@ -8,15 +9,15 @@ namespace AS1024.GeoFeed.GeoFeedLocalCache
CancellationToken _cancellationToken; CancellationToken _cancellationToken;
private readonly ILogger<GeoFeedCacheService> logger; private readonly ILogger<GeoFeedCacheService> logger;
private readonly IGeoFeedProvider feedProvider; private readonly IGeoFeedProvider feedProvider;
private readonly GeoFeedCacheDbContext dbContext; private readonly IHost host;
public GeoFeedCacheService(ILogger<GeoFeedCacheService> logger, public GeoFeedCacheService(ILogger<GeoFeedCacheService> logger,
IGeoFeedProvider feedProvider, IGeoFeedProvider feedProvider,
GeoFeedCacheDbContext dbContext) IHost host)
{ {
this.logger = logger; this.logger = logger;
this.feedProvider = feedProvider; this.feedProvider = feedProvider;
this.dbContext = dbContext; this.host = host;
} }
public Task StartAsync(CancellationToken cancellationToken) public Task StartAsync(CancellationToken cancellationToken)
@@ -32,8 +33,7 @@ namespace AS1024.GeoFeed.GeoFeedLocalCache
public async Task<bool> StartPerioidicSync() public async Task<bool> StartPerioidicSync()
{ {
if (dbContext.Database.GetPendingMigrations().Any()) await DBContextMigrate();
await dbContext.Database.MigrateAsync();
List<GeoFeedCacheEntry> geoFeedCacheEntry = []; List<GeoFeedCacheEntry> geoFeedCacheEntry = [];
while (!_cancellationToken.IsCancellationRequested) while (!_cancellationToken.IsCancellationRequested)
@@ -42,6 +42,8 @@ namespace AS1024.GeoFeed.GeoFeedLocalCache
logger.LogInformation("Running on disk fallback cache process..."); logger.LogInformation("Running on disk fallback cache process...");
try try
{ {
using var scope = host.Services.CreateScope();
using var dbContext = scope.ServiceProvider.GetRequiredService<GeoFeedCacheDbContext>();
var results = await feedProvider.GetGeoFeedData(); var results = await feedProvider.GetGeoFeedData();
results.ForEach(x => results.ForEach(x =>
@@ -69,7 +71,19 @@ namespace AS1024.GeoFeed.GeoFeedLocalCache
logger.LogWarning("On disk cache failed to run. Waiting on 30 minutes before retry..."); logger.LogWarning("On disk cache failed to run. Waiting on 30 minutes before retry...");
} }
} }
return false; return false;
} }
private async Task DBContextMigrate()
{
using IServiceScope scope = host.Services.CreateScope();
using GeoFeedCacheDbContext? dbContext =
host.Services.GetService<GeoFeedCacheDbContext>();
if (dbContext.Database.GetPendingMigrations().Any())
{
await dbContext.Database.MigrateAsync();
}
}
} }
} }