Merge pull request #48 from peek-travel/feature/auto-retry

feat: add automatic retry with exponential backoff on 429 rate limit …

Author: coladarci

CHANGELOG.md

@@ -19,6 +19,12 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 - Added `PeekAppSDK.Client.query_platform/4` for cross-brand API querying. Accepts `install_id`, HTTP method, URL path, and body params.
 
+## [2026-02-13]
+
+### Added
+
+- `query_peek_pro/4` now automatically retries on 429 rate limit errors with exponential backoff (200ms base, randomized, capped at 2s, up to 5 retries). No API changes required.
+
 ## [2026-02-12]
 
 ### Breaking

lib/peek_app_sdk/client.ex

@@ -1,5 +1,6 @@
 defmodule PeekAppSDK.Client do
   require Logger
+  use Retry
 
   alias PeekAppSDK.Config
 
@@ -32,6 +33,19 @@ defmodule PeekAppSDK.Client do
   @spec query_peek_pro(String.t(), String.t(), map(), atom() | nil) ::
           {:ok, map()} | {:error, any()}
   def query_peek_pro(install_id, gql_query, gql_variables \\ %{}, config_id \\ nil) do
+    retry with: 200 |> exponential_backoff() |> randomize() |> cap(2000) |> Stream.take(5), atoms: [:rate_limited] do
+      case do_query_peek_pro(install_id, gql_query, gql_variables, config_id) do
+        {:error, 429} -> :rate_limited
+        result -> result
+      end
+    after
+      result -> result
+    else
+      error -> error
+    end
+  end
+
+  defp do_query_peek_pro(install_id, gql_query, gql_variables, config_id) do
     body_params = %{
       "query" => gql_query,
       "variables" => gql_variables
@@ -51,7 +65,6 @@ defmodule PeekAppSDK.Client do
            body: body_params,
            headers: headers(install_id, config_id, peek_api_key)
          ) do
-      # If we get back an error, fail the whole thing and return the error for now.
       {:ok, %Tesla.Env{status: 200, body: %{errors: [_error | _rest] = errors}}} ->
         {:error, errors}
 

mix.exs

@@ -61,6 +61,7 @@ defmodule PeekAppSDK.MixProject do
       {:phoenix, "~> 1.7"},
       {:phoenix_live_view, "~> 1.0"},
       {:finch, "~> 0.13"},
+      {:retry, "~> 0.18"},
       {:esbuild, "~> 0.8", runtime: Mix.env() == :dev},
 
       # Test dependencies

mix.lock

@@ -31,6 +31,7 @@
   "plug_cowboy": {:hex, :plug_cowboy, "2.8.0", "07789e9c03539ee51bb14a07839cc95aa96999fd8846ebfd28c97f0b50c7b612", [:mix], [{:cowboy, "~> 2.7", [hex: :cowboy, repo: "hexpm", optional: false]}, {:cowboy_telemetry, "~> 0.3", [hex: :cowboy_telemetry, repo: "hexpm", optional: false]}, {:plug, "~> 1.14", [hex: :plug, repo: "hexpm", optional: false]}], "hexpm", "9cbfaaf17463334ca31aed38ea7e08a68ee37cabc077b1e9be6d2fb68e0171d0"},
   "plug_crypto": {:hex, :plug_crypto, "2.1.1", "19bda8184399cb24afa10be734f84a16ea0a2bc65054e23a62bb10f06bc89491", [:mix], [], "hexpm", "6470bce6ffe41c8bd497612ffde1a7e4af67f36a15eea5f921af71cf3e11247c"},
   "ranch": {:hex, :ranch, "1.8.1", "208169e65292ac5d333d6cdbad49388c1ae198136e4697ae2f474697140f201c", [:make, :rebar3], [], "hexpm", "aed58910f4e21deea992a67bf51632b6d60114895eb03bb392bb733064594dd0"},
