Resist to unescaped characters in gtfs

etalab · Jan 14, 2025 · e070530 · e070530
1 parent 6d2d36c
commit e070530
Showing 1 changed file with 12 additions and 5 deletions.
diff --git a/apps/transport/lib/registry/gtfs.ex b/apps/transport/lib/registry/gtfs.ex
@@ -24,11 +24,18 @@ defmodule Transport.Registry.GTFS do
       {:ok, content} ->
         Logger.debug("Valid Zip archive")
 
-        content
-        |> Utils.to_stream_of_maps()
-        |> Stream.flat_map(&handle_stop(data_source_id, &1))
-        |> Enum.to_list()
-        |> Result.ok()
+        try do
+          content
+          |> Utils.to_stream_of_maps()
+          |> Stream.flat_map(&handle_stop(data_source_id, &1))
+          |> Enum.to_list()
+          |> Result.ok()
+        rescue
+          e in NimbleCSV.ParseError ->
+            e
+            |> Exception.message()
+            |> Result.error()
+        end
     end
   end