This is only an idea and it’s pseudocode - I haven’t even compiled it yet:
defmodule FakeAdapter.Cowboy2.Conn do
@moduledoc false
@behaviour Plug.Conn.Adapter
alias Plug.Adapters.Cowboy2
defdelegate send_resp(payload, status, headers, body),
to: Cowboy2.Conn
defdelegate send_file(payload, status, headers, file, offset, length),
to: Cowboy2.Conn
defdelegate send_chunked(payload, status, headers),
to: Cowboy2.Conn
defdelegate chunk(payload, status),
to: Cowboy2.Conn
defdelegate push(payload, path, headers),
to: Cowboy2.Conn
def read_req_body(payload, _options) do
case Map.fetch(payload, :raw_body) do
{:ok, data} -> {:ok, data, payload}
:error -> {:error, :no_data}
end
end
end
defmodule InterceptAdapter do
import Plug.Conn
def init(opts), do: opts
def call(%Conn{adapter: {adapter, state}} = conn, _opts) do
case read_all_body(conn) do
{:ok, body, conn} ->
state = Map.put(state, :raw_body, body)
%{conn | adapter: {fake_adapter_for(adapter), state}}
{:error, reason} ->
halt(conn)
end
end
def read_all_body(conn, acc \\ "") do
case read_body(conn) do
{:ok, body, conn} ->
{:ok, acc <> body, conn}
{:more, partial_body, conn} ->
read_all_body(conn, acc <> partial_body)
{:error, reason} ->
{:error, reason}
end
end
defp fake_adapter_for(Elixir.Plug.Adapters.Cowboy2),
do: FakeAdapter.Cowboy2.Conn
end
So the idea is to plug InterceptAdapter before the plug parsers and theoretically you should get the ability to read more than once
