import domEventSourceCallable from 'consul-ui/utils/dom/event-source/callable'; import EventTarget from 'consul-ui/utils/dom/event-target/rsvp'; import { Promise } from 'rsvp'; import { module, skip } from 'qunit'; import { setupTest } from 'ember-qunit'; import test from 'ember-sinon-qunit/test-support/test'; module('Integration | Utility | dom/event-source/callable', function(hooks) { setupTest(hooks); test('it dispatches messages', function(assert) { assert.expect(1); const EventSource = domEventSourceCallable(EventTarget); const listener = this.stub(); const source = new EventSource( function(configuration) { return new Promise(resolve => { setTimeout(() => { this.dispatchEvent({ type: 'message', data: null, }); resolve(); }, configuration.milliseconds); }); }, { milliseconds: 100, } ); source.addEventListener('message', function() { listener(); }); return new Promise(function(resolve) { setTimeout(function() { source.close(); assert.equal(listener.callCount, 5); resolve(); }, 550); }); }); // TODO: rsvp timing seems to have completely changed // this test tests an API that is not used within the code // (using an EventSource with no callable) // so we'll come back here to investigate skip('it dispatches a single open event and closes when called with no callable', function(assert) { assert.expect(4); const EventSource = domEventSourceCallable(EventTarget, Promise); const listener = this.stub(); const source = new EventSource(); source.addEventListener('open', function(e) { assert.deepEqual(e.target, this); assert.equal(e.target.readyState, 1); listener(); }); return Promise.resolve().then(function() { assert.ok(listener.calledOnce); assert.equal(source.readyState, 2); }); }); test('it dispatches a single open event, and calls the specified callable that can dispatch an event', function(assert) { assert.expect(1); const EventSource = domEventSourceCallable(EventTarget); const listener = this.stub(); const source = new EventSource(function() { return new Promise(resolve => { setTimeout(() => { this.dispatchEvent({ type: 'message', data: {}, }); this.close(); }, 190); }); }); source.addEventListener('open', function() { // open is called first listener(); }); return new Promise(function(resolve) { source.addEventListener('message', function() { // message is called second assert.ok(listener.calledOnce); resolve(); }); }); }); test("it can be closed before the first tick, and therefore doesn't run", function(assert) { assert.expect(4); const EventSource = domEventSourceCallable(EventTarget); const listener = this.stub(); const source = new EventSource(); assert.equal(source.readyState, 0); source.close(); assert.equal(source.readyState, 2); source.addEventListener('open', function(e) { listener(); }); return Promise.resolve().then(function() { assert.notOk(listener.called); assert.equal(source.readyState, 2); }); }); });