@@ -23,45 +23,32 @@ var order = 0;
2323test ( 'RECONNECT TEST' , function ( t ) {
2424
2525 server . on ( 'open' , function ( socket ) {
26- if ( socketServer === undefined ) {
26+ if ( socketServer === undefined )
2727 socketServer = socket ;
28- }
2928 // t.equal(dopServer.getNodeBySocket(socket).socket, socket, '❌ open');
3029 } ) ;
3130 server . on ( 'connect' , function ( node ) {
3231 nodeServer = node ;
3332 tokenServer = node . token ;
3433 t . equal ( node . socket , socketServer , '❌ connect' ) ;
3534 } ) ;
36- // server.on('close', function(socket){
37- // t.equal(socket, socketServer, '❌ close');
38- // });
3935 server . on ( 'reconnect' , function ( node , oldSocket ) {
4036 t . equal ( node === nodeServer && oldSocket === socketServer , true , '❌ reconnect' ) ;
4137 } ) ;
42- server . on ( 'disconnect' , function ( node ) {
43- t . equal ( node , nodeServer , '❌ disconnect' ) ;
44- } ) ;
4538
4639
4740 nodeClient . on ( 'open' , function ( socket ) {
4841 socketClient = socket ;
49- // t.equal(dopClient.getNodeBySocket(socket).socket, socket, '✅ open');
5042 } ) ;
5143 nodeClient . on ( 'connect' , function ( ) {
5244 tokenClient = nodeClient . token ;
5345 t . equal ( nodeClient . socket , socketClient , '✅ connect' ) ;
5446 } ) ;
55- // nodeClient.on('close', function(socket){
56- // t.equal(socket, socketClient, '✅ close');
57- // });
5847 nodeClient . on ( 'reconnect' , function ( oldSocket ) {
5948 t . equal ( oldSocket , socketClient , '✅ reconnect' ) ;
49+ server . listener . close ( ) ;
6050 t . end ( ) ;
6151 } ) ;
62- nodeClient . on ( 'disconnect' , function ( ) {
63- t . equal ( 1 , 1 , '✅ disconnect' ) ;
64- } ) ;
6552} ) ;
6653
6754
@@ -75,4 +62,4 @@ setTimeout(function(){
7562setTimeout ( function ( ) {
7663 console . log ( 'reconnecting...' ) ;
7764 nodeClient . reconnect ( ) ;
78- } , 3000 ) ;
65+ } , 1000 ) ;
0 commit comments