From f9b7af64550be1320acc84d60184e8c8ce873b94 Mon Sep 17 00:00:00 2001
From: Ariel Costas Guerrero <ariel@costas.dev>
Date: Sun, 25 Jan 2026 21:05:33 +0100
Subject: feat: Add OpenTelemetry instrumentation and configuration for
 enhanced telemetry tracking

---
 .../Services/Processors/VitrasaRealTimeProcessor.cs                 | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

(limited to 'src/Enmarcha.Backend/Services/Processors/VitrasaRealTimeProcessor.cs')

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>();
 
-- 
cgit v1.3