Added migration projects and wait processes at startup

src/TagzApp.AppHost/DatabaseService.cs

@@ -12,7 +12,8 @@ public static class DatabaseConfig
 	public static IDistributedApplicationBuilder AddDatabase(
 		this IDistributedApplicationBuilder builder
 		, out IResourceBuilder<PostgresDatabaseResource> db
-		, out IResourceBuilder<PostgresDatabaseResource> securityDb)
+		, out IResourceBuilder<PostgresDatabaseResource> securityDb
+		, out IResourceBuilder<ProjectResource> migration)
 	{
 
 		var dbPassword = builder.AddParameter("dbPassword", false);
@@ -25,6 +26,13 @@ this IDistributedApplicationBuilder builder
 
 		securityDb = dbServer.AddDatabase("securitydb");
 
+
+		migration = builder.AddProject<Projects.TagzApp_MigrationService>("db-migrations")
+			.WaitFor(db)
+			.WaitFor(securityDb)
+			.WithReference(db)
+			.WithReference(securityDb);
+
 		return builder;
 
 	}

src/TagzApp.AppHost/Program.cs

@@ -3,7 +3,10 @@
 
 var builder = DistributedApplication.CreateBuilder(args);
 
-builder.AddDatabase(out var db, out var securityDb);
+builder.AddDatabase(
+	out var db,
+	out var securityDb,
+	out var migration);
 
 var twitchCache = builder.AddRedis("twitchCache");
 var twitchRelay = builder.AddExecutable("twitchrelay",
@@ -15,6 +18,7 @@
 #region Website
 
 var tagzAppWeb = builder.AddProject<Projects.TagzApp_Blazor>("web", "https")
+	.WaitForCompletion(migration)
 	.WithReference(db)
 	.WithReference(securityDb)
 	.WithEnvironment("TwitchRelayUri", "http://localhost:7082");

src/TagzApp.AppHost/TagzApp.AppHost.csproj

@@ -18,7 +18,9 @@
   </ItemGroup>
 
   <ItemGroup>
+    <ProjectReference Include="..\TagzApp.AppHostExtensions\TagzApp.AppHostExtensions.csproj" IsAspireProjectResource="false" />
     <ProjectReference Include="..\TagzApp.Blazor\TagzApp.Blazor.csproj" />
+    <ProjectReference Include="..\TagzApp.DatabaseMigration\TagzApp.MigrationService.csproj" />
   </ItemGroup>
 
 </Project>

src/TagzApp.AppHostExtensions/HealthCheckAnnotation.cs

@@ -0,0 +1,32 @@
+using System;
+using Aspire.Hosting.ApplicationModel;
+using Microsoft.Extensions.Diagnostics.HealthChecks;
+
+namespace Aspire.Hosting;
+
+/// <summary>
+/// An annotation that associates a health check factory with a resource
+/// </summary>
+/// <param name="healthCheckFactory">A function that creates the health check</param>
+public class HealthCheckAnnotation(Func<IResource, CancellationToken, Task<IHealthCheck?>> healthCheckFactory) : IResourceAnnotation
+{
+	public Func<IResource, CancellationToken, Task<IHealthCheck?>> HealthCheckFactory { get; } = healthCheckFactory;
+
+	public static HealthCheckAnnotation Create(Func<string, IHealthCheck> connectionStringFactory)
+	{
+		return new(async (resource, token) =>
+		{
+			if (resource is not IResourceWithConnectionString c)
+			{
+				return null;
+			}
+
+			if (await c.GetConnectionStringAsync(token) is not string cs)
+			{
+				return null;
+			}
+
+			return connectionStringFactory(cs);
+		});
+	}
+}

src/TagzApp.AppHostExtensions/PostgreSqlHealthCheckExtensions.cs

@@ -0,0 +1,23 @@
+using Aspire.Hosting.ApplicationModel;
+using HealthChecks.NpgSql;
+
+namespace Aspire.Hosting;
+
+public static class PostgreSqlHealthCheckExtensions
+{
+	/// <summary>
+	/// Adds a health check to the PostgreSQL server resource.
+	/// </summary>
+	public static IResourceBuilder<PostgresServerResource> WithHealthCheck(this IResourceBuilder<PostgresServerResource> builder)
+	{
+		return builder.WithAnnotation(HealthCheckAnnotation.Create(cs => new NpgSqlHealthCheck(new NpgSqlHealthCheckOptions(cs))));
+	}
+
+	/// <summary>
+	/// Adds a health check to the PostgreSQL database resource.
+	/// </summary>
+	public static IResourceBuilder<PostgresDatabaseResource> WithHealthCheck(this IResourceBuilder<PostgresDatabaseResource> builder)
+	{
+		return builder.WithAnnotation(HealthCheckAnnotation.Create(cs => new NpgSqlHealthCheck(new NpgSqlHealthCheckOptions(cs))));
+	}
+}

src/TagzApp.AppHostExtensions/RedisResourceHealthCheckExtensions.cs

@@ -0,0 +1,15 @@
+using Aspire.Hosting.ApplicationModel;
+using HealthChecks.Redis;
+
+namespace Aspire.Hosting;
+
+public static class RedisResourceHealthCheckExtensions
+{
+	/// <summary>
+	/// Adds a health check to the Redis server resource.
+	/// </summary>
+	public static IResourceBuilder<RedisResource> WithHealthCheck(this IResourceBuilder<RedisResource> builder)
+	{
+		return builder.WithAnnotation(HealthCheckAnnotation.Create(cs => new RedisHealthCheck(cs)));
+	}
+}

src/TagzApp.AppHostExtensions/TagzApp.AppHostExtensions.csproj

@@ -0,0 +1,18 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+	<ItemGroup>
+		<PackageReference Include="Aspire.Hosting" Version="8.0.*" />
+		<PackageReference Include="Aspire.Hosting.Redis" Version="8.0.*" />
+		<PackageReference Include="Aspire.Hosting.PostgreSQL" Version="8.0.*" />
+		<PackageReference Include="AspNetCore.HealthChecks.NpgSql" Version="8.0.1" />
+		<PackageReference Include="AspNetCore.HealthChecks.Redis" Version="8.0.1" />
+		<PackageReference Include="AspNetCore.HealthChecks.Uris" Version="8.0.1" />
+	</ItemGroup>
+
+</Project>