- Add redis health check

- Add health checks on startup

src/Services/Basket/Basket.API/Basket.API.csproj

@@ -7,6 +7,7 @@
 
   <ItemGroup>
     <PackageReference Include="Grpc.AspNetCore" />
+    <PackageReference Include="AspNetCore.HealthChecks.Redis" />
     <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" />
   </ItemGroup>
 

src/Services/Basket/Basket.API/CustomExtensionMethods.cs

@@ -4,6 +4,13 @@ public static class CustomExtensionMethods
 {
     public static IServiceCollection AddRedis(this IServiceCollection services, IConfiguration configuration)
     {
+        services.AddHealthChecks()
+            .AddRedis(_ =>
+            {
+                return configuration.GetConnectionString("redis");
+            },
+            "redis", tags: new[] { "ready", "liveness" });
+
         return services.AddSingleton(sp =>
         {
             var redisConfig = ConfigurationOptions.Parse(configuration.GetConnectionString("redis"), true);

src/Services/Basket/Basket.API/Program.cs

@@ -1,4 +1,6 @@
-var builder = WebApplication.CreateBuilder(args);
+using Microsoft.Extensions.Diagnostics.HealthChecks;
+
+var builder = WebApplication.CreateBuilder(args);
 
 builder.AddServiceDefaults();
 
@@ -23,20 +25,38 @@ builder.Services.AddTransient<IIdentityService, IdentityService>();
 
 var app = builder.Build();
 
-app.UseServiceDefaults();
-
-app.MapGet("/", () => Results.Redirect("/swagger"));
-
-app.MapGrpcService<BasketService>();
-app.MapControllers();
-
-var eventBus = app.Services.GetRequiredService<IEventBus>();
-
-eventBus.Subscribe<ProductPriceChangedIntegrationEvent, ProductPriceChangedIntegrationEventHandler>();
-eventBus.Subscribe<OrderStartedIntegrationEvent, OrderStartedIntegrationEventHandler>();
-
 try
 {
+    app.Logger.LogInformation("Running health checks...");
+
+    // Do a health check on startup, this will throw an exception if any of the checks fail
+    var report = await app.Services.GetRequiredService<HealthCheckService>().CheckHealthAsync();
+
+    if (report.Status == HealthStatus.Unhealthy)
+    {
+        app.Logger.LogCritical("Health checks failed!");
+        foreach (var entry in report.Entries)
+        {
+            if (entry.Value.Status == HealthStatus.Unhealthy)
+            {
+                app.Logger.LogCritical("{Check}: {Status}", entry.Key, entry.Value.Status);
+            }
+        }
+        return 1;
+    }
+
+    app.UseServiceDefaults();
+
+    app.MapGet("/", () => Results.Redirect("/swagger"));
+
+    app.MapGrpcService<BasketService>();
+    app.MapControllers();
+
+    var eventBus = app.Services.GetRequiredService<IEventBus>();
+
+    eventBus.Subscribe<ProductPriceChangedIntegrationEvent, ProductPriceChangedIntegrationEventHandler>();
+    eventBus.Subscribe<OrderStartedIntegrationEvent, OrderStartedIntegrationEventHandler>();
+
     await app.RunAsync();
 
     return 0;

src/Services/Basket/Basket.API/Properties/serviceDependencies.json

@@ -7,6 +7,11 @@
       "type": "rabbitmq",
       "connectionId": "eventbus",
       "dynamicId": null
+    },
+    "redis1": {
+      "type": "redis",
+      "connectionId": "ConnectionStrings:Redis",
+      "dynamicId": null
     }
   }
 }

src/Services/Basket/Basket.API/Properties/serviceDependencies.local.json

@@ -11,6 +11,16 @@
       "type": "rabbitmq.container",
       "connectionId": "eventbus",
       "dynamicId": null
+    },
+    "redis1": {
+      "serviceConnectorResourceId": "",
+      "containerPorts": "6379:6379",
+      "secretStore": "LocalSecretsFile",
+      "containerName": "basket-redis",
+      "containerImage": "redis:alpine",
+      "type": "redis.container",
+      "connectionId": "ConnectionStrings:Redis",
+      "dynamicId": null
     }
   }
 }

src/Services/Services.Common/CommonExtensions.cs

@@ -283,13 +283,13 @@ public static class CommonExtensions
             "servicebus" => hcBuilder.AddAzureServiceBusTopic(
                     eventBusConnectionString,
                     topicName: "eshop_event_bus",
-                    name: "servicebus-check",
+                    name: "servicebus",
-                    tags: new string[] { "servicebus" }),
+                    tags: new string[] { "ready" }),
 
             _ => hcBuilder.AddRabbitMQ(
                     $"amqp://{eventBusConnectionString}",
-                    name: "rabbitmqbus-check",
+                    name: "rabbitmq",
-                    tags: new string[] { "rabbitmqbus" })
+                    tags: new string[] { "ready" })
         };
     }