aboutsummaryrefslogtreecommitdiff
path: root/src/Enmarcha.Backend/Services/Processors/VitrasaRealTimeProcessor.cs
diff options
context:
space:
mode:
authorAriel Costas Guerrero <ariel@costas.dev>2026-01-25 21:05:33 +0100
committerAriel Costas Guerrero <ariel@costas.dev>2026-01-25 21:06:01 +0100
commitf9b7af64550be1320acc84d60184e8c8ce873b94 (patch)
treed43e995319b4a3856aa929848b9ad807afb1cf86 /src/Enmarcha.Backend/Services/Processors/VitrasaRealTimeProcessor.cs
parentc89353dede64bd2c21c0a1ebd6b6de6282998326 (diff)
feat: Add OpenTelemetry instrumentation and configuration for enhanced telemetry tracking
Diffstat (limited to 'src/Enmarcha.Backend/Services/Processors/VitrasaRealTimeProcessor.cs')
-rw-r--r--src/Enmarcha.Backend/Services/Processors/VitrasaRealTimeProcessor.cs6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/Enmarcha.Backend/Services/Processors/VitrasaRealTimeProcessor.cs b/src/Enmarcha.Backend/Services/Processors/VitrasaRealTimeProcessor.cs
index 5d44995..0ce54c2 100644
--- a/src/Enmarcha.Backend/Services/Processors/VitrasaRealTimeProcessor.cs
+++ b/src/Enmarcha.Backend/Services/Processors/VitrasaRealTimeProcessor.cs
@@ -16,13 +16,13 @@ public class VitrasaRealTimeProcessor : AbstractRealTimeProcessor
private readonly AppConfiguration _configuration;
public VitrasaRealTimeProcessor(
- HttpClient http,
+ VigoTransitApiClient api,
FeedService feedService,
ILogger<VitrasaRealTimeProcessor> logger,
ShapeTraversalService shapeService,
IOptions<AppConfiguration> options)
{
- _api = new VigoTransitApiClient(http);
+ _api = api;
_feedService = feedService;
_logger = logger;
_shapeService = shapeService;
@@ -52,6 +52,8 @@ public class VitrasaRealTimeProcessor : AbstractRealTimeProcessor
.Where(e => !string.IsNullOrWhiteSpace(e.Route) && !e.Route.Trim().EndsWith('*'))
.ToList();
+ System.Diagnostics.Activity.Current?.SetTag("realtime.count", estimates.Count);
+
var usedTripIds = new HashSet<string>();
var newArrivals = new List<Arrival>();