module ElasticsearchHermes

# File lib/elasticsearch_hermes/elasticsearch_hermes.rb, line 33
def self.client
  @client ||= ::Elasticsearch::Client.new(default_connect_options)
end

# File lib/elasticsearch_hermes/elasticsearch_hermes.rb, line 10
def self.configuration
  @configuration ||= Configuration.new
end

# File lib/elasticsearch_hermes/elasticsearch_hermes.rb, line 41
def self.connect!
  return unless client

  info = @client.info
  cluster_version = info['version']['number']
  msg = "Connected to Elastic version #{cluster_version}."
  Logger.log(msg)
end

# File lib/elasticsearch_hermes/elasticsearch_hermes.rb, line 22
def self.default_connect_options
  base_es_urls = configuration.es_url
  urls = base_es_urls.split(',').compact.uniq
  options = {
    url: urls,
    retry_on_failure: configuration.retry_on_failure,
    log: configuration.enable_logs
  }
  options
end

# File lib/elasticsearch_hermes/elasticsearch_hermes.rb, line 37
def self.fields
  configuration.fields
end

# File lib/elasticsearch_hermes/elasticsearch_hermes.rb, line 50
def self.refresh
  client.indices.refresh
end

# File lib/elasticsearch_hermes/elasticsearch_hermes.rb, line 14
def self.reset
  @configuration = Configuration.new
end

# File lib/elasticsearch_hermes/elasticsearch_hermes.rb, line 18
def self.setup
  yield(configuration)
end