require_relative "../../../spec/spec_helper"
require 'stud/temporary'
require 'manticore/client'

describe "Proxy option" do
  let(:settings) { { "hosts" => "node01" } }
  subject {
    LogStash::Outputs::ElasticSearch.new(settings)
  }

  before do
    allow(::Manticore::Client).to receive(:new).with(any_args).and_call_original
  end

  describe "valid configs" do
    before do
      subject.register
    end

    after do
      subject.close
    end

    context "when specified as a URI" do
      shared_examples("hash conversion") do |hash|
        let(:settings) { super().merge("proxy" => proxy)}
        
        it "should set the proxy to the correct hash value" do
          expect(::Manticore::Client).to have_received(:new) do |options|
            expect(options[:proxy]).to eq(hash)
          end
        end
      end
      
      describe "simple proxy" do
        let(:proxy) { LogStash::Util::SafeURI.new("http://127.0.0.1:1234") }

        include_examples("hash conversion",
          {
            :host => "127.0.0.1",
            :scheme => "http",
            :port => 1234  
          }
        )
      end
      
      
      describe "a secure authed proxy" do
        let(:proxy) { LogStash::Util::SafeURI.new("https://myuser:mypass@127.0.0.1:1234") }

        include_examples("hash conversion",
          {
            :host => "127.0.0.1",
            :scheme => "https",
            :user => "myuser",
            :password => "mypass",
            :port => 1234  
          }
        )
      end
    end

    context "when not specified" do
      it "should not send the proxy option to manticore" do
        expect(::Manticore::Client).to have_received(:new) do |options|
          expect(options).not_to include(:proxy)
        end
      end
    end
  end

  context "when specified as ''" do
    let(:settings) { super().merge("proxy" => "${A_MISSING_ENV_VARIABLE:}")}

    it "should not send the proxy option to manticore" do
      expect { subject.register }.not_to raise_error

      expect(::Manticore::Client).to have_received(:new) do |options|
        expect(options).not_to include(:proxy)
      end

      subject.close
    end
  end

  context "when specified as invalid uri" do
    let(:settings) { super().merge("proxy" => ":")}

    it "should fail" do
      # SafeURI isn't doing the proper exception wrapping for us, we can not simply :
      # expect { subject.register }.to raise_error(ArgumentError, /URI is not valid/i)
      begin
        subject.register
      rescue ArgumentError => e
        expect(e.message).to match /URI is not valid/i
      rescue java.net.URISyntaxException => e
        expect(e.message).to match /scheme name/i
      else
        fail 'exception not raised'
      end
    end
  end
end