pleroma

commit: 5f6506d864239408e9fa3705c5dd7b241307241a
parent 58f646bcda97d6a9f21aa41b55f77dd4e2a9c695
Author: Mark Felder <feld@feld.me>
Date:   Tue, 27 Aug 2024 20:39:32 -0400

Pleroma.HTTP: option stream: true will return a stream as the body for Gun adapter

Diffstat:
M
lib/pleroma/http/adapter_helper/gun.ex
9
+++++++++

1 file changed, 9 insertions(+), 0 deletions(-)
diff --git a/lib/pleroma/http/adapter_helper/gun.ex b/lib/pleroma/http/adapter_helper/gun.ex
@@ -32,6 +32,7 @@ defmodule Pleroma.HTTP.AdapterHelper.Gun do
     |> AdapterHelper.maybe_add_proxy(proxy)
     |> Keyword.merge(incoming_opts)
     |> put_timeout()
+    |> maybe_stream()
   end
 
   defp add_scheme_opts(opts, %{scheme: "http"}), do: opts
@@ -47,6 +48,14 @@ defmodule Pleroma.HTTP.AdapterHelper.Gun do
     Keyword.put(opts, :timeout, recv_timeout)
   end
 
+  # Tesla Gun adapter uses body_as: :stream
+  defp maybe_stream(opts) do
+    case Keyword.pop(opts, :stream, nil) do
+      {true, opts} -> Keyword.put(opts, :body_as, :stream)
+      {_, opts} -> opts
+    end
+  end
+
   @spec pool_timeout(pool()) :: non_neg_integer()
   def pool_timeout(pool) do
     default = Config.get([:pools, :default, :recv_timeout], 5_000)