|
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