Seeder project used for seeding

Scooletz · Scooletz · commit da8ef008638d · 2026-05-11T15:29:36.000+02:00
diff --git a/src/RavenDB.Samples.Library.App/Api.cs b/src/RavenDB.Samples.Library.App/Api.cs
@@ -1,21 +1,17 @@
 ﻿using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Azure.Functions.Worker;
-using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Logging;
 using Raven.Client.Documents;
 using Raven.Client.Documents.Linq;
 using Raven.Client.Documents.Session;
-using Raven.Migrations;
 using RavenDB.Samples.Library.Model;
 using RavenDB.Samples.Library.Model.Indexes;
 
 namespace RavenDB.Samples.Library.App;
 
-public class Api(ILogger<Api> logger, IAsyncDocumentSession session, IConfiguration config, MigrationRunner migrations)
+public class Api(ILogger<Api> logger, IAsyncDocumentSession session)
 {
-    public const string EnvVarAdminCommandKeyName = "CommandKey";
-    public const string HeaderAdminCommandKeyName = "X-Command-Key";
 
     [Function(nameof(BooksGetById))]
     public async Task<IActionResult> BooksGetById([HttpTrigger("get", Route = "books/{id}")] HttpRequest req, string id)
@@ -146,19 +142,4 @@ public async Task<IActionResult> HomeBooks([HttpTrigger("get", Route = "home/boo
         return new JsonResult(results);
     }
 
-    [Function(nameof(Migrate))]
-    public async Task<IActionResult> Migrate([HttpTrigger("post", Route = "migrate")] HttpRequest req)
-    {
-        var actual = req.Headers[HeaderAdminCommandKeyName];
-        var expected = config.GetValue<string>(EnvVarAdminCommandKeyName);
-
-        if (actual != expected)
-        {
-            return new StatusCodeResult(StatusCodes.Status403Forbidden);
-        }
-
-        migrations.Run();
-
-        return new StatusCodeResult(StatusCodes.Status202Accepted);
-    }
 }
diff --git a/src/RavenDB.Samples.Library.App/Program.cs b/src/RavenDB.Samples.Library.App/Program.cs
@@ -2,8 +2,6 @@
 using Microsoft.Azure.Functions.Worker.Builder;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
-using Raven.Migrations;
-using RavenDB.Samples.Library.Setup.Migrations;
 
 var builder = FunctionsApplication.CreateBuilder(args);
 
@@ -23,23 +21,9 @@
 builder.ConfigureFunctionsWebApplication();
 
 // https://learn.microsoft.com/en-us/dotnet/aspire/community-toolkit/ravendb?tabs=dotnet-cli#client-integration
-builder.AddRavenDBClient("library",
-    settings =>
-    {
-        settings.CreateDatabase = true;
-    });
-
-
-// TODO: extract from the value under container. As RavenDB is used in a container, the wiring is different from the app.
-var connection = "DefaultEndpointsProtocol=http;AccountName=devstoreaccount1;AccountKey=Eby8vdM02xNOcqFlqUwJPLlmEtlCDXJ1OUzFT50uSRZ6IFsuFq2UVErCz4I6tq/K1SZFPTOtr/KBHBeksoGMGw==;QueueEndpoint=http://storage:10001/devstoreaccount1;";
-builder.Services.AddSingleton(new MigrationContext(connection));
+builder.AddRavenDBClient("library");
 
 builder.Services
     .AddOpenTelemetry().WithLogging();
-builder.Services
-    .AddRavenDbMigrations(migrations =>
-    {
-        migrations.Assemblies = [typeof(ImportGoodBooks).Assembly];
-    });
 
 builder.Build().Run();
diff --git a/src/RavenDB.Samples.Library.App/RavenDB.Samples.Library.App.csproj b/src/RavenDB.Samples.Library.App/RavenDB.Samples.Library.App.csproj
@@ -12,7 +12,6 @@
     <ItemGroup>
         <FrameworkReference Include="Microsoft.AspNetCore.App"/>
         <PackageReference Include="CommunityToolkit.Aspire.RavenDB.Client" />
-        <PackageReference Include="RavenMigrations" />
         <PackageReference Include="Microsoft.ApplicationInsights.WorkerService"/>
         <PackageReference Include="Microsoft.Azure.Functions.Worker" />
         <PackageReference Include="Microsoft.Azure.Functions.Worker.ApplicationInsights" />
@@ -23,7 +22,6 @@
 
     <ItemGroup>
       <ProjectReference Include="..\RavenDB.Samples.Library.Model\RavenDB.Samples.Library.Model.csproj" />
-      <ProjectReference Include="..\RavenDB.Samples.Library.Setup\RavenDB.Samples.Library.Setup.csproj" />
     </ItemGroup>
 
 </Project>
diff --git a/src/RavenDB.Samples.Library.AppHost/AppHost.cs b/src/RavenDB.Samples.Library.AppHost/AppHost.cs
@@ -33,39 +33,27 @@
 var db = ravenDbServer
     .AddDatabase(dbName);
 
-const string commandKey = "CommandKey";
-
-var secretKey = builder.AddParameterWithRandomValue(commandKey, secret: true);
+// Seeder — runs migrations once, then exits 0; backend waits for completion
+var seeder = builder.AddProject<Projects.RavenDB_Samples_Library_Seeder>("seeder")
+    .WithReference(queues)
+    .WaitFor(queues)
+    .WithReference(db)
+    .WaitFor(db);
 
 // Library App
 var functions = builder.AddAzureFunctionsProject<Projects.RavenDB_Samples_Library_App>("app")
     .WithHostStorage(storage)
-    
+
     .WithReference(queues)
     .WaitFor(queues)
-    
-    // Required to go separately with as the bindings are not wired with the host storage
+
+    // Required to go separately as the bindings are not wired with the host storage
     .WithEnvironment("BindingConnection", queues.Resource.ConnectionStringExpression)
-    
+
     .WithReference(db)
     .WaitFor(db)
-    
-    .WithEnvironment(commandKey, secretKey)
-    .WithHttpCommand(
-        path: "/api/migrate",
-        displayName: "Migrate DB",
-
-        commandOptions: new HttpCommandOptions
-        {
-            Description = "Runs database migrations",
-            PrepareRequest = async context =>
-            {
-                var key = await secretKey.Resource.GetValueAsync(context.CancellationToken);
-                context.Request.Headers.Add("X-Command-Key", key);
-            },
-            IconName = "databaseArrowUp",
-            IsHighlighted = true
-        });
+
+    .WaitForCompletion(seeder);
 
 // Frontend
 var frontend = builder.AddNpmApp("Frontend", "../RavenDB.Samples.Library.Frontend", "dev")
diff --git a/src/RavenDB.Samples.Library.AppHost/RavenDB.Samples.Library.AppHost.csproj b/src/RavenDB.Samples.Library.AppHost/RavenDB.Samples.Library.AppHost.csproj
@@ -18,7 +18,7 @@
   <ItemGroup>
     <ProjectReference Include="..\RavenDB.Samples.Library.App\RavenDB.Samples.Library.App.csproj" />
     <ProjectReference Include="..\RavenDB.Samples.Library.ServiceDefaults\RavenDB.Samples.Library.ServiceDefaults.csproj" />
-    <ProjectReference Include="..\RavenDB.Samples.Library.Setup\RavenDB.Samples.Library.Setup.csproj" />
+    <ProjectReference Include="..\RavenDB.Samples.Library.Seeder\RavenDB.Samples.Library.Seeder.csproj" />
   </ItemGroup>
 
 
diff --git a/src/RavenDB.Samples.Library.Seeder/Migrations/001_ImportGoodbooks.cs b/src/RavenDB.Samples.Library.Seeder/Migrations/001_ImportGoodbooks.cs
@@ -11,7 +11,7 @@
 using Raven.Migrations;
 using RavenDB.Samples.Library.Model;
 
-namespace RavenDB.Samples.Library.Setup.Migrations;
+namespace RavenDB.Samples.Library.Seeder.Migrations;
 
 [Migration(1)]
 public sealed class ImportGoodBooks : Migration
diff --git a/src/RavenDB.Samples.Library.Seeder/Migrations/002_CreateIndexes.cs b/src/RavenDB.Samples.Library.Seeder/Migrations/002_CreateIndexes.cs
@@ -2,7 +2,7 @@
 using Raven.Migrations;
 using RavenDB.Samples.Library.Model.Indexes;
 
-namespace RavenDB.Samples.Library.Setup.Migrations;
+namespace RavenDB.Samples.Library.Seeder.Migrations;
 
 [Migration(2)]
 public sealed class CreateIndexes : Migration
diff --git a/src/RavenDB.Samples.Library.Seeder/Migrations/003_TimeoutManager.cs b/src/RavenDB.Samples.Library.Seeder/Migrations/003_TimeoutManager.cs
@@ -3,7 +3,7 @@
 using Raven.Migrations;
 using RavenDB.Samples.Library.Model.Indexes;
 
-namespace RavenDB.Samples.Library.Setup.Migrations;
+namespace RavenDB.Samples.Library.Seeder.Migrations;
 
 [Migration(3)]
 public sealed class TimeoutManagerMigration : Migration
diff --git a/src/RavenDB.Samples.Library.Seeder/Migrations/004_ConfigureAzureQueueETL.cs b/src/RavenDB.Samples.Library.Seeder/Migrations/004_ConfigureAzureQueueETL.cs
@@ -4,7 +4,7 @@
 using Raven.Migrations;
 using RavenDB.Samples.Library.Model;
 
-namespace RavenDB.Samples.Library.Setup.Migrations;
+namespace RavenDB.Samples.Library.Seeder.Migrations;
 
 [Migration(4)]
 public sealed class ConfigureAzureQueueETL(MigrationContext context) : Migration
diff --git a/src/RavenDB.Samples.Library.Seeder/Migrations/MigrationContext.cs b/src/RavenDB.Samples.Library.Seeder/Migrations/MigrationContext.cs
@@ -1,4 +1,4 @@
-﻿namespace RavenDB.Samples.Library.Setup.Migrations;
+﻿namespace RavenDB.Samples.Library.Seeder.Migrations;
 
 /// <summary>
 /// The context passed for the migrations.
diff --git a/src/RavenDB.Samples.Library.Seeder/Program.cs b/src/RavenDB.Samples.Library.Seeder/Program.cs
@@ -0,0 +1,22 @@
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using Raven.Migrations;
+using RavenDB.Samples.Library.Seeder;
+using RavenDB.Samples.Library.Seeder.Migrations;
+
+var builder = Host.CreateApplicationBuilder(args);
+builder.AddServiceDefaults();
+
+builder.AddRavenDBClient("library", settings => settings.CreateDatabase = true);
+
+var queues = builder.Configuration.GetConnectionString("queues")
+    ?? throw new InvalidOperationException("ConnectionStrings:queues missing.");
+builder.Services.AddSingleton(new MigrationContext(queues));
+
+builder.Services.AddRavenDbMigrations(m =>
+    m.Assemblies = [typeof(ImportGoodBooks).Assembly]);
+
+builder.Services.AddSingleton<SampleDataSeeder>();
+builder.Services.AddHostedService<SeedAndExitWorker>();
+
+await builder.Build().RunAsync();
diff --git a/src/RavenDB.Samples.Library.Seeder/RavenDB.Samples.Library.Seeder.csproj b/src/RavenDB.Samples.Library.Seeder/RavenDB.Samples.Library.Seeder.csproj
@@ -1,19 +1,23 @@
-<Project Sdk="Microsoft.NET.Sdk">
+<Project Sdk="Microsoft.NET.Sdk.Worker">
 
     <PropertyGroup>
         <TargetFramework>net10.0</TargetFramework>
+        <OutputType>Exe</OutputType>
         <ImplicitUsings>enable</ImplicitUsings>
         <Nullable>enable</Nullable>
+        <RootNamespace>RavenDB.Samples.Library.Seeder</RootNamespace>
     </PropertyGroup>
 
     <ItemGroup>
+        <PackageReference Include="CommunityToolkit.Aspire.RavenDB.Client" />
         <PackageReference Include="CsvHelper" />
         <PackageReference Include="RavenDB.Client" />
         <PackageReference Include="RavenMigrations" />
     </ItemGroup>
 
     <ItemGroup>
         <ProjectReference Include="..\RavenDB.Samples.Library.Model\RavenDB.Samples.Library.Model.csproj" />
+        <ProjectReference Include="..\RavenDB.Samples.Library.ServiceDefaults\RavenDB.Samples.Library.ServiceDefaults.csproj" />
     </ItemGroup>
 
     <ItemGroup>
diff --git a/src/RavenDB.Samples.Library.Seeder/SampleDataSeeder.cs b/src/RavenDB.Samples.Library.Seeder/SampleDataSeeder.cs
@@ -0,0 +1,8 @@
+using Raven.Migrations;
+
+namespace RavenDB.Samples.Library.Seeder;
+
+internal sealed class SampleDataSeeder(MigrationRunner runner)
+{
+    public Task SeedAllAsync(CancellationToken ct) => Task.Run(runner.Run, ct);
+}
diff --git a/src/RavenDB.Samples.Library.Seeder/SeedAndExitWorker.cs b/src/RavenDB.Samples.Library.Seeder/SeedAndExitWorker.cs
@@ -0,0 +1,26 @@
+using Microsoft.Extensions.Hosting;
+using Microsoft.Extensions.Logging;
+
+namespace RavenDB.Samples.Library.Seeder;
+
+internal sealed class SeedAndExitWorker(
+    SampleDataSeeder seeder,
+    IHostApplicationLifetime lifetime,
+    ILogger<SeedAndExitWorker> logger) : BackgroundService
+{
+    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
+    {
+        try
+        {
+            await seeder.SeedAllAsync(stoppingToken);
+            logger.LogInformation("Seed complete.");
+        }
+        catch (Exception ex)
+        {
+            logger.LogError(ex, "Seed failed.");
+            Environment.Exit(1);
+            return;
+        }
+        lifetime.StopApplication();
+    }
+}
diff --git a/src/RavenDB.Samples.Library.sln b/src/RavenDB.Samples.Library.sln
@@ -10,7 +10,7 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "RavenDB.Samples.Library.App
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "RavenDB.Samples.Library.Model", "RavenDB.Samples.Library.Model\RavenDB.Samples.Library.Model.csproj", "{14135ACF-F87E-4282-9F06-674C62EF18E0}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "RavenDB.Samples.Library.Setup", "RavenDB.Samples.Library.Setup\RavenDB.Samples.Library.Setup.csproj", "{AAC87B5A-AF1E-4229-937E-8F9AA4178871}"
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "RavenDB.Samples.Library.Seeder", "RavenDB.Samples.Library.Seeder\RavenDB.Samples.Library.Seeder.csproj", "{AAC87B5A-AF1E-4229-937E-8F9AA4178871}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-namespace RavenDB.Samples.Library.Setup.Migrations;`
	`1`	`+namespace RavenDB.Samples.Library.Seeder.Migrations;`
`2`	`2`
`3`	`3`	`/// <summary>`
`4`	`4`	`/// The context passed for the migrations.`