1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.HTTP do
7 Wrapper for `Tesla.request/2`.
10 alias Pleroma.HTTP.Connection
11 alias Pleroma.HTTP.Request
12 alias Pleroma.HTTP.RequestBuilder, as: Builder
23 See `Pleroma.HTTP.request/5`
25 @spec get(Request.url() | nil, Request.headers(), keyword()) ::
26 nil | {:ok, Env.t()} | {:error, any()}
27 def get(url, headers \\ [], options \\ [])
28 def get(nil, _, _), do: nil
29 def get(url, headers, options), do: request(:get, url, "", headers, options)
32 Performs POST request.
34 See `Pleroma.HTTP.request/5`
36 @spec post(Request.url(), String.t(), Request.headers(), keyword()) ::
37 {:ok, Env.t()} | {:error, any()}
38 def post(url, body, headers \\ [], options \\ []),
39 do: request(:post, url, body, headers, options)
42 Builds and performs http request.
45 `method` - :get, :post, :put, :delete
48 `headers` - a keyworld list of headers, e.g. `[{"content-type", "text/plain"}]`
49 `options` - custom, per-request middleware or adapter options
52 `{:ok, %Tesla.Env{}}` or `{:error, error}`
55 @spec request(atom(), Request.url(), String.t(), Request.headers(), keyword()) ::
56 {:ok, Env.t()} | {:error, any()}
57 def request(method, url, body, headers, options) when is_binary(url) do
58 with uri <- URI.parse(url),
59 received_adapter_opts <- Keyword.get(options, :adapter, []),
60 adapter_opts <- Connection.options(uri, received_adapter_opts),
61 options <- put_in(options[:adapter], adapter_opts),
62 params <- Keyword.get(options, :params, []),
63 request <- build_request(method, headers, options, url, body, params),
64 client <- Tesla.client([Tesla.Middleware.FollowRedirects], tesla_adapter()),
65 pid <- Process.whereis(adapter_opts[:pool]) do
67 if tesla_adapter() == Tesla.Adapter.Gun do
68 if pid, do: Process.alive?(pid), else: false
76 |> Map.put(:env, Pleroma.Config.get([:env]))
77 |> Map.put(:pool_alive?, pool_alive?)
86 Connection.after_request(adapter_opts)
92 @spec request(Client.t(), keyword(), map()) :: {:ok, Env.t()} | {:error, any()}
93 def request(%Client{} = client, request, %{env: :test}), do: request_try(client, request)
95 def request(%Client{} = client, request, %{body_as: :chunks}) do
96 request_try(client, request)
99 def request(%Client{} = client, request, %{pool_alive?: false}) do
100 request_try(client, request)
103 def request(%Client{} = client, request, %{pool: pool, timeout: timeout}) do
105 :poolboy.transaction(
107 &Pleroma.Pool.Request.execute(&1, client, request, timeout + 500),
114 :exit, {:timeout, _} ->
115 Logger.warn("Receive response from pool failed #{request[:url]}")
116 {:error, :recv_pool_timeout}
123 @spec request_try(Client.t(), keyword()) :: {:ok, Env.t()} | {:error, any()}
124 def request_try(client, request) do
126 Tesla.request(client, request)
136 defp build_request(method, headers, options, url, body, params) do
138 |> Builder.method(method)
139 |> Builder.headers(headers)
140 |> Builder.opts(options)
142 |> Builder.add_param(:body, :body, body)
143 |> Builder.add_param(:query, :query, params)
144 |> Builder.convert_to_keyword()
147 defp tesla_adapter, do: Application.get_env(:tesla, :adapter)