Refactor data fetching and error handling for better reliability

Updated data fetching to use asynchronous methods (`FetchBetriebspunkt`) for improved scalability and consistency across event handlers. Enhanced error handling in background information updates to log exceptions, preventing silent failures. Minor adjustments include extending `Flags` enum, refining delay handling logic, and increasing periodic timer intervals for better performance.

Author: kimonmeier

Streckenbuch.Client/Events/ApproachingStop/ApproachingStopEventHandler.cs

@@ -16,7 +16,7 @@ public ApproachingStopEventHandler(AudioState audioState, DataState dataState)
 
     public async Task<Unit> Handle(ApproachingStopEvent request, CancellationToken cancellationToken)
     {
-        var betriebspunkt = _dataState.Betriebspunkte.SingleOrDefault(x => x.Id == request.BetriebspunktId);
+        var betriebspunkt = await _dataState.FetchBetriebspunkt(request.BetriebspunktId);
 
         if (betriebspunkt is null)
         {

Streckenbuch.Client/Events/StopAdded/StopAddedHandler.cs

@@ -19,7 +19,7 @@ public StopAddedHandler(AudioState audioState, DataState dataState, FahrenPositi
 
     public async Task<Unit> Handle(Shared.Contracts.StopAdded request, CancellationToken cancellationToken)
     {
-        var betriebspunkt = _dataState.Betriebspunkte.SingleOrDefault(x => x.Id == request.BetriebspunktId);
+        var betriebspunkt = await _dataState.FetchBetriebspunkt(request.BetriebspunktId);
 
         if (betriebspunkt is null)
         {

Streckenbuch.Client/Events/StopCanceled/StopCaneledHandler.cs

@@ -16,7 +16,7 @@ public StopCaneledHandler(AudioState audioState, DataState dataState)
 
     public async Task<Unit> Handle(Shared.Contracts.StopCanceled request, CancellationToken cancellationToken)
     {
-        var betriebspunkt = _dataState.Betriebspunkte.SingleOrDefault(x => x.Id == request.BetriebspunktId);
+        var betriebspunkt = await _dataState.FetchBetriebspunkt(request.BetriebspunktId);
 
         if (betriebspunkt is null)
         {

Streckenbuch.Client/Events/StopDelayIntroduced/StopDelayIntroducedHandler.cs

@@ -16,7 +16,7 @@ public StopDelayIntroducedHandler(AudioState audioState, DataState dataState)
 
     public async Task<Unit> Handle(Shared.Contracts.StopDelayIntroduced request, CancellationToken cancellationToken)
     {
-        var betriebspunkt = _dataState.Betriebspunkte.SingleOrDefault(x => x.Id == request.BetriebspunktId);
+        var betriebspunkt = await _dataState.FetchBetriebspunkt(request.BetriebspunktId);
 
         if (betriebspunkt is null)
         {

Streckenbuch.Client/States/DataState.cs

@@ -8,23 +8,28 @@ namespace Streckenbuch.Client.States;
 
 public class DataState
 {
-    public IReadOnlyList<BetriebspunktProto> Betriebspunkte => _betriebspunkte.AsReadOnly();
-    
+    private readonly BetriebspunkteService.BetriebspunkteServiceClient _betriebspunkteService;
 
     private readonly List<BetriebspunktProto> _betriebspunkte = new();
 
     public DataState(BetriebspunkteService.BetriebspunkteServiceClient betriebspunkteService)
     {
-        FetchBetriebspunkte(betriebspunkteService);
+        _betriebspunkteService = betriebspunkteService;
     }
 
-    private void FetchBetriebspunkte(BetriebspunkteService.BetriebspunkteServiceClient betriebspunkteService)
+    public async Task<List<BetriebspunktProto>> FetchBetriebspunkte()
     {
-        var responseTask = betriebspunkteService.ListAllBetriebspunkteAsync(new Empty()).ResponseAsync;
+        if (_betriebspunkte.Count == 0)
+        {
+            _betriebspunkte.AddRange((await _betriebspunkteService.ListAllBetriebspunkteAsync(new Empty())).Betriebspunkte);
+        }
 
-        responseTask.ConfigureAwait(false);
-        responseTask.ContinueWith(x => _betriebspunkte.AddRange(x.Result.Betriebspunkte));
+        return _betriebspunkte;
+    }
+
+    public async Task<BetriebspunktProto?> FetchBetriebspunkt(Guid id)
+    {
+        var list = await FetchBetriebspunkte();
+        return list.FirstOrDefault(x => x.Id == id);
     }
-    
-    
 }

Streckenbuch.Miku/Models/Fahrten/FahrtenRoot.cs

@@ -146,7 +146,7 @@ public class Haltestellen : IEquatable<Haltestellen>
     public string Bezeichnung { get; set; }
 
     [JsonPropertyName("flags")]
-    public List<Flags>? Flags { get; set; }
+    public List<string>? Flags { get; set; }
 
     [JsonPropertyName("abfahrtszeiten")]
     public Zeiten? Abfahrtszeiten { get; set; }

Streckenbuch.Miku/Models/Fahrten/Flags.cs

@@ -2,5 +2,6 @@
 
 public enum Flags
 {
-    AUSFALL
+    AUSFALL,
+    AO_HALT
 }

Streckenbuch.Server/Background/UpdateBackgroundInformation.cs

@@ -20,7 +20,7 @@ public UpdateBackgroundInformation(ILogger<UpdateBackgroundInformation> logger,
 
     protected override async Task ExecuteAsync(CancellationToken stoppingToken)
     {
-        using PeriodicTimer timer = new PeriodicTimer(TimeSpan.FromSeconds(5));
+        using PeriodicTimer timer = new PeriodicTimer(TimeSpan.FromSeconds(30));
 
         while (!stoppingToken.IsCancellationRequested)
         {
@@ -43,9 +43,15 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
 
     private async Task UpdateInformationForTrain(Guid clientId, int trainNumber)
     {
-        var fahrtInformation = await _mikuApi.Fahrt.ListByTrainNumber(trainNumber);
-        
-        await _continuousConnectionState.ProcessMikuInformation(clientId, fahrtInformation.Haltestellen);
+        try
+        {
+            var fahrtInformation = await _mikuApi.Fahrt.ListByTrainNumber(trainNumber);
+
+            await _continuousConnectionState.ProcessMikuInformation(clientId, fahrtInformation.Haltestellen);
+        } catch (Exception e)
+        {
+            _logger.LogError(e, "Error while updating background information for train {0}", trainNumber);
+        }
     }
 
 }

Streckenbuch.Server/States/ContinuousConnectionState.cs

@@ -135,7 +135,14 @@ public async Task ProcessMikuInformation(Guid clientId, List<Haltestellen> halte
 
         foreach (Haltestellen changedHaltestellen in changed)
         {
-            await HandleChangedMessageAsync(clientId, changedHaltestellen, oldStops[changedHaltestellen.BetriebspunktId], haltestellen[haltestellen.IndexOf(changedHaltestellen) - 1], betriebspunkteRepository);
+            Haltestellen? previousHaltestelle = null;
+            var index = haltestellen.IndexOf(changedHaltestellen);
+            if (index != 0)
+            {
+                previousHaltestelle = haltestellen[haltestellen.IndexOf(changedHaltestellen) - 1];
+            }
+            
+            await HandleChangedMessageAsync(clientId, changedHaltestellen, oldStops[changedHaltestellen.BetriebspunktId], previousHaltestelle, betriebspunkteRepository);
         }
 
         _processedHaltestellen[clientId] = haltestellen;
@@ -161,7 +168,7 @@ private async Task HandleStopRemovedMessageAsync(Guid clientId, Haltestellen rem
         });
     }
 
-    private async Task HandleChangedMessageAsync(Guid clientId, Haltestellen changedHaltestelle, Haltestellen oldHaltestelle, Haltestellen previousHaltestelle, BetriebspunkteRepository betriebspunkteRepository)
+    private async Task HandleChangedMessageAsync(Guid clientId, Haltestellen changedHaltestelle, Haltestellen oldHaltestelle, Haltestellen? previousHaltestelle, BetriebspunkteRepository betriebspunkteRepository)
     {
         var betriebspunktId = await betriebspunkteRepository.GetIdByMikuId(changedHaltestelle.BetriebspunktId);
 
@@ -185,14 +192,14 @@ private void HandleStopCancellation(Guid clientId, Haltestellen changedHaltestel
         });
     }
 
-    private void HandleStopDelay(Guid clientId, Haltestellen changedHaltestelle, Haltestellen oldHaltestelle, Guid betriebspunktId, Haltestellen previousHaltestelle)
+    private void HandleStopDelay(Guid clientId, Haltestellen changedHaltestelle, Haltestellen oldHaltestelle, Guid betriebspunktId, Haltestellen? previousHaltestelle)
     {
         if (changedHaltestelle.Verspaetungsgrund is null)
         {
             return;
         }
 
-        if (previousHaltestelle.Verspaetungsgrund is not null)
+        if (previousHaltestelle?.Verspaetungsgrund is not null)
         {
             return;
         }
@@ -220,16 +227,22 @@ private void HandleStopDelay(Guid clientId, Haltestellen changedHaltestelle, Hal
         static bool HasSignificantIncrease(int? newDelay, int? oldDelay) =>
             newDelay.HasValue && ((!oldDelay.HasValue && newDelay.Value > 3) || (oldDelay.HasValue && newDelay.Value > oldDelay.Value + 2));
 
-        if (HasSignificantIncrease(changed.Ankunftszeiten.Verspaetung, old.Ankunftszeiten.Verspaetung)
-            || (isNewDelayReason && changed.Ankunftszeiten.Verspaetung.HasValue))
+        if (changed.Ankunftszeiten is not null && old.Ankunftszeiten is not null)
         {
-            return changed.Ankunftszeiten.Verspaetung;
+            if (HasSignificantIncrease(changed.Ankunftszeiten.Verspaetung, old.Ankunftszeiten.Verspaetung)
+                || (isNewDelayReason && changed.Ankunftszeiten.Verspaetung.HasValue))
+            {
+                return changed.Ankunftszeiten.Verspaetung;
+            }
         }
 
-        if (HasSignificantIncrease(changed.Abfahrtszeiten.Verspaetung, old.Abfahrtszeiten.Verspaetung)
-            || (isNewDelayReason && changed.Abfahrtszeiten.Verspaetung.HasValue))
+        if (changed.Abfahrtszeiten is not null && old.Abfahrtszeiten is not null)
         {
-            return changed.Abfahrtszeiten.Verspaetung;
+            if (HasSignificantIncrease(changed.Abfahrtszeiten.Verspaetung, old.Abfahrtszeiten.Verspaetung)
+                || (isNewDelayReason && changed.Abfahrtszeiten.Verspaetung.HasValue))
+            {
+                return changed.Abfahrtszeiten.Verspaetung;
+            }
         }
 
         return null;