require 'webrick'
require 'spec_helper'
require 'json'

describe 'Bugsnag' do
  server = nil
  queue = Queue.new

  before do
    server = WEBrick::HTTPServer.new :Port => 0, :Logger => WEBrick::Log.new("/dev/null"), :AccessLog => []
    server.mount_proc '/' do |req, res|
      queue.push req.body
      res.status = 200
      res.body = "OK\n"
    end
    Thread.new{ server.start }
  end

  after do
    server.stop
    queue.clear
  end

  let(:request) { JSON.parse(queue.pop) }

  it 'should run the rake middleware when rake tasks crash' do
    #Skips this test in ruby 1.9.3 with travis
    unless ENV['TRAVIS'] && RUBY_VERSION == "1.9.3"
      ENV['BUGSNAG_TEST_SERVER_PORT'] = server.config[:Port].to_s
      task_fixtures_path = File.join(File.dirname(__FILE__), 'fixtures', 'tasks')
      Dir.chdir(task_fixtures_path) do
        system("bundle exec rake test:crash > /dev/null 2>&1")
      end

      result = request()
      expect(result["events"][0]["metaData"]["rake_task"]).not_to be_nil
      expect(result["events"][0]["metaData"]["rake_task"]["name"]).to eq("test:crash")
    end
  end

  it 'should send notifications over the wire' do
    Bugsnag.configure do |config|
      config.endpoint = "http://localhost:#{server.config[:Port]}"
    end
    WebMock.allow_net_connect!

    Bugsnag.notify 'yo'

    expect(request['events'][0]['exceptions'][0]['message']).to eq('yo')
  end

  it 'should work with threadpool delivery' do
    Bugsnag.configure do |config|
      config.endpoint = "http://localhost:#{server.config[:Port]}"
      config.delivery_method = :thread_queue
    end
    WebMock.allow_net_connect!

    Bugsnag.notify 'yo'

    expect(request['events'][0]['exceptions'][0]['message']).to eq('yo')
  end

  it 'should work with threadpool delivery after fork' do
    is_jruby = defined?(RUBY_ENGINE) && RUBY_ENGINE == 'jruby'
    unless is_jruby #jruby doesn't support fork, so this test doesn't apply
      Bugsnag.configure do |config|
        config.endpoint = "http://localhost:#{server.config[:Port]}"
        config.delivery_method = :thread_queue
      end
      WebMock.allow_net_connect!

      Bugsnag.notify 'yo'

      Process.fork do
        Bugsnag.notify 'yo too'
      end
      Process.wait

      expect(queue.length).to eq(2)
    end
  end

  describe 'with a proxy' do
    proxy = nil
    pqueue = Queue.new

    before do
      proxy = WEBrick::HTTPServer.new :Port => 0, :Logger => WEBrick::Log.new("/dev/null"), :AccessLog => []
      proxy.mount_proc '/' do |req, res|
        pqueue.push req
        res.status = 200
        res.body = "OK\n"
      end
      Thread.new{ proxy.start }
    end
    after do
      proxy.stop
    end

    let(:proxied_request) { pqueue.pop }

    it 'should use a proxy when configured' do
      Bugsnag.configure do |config|

        config.endpoint = "http://localhost:#{server.config[:Port]}"

        config.proxy_host = 'localhost'
        config.proxy_port = proxy.config[:Port]
        config.proxy_user = 'conrad'
        config.proxy_password = '$ecret'
      end

      Bugsnag.notify 'oy'

      r = proxied_request

      expect(r.header['proxy-authorization'].first).to eq("Basic Y29ucmFkOiRlY3JldA==")
      expect(r.request_line).to eq("POST http://localhost:#{server.config[:Port]}/ HTTP/1.1\r\n")
    end
  end
end