require 'logstash-logger'

describe LogStashLogger::Device do
  include_context 'device'

  context "when port is specified" do
    it "defaults type to UDP" do
      expect(device_with_port).to be_a LogStashLogger::Device::UDP
    end
  end

  context "when passing in configuration" do
    let(:configuration) { {type: :udp, port: port} }

    subject(:new_device) { described_class.new(configuration) }

    it "does not mutate the passed configuration" do
      expect{ new_device }.to_not change { configuration }
      expect( new_device ).to be_a LogStashLogger::Device::UDP
    end
  end

  context "when configuration type is a String" do
    let(:configuration) { {type: "udp", port: port} }

    subject(:new_device) { described_class.new(configuration) }

    it "it correctly recognizes the device type" do
      expect(new_device).to be_a LogStashLogger::Device::UDP
    end
  end

  describe ".parse_uri_config" do
    subject(:parse_uri_config) { described_class.parse_uri_config(uri_config) }

    context "when uri_config is valid" do
      let(:uri_config) { udp_uri_config }
      it { is_expected.to eq({type: 'udp', host: 'localhost', port: 5228, path: ''}) }
    end

    context "when uri is invalid" do
      let(:uri_config) { invalid_uri_config }
      specify { expect { parse_uri_config }.to raise_error(URI::InvalidURIError) }
    end
  end

  describe "Parsing URI configurations" do
    subject(:new_device) { described_class.new(uri_config) }

    context "when URI config is udp" do
      let(:uri_config) { udp_uri_config }
      it { is_expected.to be_a LogStashLogger::Device::UDP }
    end

    context "when URI config is tcp" do
      let(:uri_config) { tcp_uri_config }
      it { is_expected.to be_a LogStashLogger::Device::TCP }
    end

    context "when URI config is unix" do
      let(:uri_config) { unix_uri_config }
      it { is_expected.to be_a LogStashLogger::Device::Unix }
    end

    context "when URI config is file" do
      let(:uri_config) { file_uri_config }
      it { is_expected.to be_a LogStashLogger::Device::File }
    end

    context "when URI config is redis" do
      let(:uri_config) { redis_uri_config }
      it { is_expected.to be_a LogStashLogger::Device::Redis }
      context "list specified" do
        let(:uri_config) { redis_uri_config.merge({list: 'mylist'}) }
        it 'is expected to have the list option set' do
          expect(new_device.list).to eq('mylist')
        end
      end
    end

    context "when URI config is kafka" do
      let(:uri_config) { kafka_uri_config }
      it { is_expected.to be_a LogStashLogger::Device::Kafka }
    end

    context "when URI config is stdout" do
      let(:uri_config) { stdout_uri_config }
      it { is_expected.to be_a LogStashLogger::Device::Stdout }
    end

    context 'when URI config is stderr' do
      let(:uri_config) { stderr_uri_config }
      it { is_expected.to be_a LogStashLogger::Device::Stderr }
    end
  end

end