From ef2df90ffb195edcddd701511dc5953c7baa63af Mon Sep 17 00:00:00 2001 From: Ariel Costas Guerrero Date: Fri, 26 Dec 2025 15:56:09 +0100 Subject: Move OpenTripPlanner source to separate package --- .../Queries/ArrivalsAtStop.cs | 199 +++++++++++++++++++++ .../Queries/StopTile.cs | 76 ++++++++ 2 files changed, 275 insertions(+) create mode 100644 src/Costasdev.Busurbano.Sources.OpenTripPlannerGql/Queries/ArrivalsAtStop.cs create mode 100644 src/Costasdev.Busurbano.Sources.OpenTripPlannerGql/Queries/StopTile.cs (limited to 'src/Costasdev.Busurbano.Sources.OpenTripPlannerGql/Queries') diff --git a/src/Costasdev.Busurbano.Sources.OpenTripPlannerGql/Queries/ArrivalsAtStop.cs b/src/Costasdev.Busurbano.Sources.OpenTripPlannerGql/Queries/ArrivalsAtStop.cs new file mode 100644 index 0000000..bbf2c08 --- /dev/null +++ b/src/Costasdev.Busurbano.Sources.OpenTripPlannerGql/Queries/ArrivalsAtStop.cs @@ -0,0 +1,199 @@ +using System.Globalization; +using System.Text.Json.Serialization; +using Costasdev.Busurbano.Sources.OpenTripPlannerGql; + +namespace Costasdev.Busurbano.Sources.OpenTripPlannerGql.Queries; + +public class ArrivalsAtStopContent : IGraphRequest +{ + public record Args(string Id, bool Reduced); + + public static string Query(Args args) + { + var startTime = DateTimeOffset.UtcNow.AddMinutes(-75); + var startTimeUnix = startTime.ToUnixTimeSeconds(); + var geometryField = args.Reduced ? "" : @"tripGeometry { points }"; + + return string.Create(CultureInfo.InvariantCulture, $@" + query Query {{ + stop(id:""{args.Id}"") {{ + code + name + lat + lon + routes {{ + gtfsId + shortName + color + textColor + }} + arrivals: stoptimesWithoutPatterns(numberOfDepartures: 100, startTime: {startTimeUnix}, timeRange: 14400) {{ + headsign + scheduledDeparture + serviceDay + pickupType + + trip {{ + gtfsId + serviceId + routeShortName + route {{ + gtfsId + color + textColor + longName + }} + departureStoptime {{ + scheduledDeparture + }} + {geometryField} + stoptimes {{ + stop {{ + name + lat + lon + }} + scheduledDeparture + }} + }} + }} + }} + }} + "); + } +} + +public class ArrivalsAtStopResponse : AbstractGraphResponse +{ + [JsonPropertyName("stop")] public required StopItem Stop { get; set; } + + public class StopItem + { + [JsonPropertyName("code")] public required string Code { get; set; } + + [JsonPropertyName("name")] public required string Name { get; set; } + + [JsonPropertyName("lat")] public double Lat { get; set; } + + [JsonPropertyName("lon")] public double Lon { get; set; } + + [JsonPropertyName("routes")] public List Routes { get; set; } = []; + + [JsonPropertyName("arrivals")] public List Arrivals { get; set; } = []; + } + + public class Arrival + { + [JsonPropertyName("headsign")] public required string Headsign { get; set; } + + [JsonPropertyName("scheduledDeparture")] + public int ScheduledDepartureSeconds { get; set; } + + [JsonPropertyName("serviceDay")] + public long ServiceDay { get; set; } + + [JsonPropertyName("pickupType")] public required string PickupTypeOriginal { get; set; } + + public PickupType PickupTypeParsed => PickupType.Parse(PickupTypeOriginal); + + [JsonPropertyName("trip")] public required TripDetails Trip { get; set; } + } + + public class TripDetails + { + [JsonPropertyName("gtfsId")] public required string GtfsId { get; set; } + + [JsonPropertyName("serviceId")] public required string ServiceId { get; set; } + + [JsonPropertyName("routeShortName")] public required string RouteShortName { get; set; } + + [JsonPropertyName("departureStoptime")] + public required DepartureStoptime DepartureStoptime { get; set; } + + [JsonPropertyName("route")] public required RouteDetails Route { get; set; } + + [JsonPropertyName("tripGeometry")] public GeometryDetails? Geometry { get; set; } + + [JsonPropertyName("stoptimes")] public List Stoptimes { get; set; } = []; + } + + public class GeometryDetails + { + [JsonPropertyName("points")] public string? Points { get; set; } + } + + public class StoptimeDetails + { + [JsonPropertyName("stop")] public required StopDetails Stop { get; set; } + [JsonPropertyName("scheduledDeparture")] public int ScheduledDeparture { get; set; } + } + + public class StopDetails + { + [JsonPropertyName("name")] public required string Name { get; set; } + [JsonPropertyName("lat")] public double Lat { get; set; } + [JsonPropertyName("lon")] public double Lon { get; set; } + } + + public class DepartureStoptime + { + [JsonPropertyName("scheduledDeparture")] + public int ScheduledDeparture { get; set; } + } + + public class RouteDetails + { + [JsonPropertyName("gtfsId")] public required string GtfsId { get; set; } + public string GtfsIdValue => GtfsId.Split(':', 2)[1]; + + [JsonPropertyName("shortName")] public string? ShortName { get; set; } + + [JsonPropertyName("color")] public string? Color { get; set; } + + [JsonPropertyName("textColor")] public string? TextColor { get; set; } + + [JsonPropertyName("longName")] public string? LongName { get; set; } + } + + public class PickupType + { + private readonly string _value; + + private PickupType(string value) + { + _value = value; + } + + public static PickupType Parse(string value) + { + return value switch + { + "SCHEDULED" => Scheduled, + "NONE" => None, + "CALL_AGENCY" => CallAgency, + "COORDINATE_WITH_DRIVER" => CoordinateWithDriver, + _ => throw new ArgumentException("Unsupported pickup type ", value) + }; + } + + public static readonly PickupType Scheduled = new PickupType("SCHEDULED"); + public static readonly PickupType None = new PickupType("NONE"); + public static readonly PickupType CallAgency = new PickupType("CALL_AGENCY"); + public static readonly PickupType CoordinateWithDriver = new PickupType("COORDINATE_WITH_DRIVER"); + + public override bool Equals(object? other) + { + if (other is not PickupType otherPt) + { + return false; + } + + return otherPt._value == _value; + } + + public override int GetHashCode() + { + return _value.GetHashCode(); + } + } +} diff --git a/src/Costasdev.Busurbano.Sources.OpenTripPlannerGql/Queries/StopTile.cs b/src/Costasdev.Busurbano.Sources.OpenTripPlannerGql/Queries/StopTile.cs new file mode 100644 index 0000000..792d19e --- /dev/null +++ b/src/Costasdev.Busurbano.Sources.OpenTripPlannerGql/Queries/StopTile.cs @@ -0,0 +1,76 @@ +using System.Globalization; +using System.Text.Json.Serialization; + +namespace Costasdev.Busurbano.Sources.OpenTripPlannerGql.Queries; + +public class StopTileRequestContent : IGraphRequest +{ + public record Bbox(double MinLon, double MinLat, double MaxLon, double MaxLat); + + public static string Query(Bbox bbox) + { + return string.Create(CultureInfo.InvariantCulture, $@" + query Query {{ + stopsByBbox( + minLat: {bbox.MinLat:F6} + minLon: {bbox.MinLon:F6} + maxLon: {bbox.MaxLon:F6} + maxLat: {bbox.MaxLat:F6} + ) {{ + gtfsId + code + name + lat + lon + routes {{ + gtfsId + shortName + color + textColor + }} + }} + }} + "); + } +} + +public class StopTileResponse : AbstractGraphResponse +{ + [JsonPropertyName("stopsByBbox")] + public List? StopsByBbox { get; set; } + + public record Stop + { + [JsonPropertyName("gtfsId")] + public required string GtfsId { get; set; } + + [JsonPropertyName("code")] + public string? Code { get; set; } + + [JsonPropertyName("name")] + public required string Name { get; set; } + + [JsonPropertyName("lat")] + public required double Lat { get; set; } + + [JsonPropertyName("lon")] + public required double Lon { get; set; } + + [JsonPropertyName("routes")] + public List? Routes { get; set; } + } + + public record Route + { + [JsonPropertyName("gtfsId")] + public required string GtfsId { get; set; } + [JsonPropertyName("shortName")] + public required string ShortName { get; set; } + + [JsonPropertyName("color")] + public string? Color { get; set; } + + [JsonPropertyName("textColor")] + public string? TextColor { get; set; } + } +} -- cgit v1.3