little refactoring

This commit is contained in:
Alex S 2019-08-23 18:17:13 +03:00
parent 65fd5bdf4c
commit 431cf60510

View File

@ -160,26 +160,25 @@ defmodule Pleroma.Gun.Connections do
result = result =
if opts[:proxy] do if opts[:proxy] do
tls_opts = Map.get(opts, :tls_opts, [])
connect_opts = %{host: host, port: port}
connect_opts =
if uri.scheme == "https" do
Map.put(connect_opts, :protocols, [:http2])
|> Map.put(:transport, :tls)
|> Map.put(:tls_opts, tls_opts)
else
connect_opts
end
with {proxy_host, proxy_port} <- opts[:proxy], with {proxy_host, proxy_port} <- opts[:proxy],
tls_opts <- Map.get(opts, :tls_opts, []),
open_opts <- Map.delete(opts, :tls_opts), open_opts <- Map.delete(opts, :tls_opts),
{:ok, conn} <- API.open(proxy_host, proxy_port, open_opts), {:ok, conn} <- API.open(proxy_host, proxy_port, open_opts),
{:ok, _} <- API.await_up(conn) do {:ok, _} <- API.await_up(conn),
connect_opts = %{host: host, port: port} stream <- API.connect(conn, connect_opts),
{:response, :fin, 200, _} <- API.await(conn, stream) do
connect_opts = {:ok, conn, true}
if uri.scheme == "https" do
Map.put(connect_opts, :protocols, [:http2])
|> Map.put(:transport, :tls)
|> Map.put(:tls_opts, tls_opts)
else
connect_opts
end
with stream <- API.connect(conn, connect_opts),
{:response, :fin, 200, _} <- API.await(conn, stream) do
{:ok, conn, true}
end
else else
{:error, error} -> {:error, error} ->
{:error, error} {:error, error}