Merge pull request #6 from cujojs/add-unit-tests

Add unit tests

Author: briancavalier

README.md

@@ -54,6 +54,10 @@ If the WebSocket closes before the stream ends, the returned promise will fulfil
 
 ####`fromEventSource(eventSource [, dispose]) -> Stream`
 
+### fromEventSourceOn
+
+####`fromEventSourceOn(eventName, eventSource [, dispose]) -> Stream`
+
 ### fromMessagePort
 
 ####`fromMessagePort(port [, dispose]) -> Stream`

most-w3msg.js

@@ -1,4 +1,4 @@
-/** @license MIT License (c) copyright 2010-2014 original author or authors */
+/** @license MIT License (c) copyright 2010-2015 original author or authors */
 /** @author Brian Cavalier */
 /** @author John Hann */
 

package.json

@@ -16,7 +16,7 @@
   "author": "brian@hovercraftstudios.com",
   "license": "MIT",
   "dependencies": {
-    "most": "~0.8"
+    "most": "^0.13.0"
   },
   "devDependencies": {
     "jshint": "~2.5",

test/helper/fakes.js

@@ -0,0 +1,62 @@
+exports.FakeEventTarget = FakeEventTarget;
+exports.FakeEventSource = FakeEventSource;
+exports.FakeWebSocket = FakeWebSocket;
+exports.FakeMessagePort = FakeMessagePort;
+
+function FakeEventTarget() {
+    this._events = {};
+}
+
+FakeEventTarget.prototype.emit = function(e, x) {
+    var handler = this._events[e];
+    if(typeof handler !== 'function') {
+        return;
+    }
+    handler(x);
+};
+
+FakeEventTarget.prototype.addEventListener = function(e, handler) {
+    this._events[e] = handler;
+};
+
+FakeEventTarget.prototype.removeEventListener = function(e, handler) {
+    if(handler !== this._events[e]) {
+        throw new Error('removed wrong handler');
+    }
+    this._events[e] = void 0;
+};
+
+function FakeEventSource() {
+    FakeEventTarget.call(this);
+    this.isOpen = true;
+}
+
+FakeEventSource.prototype = Object.create(FakeEventTarget.prototype);
+
+FakeEventSource.prototype.close = function() {
+    if(!this.isOpen) {
+        throw new Error('closed more than once');
+    }
+    this.isOpen = false;
+    this.emit('close', void 0);
+};
+
+function FakeWebSocket() {
+    FakeEventSource.call(this);
+}
+
+FakeWebSocket.prototype = Object.create(FakeEventSource.prototype);
+
+FakeWebSocket.prototype.send = function(x) {
+    this.emit('message', x);
+};
+
+function FakeMessagePort() {
+    FakeEventTarget.call(this);
+}
+
+FakeMessagePort.prototype = Object.create(FakeEventTarget.prototype);
+
+FakeMessagePort.prototype.postMessage = function(x) {
+    this.emit('message', x);
+};

test/most-w3msg-test.js

@@ -1,14 +1,88 @@
 require('buster').spec.expose();
-//var expect = require('buster').expect;
+var expect = require('buster').expect;
+var fakes = require('./helper/fakes');
 
 var mws = require('../most-w3msg');
-var fromWebSocket = mws.fromWebSocket;
-var toWebSocket = mws.toWebSocket;
+
+var sentinel = { value: 'sentinel' };
 
 describe('fromWebSocket', function() {
-	it('should contain messages received by WebSocket');
+	it('should contain messages received by WebSocket', function() {
+		var ws = new fakes.FakeWebSocket();
+
+		var s = mws.fromWebSocket(ws, ws.close.bind(ws));
+		var spy = this.spy();
+
+		setTimeout(function() {
+			ws.send(sentinel);
+		}, 0);
+
+		return s.take(1).observe(spy).then(function() {
+			expect(spy).toHaveBeenCalledOnceWith(sentinel);
+		});
+	});
+
+	it('should call disposer when stream ends', function() {
+		var ws = new fakes.FakeWebSocket();
+
+		var spy = this.spy();
+		var s = mws.fromWebSocket(ws, spy);
+
+		setTimeout(function() {
+			ws.send(sentinel);
+		}, 0);
+
+		return s.take(1).drain().then(function() {
+			expect(spy).toHaveBeenCalledOnce();
+		});
+	});
+});
+
+describe('fromEventSource', function() {
+	it('should contain messages received by EventSource', function() {
+		var es = new fakes.FakeEventSource();
+
+		var s = mws.fromEventSource(es, es.close.bind(es));
+		var spy = this.spy();
+
+		setTimeout(function() {
+			es.emit('message', sentinel);
+		}, 0);
+
+		return s.take(1).observe(spy).then(function() {
+			expect(spy).toHaveBeenCalledOnceWith(sentinel);
+		});
+	});
+
+	it('should call disposer when stream ends', function() {
+		var es = new fakes.FakeEventSource();
+
+		var spy = this.spy();
+		var s = mws.fromEventSource(es, spy);
+
+		setTimeout(function() {
+			es.emit('message', sentinel);
+		}, 0);
+
+		return s.take(1).drain().then(function() {
+			expect(spy).toHaveBeenCalledOnce();
+		});
+	});
 });
 
-describe('toWebSocket', function() {
-	it('should send messages to WebSocket');
+describe('fromEventSourceOn', function() {
+	it('should contain events received by EventSource', function() {
+		var es = new fakes.FakeEventSource();
+
+		var s = mws.fromEventSourceOn('test', es, es.close.bind(es));
+		var spy = this.spy();
+
+		setTimeout(function() {
+			es.emit('test', sentinel);
+		}, 0);
+
+		return s.take(1).observe(spy).then(function() {
+			expect(spy).toHaveBeenCalledOnceWith(sentinel);
+		});
+	});
 });