# frozen_string_literal: true

require 'spec_helper'
require 'tempfile'

RSpec.describe RSpec::Hive::Configuration do
  RSpec.shared_examples('config') do
    its(:host) do
      is_expected.to eq(expected_host)
    end

    its(:port) do
      is_expected.to eq(expected_port)
    end

    its(:host_shared_directory_path) do
      is_expected.to match(expected_host_shared_directory_path)
    end

    its(:docker_shared_directory_path) do
      is_expected.to eq(expected_docker_shared_directory_path)
    end

    its(:hive_version) do
      is_expected.to eq(expected_hive_version)
    end

    its(:connection_timeout) do
      is_expected.to eq(expected_timeout)
    end

    its(:hive_options) do
      is_expected.to eq(expected_hive_options)
    end
  end

  let(:expected_host_shared_directory_path) { '/Users/Shared/tmp/spec-tmp-files' }
  let(:expected_docker_shared_directory_path) { '/tmp/spec-tmp-files' }
  let(:expected_timeout) { 120 }
  let(:expected_hive_options) { {} }

  context 'when no configuration file is provided' do
    let(:expected_port) { 10_000 }
    let!(:original_host_os) { RbConfig::CONFIG['host_os'] }
    let(:expected_hive_version) { described_class::DEFAULT_VERSION }

    before { allow(Dir).to receive(:mktmpdir) { mock_tmpdir } }

    context 'when on Mac' do
      let(:mock_tmpdir) { '/Users/Shared/test/' }
      let(:expected_host) { '127.0.0.1' }
      let(:expected_host_shared_directory_path) { '/Users/Shared/test/spec-tmp-files' }

      before do
        RbConfig::CONFIG['host_os'] = 'mac os'
      end

      after { RbConfig::CONFIG['host_os'] = original_host_os }

      include_examples('config')
    end

    context 'when on Linux' do
      let(:mock_tmpdir) { '/tmp/test/' }
      let(:expected_host) { '127.0.0.1' }
      let(:expected_host_shared_directory_path) { '/tmp/test/spec-tmp-files' }

      before do
        RbConfig::CONFIG['host_os'] = 'linux'
      end

      after { RbConfig::CONFIG['host_os'] = original_host_os }

      include_examples('config')
    end
  end

  context 'when there is a configuration file' do
    let(:path_to_config_file) do
      Tempfile.open(%w[config .yml]) do |f|
        f.write yaml_hash.to_yaml
        f.path
      end
    end
    let(:expected_host) { '127.0.0.2' }
    let(:expected_port) { 10_001 }

    context 'where all parameters are present' do
      subject { described_class.new(path_to_config_file) }

      let(:expected_hive_version) { 12 }

      let(:yaml_hash) do
        {
          'hive' =>
            {
              'host' => '127.0.0.2',
              'port' => 10_001,
              'host_shared_directory_path' => expected_host_shared_directory_path,
              'docker_shared_directory_path' => expected_docker_shared_directory_path,
              'hive_version' => '12',
              'timeout' => 120
            }
        }
      end

      after { File.unlink(path_to_config_file) }

      include_examples('config')
    end

    context 'where there are only required parameters' do
      subject { described_class.new(path_to_config_file) }

      let(:expected_hive_version) { described_class::DEFAULT_VERSION }
      let(:yaml_hash) do
        {
          'hive' =>
            {
              'host' => '127.0.0.2',
              'port' => 10_001,
              'host_shared_directory_path' => expected_host_shared_directory_path,
              'docker_shared_directory_path' => expected_docker_shared_directory_path
            }
        }
      end

      after { File.unlink(path_to_config_file) }

      include_examples('config')
    end

    context 'where there are some parameters required and optional' do
      subject { described_class.new(path_to_config_file) }

      let(:yaml_hash) do
        {
          'hive' =>
            {
              'host' => '127.0.0.2',
              'port' => 10_001,
              'host_shared_directory_path' => expected_host_shared_directory_path,
              'docker_shared_directory_path' => expected_docker_shared_directory_path,
              'hive_version' => 11,
              'timeout' => 60,
              'hive_options' => {
                'mapred.child.java.opts' => '-Xmx64m'
              }
            }
        }
      end
      let(:expected_timeout) { 60 }
      let(:expected_hive_version) { 11 }
      let(:expected_java_opts) { '-Xmx64m' }
      let(:expected_hive_options) do
        {
          'mapred.child.java.opts' => expected_java_opts
        }
      end

      after { File.unlink(path_to_config_file) }

      include_examples('config')
    end
  end
end