require 'spec_helper'

describe EventMachine::Logger do
  let(:loggr) { ::Logger.new(STDOUT) }

  context 'creating' do
    it 'instantiates with a logger' do
      EM.run_block do
        eml = EventMachine::Logger.new(loggr)
        eml.logger.should eq(loggr)
      end
    end

    it 'adds a shutdown hook when the reactor is running' do
      EM.run_block do
        EM.should_receive(:add_shutdown_hook).and_yield
        eml = EventMachine::Logger.new(loggr)
      end
    end

    it 'starts the queue processor' do
      eml = EventMachine::Logger.new(loggr)
      loggr.should_receive('add').once

      EM.run_block do
        eml.debug('this is a test')
        EM.stop
      end
    end
  end

  context 'log statements' do
    let(:eml) { EventMachine::Logger.new(loggr) }

    %w(debug info warn error fatal).each do |l|
      describe "##{l}" do
        it 'pushes the log message onto the logger_queue' do
          eml.logger_queue.should_receive('push').once
          eml.send("#{l}", 'this is a test')
        end
      end
    end

    describe "#unknown" do
      it 'pushes the log message onto the logger_queue' do
        eml.logger_queue.should_receive('push').once
        eml.unknown('this is a test')
      end
    end

    describe '#<<' do
      it 'pushes the log message onto the logger_queue' do
        eml.logger_queue.should_receive('push').once
        eml << 'this is a test'
      end
    end
  end

  context 'queuing' do
    describe '#add' do
      context 'when logging below the defined level' do
        it 'pushes the log message onto the logger_queue' do
          loggr.level = ::Logger::WARN
          eml = EventMachine::Logger.new(loggr)
          eml.logger_queue.should_not_receive('push')
          eml.add(::Logger::INFO, 'this is a test').should be_true
        end
      end

      context 'when logging above the defined level' do
        it 'pushes the log message onto the logger_queue' do
          eml = EventMachine::Logger.new(loggr)
          eml.logger_queue.should_receive('push').once
          eml.add(::Logger::INFO, 'this is a test')
        end
      end

      context 'when using a block' do
        it 'evaluates the block' do
          eml = EventMachine::Logger.new(loggr)
          eml.logger_queue.should_receive('push').once
          eml.add(::Logger::INFO) { 'ohai' }
        end
      end
    end
  end

  context 'shutdown' do
    it 'drains the queue on shutdown' do
      eml = EventMachine::Logger.new(loggr)
      eml.logger_queue << EventMachine::LogMessage.new(::Logger::WARN, 'test message', $0)
      # 3.times { eml.add(::Logger::WARN) { 'ohai' } }
      eml.drain
      eml.logger_queue.should be_empty
    end
  end

  context 'delegating to logger' do
    describe 'method_missing' do
      it 'passes through to the underlying logger' do
        eml = EventMachine::Logger.new(loggr)
        loggr.should_receive("level").once
        eml.level
      end

      it 'returns the underlying loggers value' do
        loggr.level = ::Logger::WARN
        eml = EventMachine::Logger.new(loggr)
        eml.level.should eq(::Logger::WARN)
      end
    end

    describe 'respond_to?' do
      it 'responds to methods defined on the logger' do
        eml = EventMachine::Logger.new(loggr)
        eml.respond_to?('level').should be_true
      end
    end
  end

end