rackstash/spec/rackstash/adapter/base_adapter_spec.rb

# frozen_string_literal: true
#
# Copyright 2017 - 2018 Holger Just
#
# This software may be modified and distributed under the terms
# of the MIT license. See the LICENSE.txt file for details.

require 'spec_helper'

require 'rackstash/adapter/base_adapter'

describe Rackstash::Adapter::BaseAdapter do
  let(:adapter) { described_class.new }

  describe '.parse_uri_options' do
    it 'returns a Hash of query options' do
      expect(described_class.send :parse_uri_options, URI('/?foo=bar&baz=bums'))
        .to eql foo: 'bar', baz: 'bums'
    end

    it 'does not parse special values' do
      expect(described_class.send :parse_uri_options, URI('/?i=42&f=3.14&b=false&a[]=nil'))
        .to eql i: '42', f: '3.14', b: 'false', :'a[]' => 'nil'
    end

    it 'accepts common separators' do
      expect(described_class.send :parse_uri_options, URI('/?a=b;c=d&e=f;g=h'))
        .to eql a: 'b', c: 'd', e: 'f', g: 'h'
    end

    it 'parses multiple values of the same key into an array' do
      expect(described_class.send :parse_uri_options, URI('/?key=foo&key=bar&key=baz'))
        .to eql key: ['foo', 'bar', 'baz']
    end
  end

  describe '#initialize' do
    it 'accepts any arguments' do
      described_class.new
      described_class.new(:foo)
      described_class.new(123, [:foo])
    end
  end

  describe '#default_encoder' do
    it 'returns an encoder' do
      expect(adapter.default_encoder).to respond_to(:encode)
    end
  end

  describe '#close' do
    it 'does nothing' do
      expect(adapter.close).to be nil
    end
  end

  describe '#reopen' do
    it 'does nothing' do
      expect(adapter.reopen).to be nil
    end
  end

  describe '#write' do
    it 'calls write_single' do
      expect(adapter).to receive(:write_single).with('a log line')
      adapter.write('a log line')
    end
  end

  describe '#write_single' do
    it 'is not implemented in the abstract base class' do
      expect { adapter.write('something') }
        .to raise_error(Rackstash::NotImplementedHereError)
    end
  end
end