Added retry checking into do_get in the api. A 'retry' (429) will be…

lib/ex_pwned/api.ex

@@ -18,10 +18,23 @@ defmodule ExPwned.Api do
         do: do_get(path_arg, Enum.into(query_params, %{}))
 
       def do_get(path_arg, query_params) do
-        path_arg
-        |> build_url(query_params)
-        |> HTTPoison.get(headers())
-        |> Parser.parse()
+        {:ok, result, status} =
+          path_arg
+          |> build_url(query_params)
+          |> HTTPoison.get(headers())
+          |> Parser.parse()
+
+        case result do
+          :retry ->
+            # the server sent us a Retry-After header
+            # status is in Seconds
+            {sleep_time, _} = Integer.parse(status)
+            :timer.sleep(sleep_time * 1000)
+            do_get(path_arg, query_params)
+
+          _ ->
+            {:ok, result, status}
+        end
       end
     end
   end

lib/ex_pwned/parser.ex

@@ -20,6 +20,11 @@ defmodule ExPwned.Parser do
       {:ok, %HTTPoison.Response{body: _, headers: _, status_code: 403}} ->
         {:error, "no user agent has been specified in the request", 403}
 
+      {:ok, %HTTPoison.Response{body: _, headers: headers, status_code: 429}} ->
+        m = Enum.into(headers, %{})
+        retry_seconds = Map.fetch!(m, "Retry-After")
+        {:ok, :retry, retry_seconds}
+
       {:ok, %HTTPoison.Response{body: body, headers: _, status_code: status}} ->
         {:error, body, status}
 

mix.exs

@@ -25,7 +25,8 @@ defmodule ExPwned.Mixfile do
       {:httpoison, "~> 0.9 or ~> 0.10"},
       {:poison, "~> 2.0 or ~> 3.0"},
       {:earmark, "~> 0.1", only: :dev},
-      {:ex_doc, "~> 0.11", only: :dev}
+      {:ex_doc, "~> 0.11", only: :dev},
+      {:credo, "~> 0.10.0", only: [:dev, :test], runtime: false}
     ]
   end
 

mix.lock

@@ -1,10 +1,15 @@
-%{"certifi": {:hex, :certifi, "0.7.0", "861a57f3808f7eb0c2d1802afeaae0fa5de813b0df0979153cbafcd853ababaf", [:rebar3], []},
+%{
+  "bunt": {:hex, :bunt, "0.2.0", "951c6e801e8b1d2cbe58ebbd3e616a869061ddadcc4863d0a2182541acae9a38", [:mix], [], "hexpm"},
+  "certifi": {:hex, :certifi, "0.7.0", "861a57f3808f7eb0c2d1802afeaae0fa5de813b0df0979153cbafcd853ababaf", [:rebar3], []},
+  "credo": {:hex, :credo, "0.10.2", "03ad3a1eff79a16664ed42fc2975b5e5d0ce243d69318060c626c34720a49512", [:mix], [{:bunt, "~> 0.2.0", [hex: :bunt, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: false]}], "hexpm"},
   "earmark": {:hex, :earmark, "0.2.1", "ba6d26ceb16106d069b289df66751734802777a3cbb6787026dd800ffeb850f3", [:mix], []},
   "ex_doc": {:hex, :ex_doc, "0.12.0", "b774aabfede4af31c0301aece12371cbd25995a21bb3d71d66f5c2fe074c603f", [:mix], [{:earmark, "~> 0.2", [hex: :earmark, optional: false]}]},
   "hackney": {:hex, :hackney, "1.6.3", "d489d7ca2d4323e307bedc4bfe684323a7bf773ecfd77938f3ee8074e488e140", [:mix, :rebar3], [{:certifi, "0.7.0", [hex: :certifi, optional: false]}, {:idna, "1.2.0", [hex: :idna, optional: false]}, {:metrics, "1.0.1", [hex: :metrics, optional: false]}, {:mimerl, "1.0.2", [hex: :mimerl, optional: false]}, {:ssl_verify_fun, "1.1.1", [hex: :ssl_verify_fun, optional: false]}]},
   "httpoison": {:hex, :httpoison, "0.10.0", "4727b3a5e57e9a4ff168a3c2883e20f1208103a41bccc4754f15a9366f49b676", [:mix], [{:hackney, "~> 1.6.3", [hex: :hackney, optional: false]}]},
   "idna": {:hex, :idna, "1.2.0", "ac62ee99da068f43c50dc69acf700e03a62a348360126260e87f2b54eced86b2", [:rebar3], []},
+  "jason": {:hex, :jason, "1.1.1", "d3ccb840dfb06f2f90a6d335b536dd074db748b3e7f5b11ab61d239506585eb2", [:mix], [{:decimal, "~> 1.0", [hex: :decimal, repo: "hexpm", optional: true]}], "hexpm"},
   "metrics": {:hex, :metrics, "1.0.1", "25f094dea2cda98213cecc3aeff09e940299d950904393b2a29d191c346a8486", [:rebar3], []},
   "mimerl": {:hex, :mimerl, "1.0.2", "993f9b0e084083405ed8252b99460c4f0563e41729ab42d9074fd5e52439be88", [:rebar3], []},
   "poison": {:hex, :poison, "3.0.0", "625ebd64d33ae2e65201c2c14d6c85c27cc8b68f2d0dd37828fde9c6920dd131", [:mix], []},
-  "ssl_verify_fun": {:hex, :ssl_verify_fun, "1.1.1", "28a4d65b7f59893bc2c7de786dec1e1555bd742d336043fe644ae956c3497fbe", [:make, :rebar], []}}
+  "ssl_verify_fun": {:hex, :ssl_verify_fun, "1.1.1", "28a4d65b7f59893bc2c7de786dec1e1555bd742d336043fe644ae956c3497fbe", [:make, :rebar], []},
+}