some better error handling

a92a415 · gmorell · 2025-09-05 21:13

10 files +9 -3

Files changed

modified apps/room_gtfs/lib/room_gtfs/gtfs_worker.ex
+8 −2
@@ -187,7 +187,7 @@ defmodule RoomGtfs.Worker do
187 187 GenServer.call(state.child_rt, {:query_realtime, trips, stop})
188 188 catch
189 189 :exit, _ ->
190 − IO.puts("timeout? exit")
190 + IO.puts("timeout? exit?")
191 191 []
192 192 after
193 193 []
@@ -271,7 +271,12 @@ defmodule RoomGtfs.Worker.RT do
271 271
272 272 def fetch_rt_url(url) do
273 273 case HTTPoison.get(url, [], follow_redirect: true) do
274 − {:ok, result} -> {:ok, result.body |> TransitRealtime.FeedMessage.decode()}
274 + {:ok, result} -> {:ok, try do
275 + result.body |> TransitRealtime.FeedMessage.decode()
276 + rescue
277 + e -> IO.inspect(e)
278 + {:error, :risen}
279 + end}
275 280 {:error, error} -> {:error, error}
276 281 end
277 282 end
@@ -798,6 +803,7 @@ end
798 803 {:error, term} ->
799 804 Logger.error(term)
800 805 end
806 + {:error, error} -> Logger.error(error)
801 807 end
802 808 end
803 809
modified apps/room_sanctum/lib/room_sanctum/workers/vision_worker.ex
+1 −1
@@ -46,7 +46,7 @@ defmodule RoomSanctum.Worker.Vision do
46 46 def get_state(name) do
47 47 "vision#{name}"
48 48 |> via_tuple
49 − |> GenServer.call(:return_state)
49 + |> GenServer.call(:return_state, 15_000)
50 50 end
51 51
52 52 #

Parents: eb5b50b