Rakefile

# Licensed to Elasticsearch B.V. under one or more contributor
# license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright
# ownership. Elasticsearch B.V. licenses this file to you under
# the Apache License, Version 2.0 (the "License"); you may
# not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#   http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied.  See the License for the
# specific language governing permissions and limitations
# under the License.

# Admin client is used by tests and other rake tasks to communicate with a running cluster.
def admin_client
  $admin_client ||= begin
                      transport_options = {}
                      test_suite = ENV['TEST_SUITE'].freeze || 'free'
                      password = ENV['ELASTIC_PASSWORD'] || 'changeme'
                      user     = ENV['ELASTIC_USER'] || 'elastic'

                      if (hosts = ENV['TEST_ES_SERVER'] || ENV['ELASTICSEARCH_HOSTS'] || 'https://localhost:9200')
                        split_hosts = hosts.split(',').map do |host|
                          /(http\:\/\/)?\S+/.match(host)
                        end
                        uri = URI.parse(split_hosts.first[0])
                      end

                      if test_suite == 'platinum'
                        transport_options.merge!(
                          ssl: {
                            verify: false,
                            ca_path: CERT_DIR
                          }
                        )

                        url = "https://#{user}:#{password}@#{uri.host}:#{uri.port}"
                      else
                        url = "http://#{user}:#{password}@#{uri.host}:#{uri.port}"
                      end
                      puts "Elasticsearch Client url: #{url}"
                      Elasticsearch::Client.new(host: url, transport_options: transport_options)
                    end
end

import 'rake_tasks/elasticsearch_tasks.rake'
import 'rake_tasks/test_tasks.rake'
import 'rake_tasks/doc_generator.rake'
import 'rake_tasks/docker_tasks.rake'
require 'pathname'

CURRENT_PATH = Pathname(File.expand_path(__dir__))
SUBPROJECTS = [
  'elasticsearch',
  'elasticsearch-api',
  'elasticsearch-api/utils'
].freeze

RELEASE_TOGETHER = [
  'elasticsearch',
  'elasticsearch-api'
].freeze

CERT_DIR = ENV['CERT_DIR'] || '.ci/certs'

# Import build task after setting constants:
import 'rake_tasks/automation.rake'

# TODO: Figure out "bundle exec or not"
# subprojects.each { |project| $LOAD_PATH.unshift CURRENT_PATH.join(project, "lib").to_s }

task :default do
  system 'rake --tasks'
end

desc 'Run Ruby console with the Elasticsearch client libraries loaded'
task :console do
  system './elasticsearch/bin/elastic_ruby_console'
end

desc 'Display information about subprojects'
task :subprojects do
  puts '-' * 80
  SUBPROJECTS.each do |project|
    commit  = `git log --pretty=format:'%h %ar: %s' -1 #{project}`
    version = Gem::Specification::load(CURRENT_PATH.join(project, "#{project}.gemspec").to_s).version.to_s
    puts "#{version}".ljust(10) +
         "| \e[1m#{project.ljust(SUBPROJECTS.map {|s| s.length}.max)}\e[0m | #{commit[ 0..80]}..."
  end
end

desc 'Alias for `bundle:install`'
task bundle: 'bundle:install'

namespace :bundle do
  desc 'Run `bundle install` in all subprojects'
  task :install do
    SUBPROJECTS.each do |project|
      puts '-' * 80
      sh "cd #{CURRENT_PATH.join(project)} && unset BUNDLE_GEMFILE && bundle install --quiet"
      puts
    end
  end

  desc 'Remove Gemfile.lock in all subprojects'
  task :clean do
    SUBPROJECTS.each do |project|
      sh "rm -f #{CURRENT_PATH.join(project)}/Gemfile.lock"
    end
  end
end

desc 'Generate documentation for all subprojects'
task :doc do
  SUBPROJECTS.each do |project|
    sh "cd #{CURRENT_PATH.join(project)} && rake doc"
    puts '-' * 80
  end
end

desc 'Release all subprojects to Rubygems'
task :release do
  RELEASE_TOGETHER.each do |project|
    sh "cd #{CURRENT_PATH.join(project)} && bundle exec rake release"
    puts '-' * 80
  end
end

desc 'Server info'
task :info do
  require 'elasticsearch'

  client = Elasticsearch::Client.new(url: ENV['TEST_ES_SERVER'], api_key: ENV['ES_API_KEY'])
  info = client.info
  puts "Connected to Elasticsearch cluster #{info['cluster_name']}"
end