# encoding: utf-8
require 'spec_helper'

describe 'Bugsnag::Que', :order => :defined do
  before do
    unless defined?(::Que)
      @mocked_que = true
      class ::Que
        Version = '9.9.9'
        class << self
          attr_accessor :error_notifier
        end
      end
      module Kernel
        alias_method :old_require, :require
        def require(path)
          old_require(path) unless /^que/.match(path)
        end
      end
    end
  end

  it "should create and register a que handler" do
    error = RuntimeError.new("oops")
    job = double('que_job')
    expect(job).to receive(:dup).and_return({
      :error_count => 0,
      :job_class => 'ActiveJob::QueueAdapters::QueAdapter::JobWrapper',
      :args => [{"queue_name" => "foo", "arguments" => "bar"}],
      :job_id => "ID"
    })

    report = double('report')
    expect(Bugsnag).to receive(:notify).with(error, true).and_yield(report)
    expect(report).to receive(:add_tab).with(:job, {
      :error_count => 1,
      :job_class => 'ActiveJob::QueueAdapters::QueAdapter::JobWrapper',
      :job_id => "ID",
      :wrapper_job_class => 'ActiveJob::QueueAdapters::QueAdapter::JobWrapper',
      :wrapper_job_id => "ID",
      :queue => "foo",
      :args => "bar"
    })
    expect(report).to receive(:severity=).with("error")
    expect(report).to receive(:severity_reason=).with({
      :type => Bugsnag::Report::UNHANDLED_EXCEPTION_MIDDLEWARE,
      :attributes => {
        :framework => 'Que'
      }
    })

    allow(Que).to receive(:respond_to?).with(:error_notifier=).and_return(true)
    config = double('config')
    allow(Bugsnag).to receive(:configuration).and_return(config)
    expect(config).to receive(:app_type)
    expect(config).to receive(:app_type=).with('que')
    runtime = {}
    expect(config).to receive(:runtime_versions).and_return(runtime)
    allow(config).to receive(:clear_request_data)
    expect(Que).to receive(:error_notifier=) do |handler|
      handler.call(error, job)
    end

    #Kick off
    load './lib/bugsnag/integrations/que.rb'
    
    expect(runtime).to eq("que" => "9.9.9")
  end

  context 'when the job is nil' do
    it 'notifies Bugsnag' do
      load './lib/bugsnag/integrations/que.rb'
      error = RuntimeError.new('nil job')
      report = Bugsnag::Report.new(error, Bugsnag::Configuration.new)
      expect(Bugsnag).to receive(:notify).with(error, true).and_yield(report)

      Que.error_notifier.call(error, nil)

      expect(report.meta_data['custom'].fetch('job')).to eq(nil)
      expect(report.severity).to eq('error')
      expect(report.severity_reason).to eq({
        :type => Bugsnag::Report::UNHANDLED_EXCEPTION_MIDDLEWARE,
        :attributes => {:framework => 'Que'},
      })
    end
  end

  after do
    Object.send(:remove_const, :Que) if @mocked_que
    module Kernel
      alias_method :require, :old_require
    end
  end
end