body
- Modify `close/1` function to do the same thing it does for hackney,
which is - close the client rather than the whole connection
- Release the connection when there is no body to chunk
defmodule Pleroma.ReverseProxy.Client.Tesla do
@behaviour Pleroma.ReverseProxy.Client
defmodule Pleroma.ReverseProxy.Client.Tesla do
@behaviour Pleroma.ReverseProxy.Client
+ alias Pleroma.Gun.ConnectionPool
+
@type headers() :: [{String.t(), String.t()}]
@type status() :: pos_integer()
@type headers() :: [{String.t(), String.t()}]
@type status() :: pos_integer()
if is_map(response.body) and method != :head do
{:ok, response.status, response.headers, response.body}
else
if is_map(response.body) and method != :head do
{:ok, response.status, response.headers, response.body}
else
+ conn_pid = response.opts[:adapter][:conn]
+ ConnectionPool.release_conn(conn_pid)
{:ok, response.status, response.headers}
end
else
{:ok, response.status, response.headers}
end
else
# if there were redirects we need to checkout old conn
conn = opts[:old_conn] || opts[:conn]
# if there were redirects we need to checkout old conn
conn = opts[:old_conn] || opts[:conn]
- if conn, do: :ok = Pleroma.Gun.ConnectionPool.release_conn(conn)
+ if conn, do: :ok = ConnectionPool.release_conn(conn)
@impl true
@spec close(map) :: :ok | no_return()
def close(%{pid: pid}) do
@impl true
@spec close(map) :: :ok | no_return()
def close(%{pid: pid}) do
- adapter = check_adapter()
- adapter.close(pid)
+ ConnectionPool.release_conn(pid)
end
defp check_adapter do
end
defp check_adapter do
{:ok, code, _, _} ->
{:error, {:invalid_http_response, code}}
{:ok, code, _, _} ->
{:error, {:invalid_http_response, code}}
+ {:ok, code, _} ->
+ {:error, {:invalid_http_response, code}}
+
{:error, error} ->
{:error, error}
end
{:error, error} ->
{:error, error}
end