if Code.ensure_loaded?(Mint.HTTP) do
  defmodule Assent.HTTPAdapter.Mint do
    @moduledoc false
    alias Assent.{HTTPAdapter, HTTPAdapter.HTTPResponse}

    @behaviour HTTPAdapter

    @impl HTTPAdapter
    def request(method, url, body, headers, mint_opts \\ nil) do
      IO.warn(
        "#{inspect(__MODULE__)} is deprecated, consider use #{inspect(Assent.HTTPAdapter.Finch)} instead"
      )

      headers = headers ++ [HTTPAdapter.user_agent_header()]

      %{scheme: scheme, port: port, host: host, path: path, query: query} = URI.parse(url)

      path = add_query_to_path(path, query)

      scheme
      |> open_mint_conn(host, port, mint_opts)
      |> mint_request(method, path, headers, body)
      |> format_response()
    end

    defp add_query_to_path(path, query) when is_binary(query), do: path <> "?" <> query
    defp add_query_to_path(path, _any), do: path

    defp open_mint_conn(scheme, host, port, nil), do: open_mint_conn(scheme, host, port, [])
    defp open_mint_conn("http", host, port, opts), do: open_mint_conn(:http, host, port, opts)
    defp open_mint_conn("https", host, port, opts), do: open_mint_conn(:https, host, port, opts)

    defp open_mint_conn(scheme, host, port, opts) when is_atom(scheme) do
      transport_opts = Keyword.get(opts, :transport_opts, [])
      opts = Keyword.put(opts, :transport_opts, transport_opts)

      Mint.HTTP.connect(scheme, host, port, opts)
    end

    defp mint_request(resp, :get, path, headers, body),
      do: mint_request(resp, "GET", path, headers, body)

    defp mint_request(resp, :post, path, headers, body),
      do: mint_request(resp, "POST", path, headers, body)

    defp mint_request(resp, method, nil, headers, body),
      do: mint_request(resp, method, "/", headers, body)

    defp mint_request({:ok, conn}, method, path, headers, body) do
      conn
      |> Mint.HTTP.request(method, path, headers, body)
      |> await_response()
    end

    defp mint_request({:error, error}, _method, _path, _headers, _body), do: {:error, error}

    defp await_response({:ok, conn, request_ref}), do: await_response(conn, request_ref)

    defp await_response(conn, request_ref, timeout \\ 5_000, responses \\ []) do
      start_time = monotonic_timestamp()

      receive do
        {:tcp, _, _} = message ->
          handle_response(conn, request_ref, message, timeout, start_time, responses)

        {:ssl, _, _} = message ->
          handle_response(conn, request_ref, message, timeout, start_time, responses)
      after
        timeout -> {:error, :timeout}
      end
    end

    defp monotonic_timestamp, do: :erlang.monotonic_time(:millisecond)

    defp handle_response(conn, request_ref, message, timeout, start_time, prev_responses) do
      case Mint.HTTP.stream(conn, message) do
        {:ok, conn, responses} ->
          case completed?(responses) do
            true ->
              {:ok, prev_responses ++ responses}

            false ->
              new_timeout = new_timeout(timeout, start_time)

              await_response(conn, request_ref, new_timeout, prev_responses ++ responses)
          end

        {:error, _, e, _} ->
          {:error, e}

        :unknown ->
          new_timeout = new_timeout(timeout, start_time)

          await_response(conn, request_ref, new_timeout, prev_responses)
      end
    end

    defp new_timeout(timeout, start_time),
      do: max(timeout - (monotonic_timestamp() - start_time), 0)

    defp completed?([{:done, _request_ref} | _rest]), do: true
    defp completed?([_resp | responses]), do: completed?(responses)
    defp completed?([]), do: false

    defp format_response({:ok, responses}) do
      [{:status, _, status}, {:headers, _, headers} | responses] = responses
      body = merge_body(responses)

      {:ok, %HTTPResponse{status: status, headers: headers, body: body}}
    end

    defp format_response({:error, response}), do: {:error, response}

    defp merge_body([{:data, _request, new_body} | rest], body),
      do: merge_body(rest, body <> new_body)

    defp merge_body(_rest, body), do: body
    defp merge_body(responses), do: merge_body(responses, "")
  end
end