| | | 1 | | using Chronicis.Api.Data; |
| | | 2 | | using Chronicis.Shared.DTOs; |
| | | 3 | | using Microsoft.EntityFrameworkCore; |
| | | 4 | | |
| | | 5 | | namespace Chronicis.Api.Services; |
| | | 6 | | |
| | | 7 | | public class DatabaseHealthCheckService : HealthCheckServiceBase |
| | | 8 | | { |
| | | 9 | | private readonly ChronicisDbContext _context; |
| | | 10 | | |
| | | 11 | | public DatabaseHealthCheckService(ChronicisDbContext context, ILogger<DatabaseHealthCheckService> logger) |
| | 0 | 12 | | : base(logger) |
| | | 13 | | { |
| | 0 | 14 | | _context = context; |
| | 0 | 15 | | } |
| | | 16 | | |
| | | 17 | | protected override async Task<(string Status, string? Message)> PerformHealthCheckAsync() |
| | | 18 | | { |
| | 0 | 19 | | var canConnect = await _context.Database.CanConnectAsync(); |
| | | 20 | | |
| | 0 | 21 | | if (!canConnect) |
| | | 22 | | { |
| | 0 | 23 | | return (HealthStatus.Unhealthy, "Cannot connect to database"); |
| | | 24 | | } |
| | | 25 | | |
| | | 26 | | // Optional: Try a simple query to verify deeper connectivity |
| | | 27 | | try |
| | | 28 | | { |
| | 0 | 29 | | await _context.Database.ExecuteSqlRawAsync("SELECT 1"); |
| | 0 | 30 | | return (HealthStatus.Healthy, "Database connection successful"); |
| | | 31 | | } |
| | 0 | 32 | | catch (Exception ex) |
| | | 33 | | { |
| | 0 | 34 | | return (HealthStatus.Degraded, $"Connected but query failed: {ex.Message}"); |
| | | 35 | | } |
| | 0 | 36 | | } |
| | | 37 | | } |