aboutsummaryrefslogtreecommitdiff
path: root/src/Enmarcha.Backend/Services/Processors/VitrasaRealTimeProcessor.cs
diff options
context:
space:
mode:
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>();