Update health check message and use unbuffered queries in repositories

src/FunderMaps.Core/HealthChecks/TippecanoeHealthCheck.cs

@@ -26,7 +26,7 @@ public async Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context
         {
             logger.LogTrace(exception, "Health check failed");
 
-            return HealthCheckResult.Unhealthy("blob storage service");
+            return HealthCheckResult.Unhealthy("tileset generator is unhealthy");
         }
     }
 }

src/FunderMaps.Data/Repositories/AddressRepository.cs

@@ -107,7 +107,7 @@ OFFSET  @offset
 
         await using var connection = DbContextFactory.DbProvider.ConnectionScope();
 
-        foreach (var item in await connection.QueryAsync<Address>(sql, navigation))
+        await foreach (var item in connection.QueryUnbufferedAsync<Address>(sql, navigation))
         {
             yield return CacheEntity(item);
         }

src/FunderMaps.Data/Repositories/AnalysisRepository.cs

@@ -222,7 +222,7 @@ public async IAsyncEnumerable<AnalysisProduct> ListAllAsync(Navigation navigatio
 
         await using var connection = DbContextFactory.DbProvider.ConnectionScope();
 
-        foreach (var item in await connection.QueryAsync<AnalysisProduct>(sql, navigation))
+        await foreach (var item in connection.QueryUnbufferedAsync<AnalysisProduct>(sql, navigation))
         {
             yield return item;
         }

src/FunderMaps.Data/Repositories/BuildingRepository.cs

@@ -117,7 +117,7 @@ OFFSET  @offset
 
         await using var connection = DbContextFactory.DbProvider.ConnectionScope();
 
-        foreach (var item in await connection.QueryAsync<Building>(sql, navigation))
+        await foreach (var item in connection.QueryUnbufferedAsync<Building>(sql, navigation))
         {
             yield return CacheEntity(item);
         }

src/FunderMaps.Data/Repositories/BundleRepository.cs

@@ -80,7 +80,7 @@ OFFSET  @offset
 
         await using var connection = DbContextFactory.DbProvider.ConnectionScope();
 
-        foreach (var item in await connection.QueryAsync<Bundle>(sql, navigation))
+        await foreach (var item in connection.QueryUnbufferedAsync<Bundle>(sql, navigation))
         {
             yield return CacheEntity(item);
         }
@@ -108,7 +108,7 @@ WHERE   enabled
 
         await using var connection = DbContextFactory.DbProvider.ConnectionScope();
 
-        foreach (var item in await connection.QueryAsync<Bundle>(sql))
+        await foreach (var item in connection.QueryUnbufferedAsync<Bundle>(sql))
         {
             yield return CacheEntity(item);
         }

src/FunderMaps.Data/Repositories/ContractorRepository.cs

@@ -54,7 +54,7 @@ public override async IAsyncEnumerable<Contractor> ListAllAsync(Navigation navig
 
         await using var connection = DbContextFactory.DbProvider.ConnectionScope();
 
-        foreach (var item in await connection.QueryAsync<Contractor>(sql))
+        await foreach (var item in connection.QueryUnbufferedAsync<Contractor>(sql))
         {
             yield return CacheEntity(item);
         }

src/FunderMaps.Data/Repositories/KeystoreRepository.cs

@@ -52,7 +52,7 @@ public override async IAsyncEnumerable<KeyStore> ListAllAsync(Navigation navigat
 
         await using var connection = DbContextFactory.DbProvider.ConnectionScope();
 
-        foreach (var item in await connection.QueryAsync<KeyStore>(sql))
+        await foreach (var item in connection.QueryUnbufferedAsync<KeyStore>(sql))
         {
             yield return item;
         }

src/FunderMaps.Data/Repositories/MapsetRepository.cs

@@ -87,7 +87,7 @@ FROM    maplayer.map_organization mo
 
         await using var connection = DbContextFactory.DbProvider.ConnectionScope();
 
-        foreach (var item in await connection.QueryAsync<Mapset>(sql, new { id }))
+        await foreach (var item in connection.QueryUnbufferedAsync<Mapset>(sql, new { id }))
         {
             yield return item;
         }

src/FunderMaps.Data/Repositories/NeighborhoorRepository.cs

@@ -145,7 +145,7 @@ OFFSET  @offset
 
         await using var connection = DbContextFactory.DbProvider.ConnectionScope();
 
-        foreach (var item in await connection.QueryAsync<Neighborhood>(sql, navigation))
+        await foreach (var item in connection.QueryUnbufferedAsync<Neighborhood>(sql, navigation))
         {
             yield return CacheEntity(item);
         }

src/FunderMaps.Data/Repositories/TelemetryRepository.cs

@@ -80,7 +80,7 @@ FROM    application.product_tracker AS pt
 
         await using var connection = DbContextFactory.DbProvider.ConnectionScope();
 
-        foreach (var item in await connection.QueryAsync<Guid>(sql))
+        await foreach (var item in connection.QueryUnbufferedAsync<Guid>(sql))
         {
             yield return item;
         }
@@ -104,7 +104,7 @@ FROM    application.product_tracker AS pt
 
         await using var connection = DbContextFactory.DbProvider.ConnectionScope();
 
-        foreach (var item in await connection.QueryAsync<ProductCall>(sql, new { id }))
+        await foreach (var item in connection.QueryUnbufferedAsync<ProductCall>(sql, new { id }))
         {
             yield return item;
         }