1
+ /* eslint-disable standard/no-callback-literal */
1
2
2
3
/**
3
4
* Tests dependencies.
@@ -352,18 +353,18 @@ describe('server', function () {
352
353
var socket = new eioc . Socket ( 'ws://localhost:%d' . s ( port ) ) ;
353
354
socket . on ( 'open' , function ( ) {
354
355
request . get ( 'http://localhost:%d/engine.io/' . s ( port ) )
355
- . set ( { connection : 'close' } )
356
- . query ( { transport : 'websocket' , sid : socket . id } )
357
- . end ( function ( err , res ) {
358
- expect ( err ) . to . be ( null ) ;
359
- expect ( res . status ) . to . be ( 400 ) ;
360
- expect ( res . body . code ) . to . be ( 3 ) ;
361
- socket . send ( 'echo' ) ;
362
- socket . on ( 'message' , function ( msg ) {
363
- expect ( msg ) . to . be ( 'echo' ) ;
364
- done ( ) ;
356
+ . set ( { connection : 'close' } )
357
+ . query ( { transport : 'websocket' , sid : socket . id } )
358
+ . end ( function ( err , res ) {
359
+ expect ( err ) . to . be ( null ) ;
360
+ expect ( res . status ) . to . be ( 400 ) ;
361
+ expect ( res . body . code ) . to . be ( 3 ) ;
362
+ socket . send ( 'echo' ) ;
363
+ socket . on ( 'message' , function ( msg ) {
364
+ expect ( msg ) . to . be ( 'echo' ) ;
365
+ done ( ) ;
366
+ } ) ;
365
367
} ) ;
366
- } ) ;
367
368
} ) ;
368
369
} ) ;
369
370
} ) ;
@@ -1353,7 +1354,7 @@ describe('server', function () {
1353
1354
} ) ;
1354
1355
1355
1356
it ( 'should arrive when binary data is sent as Buffer (ws)' , function ( done ) {
1356
- var binaryData = new Buffer ( 5 ) ;
1357
+ var binaryData = Buffer . allocUnsafe ( 5 ) ;
1357
1358
for ( var i = 0 ; i < binaryData . length ; i ++ ) {
1358
1359
binaryData . writeInt8 ( i , i ) ;
1359
1360
}
@@ -1379,7 +1380,7 @@ describe('server', function () {
1379
1380
} ) ;
1380
1381
1381
1382
it ( 'should arrive when binary data sent as Buffer (polling)' , function ( done ) {
1382
- var binaryData = new Buffer ( 5 ) ;
1383
+ var binaryData = Buffer . allocUnsafe ( 5 ) ;
1383
1384
for ( var i = 0 ; i < binaryData . length ; i ++ ) {
1384
1385
binaryData . writeInt8 ( i , i ) ;
1385
1386
}
@@ -1406,7 +1407,7 @@ describe('server', function () {
1406
1407
} ) ;
1407
1408
1408
1409
it ( 'should arrive as ArrayBuffer if requested when binary data sent as Buffer (ws)' , function ( done ) {
1409
- var binaryData = new Buffer ( 5 ) ;
1410
+ var binaryData = Buffer . allocUnsafe ( 5 ) ;
1410
1411
for ( var i = 0 ; i < binaryData . length ; i ++ ) {
1411
1412
binaryData . writeInt8 ( i , i ) ;
1412
1413
}
@@ -1435,7 +1436,7 @@ describe('server', function () {
1435
1436
} ) ;
1436
1437
1437
1438
it ( 'should arrive as ArrayBuffer if requested when binary data sent as Buffer (polling)' , function ( done ) {
1438
- var binaryData = new Buffer ( 5 ) ;
1439
+ var binaryData = Buffer . allocUnsafe ( 5 ) ;
1439
1440
for ( var i = 0 ; i < binaryData . length ; i ++ ) {
1440
1441
binaryData . writeInt8 ( i , i ) ;
1441
1442
}
@@ -1516,8 +1517,8 @@ describe('server', function () {
1516
1517
var socket = new eioc . Socket ( 'ws://localhost:%d' . s ( port ) , { transports : [ 'websocket' ] } ) ;
1517
1518
socket . on ( 'open' , function ( ) {
1518
1519
for ( var i = 0 ; i < messageCount ; i ++ ) {
1519
- // connection.send('message: ' + i); // works
1520
- connection . send ( messagePayload + '|message: ' + i ) ; // does not work
1520
+ // connection.send('message: ' + i); // works
1521
+ connection . send ( messagePayload + '|message: ' + i ) ; // does not work
1521
1522
}
1522
1523
var receivedCount = 0 ;
1523
1524
socket . on ( 'message' , function ( msg ) {
@@ -1614,7 +1615,8 @@ describe('server', function () {
1614
1615
key : fs . readFileSync ( 'test/fixtures/server.key' ) ,
1615
1616
cert : fs . readFileSync ( 'test/fixtures/server.crt' ) ,
1616
1617
ca : fs . readFileSync ( 'test/fixtures/ca.crt' ) ,
1617
- requestCert : true
1618
+ requestCert : true ,
1619
+ rejectUnauthorized : false
1618
1620
} ;
1619
1621
1620
1622
var opts = {
@@ -2309,7 +2311,7 @@ describe('server', function () {
2309
2311
it ( 'should compress by default' , function ( done ) {
2310
2312
var engine = listen ( { transports : [ 'polling' ] } , function ( port ) {
2311
2313
engine . on ( 'connection' , function ( conn ) {
2312
- var buf = new Buffer ( 1024 ) ;
2314
+ var buf = Buffer . allocUnsafe ( 1024 ) ;
2313
2315
for ( var i = 0 ; i < buf . length ; i ++ ) buf [ i ] = i % 0xff ;
2314
2316
conn . send ( buf ) ;
2315
2317
} ) ;
@@ -2337,7 +2339,7 @@ describe('server', function () {
2337
2339
it ( 'should compress using deflate' , function ( done ) {
2338
2340
var engine = listen ( { transports : [ 'polling' ] } , function ( port ) {
2339
2341
engine . on ( 'connection' , function ( conn ) {
2340
- var buf = new Buffer ( 1024 ) ;
2342
+ var buf = Buffer . allocUnsafe ( 1024 ) ;
2341
2343
for ( var i = 0 ; i < buf . length ; i ++ ) buf [ i ] = i % 0xff ;
2342
2344
conn . send ( buf ) ;
2343
2345
} ) ;
@@ -2365,7 +2367,7 @@ describe('server', function () {
2365
2367
it ( 'should set threshold' , function ( done ) {
2366
2368
var engine = listen ( { transports : [ 'polling' ] , httpCompression : { threshold : 0 } } , function ( port ) {
2367
2369
engine . on ( 'connection' , function ( conn ) {
2368
- var buf = new Buffer ( 10 ) ;
2370
+ var buf = Buffer . allocUnsafe ( 10 ) ;
2369
2371
for ( var i = 0 ; i < buf . length ; i ++ ) buf [ i ] = i % 0xff ;
2370
2372
conn . send ( buf ) ;
2371
2373
} ) ;
@@ -2390,7 +2392,7 @@ describe('server', function () {
2390
2392
it ( 'should disable compression' , function ( done ) {
2391
2393
var engine = listen ( { transports : [ 'polling' ] , httpCompression : false } , function ( port ) {
2392
2394
engine . on ( 'connection' , function ( conn ) {
2393
- var buf = new Buffer ( 1024 ) ;
2395
+ var buf = Buffer . allocUnsafe ( 1024 ) ;
2394
2396
for ( var i = 0 ; i < buf . length ; i ++ ) buf [ i ] = i % 0xff ;
2395
2397
conn . send ( buf ) ;
2396
2398
} ) ;
@@ -2415,7 +2417,7 @@ describe('server', function () {
2415
2417
it ( 'should disable compression per message' , function ( done ) {
2416
2418
var engine = listen ( { transports : [ 'polling' ] } , function ( port ) {
2417
2419
engine . on ( 'connection' , function ( conn ) {
2418
- var buf = new Buffer ( 1024 ) ;
2420
+ var buf = Buffer . allocUnsafe ( 1024 ) ;
2419
2421
for ( var i = 0 ; i < buf . length ; i ++ ) buf [ i ] = i % 0xff ;
2420
2422
conn . send ( buf , { compress : false } ) ;
2421
2423
} ) ;
@@ -2440,7 +2442,7 @@ describe('server', function () {
2440
2442
it ( 'should not compress when the byte size is below threshold' , function ( done ) {
2441
2443
var engine = listen ( { transports : [ 'polling' ] } , function ( port ) {
2442
2444
engine . on ( 'connection' , function ( conn ) {
2443
- var buf = new Buffer ( 100 ) ;
2445
+ var buf = Buffer . allocUnsafe ( 100 ) ;
2444
2446
for ( var i = 0 ; i < buf . length ; i ++ ) buf [ i ] = i % 0xff ;
2445
2447
conn . send ( buf ) ;
2446
2448
} ) ;
@@ -2478,7 +2480,7 @@ describe('server', function () {
2478
2480
done ( ) ;
2479
2481
} ;
2480
2482
2481
- var buf = new Buffer ( 100 ) ;
2483
+ var buf = Buffer . allocUnsafe ( 100 ) ;
2482
2484
for ( var i = 0 ; i < buf . length ; i ++ ) buf [ i ] = i % 0xff ;
2483
2485
conn . send ( buf , { compress : true } ) ;
2484
2486
} ) ;
@@ -2500,7 +2502,7 @@ describe('server', function () {
2500
2502
done ( ) ;
2501
2503
} ;
2502
2504
2503
- var buf = new Buffer ( 100 ) ;
2505
+ var buf = Buffer . allocUnsafe ( 100 ) ;
2504
2506
for ( var i = 0 ; i < buf . length ; i ++ ) buf [ i ] = i % 0xff ;
2505
2507
conn . send ( buf , { compress : true } ) ;
2506
2508
} ) ;
0 commit comments