describe("Messagebus", function() {

  it("submits change requests", function(done){
    spyOn(this.MockedXMLHttpRequest.prototype, 'send').and.callThrough();
    var spec = this;
    MessageBus.subscribe('/test', function(){
      expect(spec.MockedXMLHttpRequest.prototype.send)
        .toHaveBeenCalled()
      var req = JSON.parse(spec.MockedXMLHttpRequest.prototype.send.calls.argsFor(0)[0]);
      expect(req['/test']).toEqual(-1)
      expect(req['__seq']).not.toBeUndefined();
      done()
    });
  });

  it("calls callbacks", function(done){
    MessageBus.subscribe('/test', function(message){
      expect(message.password).toEqual('MessageBusRocks!');
      done();
    });
  });

  it('returns status', function(done){
    MessageBus.pause();
    expect(MessageBus.status()).toMatch("paused");
    MessageBus.resume();
    expect(MessageBus.status()).toMatch("started");
    MessageBus.stop();
    expect(MessageBus.status()).toMatch("stopped");
    done();
  });

  it('stores messages when paused, then delivers them when resumed', function(done){
    MessageBus.pause()
    spyOn(this.MockedXMLHttpRequest.prototype, 'send').and.callThrough();
    var spec = this;
    var onMessageSpy = jasmine.createSpy('onMessageSpy');
    MessageBus.subscribe('/test', onMessageSpy);
    setTimeout(function(){
      expect(spec.MockedXMLHttpRequest.prototype.send).toHaveBeenCalled()
      expect(onMessageSpy).not.toHaveBeenCalled()
      MessageBus.resume()
    }, 1010) // greater than delayPollTimeout of 500 + 500 random
    setTimeout(function(){
      expect(onMessageSpy).toHaveBeenCalled()
      done()
    }, 1050) // greater than first timeout above
  });

  it('can unsubscribe from callbacks', function(done){
    var onMessageSpy = jasmine.createSpy('onMessageSpy');
    MessageBus.subscribe('/test', onMessageSpy);
    MessageBus.unsubscribe('/test', onMessageSpy);
    MessageBus.subscribe('/test', function(){
      expect(onMessageSpy).not.toHaveBeenCalled()
      done()
    });
  });

  testMB('sets dlp paramater when longPolling is disabled', function(){
    MessageBus.enableLongPolling = false
    this.perform(function(message, xhr){
      expect(xhr.url).toMatch("dlp=t");
    }).finally(function(){
      MessageBus.enableLongPolling = true
    })
  });

  testMB('respects baseUrl setting', function(){
    MessageBus.baseUrl = "/a/test/base/url/";
    this.perform(function(message, xhr){
      expect(xhr.url).toMatch("/a/test/base/url/");
    }).finally(function(){
      MessageBus.baseUrl = "/";
    })
  });

  it('removes itself from root namespace when noConflict is called', function(){
    expect(window.MessageBus).not.toBeUndefined();
    var mb = window.MessageBus;
    expect(mb).toEqual(window.MessageBus.noConflict());
    expect(window.MessageBus).toBeUndefined();
    // reset it so afterEach has something to work on
    window.MessageBus = mb;
  });

  it('respects minPollInterval setting with defaults', function(){
    expect(MessageBus.minPollInterval).toEqual(100);
    MessageBus.minPollInterval = 1000;
    expect(MessageBus.minPollInterval).toEqual(1000);
  });

  testMB('sends using custom header', function(){
    MessageBus.headers['X-MB-TEST-VALUE'] = '42';
    this.perform(function(message, xhr){
      expect(xhr.headers).toEqual({
        'X-SILENCE-LOGGER': 'true',
        'X-MB-TEST-VALUE': '42',
        'Content-Type': 'application/json'
      });
    }).finally(function(){
      MessageBus.headers = {};
    })
  });

});