diff options
author | rinpatch <rinpatch@sdf.org> | 2020-07-26 20:44:26 +0300 |
---|---|---|
committer | rinpatch <rinpatch@sdf.org> | 2020-07-26 20:52:00 +0300 |
commit | 6bf8eee5f90d27d81e645cacfff60b001316f5cd (patch) | |
tree | 01741c1785ffb8796572cdf5f14a9416dfbf1265 | |
parent | d4fbec62a37f229108a4ae5ef069042a8aa4aa22 (diff) | |
download | pleroma-6bf8eee5f90d27d81e645cacfff60b001316f5cd.tar.gz |
ReverseProxy tesla client: remove handling of old_conn
This is no longer relevant because we use a custom
FollowRedirects middleware now
-rw-r--r-- | lib/pleroma/reverse_proxy/client/tesla.ex | 11 |
1 files changed, 2 insertions, 9 deletions
diff --git a/lib/pleroma/reverse_proxy/client/tesla.ex b/lib/pleroma/reverse_proxy/client/tesla.ex index 84addc404..d5a339681 100644 --- a/lib/pleroma/reverse_proxy/client/tesla.ex +++ b/lib/pleroma/reverse_proxy/client/tesla.ex @@ -45,15 +45,8 @@ defmodule Pleroma.ReverseProxy.Client.Tesla do @impl true @spec stream_body(map()) :: {:ok, binary(), map()} | {:error, atom() | String.t()} | :done | no_return() - def stream_body(%{pid: pid, opts: opts, fin: true}) do - # if connection was reused, but in tesla were redirects, - # tesla returns new opened connection, which must be closed manually - if opts[:old_conn], do: Tesla.Adapter.Gun.close(pid) - # if there were redirects we need to checkout old conn - conn = opts[:old_conn] || opts[:conn] - - if conn, do: :ok = ConnectionPool.release_conn(conn) - + def stream_body(%{pid: pid, fin: true}) do + ConnectionPool.release_conn(pid) :done end |