Skip to content

Commit 3b99a62

Browse files
committed
Updated dop-transport dependency
1 parent 5be8423 commit 3b99a62

File tree

4 files changed

+97
-99
lines changed

4 files changed

+97
-99
lines changed

.prettierrc

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
{
2+
"printWidth": 80,
3+
"tabWidth": 4,
4+
"semi": false,
5+
"singleQuote": true,
6+
"bracketSpacing": true
7+
}

.vscode/settings.json

Lines changed: 0 additions & 9 deletions
This file was deleted.

package.json

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "dop",
3-
"version": "0.43.0",
3+
"version": "0.43.1",
44
"main": "./dist/dop.nodejs.js",
55
"browser": "./dist/dop.js",
66
"unpkg": "./dist/dop.min.js",
@@ -34,7 +34,7 @@
3434
"client"
3535
],
3636
"dependencies": {
37-
"dop-transports": "^2.0.11"
37+
"dop-transports": "^2.0.14"
3838
},
3939
"devDependencies": {
4040
"coveralls": "^2.11.4",

test/protocol/queue.js

Lines changed: 88 additions & 88 deletions
Original file line numberDiff line numberDiff line change
@@ -1,88 +1,88 @@
1-
var test = require('tape');
2-
var dop = require('../.proxy').create()
3-
var dopServer = require('../.proxy').create();
4-
var dopClient = require('../.proxy').create();
5-
6-
var transportName = process.argv[2]|| 'local';
7-
var transportListen = require('dop-transports').listen[transportName];
8-
var transportConnect = require('dop-transports').connect[transportName];
9-
10-
11-
12-
test('QUEUE TEST', function(t) {
13-
14-
var server = dopServer.listen({transport:transportListen, timeout:2});
15-
var nodeClient = dopClient.connect({transport:transportConnect, listener:server});
16-
dopServer.env = 'SERVER'
17-
dopClient.env = 'CLIENT'
18-
var nodeServer, socketServer, socketClient;
19-
var tokenServer, tokenClient;
20-
var order = 0;
21-
22-
23-
var msg=0;
24-
function send() {
25-
nodeClient.send(String(msg));
26-
if (nodeServer)
27-
nodeServer.send(String(msg));
28-
if (msg++ < 15)
29-
setTimeout(send, 300);
30-
}
31-
send();
32-
33-
34-
var incS=0, incC=1;
35-
36-
server.on('connect', function(node){
37-
nodeServer = node;
38-
});
39-
server.on('message', function(node, message){
40-
if (message[0] !== '[') {
41-
t.equal(message, String(incS++), '❌ message `'+message+'`');
42-
if (incS===16 && incC===16) {
43-
server.listener.close();
44-
t.end();
45-
}
46-
}
47-
});
48-
49-
nodeClient.on('message', function(message){
50-
if (message[0] !== '[') {
51-
t.equal(message, String(incC++), '✅ message `'+message+'`');
52-
if (incS===16 && incC===16) {
53-
t.end();
54-
try {
55-
server.listener.close();
56-
nodeClient.socket.close();
57-
} catch(e) {
58-
// process.exit();
59-
}
60-
}
61-
}
62-
});
63-
64-
65-
66-
67-
68-
69-
setTimeout(function(){
70-
// console.log( 'closing...' );
71-
nodeClient.socket.close();
72-
setTimeout(function(){
73-
// console.log( 'reconnecting...' );
74-
nodeClient.reconnect();
75-
},500);
76-
}, 1000);
77-
78-
setTimeout(function(){
79-
// console.log( 'closing2...' );
80-
nodeClient.socket.close();
81-
setTimeout(function(){
82-
// console.log( 'reconnecting2...' );
83-
nodeClient.reconnect();
84-
},500);
85-
}, 2000);
86-
87-
88-
});
1+
var test = require('tape');
2+
var dop = require('../.proxy').create()
3+
var dopServer = require('../.proxy').create();
4+
var dopClient = require('../.proxy').create();
5+
6+
var transportName = process.argv[2]|| 'local';
7+
var transportListen = require('dop-transports').listen[transportName];
8+
var transportConnect = require('dop-transports').connect[transportName];
9+
10+
11+
12+
test('QUEUE TEST', function(t) {
13+
14+
var server = dopServer.listen({transport:transportListen, timeout:2});
15+
var nodeClient = dopClient.connect({transport:transportConnect, listener:server});
16+
dopServer.env = 'SERVER'
17+
dopClient.env = 'CLIENT'
18+
var nodeServer, socketServer, socketClient;
19+
var tokenServer, tokenClient;
20+
var order = 0;
21+
22+
23+
var msg=0;
24+
function send() {
25+
nodeClient.send(String(msg));
26+
if (nodeServer)
27+
nodeServer.send(String(msg));
28+
if (msg++ < 15)
29+
setTimeout(send, 300);
30+
}
31+
send();
32+
33+
34+
var incS=0, incC=1;
35+
36+
server.on('connect', function(node){
37+
nodeServer = node;
38+
});
39+
server.on('message', function(node, message){
40+
if (message[0] !== '[') {
41+
t.equal(message, String(incS++), '❌ message `'+message+'`');
42+
if (incS===16 && incC===16) {
43+
server.listener.close();
44+
t.end();
45+
}
46+
}
47+
});
48+
49+
nodeClient.on('message', function(message){
50+
if (message[0] !== '[') {
51+
t.equal(message, String(incC++), '✅ message `'+message+'`');
52+
if (incS===16 && incC===16) {
53+
t.end();
54+
try {
55+
server.listener.close();
56+
nodeClient.socket.close();
57+
} catch(e) {
58+
// process.exit();
59+
}
60+
}
61+
}
62+
});
63+
64+
65+
66+
67+
68+
69+
setTimeout(function(){
70+
// console.log( 'closing...' );
71+
nodeClient.socket.close();
72+
setTimeout(function(){
73+
// console.log( 'reconnecting...' );
74+
nodeClient.reconnect();
75+
},500);
76+
}, 1000);
77+
78+
setTimeout(function(){
79+
// console.log( 'closing2...' );
80+
nodeClient.socket.close();
81+
setTimeout(function(){
82+
// console.log( 'reconnecting2...' );
83+
nodeClient.reconnect();
84+
},500);
85+
}, 2000);
86+
87+
88+
});

0 commit comments

Comments
 (0)