+  "retry": {:hex, :retry, "0.19.0", "aeb326d87f62295d950f41e1255fe6f43280a1b390d36e280b7c9b00601ccbc2", [:mix], [], "hexpm", "85ef376aa60007e7bff565c366310966ec1bd38078765a0e7f20ec8a220d02ca"},
   "telemetry": {:hex, :telemetry, "1.3.0", "fedebbae410d715cf8e7062c96a1ef32ec22e764197f70cda73d82778d61e7a2", [:rebar3], [], "hexpm", "7015fc8919dbe63764f4b4b87a95b7c0996bd539e0d499be6ec9d7f3875b79e6"},
   "tesla": {:hex, :tesla, "1.16.0", "de77d083aea08ebd1982600693ff5d779d68a4bb835d136a0394b08f69714660", [:mix], [{:castore, "~> 0.1 or ~> 1.0", [hex: :castore, repo: "hexpm", optional: true]}, {:exjsx, ">= 3.0.0", [hex: :exjsx, repo: "hexpm", optional: true]}, {:finch, "~> 0.13", [hex: :finch, repo: "hexpm", optional: true]}, {:fuse, "~> 2.4", [hex: :fuse, repo: "hexpm", optional: true]}, {:gun, ">= 1.0.0", [hex: :gun, repo: "hexpm", optional: true]}, {:hackney, "~> 1.21", [hex: :hackney, repo: "hexpm", optional: true]}, {:ibrowse, "4.4.2", [hex: :ibrowse, repo: "hexpm", optional: true]}, {:jason, ">= 1.0.0", [hex: :jason, repo: "hexpm", optional: true]}, {:mime, "~> 1.0 or ~> 2.0", [hex: :mime, repo: "hexpm", optional: false]}, {:mint, "~> 1.0", [hex: :mint, repo: "hexpm", optional: true]}, {:mox, "~> 1.0", [hex: :mox, repo: "hexpm", optional: true]}, {:msgpax, "~> 2.3", [hex: :msgpax, repo: "hexpm", optional: true]}, {:poison, ">= 1.0.0", [hex: :poison, repo: "hexpm", optional: true]}, {:telemetry, "~> 0.4 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: true]}], "hexpm", "eb3bdfc0c6c8a23b4e3d86558e812e3577acff1cb4acb6cfe2da1985a1035b89"},
   "websock": {:hex, :websock, "0.5.3", "2f69a6ebe810328555b6fe5c831a851f485e303a7c8ce6c5f675abeb20ebdadc", [:mix], [], "hexpm", "6105453d7fac22c712ad66fab1d45abdf049868f253cf719b625151460b8b453"},

test/peek_app_sdk/client_test.exs

@@ -313,4 +313,79 @@ defmodule PeekAppSDK.ClientTest do
       assert_raise RuntimeError, fn -> Client.operation_name(query) end
     end
   end
+
+  describe "query_peek_pro/4 retry behavior" do
+    test "retries on 429 rate limit and succeeds on subsequent attempt" do
+      install_id = "test_install_id"
+      query = "query Test { test }"
+      response_data = %{test: "success"}
+
+      call_count = :counters.new(1, [:atomics])
+
+      Tesla.Adapter.Finch
+      |> Mimic.stub(:call, fn _env, _opts ->
+        count = :counters.get(call_count, 1)
+        :counters.add(call_count, 1, 1)
+
+        if count < 2 do
+          {:ok, %Tesla.Env{status: 429, body: %{error: "rate limited"}}}
+        else
+          {:ok, %Tesla.Env{status: 200, body: %{data: response_data}}}
+        end
+      end)
+
+      assert {:ok, ^response_data} = Client.query_peek_pro(install_id, query)
+      assert :counters.get(call_count, 1) == 3
+    end
+
+    test "returns error after exhausting all retry attempts on persistent 429" do
+      install_id = "test_install_id"
+      query = "query Test { test }"
+
+      call_count = :counters.new(1, [:atomics])
+
+      Tesla.Adapter.Finch
+      |> Mimic.stub(:call, fn _env, _opts ->
+        :counters.add(call_count, 1, 1)
+        {:ok, %Tesla.Env{status: 429, body: %{error: "rate limited"}}}
+      end)
+
+      assert :rate_limited = Client.query_peek_pro(install_id, query)
+      # 1 initial attempt + 5 retries = 6 total calls
+      assert :counters.get(call_count, 1) == 6
+    end
+
+    test "does not retry on non-429 errors" do
+      install_id = "test_install_id"
+      query = "query Test { test }"
+
+      call_count = :counters.new(1, [:atomics])
+
+      Tesla.Adapter.Finch
+      |> Mimic.stub(:call, fn _env, _opts ->
+        :counters.add(call_count, 1, 1)
+        {:ok, %Tesla.Env{status: 500, body: %{error: "server error"}}}
+      end)
+
+      assert {:error, 500} = Client.query_peek_pro(install_id, query)
+      assert :counters.get(call_count, 1) == 1
+    end
+
+    test "does not retry on GraphQL errors" do
+      install_id = "test_install_id"
+      query = "query Test { test }"
+      errors = [%{message: "Invalid query"}]
+
+      call_count = :counters.new(1, [:atomics])
+
+      Tesla.Adapter.Finch
+      |> Mimic.stub(:call, fn _env, _opts ->
+        :counters.add(call_count, 1, 1)
+        {:ok, %Tesla.Env{status: 200, body: %{errors: errors}}}
+      end)
+
+      assert {:error, ^errors} = Client.query_peek_pro(install_id, query)
+      assert :counters.get(call_count, 1) == 1
+    end
+  end
 end