|
1 | 1 | 'use strict';
|
2 |
| -var common = require('../common'); |
3 |
| -var assert = require('assert'); |
| 2 | +const common = require('../common'); |
| 3 | +const assert = require('assert'); |
4 | 4 |
|
5 | 5 | if (!common.hasCrypto) {
|
6 | 6 | common.skip('missing crypto');
|
7 | 7 | return;
|
8 | 8 | }
|
9 |
| -var tls = require('tls'); |
| 9 | +const tls = require('tls'); |
10 | 10 |
|
11 |
| -var net = require('net'); |
12 |
| -var fs = require('fs'); |
13 |
| -var path = require('path'); |
| 11 | +const net = require('net'); |
| 12 | +const fs = require('fs'); |
| 13 | +const path = require('path'); |
14 | 14 |
|
15 |
| -var serverConnected = 0; |
16 |
| -var clientConnected = 0; |
| 15 | +let serverConnected = 0; |
| 16 | +let clientConnected = 0; |
17 | 17 |
|
18 |
| -var options = { |
| 18 | +const options = { |
19 | 19 | key: fs.readFileSync(path.join(common.fixturesDir, 'test_key.pem')),
|
20 | 20 | cert: fs.readFileSync(path.join(common.fixturesDir, 'test_cert.pem'))
|
21 | 21 | };
|
22 | 22 |
|
23 |
| -var server = tls.createServer(options, function(socket) { |
| 23 | +const server = tls.createServer(options, (socket) => { |
24 | 24 | serverConnected++;
|
25 | 25 | socket.end('Hello');
|
26 |
| -}).listen(0, function() { |
27 |
| - var waiting = 2; |
| 26 | +}).listen(0, () => { |
| 27 | + let waiting = 2; |
28 | 28 | function establish(socket) {
|
29 |
| - var client = tls.connect({ |
| 29 | + const client = tls.connect({ |
30 | 30 | rejectUnauthorized: false,
|
31 | 31 | socket: socket
|
32 |
| - }, function() { |
| 32 | + }, () => { |
33 | 33 | clientConnected++;
|
34 |
| - var data = ''; |
35 |
| - client.on('data', function(chunk) { |
| 34 | + let data = ''; |
| 35 | + client.on('data', common.mustCall((chunk) => { |
36 | 36 | data += chunk.toString();
|
37 |
| - }); |
38 |
| - client.on('end', function() { |
39 |
| - assert.equal(data, 'Hello'); |
| 37 | + })); |
| 38 | + client.on('end', common.mustCall(() => { |
| 39 | + assert.strictEqual(data, 'Hello'); |
40 | 40 | if (--waiting === 0)
|
41 | 41 | server.close();
|
42 |
| - }); |
| 42 | + })); |
43 | 43 | });
|
44 | 44 | assert(client.readable);
|
45 | 45 | assert(client.writable);
|
46 | 46 |
|
47 | 47 | return client;
|
48 | 48 | }
|
49 | 49 |
|
| 50 | + const { port } = server.address(); |
| 51 | + |
50 | 52 | // Immediate death socket
|
51 |
| - var immediateDeath = net.connect(this.address().port); |
| 53 | + const immediateDeath = net.connect(port); |
52 | 54 | establish(immediateDeath).destroy();
|
53 | 55 |
|
54 | 56 | // Outliving
|
55 |
| - var outlivingTCP = net.connect(this.address().port); |
56 |
| - outlivingTCP.on('connect', function() { |
| 57 | + const outlivingTCP = net.connect(port, common.mustCall(() => { |
57 | 58 | outlivingTLS.destroy();
|
58 | 59 | next();
|
59 |
| - }); |
60 |
| - var outlivingTLS = establish(outlivingTCP); |
| 60 | + })); |
| 61 | + const outlivingTLS = establish(outlivingTCP); |
61 | 62 |
|
62 | 63 | function next() {
|
63 | 64 | // Already connected socket
|
64 |
| - var connected = net.connect(server.address().port, function() { |
| 65 | + const connected = net.connect(port, common.mustCall(() => { |
65 | 66 | establish(connected);
|
66 |
| - }); |
| 67 | + })); |
67 | 68 |
|
68 | 69 | // Connecting socket
|
69 |
| - var connecting = net.connect(server.address().port); |
| 70 | + const connecting = net.connect(port); |
70 | 71 | establish(connecting);
|
71 |
| - |
72 | 72 | }
|
73 | 73 | });
|
74 | 74 |
|
75 |
| -process.on('exit', function() { |
76 |
| - assert.equal(serverConnected, 2); |
77 |
| - assert.equal(clientConnected, 2); |
| 75 | +process.on('exit', () => { |
| 76 | + assert.strictEqual(serverConnected, 2); |
| 77 | + assert.strictEqual(clientConnected, 2); |
78 | 78 | });
|
0 commit comments