belt

defmodule Belt.Test.Provider.S3 do
  use Belt.Test.Provider,
    provider: Belt.Provider.S3

  defp fetch_var(var) do
    Application.fetch_env(:belt, Belt.Test.Provider.S3)
    |> case do
      :error -> fetch_env_var(var)
      {:ok, vals} ->
        case vals[var] do
          nil -> fetch_env_var(var)
          val -> val
        end
    end
  end

  defp fetch_env_var(var) do
    env_var = "BELT_TEST_S3_#{var}" |> String.upcase()
    case System.get_env(env_var) do
      nil ->
        {:error,
         "Missing config for Belt.Provider.S3 test. " <>
         "Set \"config :belt, Belt.Test.Provider.S3, #{var}: val\" "<>
         "or environment variable \"#{env_var}\""}
      "true" -> true
      "false" -> false
      val ->
        case Integer.parse(val) do
          :error -> val
          {num, _} -> num
        end
    end
  end

  def config_opts(_context) do
    vars = [:host, :region, :access_key_id, :secret_access_key, :port, :bucket, :https]
    vals = vars |> Enum.map(&fetch_var(&1))

    errors = Enum.reduce(vals, [], fn(val, acc) ->
      case val do
        {:error, message} -> [message | acc]
        _ -> acc
      end
    end)

    if Enum.empty?(errors),
      do: Enum.zip(vars, vals),
      else: {:error, Enum.join(errors, "\n")}
  end

  test "get presigned url",
      %{provider: provider, _files: [file | _]} = context do
    {:ok, config} = provider.new(config_opts(context))
    {:ok, %{identifier: identifier}} = Belt.store(config, file)

    {:ok, url} = Belt.get_url(config, identifier, presign: true)
    uri = URI.parse(url)

    assert uri.host != nil
    assert uri.scheme in ["http", "https"]
    assert uri.path != nil
  end
end