Pass Hackney options from config (beam-community#506)

README.md

@@ -85,6 +85,14 @@ Moreover, if you are using Poison instead of Jason, you can configure the librar
 config :stripity_stripe, json_library: Poison
 ```
 
+### Timeout
+
+To set timeouts, pass opts for the http client. The default one is Hackney.
+
+```ex
+config :stripity_stripe, hackney_opts: [{:connect_timeout, 1000}, {:recv_timeout, 5000}])
+```
+
 ## Note: Object Expansion
 
 Some Stripe API endpoints support returning related objects via the object expansion query parameter. To take advantage of this feature, stripity_stripe accepts

lib/stripe/api.ex

@@ -135,6 +135,15 @@ defmodule Stripe.API do
     end
   end
 
+  @spec add_options_from_config(list) :: list
+  defp add_options_from_config(opts) do
+    if is_list(Stripe.Config.resolve(:hackney_opts)) do
+      opts ++ Stripe.Config.resolve(:hackney_opts)
+    else
+      opts
+    end
+  end
+
   @doc """
   A low level utility function to make a direct request to the Stripe API
 
@@ -233,6 +242,7 @@ defmodule Stripe.API do
       []
       |> add_default_options()
       |> add_pool_option()
+      |> add_options_from_config()
 
     http_module().request(method, req_url, req_headers, req_body, req_opts)
     |> handle_response()
@@ -255,6 +265,7 @@ defmodule Stripe.API do
       opts
       |> add_default_options()
       |> add_pool_option()
+      |> add_options_from_config()
 
     http_module().request(method, req_url, req_headers, body, req_opts)
     |> handle_response()

test/stripe/api_test.exs

@@ -39,4 +39,44 @@ defmodule Stripe.APITest do
     {:ok, body} = Stripe.API.oauth_request(:post, "token", %{})
     assert Map.keys(body) |> Enum.member?("Authorization") == false
   end
+
+  test "reads hackney timeout opts from config" do
+    # Return request opts as response body
+    defmodule HackneyMock do
+      def request(_, _, headers, _, opts) do
+        kv_opts =
+          opts
+          |> Enum.reduce(%{}, fn opt, acc ->
+            case opt do
+              {k, v} ->
+                Map.put(acc, k, v)
+
+              _ ->
+                Map.put(acc, opt, opt)
+            end
+          end)
+
+        {:ok, 200, headers, Poison.encode!(kv_opts)}
+      end
+    end
+
+    Application.put_env(:stripity_stripe, :http_module, HackneyMock)
+
+    {:ok, request_opts} = Stripe.API.request(%{}, :get, "/", %{}, [])
+    refute Map.has_key?(request_opts, "connect_timeout")
+    refute Map.has_key?(request_opts, "recv_timeout")
+
+    Application.put_env(:stripity_stripe, :hackney_opts, [
+      {:connect_timeout, 1000},
+      {:recv_timeout, 5000}
+    ])
+
+    {:ok, request_opts} = Stripe.API.oauth_request(:post, "token", %{})
+    assert request_opts["connect_timeout"] == 1000
+    assert request_opts["recv_timeout"] == 5000
+
+    {:ok, request_opts} = Stripe.API.request(%{}, :get, "/", %{}, [])
+    assert request_opts["connect_timeout"] == 1000
+    assert request_opts["recv_timeout"] == 5000
+  end
 end