fix(producer): add logging + catch gone when reproducing

Informatievlaanderen · Oct 23, 2024 · f8bc7c6 · f8bc7c6
1 parent ba501bc
commit f8bc7c6
Showing 1 changed file with 18 additions and 4 deletions.
diff --git a/src/BuildingRegistry.Producer.Snapshot.Oslo/SnapshotReproducer.cs b/src/BuildingRegistry.Producer.Snapshot.Oslo/SnapshotReproducer.cs
@@ -2,6 +2,8 @@
 {
     using System;
     using System.Collections.Generic;
+    using System.Net;
+    using System.Net.Http;
     using System.Threading;
     using System.Threading.Tasks;
     using Be.Vlaanderen.Basisregisters.GrAr.Notifications;
@@ -55,10 +57,22 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
                         //reproduce
                         foreach (var id in idsToProcess)
                         {
-                            await FindAndProduce(async () =>
-                                    await _osloProxy.GetSnapshot(id.PersistentLocalId.ToString(), stoppingToken),
-                                id.Position,
-                                stoppingToken);
+                            try
+                            {
+                                await FindAndProduce(async () =>
+                                        await _osloProxy.GetSnapshot(id.PersistentLocalId.ToString(), stoppingToken),
+                                    id.Position,
+                                    stoppingToken);
+                            }
+                            catch (HttpRequestException e) when (e.StatusCode == HttpStatusCode.Gone)
+                            {
+                                _logger.LogInformation($"Snapshot '{id}' gone");
+                            }
+                            catch (Exception ex)
+                            {
+                                _logger.LogError($"Error while reproducing snapshot {id}", ex);
+                                throw;
+                            }
                         }
 
                         await Task.Delay(TimeSpan.FromHours(1), stoppingToken);