require 'spec_helper'

describe Bidu::Mercy::Report::Error do
  let(:errors) { 1 }
  let(:successes) { 1 }
  let(:old_errors) { 2 }
  let(:threshold) { 0.02 }
  let(:period) { 1.day }
  let(:external_key) { :external_id }
  let(:scope) { :with_error }
  let(:base_scope) { :all }
  let(:options) do
    {
      period: period,
      threshold: threshold,
      scope: scope,
      base_scope: base_scope,
      clazz: Document,
      external_key: external_key
    }
  end
  let(:subject) { described_class.new(options) }
  let(:types) { [:a] }
  before do
    Document.all.each(&:destroy)
    types.each do |type|
      successes.times { Document.create status: :success, doc_type: type }
      errors.times do |i|
        Document.create status: :error, external_id: 10 * successes + i, outter_external_id: i, doc_type: type
      end
      old_errors.times do
        Document.create status: :error, created_at: 2.days.ago, updated_at: 2.days.ago, doc_type: type
      end
    end
  end

  describe '#status' do
    context 'when are more errors than the allowed by the threshold' do
      let(:errors) { 1 }
      let(:successes) { 3 }
      it { expect(subject.status).to eq(:error) }
    end

    context 'when the threshold is 0 and there are no errors' do
      let(:errors) { 0 }
      let(:threshold) { 0 }
      it { expect(subject.status).to eq(:ok) }
    end

    context 'when the threshold is 100% and there is 100% error' do
      let(:successes) { 0 }
      let(:threshold) { 1 }
      it { expect(subject.status).to eq(:ok) }
    end

    context 'when there are no documents' do
      let(:successes) { 0 }
      let(:errors) { 0 }
      it { expect(subject.status).to eq(:ok) }
    end

    context 'when there are older errors out of the period' do
      let(:threshold) { 0.6 }

      it 'ignores the older errros' do
        expect(subject.status).to eq(:ok)
      end

      context 'when passing a bigger period' do
        let(:period) { 3.days }

        it 'consider the older errros' do
          expect(subject.status).to eq(:error)
        end
      end
    end
  end

  describe 'percentage' do
    context 'when there are 25% erros' do
      let(:errors) { 1 }
      let(:successes) { 3 }
      it { expect(subject.percentage).to eq(0.25) }
    end

    context 'when there are no errors' do
      let(:errors) { 0 }
      let(:threshold) { 0 }
      it { expect(subject.percentage).to eq(0) }
    end

    context 'when there is 100% error' do
      let(:successes) { 0 }
      let(:threshold) { 1 }
      it { expect(subject.percentage).to eq(1) }
    end

    context 'when there are no documents' do
      let(:successes) { 0 }
      let(:errors) { 0 }
      it { expect(subject.percentage).to eq(0) }
    end

    context 'when there are older errors out of the period' do
      let(:old_errors) { 2 }

      it 'ignores the older errros' do
        expect(subject.percentage).to eq(0.5)
      end

      context 'when passing a bigger period' do
        let(:period) { 3.days }

        it 'consider the older errros' do
          expect(subject.percentage).to eq(0.75)
        end
      end
    end

    context 'when configuring with a complex scope' do
      let(:types) { [:a, :b] }
      let(:old_errors) { 0 }
      let(:scope) { :'with_error.type_b' }
      let(:errors) { 1 }
      let(:successes) { 3 }
      context 'as symbol' do
        let(:scope) { :'with_error.type_b' }

        it 'fetches from each scope in order' do
          expect(subject.percentage).to eq(0.125)
        end
      end

      context 'as string where scope' do
        let(:scope) { "status = 'error' and doc_type = 'b'" }

        it 'fetches from each scope in order' do
          expect(subject.percentage).to eq(0.125)
        end
      end

      context 'as hash where scope' do
        let(:scope) { { status: :error, doc_type: :b } }

        it 'fetches from each scope in order' do
          expect(subject.percentage).to eq(0.125)
        end
      end
    end

    context 'when using a base scope' do
      let(:types) { [:a, :b, :b, :b] }
      let(:old_errors) { 0 }
      let(:errors) { 1 }
      let(:successes) { 3 }

      context 'as symbol' do
        let(:base_scope) { :type_b }

        it 'fetches from each scope in order' do
          expect(subject.percentage).to eq(0.25)
        end
      end

      context 'as where clause' do
        let(:base_scope) { "doc_type = 'b'" }

        it 'fetches from each scope in order' do
          expect(subject.percentage).to eq(0.25)
        end
      end

      context 'as hash' do
        let(:base_scope) { { doc_type: :b } }

        it 'fetches from each scope in order' do
          expect(subject.percentage).to eq(0.25)
        end
      end
    end
  end

  describe '#scoped' do
    context 'when there are 25% erros' do
      let(:errors) { 1 }
      let(:successes) { 3 }
      it 'returns only the scoped documents' do
        expect(subject.scoped.count).to eq(1)
      end
    end

    context 'when there are no errors' do
      let(:errors) { 0 }
      let(:threshold) { 0 }
      it { expect(subject.scoped).to be_empty }
    end

    context 'when there are no documents' do
      let(:successes) { 0 }
      let(:errors) { 0 }
      it { expect(subject.scoped).to be_empty }
    end

    context 'when there are older errors out of the period' do
      let(:old_errors) { 2 }

      it 'ignores the older errros' do
        expect(subject.scoped.count).to eq(1)
      end

      context 'when passing a bigger period' do
        let(:period) { 3.days }

        it 'consider the older errros' do
          expect(subject.scoped.count).to eq(3)
        end
      end
    end

    context 'when configured with a complex scope' do
      let(:types) { [:a, :b, :b] }
      let(:old_errors) { 0 }

      context 'as symbol' do
        let(:scope) { :'with_error.type_b' }

        it 'fetches from each scope in order' do
          expect(subject.scoped.count).to eq(Document.with_error.type_b.count)
          expect(subject.scoped.count).to eq(2 * Document.with_error.type_a.count)
        end
      end

      context 'as hash' do
        let(:scope) { { status: :error, doc_type: :b } }

        it 'fetches from each scope in order' do
          expect(subject.scoped.count).to eq(Document.with_error.type_b.count)
          expect(subject.scoped.count).to eq(2 * Document.with_error.type_a.count)
        end
      end

      context 'as string where scope' do
        let(:scope) { "status = 'error' and doc_type = 'b'" }

        it 'fetches from each scope in order' do
          expect(subject.scoped.count).to eq(Document.with_error.type_b.count)
          expect(subject.scoped.count).to eq(2 * Document.with_error.type_a.count)
        end
      end
    end

    context 'when using a base scope' do
      let(:types) { [:a, :b, :b, :b] }
      let(:old_errors) { 0 }

      context 'as symbol' do
        let(:base_scope) { :type_b }

        it 'fetches from each scope in order' do
          expect(subject.scoped.count).to eq(Document.with_error.type_b.count)
          expect(subject.scoped.count).to eq(3 * Document.with_error.type_a.count)
        end
      end

      context 'as where clause' do
        let(:base_scope) { "doc_type = 'b'" }

        it 'fetches from each scope in order' do
          expect(subject.scoped.count).to eq(Document.with_error.type_b.count)
          expect(subject.scoped.count).to eq(3 * Document.with_error.type_a.count)
        end
      end

      context 'as hash' do
        let(:base_scope) { { doc_type: :b } }

        it 'fetches from each scope in order' do
          expect(subject.scoped.count).to eq(Document.with_error.type_b.count)
          expect(subject.scoped.count).to eq(3 * Document.with_error.type_a.count)
        end
      end
    end
  end

  describe '#error?' do
    context 'when errors percentage overcames threshold' do
      it { expect(subject.error?).to be_truthy }
    end

    context 'when errors percentage does not overcames threshold' do
      let(:errors) { 0 }
      it { expect(subject.error?).to be_falsey }
    end
  end

  describe '#status' do
    context 'when errors percentage overcames threshold' do
      it { expect(subject.status).to eq(:error) }
    end

    context 'when errors percentage does not overcames threshold' do
      let(:errors) { 0 }
      it { expect(subject.status).to eq(:ok) }
    end
  end

  describe '#as_json' do
    let(:expected) do
      { ids: ids_expected, percentage: percentage_expected, status: status_expected }
    end

    context 'when everything is ok' do
      let(:errors) { 1 }
      let(:successes) { 9 }
      let(:ids_expected) { [90] }
      let(:status_expected) { :ok }
      let(:percentage_expected) { 0.1 }
      let(:threshold) { 0.5 }

      it 'returns the external keys, status and error percentage' do
        expect(subject.as_json).to eq(expected)
      end

    end

    context 'when there are 75% erros' do
      let(:status_expected) { :error }
      let(:percentage_expected) { 0.75 }
      let(:errors) { 3 }
      let(:successes) { 1 }
      let(:ids_expected) { [10, 11, 12] }

      it 'returns the external keys, status and error percentage' do
        expect(subject.as_json).to eq(expected)
      end

      context 'when configurated with different external key' do
        let(:external_key) { :outter_external_id }
        let(:ids_expected) { [0, 1, 2] }

        it 'returns the correct external keys' do
          expect(subject.as_json).to eq(expected)
        end

        context 'when some external ids are the same' do
          let(:ids_expected) { [10, 10, 10] }
          before do
            Document.update_all(outter_external_id: 10)
          end

          it 'returns the correct external keys' do
            expect(subject.as_json).to eq(expected)
          end

          context 'and passing uniq option' do
            before { options[:uniq] = true }
            let(:ids_expected) { [10] }

            it 'returns the correct external keys only once' do
              expect(subject.as_json).to eq(expected)
            end
          end
        end

        context 'with a limit' do
          before { options[:limit] = 2 }
          let(:ids_expected) { [0, 1] }

          it 'returns only the limited ids' do
            expect(subject.as_json).to eq(expected)
          end
        end
      end

      context 'when configurated without external key' do
        before { options.delete(:external_key) }
        let(:ids_expected) { Document.with_error.where('created_at > ?', 30.hours.ago).map(&:id) }

        it 'returns the ids as default id' do
          expect(subject.as_json).to eq(expected)
        end
      end
    end
  end
end