make the HTTP producer configurable

mbta · Mar 13, 2019 · d6b336e · d6b336e
1 parent bfb254e
commit d6b336e
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 4 deletions.
diff --git a/config/config.exs b/config/config.exs
@@ -58,6 +58,7 @@ config :concentrate,
   ],
   file_tap: [
     enabled?: false
-  ]
+  ],
+  http_producer: Concentrate.Producer.HTTPoison
 
 import_config "#{Mix.env()}.exs"
diff --git a/lib/concentrate/filter/alert/supervisor.ex b/lib/concentrate/filter/alert/supervisor.ex
@@ -12,7 +12,7 @@ defmodule Concentrate.Filter.Alert.Supervisor do
       Supervisor.start_link(
         [
           {
-            Concentrate.Producer.HTTPoison,
+            Application.get_env(:concentrate, :http_producer),
             {
               config[:url],
               parser: Concentrate.Parser.Alerts,

diff --git a/lib/concentrate/filter/gtfs/supervisor.ex b/lib/concentrate/filter/gtfs/supervisor.ex
@@ -12,7 +12,7 @@ defmodule Concentrate.Filter.GTFS.Supervisor do
       Supervisor.start_link(
         [
           {
-            Concentrate.Producer.HTTPoison,
+            Application.get_env(:concentrate, :http_producer),
             {
               config[:url],
               parser: Concentrate.Filter.GTFS.Unzip,

diff --git a/lib/concentrate/supervisor/pipeline.ex b/lib/concentrate/supervisor/pipeline.ex
@@ -53,7 +53,7 @@ defmodule Concentrate.Supervisor.Pipeline do
 
       child_spec(
         {
-          Concentrate.Producer.HTTPoison,
+          Application.get_env(:concentrate, :http_producer),
           {url, [name: source, parser: parser] ++ opts}
         },
         id: source