Fix option parsing for client

upmaru · Dec 2, 2024 · 03a71aa · 03a71aa
1 parent 96cf073
commit 03a71aa
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/lib/lexdee/client.ex b/lib/lexdee/client.ex
@@ -34,7 +34,7 @@ defmodule Lexdee.Client do
     timeout = Keyword.get(options, :timeout, 30_000)
 
     if Application.get_env(:lexdee, :environment) == :test do
-      {Tesla.Adapter.Mint, timeout: timeout}
+      {Tesla.Adapter.Mint, timeout: timeout, transport_opts: []}
     else
       {Tesla.Adapter.Mint,
        timeout: timeout,

diff --git a/lib/lexdee/observer.ex b/lib/lexdee/observer.ex
@@ -61,7 +61,7 @@ defmodule Lexdee.Observer do
     resource = Keyword.get(opts, :resource)
     type = to_string(Keyword.get(opts, :type, "operation"))
 
-    %{adapter: {_, _, options}, pre: middlewares} = client
+    %{adapter: {_, _, [options]}, pre: middlewares} = client
 
     {_, _, [base_url]} =
       Enum.find(middlewares, fn {k, _, _v} ->
@@ -75,14 +75,14 @@ defmodule Lexdee.Observer do
         "wss://#{base_uri.host}:#{base_uri.port}/1.0/events?type=#{type}"
 
     timeout = Keyword.get(options, :timeout, 30_000)
+
     transport_opts =
       options
-      |> Keyword.get(:transport_opts, [])
+      |> Keyword.fetch!(:transport_opts)
       |> Keyword.put(:timeout, timeout)
 
     options =
       options
-      |> List.flatten()
       |> Keyword.put(:protocols, [:http1])
       |> Keyword.put(:transport_opts, transport_opts)