Merge pull request #4 from kimcu-on-thenet/feature/efcore-migration-h…

…ostedservice

Feature/efcore migration hostedservice

README.md

@@ -15,26 +15,21 @@ $ docker-compose -f docker-compose.yml -f docker-compose.override.yml run sqlser
 
 ## Step 2
 
-```bash
-$ cd src\ProductCatalog\CoolStore.ProductCatalogApi
-$ dotnet ef database update
-```
-
-## Step 3
-
 ```bash
 $ dotnet run -p \src\GraphApi\CoolStore.GraphApi\CoolStore.GraphApi.csproj
 $ dotnet run -p \src\ProductCatalog\CoolStore.ProductCatalogApi\CoolStore.ProductCatalogApi.csproj
 ```
 
-## Step 4
+## Step 3
 Go to http://localhost:5000
 
 ```js
-products(currentPage: 1, highPrice: 1000) {
-  id
-  name
-  imageUrl
+query{
+    products(currentPage: 1, highPrice: 1000) {
+    id
+    name
+    imageUrl
+  }
 }
 ```
 

src/BuildingBlocks/N8T.Infra/Data/DbContextMigratorHostedService.cs

@@ -0,0 +1,31 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace N8T.Infrastructure.Data
+{
+    public class DbContextMigratorHostedService : IHostedService
+    {
+        private readonly IServiceProvider _serviceProvider;
+        public DbContextMigratorHostedService(IServiceProvider serviceProvider)
+            => this._serviceProvider = serviceProvider;
+
+        #region Implementation of IHostedService
+
+        public async Task StartAsync(CancellationToken cancellationToken)
+        {
+            using var scope = this._serviceProvider.CreateScope();
+
+            var applicationDbContext = scope.ServiceProvider.GetRequiredService<DbContext>();
+
+            await applicationDbContext.Database.MigrateAsync(cancellationToken);
+        }
+
+        public Task StopAsync(CancellationToken cancellationToken) => Task.CompletedTask;
+
+        #endregion
+    }
+}

src/ProductCatalog/CoolStore.ProductCatalogApi/CoolStore.ProductCatalogApi.csproj

@@ -37,6 +37,7 @@
   </ItemGroup>
 
   <ItemGroup>
+    <Folder Include="HostedServices\" />
     <Folder Include="Persistence\Migrations\" />
   </ItemGroup>
 

src/ProductCatalog/CoolStore.ProductCatalogApi/Program.cs

@@ -11,6 +11,7 @@
 using N8T.Infrastructure.Options;
 using Serilog;
 using System.Threading.Tasks;
+using N8T.Infrastructure.Data;
 
 namespace CoolStore.ProductCatalogApi
 {
@@ -59,6 +60,7 @@ private static async Task Main(string[] args)
                 });
             builder.Services.AddScoped<DbContext>(provider => provider.GetService<ProductCatalogDbContext>());
             builder.Services.AddScoped<IDomainEventContext>(provider => provider.GetService<ProductCatalogDbContext>());
+            builder.Services.AddHostedService<DbContextMigratorHostedService>();
 
             var app = builder.Build();
             app.Listen(serviceOptions.ProductCatalogService.RestUri);