git.squeep.com Git - akkoma/blob - lib/pleroma/reverse_proxy/client.ex

   1 defmodule Pleroma.ReverseProxy.Client do
   2   @callback request(atom(), String.t(), [tuple()], String.t(), list()) ::
   3               {:ok, pos_integer(), [tuple()], reference() | map()}
   4               | {:ok, pos_integer(), [tuple()]}
   5               | {:ok, reference()}
   6               | {:error, term()}
   7
   8   @callback stream_body(reference() | pid() | map()) ::
   9               {:ok, binary()} | :done | {:error, String.t()}
  10
  11   @callback close(reference() | pid() | map()) :: :ok
  12
  13   def request(method, url, headers, "", opts \\ []) do
  14     client().request(method, url, headers, "", opts)
  15   end
  16
  17   def stream_body(ref), do: client().stream_body(ref)
  18
  19   def close(ref), do: client().close(ref)
  20
  21   defp client do
  22     Pleroma.Config.get([Pleroma.ReverseProxy.Client], :hackney)
  23   end
  24 end