elastix_reloaded

defmodule Elastix.Search do
  @moduledoc """
  """
  import Elastix.HTTP, only: [prepare_url: 2]
  alias Elastix.HTTP

  @doc false
  def search(elastic_url, index, types, data) do
    search(elastic_url, index, types, data, [])
  end

  @doc false
  def search(elastic_url, index, types, data, query_params, options \\ []) do
    prepare_url(elastic_url, make_path(index, types, query_params))
    |> HTTP.post(Poison.encode!(data), [], options)
  end

  @doc false
  def scroll(elastic_url, data, options \\ []) do
    prepare_url(elastic_url, "_search/scroll")
    |> HTTP.post(Poison.encode!(data), [], options)
  end

  @doc false
  def count(elastic_url, index, types, data) do
    count(elastic_url, index, types, data, [])
  end

  @doc false
  def count(elastic_url, index, types, data, query_params, options \\ []) do
    elastic_url <> make_path(index, types, query_params, "_count")
    |> HTTP.post(Poison.encode!(data), [], options)
  end

  @doc false
  def make_path(index, types, query_params, api_type \\ "_search") do
    path_root = "/#{index}"

    path = case types do
      [] -> path_root
      _ -> path_root <> "/" <> Enum.join types, ","
    end

    full_path = "#{path}/#{api_type}"

    case query_params do
      [] -> full_path
      _ -> add_query_params(full_path, query_params)
    end
  end

  @doc false
  defp add_query_params(path, query_params) do
    query_string = Enum.map_join query_params, "&", fn(param) ->
      "#{elem(param, 0)}=#{elem(param, 1)}"
    end

    "#{path}?#{query_string}"
  end
end