direct access to the realtime

17909df · gmorell · 2025-09-13 16:58

5 files +4 -1

Files changed

modified apps/room_gtfs/lib/room_gtfs/gtfs_worker.ex
+4 −1
@@ -52,7 +52,7 @@ defmodule RoomGtfs.Worker do
52 52 end
53 53
54 54 def get_current_realtime(name, trips, stop) do
55 − "gtfs#{name}"
55 + "gtfs-rt#{name}"
56 56 |> via_tuple
57 57 |> GenServer.call({:query_realtime, trips, stop}, 30_000)
58 58 end
@@ -839,6 +839,9 @@ end
839 839 |> Enum.filter(fn x -> x != "" end)
840 840 |> XP.parse_stream
841 841
842 + Logger.info({"datum", as_csv})
843 + IO.inspect({"datum", as_csv})
844 +
842 845 case name do
843 846 'agency.txt' ->
844 847 write_file(as_csv, :agency, state.id)

Parents: a92a415