Making events_transports test

Author: Josema

src/env/browser/websocket.js

@@ -13,20 +13,14 @@ function websocket(dop, node, options) {
 
     var api = options.transport.api(),
         socket = new api(url),
-        send = socket.send,
-        send_queue = [];
+        send = socket.send;
 
     socket.send = function(message) {
-        // (socket.readyState !== 1) ?
-            // send_queue.push(message)
-        // :
-            send.call(socket, message);
+        send.call(socket, message);
     };
 
     socket.addEventListener('open', function() {
         dop.core.onopen(node, socket);
-        // while (send_queue.length>0)
-            // send.call(socket, send_queue.shift());
     });
 
     socket.addEventListener('message', function(message) {

test/events_transports.js

@@ -0,0 +1,85 @@
+var test = require('tape');
+var dop = require('../dist/nodejs').create();
+var dopClient = require('../dist/nodejs').create();
+var localtransportlisten = require('dop-transports').listen.local;
+var localtransportconnect = require('dop-transports').connect.local;
+
+// Browsers
+var server = dop.listen({transport:localtransportlisten});
+var client = dopClient.connect({transport:localtransportconnect, listener:server});
+// node.js (WebSockets)
+var server = dop.listen({});
+var client = dopClient.connect({});
+
+
+test('Events', function(t) {
+    var sock, msg;
+    var sock2, msg2;
+    var order = 1;
+
+    server.on('open', function(socket){
+        sock = socket;
+        t.equal(order++, 1, 'server/open');
+    });
+
+    server.listener.on('connection', function(socket){
+        sock.on('message', onmessageserver);
+        t.equal(order++, 2, 'server/connection');
+        t.equal(sock, socket, 'server/connection sock');
+    });
+
+    client.on('open', function(socket){
+        sock2 = socket;
+        t.equal(order++, 3, 'client/open');
+    });
+
+    client.socket.on('open', function(){
+        sock2.on('message', onmessageclient);
+        t.equal(order++, 4, 'clientsocket/open');
+        t.equal(sock2, this, 'clientsocket/open sock');
+    });
+
+
+    client.on('message', function(socket, message){
+        msg2 = message;
+        t.equal(order++, 5, 'client/message');
+        t.equal(sock2, socket, 'client/message sock');
+    });
+    function onmessageclient(message){
+        t.equal(order++, 6, 'clientsocket/message');
+        t.equal(msg2, message, 'clientsocket/message msg');
+    };
+
+    server.on('message', function(socket, message){
+        msg = message;
+        t.equal(order++, 7, 'server/message');
+        t.equal(sock, socket, 'server/message sock');
+    });
+    function onmessageserver(message){
+        t.equal(order++, 8, 'serverlistener/message');
+        t.equal(msg, message, 'serverlistener/message msg');
+        t.end();
+        try {server.listener.close()} catch(e) {}
+    };
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+});
+
+
+