module Springy

# File lib/springy.rb, line 20
def client
  @client ||= Elasticsearch::Client.new
end

# File lib/springy.rb, line 24
def client=(client)
  @client = client
end

# File lib/springy.rb, line 53
def count_index(name, params = {})
  client.count({index: name}.merge(params))['count']
end

# File lib/springy.rb, line 45
def create_index(name, params = {})
  client.indices.create({index: name}.merge(params)) unless index_exists? name
end

# File lib/springy.rb, line 41
def delete_index(name)
  client.indices.delete(index: name) if index_exists? name
end

# File lib/springy.rb, line 57
def index_document(params = {})
  Utils.require_params!(:index_document, params, :index, :type, :body)

  raise IndexDoesNotExistError.new(
    "index #{params[:index]} does not exist"
  ) unless index_exists? params[:index]

  client.index(params)
end

# File lib/springy.rb, line 37
def index_exists?(name)
  client.indices.exists? index: name
end

# File lib/springy.rb, line 67
def query(options = {})
  API.new(root: options)
end

# File lib/springy.rb, line 49
def refresh_index(name, params = {})
  client.indices.refresh({index: name}.merge(params)) if index_exists? name
end

# File lib/springy.rb, line 28
def search(options = {})
  client.search(options)
rescue Elasticsearch::Transport::Transport::Errors::BadRequest => bre
  msg = bre.message[-150..-1]
  msg << "\n\n"
  msg << JSON.pretty_generate(options)
  raise msg
end