elixir-tesla
diff --git a/‎.github/workflows/release.yml
Lines changed: 1 addition & 1 deletion b/‎.github/workflows/release.yml
Lines changed: 1 addition & 1 deletion
diff --git a/‎.github/workflows/test.yml
Lines changed: 2 additions & 2 deletions b/‎.github/workflows/test.yml
Lines changed: 2 additions & 2 deletions
diff --git a/‎lib/tesla/adapter/mint.ex
Lines changed: 2 additions & 0 deletions b/‎lib/tesla/adapter/mint.ex
Lines changed: 2 additions & 0 deletions
diff --git a/‎lib/tesla/middleware/base_url.ex
Lines changed: 52 additions & 0 deletions b/‎lib/tesla/middleware/base_url.ex
Lines changed: 52 additions & 0 deletions
diff --git a/‎lib/tesla/middleware/compression.ex
Lines changed: 57 additions & 6 deletions b/‎lib/tesla/middleware/compression.ex
Lines changed: 57 additions & 6 deletions
diff --git a/‎lib/tesla/middleware/core.ex
Lines changed: 0 additions & 131 deletions b/‎lib/tesla/middleware/core.ex
Lines changed: 0 additions & 131 deletions
diff --git a/‎lib/tesla/middleware/headers.ex
Lines changed: 24 additions & 0 deletions b/‎lib/tesla/middleware/headers.ex
Lines changed: 24 additions & 0 deletions
diff --git a/‎lib/tesla/middleware/logger.ex
Lines changed: 13 additions & 3 deletions b/‎lib/tesla/middleware/logger.ex
Lines changed: 13 additions & 3 deletions
@@ -9,7 +9,7 @@ jobs:
     name: Publish
     runs-on: ubuntu-latest
     steps:
-    - uses: actions/checkout@v3
+    - uses: actions/checkout@v4
     - name: Set up Elixir
       uses: erlef/setup-beam@v1
       with:
 
@@ -15,7 +15,7 @@ jobs:
           - 25.3
           - 24.3
     steps:
-    - uses: actions/checkout@v3
+    - uses: actions/checkout@v4
     - name: Set up Elixir
       uses: erlef/setup-beam@v1
       with:
@@ -79,7 +79,7 @@ jobs:
   Linting:
     runs-on: ubuntu-latest
     steps:
-    - uses: actions/checkout@v3
+    - uses: actions/checkout@v4
     - name: Set up Elixir
       uses: erlef/setup-beam@v1
       with:
 
@@ -155,6 +155,8 @@ if Code.ensure_loaded?(Mint.HTTP) do
           _ -> opts
         end
 
+      opts = Map.put_new(opts, :mode, :passive)
+
       with {:ok, conn} <-
              HTTP.connect(String.to_atom(uri.scheme), uri.host, uri.port, Enum.into(opts, [])) do
         # If there were redirects, and passed `closed_conn: false`, we need to close opened connections to these intermediate hosts.
 
