Keep existing data if we can't decode source.

mbta · Nov 22, 2024 · a5b34cc · a5b34cc
1 parent 6028992
commit a5b34cc
Showing 1 changed file with 17 additions and 8 deletions.
diff --git a/lib/screens/last_trip/poller.ex b/lib/screens/last_trip/poller.ex
@@ -2,6 +2,7 @@ defmodule Screens.LastTrip.Poller do
   @moduledoc """
   GenServer that polls predictions to calculate the last trip of the day
   """
+  require Logger
   alias Screens.LastTrip.Cache
   alias Screens.LastTrip.Parser
   alias Screens.LastTrip.TripUpdates
@@ -32,14 +33,20 @@ defmodule Screens.LastTrip.Poller do
         :ok = Cache.reset()
         %{state | next_reset: next_reset()}
       else
-        {:ok,
-         %{
-           trip_updates: trip_updates,
-           vehicle_positions: vehicle_positions
-         }} = fetch_trip_updates_and_vehicle_positions()
-
-        update_last_trips(trip_updates)
-        update_recent_departures(trip_updates, vehicle_positions)
+        case fetch_trip_updates_and_vehicle_positions() do
+          {:ok,
+           %{
+             trip_updates: trip_updates,
+             vehicle_positions: vehicle_positions
+           }} ->
+            update_last_trips(trip_updates)
+            update_recent_departures(trip_updates, vehicle_positions)
+
+          {:error, error} ->
+            Logger.warning(
+              "[last_trip_poller] failed while polling for new data: #{inspect(error)}"
+            )
+        end
 
         state
       end
@@ -57,6 +64,8 @@ defmodule Screens.LastTrip.Poller do
          trip_updates: trip_updates,
          vehicle_positions: vehicle_positions
        }}
+    else
+      {:error, error} -> {:error, error}
     end
   end