@@ -0,0 +1,52 @@
+defmodule Tesla.Middleware.BaseUrl do
+  @moduledoc """
+  Set base URL for all requests.
+
+  The base URL will be prepended to request path/URL only
+  if it does not include http(s).
+
+  ## Examples
+
+  ```
+  defmodule MyClient do
+    use Tesla
+
+    plug Tesla.Middleware.BaseUrl, "https://example.com/foo"
+  end
+
+  MyClient.get("/path") # equals to GET https://example.com/foo/path
+  MyClient.get("path") # equals to GET https://example.com/foo/path
+  MyClient.get("") # equals to GET https://example.com/foo
+  MyClient.get("http://example.com/bar") # equals to GET http://example.com/bar
+  ```
+  """
+
+  @behaviour Tesla.Middleware
+
+  @impl Tesla.Middleware
+  def call(env, next, base) do
+    env
+    |> apply_base(base)
+    |> Tesla.run(next)
+  end
+
+  defp apply_base(env, base) do
+    if Regex.match?(~r/^https?:\/\//i, env.url) do
+      # skip if url is already with scheme
+      env
+    else
+      %{env | url: join(base, env.url)}
+    end
+  end
+
+  defp join(base, url) do
+    case {String.last(to_string(base)), url} do
+      {nil, url} -> url
+      {"/", "/" <> rest} -> base <> rest
+      {"/", rest} -> base <> rest
+      {_, ""} -> base
+      {_, "/" <> rest} -> base <> "/" <> rest
+      {_, rest} -> base <> "/" <> rest
+    end
+  end
+end
@@ -25,11 +25,16 @@ defmodule Tesla.Middleware.Compression do
   def call(env, next, opts) do
     env
     |> compress(opts)
-    |> Tesla.put_headers([{"accept-encoding", "gzip, deflate"}])
+    |> add_accept_encoding()
     |> Tesla.run(next)
     |> decompress()
   end
 
+  @doc false
+  def add_accept_encoding(env) do
+    Tesla.put_headers(env, [{"accept-encoding", "gzip, deflate, identity"}])
+  end
+
   defp compressible?(body), do: is_binary(body)
 
   @doc """
@@ -61,13 +66,59 @@ defmodule Tesla.Middleware.Compression do
   def decompress({:error, reason}), do: {:error, reason}
 
   def decompress(env) do
+    codecs = compression_algorithms(Tesla.get_header(env, "content-encoding"))
+    {decompressed_body, unknown_codecs} = decompress_body(codecs, env.body, [])
+
     env
-    |> Tesla.put_body(decompress_body(env.body, Tesla.get_header(env, "content-encoding")))
+    |> put_decompressed_body(decompressed_body)
+    |> put_or_delete_content_encoding(unknown_codecs)
+  end
+
+  defp put_or_delete_content_encoding(env, []) do
+    Tesla.delete_header(env, "content-encoding")
+  end
+
+  defp put_or_delete_content_encoding(env, unknown_codecs) do
+    Tesla.put_header(env, "content-encoding", Enum.join(unknown_codecs, ", "))
+  end
+
+  defp decompress_body([gzip | rest], body, acc) when gzip in ["gzip", "x-gzip"] do
+    decompress_body(rest, :zlib.gunzip(body), acc)
   end
 
-  defp decompress_body(<<31, 139, 8, _::binary>> = body, "gzip"), do: :zlib.gunzip(body)
-  defp decompress_body(body, "deflate"), do: :zlib.unzip(body)
-  defp decompress_body(body, _content_encoding), do: body
+  defp decompress_body(["deflate" | rest], body, acc) do
+    decompress_body(rest, :zlib.unzip(body), acc)
+  end
+
+  defp decompress_body(["identity" | rest], body, acc) do
+    decompress_body(rest, body, acc)
+  end
+
+  defp decompress_body([codec | rest], body, acc) do
+    decompress_body(rest, body, [codec | acc])
+  end
+
+  defp decompress_body([], body, acc) do
+    {body, acc}
+  end
+
+  defp compression_algorithms(nil) do
+    []
+  end
+
+  defp compression_algorithms(value) do
+    value
+    |> String.downcase()
+    |> String.split(",", trim: true)
+    |> Enum.map(&String.trim/1)
+    |> Enum.reverse()
+  end
+
+  defp put_decompressed_body(env, body) do
+    env
+    |> Tesla.put_body(body)
+    |> Tesla.delete_header("content-length")
+  end
 end
 
 defmodule Tesla.Middleware.CompressRequest do
@@ -99,7 +150,7 @@ defmodule Tesla.Middleware.DecompressResponse do
   @impl Tesla.Middleware
   def call(env, next, _opts) do
     env
-    |> Tesla.put_headers([{"accept-encoding", "gzip, deflate"}])
+    |> Tesla.Middleware.Compression.add_accept_encoding()
     |> Tesla.run(next)
     |> Tesla.Middleware.Compression.decompress()
   end
 
@@ -0,0 +1,24 @@
+defmodule Tesla.Middleware.Headers do
+  @moduledoc """
+  Set default headers for all requests
+
+  ## Examples
+
+  ```
+  defmodule Myclient do
+    use Tesla
+
+    plug Tesla.Middleware.Headers, [{"user-agent", "Tesla"}]
+  end
+  ```
+  """
+
+  @behaviour Tesla.Middleware
+
+  @impl Tesla.Middleware
+  def call(env, next, headers) do
+    env
+    |> Tesla.put_headers(headers)
+    |> Tesla.run(next)
+  end
+end
@@ -109,7 +109,7 @@ defmodule Tesla.Middleware.Logger do
   By default, the following log levels will be used:
 
   - `:error` - for errors, 5xx and 4xx responses
-  - `:warn` - for 3xx responses
+  - `:warn` or `:warning` - for 3xx responses
   - `:info` - for 2xx responses
 
   You can customize this setting by providing your own `log_level/1` function:
@@ -186,7 +186,13 @@ defmodule Tesla.Middleware.Logger do
 
   @format Formatter.compile(@config[:format])
 
-  @type log_level :: :info | :warn | :error
+  @type log_level :: :info | :warn | :warning | :error
+
+  if Version.compare(System.version(), "1.11.0") == :lt do
+    @warning_level :warn
+  else
+    @warning_level :warning
+  end
 
   require Logger
 
@@ -221,9 +227,13 @@ defmodule Tesla.Middleware.Logger do
       fun when is_function(fun) ->
         case fun.(env) do
           :default -> default_log_level(env)
+          warning when warning in [:warn, :warning] -> @warning_level
           level -> level
         end
 
+      warning when warning in [:warn, :warning] ->
+        @warning_level
+
       atom when is_atom(atom) ->
         atom
     end
@@ -233,7 +243,7 @@ defmodule Tesla.Middleware.Logger do
   def default_log_level(env) do
     cond do
       env.status >= 400 -> :error
-      env.status >= 300 -> :warn
+      env.status >= 300 -> @warning_level
       true -> :info
     end
   end