@@ -99,7 +99,7 @@ function ClientRequest(input, options, cb) {
99
99
}
100
100
101
101
var agent = options . agent ;
102
- var defaultAgent = options . _defaultAgent || Agent . globalAgent ;
102
+ const defaultAgent = options . _defaultAgent || Agent . globalAgent ;
103
103
if ( agent === false ) {
104
104
agent = new defaultAgent . constructor ( ) ;
105
105
} else if ( agent === null || agent === undefined ) {
@@ -115,7 +115,7 @@ function ClientRequest(input, options, cb) {
115
115
}
116
116
this . agent = agent ;
117
117
118
- var protocol = options . protocol || defaultAgent . protocol ;
118
+ const protocol = options . protocol || defaultAgent . protocol ;
119
119
var expectedProtocol = defaultAgent . protocol ;
120
120
if ( this . agent && this . agent . protocol )
121
121
expectedProtocol = this . agent . protocol ;
@@ -131,20 +131,20 @@ function ClientRequest(input, options, cb) {
131
131
throw new ERR_INVALID_PROTOCOL ( protocol , expectedProtocol ) ;
132
132
}
133
133
134
- var defaultPort = options . defaultPort ||
134
+ const defaultPort = options . defaultPort ||
135
135
this . agent && this . agent . defaultPort ;
136
136
137
- var port = options . port = options . port || defaultPort || 80 ;
138
- var host = options . host = validateHost ( options . hostname , 'hostname' ) ||
137
+ const port = options . port = options . port || defaultPort || 80 ;
138
+ const host = options . host = validateHost ( options . hostname , 'hostname' ) ||
139
139
validateHost ( options . host , 'host' ) || 'localhost' ;
140
140
141
- var setHost = ( options . setHost === undefined || Boolean ( options . setHost ) ) ;
141
+ const setHost = ( options . setHost === undefined || Boolean ( options . setHost ) ) ;
142
142
143
143
this . socketPath = options . socketPath ;
144
144
this . timeout = options . timeout ;
145
145
146
146
var method = options . method ;
147
- var methodIsString = ( typeof method === 'string' ) ;
147
+ const methodIsString = ( typeof method === 'string' ) ;
148
148
if ( method !== null && method !== undefined && ! methodIsString ) {
149
149
throw new ERR_INVALID_ARG_TYPE ( 'method' , 'string' , method ) ;
150
150
}
@@ -197,7 +197,7 @@ function ClientRequest(input, options, cb) {
197
197
}
198
198
}
199
199
200
- var headersArray = Array . isArray ( options . headers ) ;
200
+ const headersArray = Array . isArray ( options . headers ) ;
201
201
if ( ! headersArray ) {
202
202
if ( options . headers ) {
203
203
var keys = Object . keys ( options . headers ) ;
@@ -244,7 +244,7 @@ function ClientRequest(input, options, cb) {
244
244
options . headers ) ;
245
245
}
246
246
247
- var oncreate = ( err , socket ) => {
247
+ const oncreate = ( err , socket ) => {
248
248
if ( called )
249
249
return ;
250
250
called = true ;
@@ -327,15 +327,15 @@ function emitAbortNT() {
327
327
328
328
function createHangUpError ( ) {
329
329
// eslint-disable-next-line no-restricted-syntax
330
- var error = new Error ( 'socket hang up' ) ;
330
+ const error = new Error ( 'socket hang up' ) ;
331
331
error . code = 'ECONNRESET' ;
332
332
return error ;
333
333
}
334
334
335
335
336
336
function socketCloseListener ( ) {
337
- var socket = this ;
338
- var req = socket . _httpMessage ;
337
+ const socket = this ;
338
+ const req = socket . _httpMessage ;
339
339
debug ( 'HTTP socket close' ) ;
340
340
341
341
// Pull through final chunk, if anything is buffered.
@@ -386,8 +386,8 @@ function socketCloseListener() {
386
386
}
387
387
388
388
function socketErrorListener ( err ) {
389
- var socket = this ;
390
- var req = socket . _httpMessage ;
389
+ const socket = this ;
390
+ const req = socket . _httpMessage ;
391
391
debug ( 'SOCKET ERROR:' , err . message , err . stack ) ;
392
392
393
393
if ( req ) {
@@ -400,7 +400,7 @@ function socketErrorListener(err) {
400
400
// Handle any pending data
401
401
socket . read ( ) ;
402
402
403
- var parser = socket . parser ;
403
+ const parser = socket . parser ;
404
404
if ( parser ) {
405
405
parser . finish ( ) ;
406
406
freeParser ( parser , req , socket ) ;
@@ -413,16 +413,16 @@ function socketErrorListener(err) {
413
413
}
414
414
415
415
function freeSocketErrorListener ( err ) {
416
- var socket = this ;
416
+ const socket = this ;
417
417
debug ( 'SOCKET ERROR on FREE socket:' , err . message , err . stack ) ;
418
418
socket . destroy ( ) ;
419
419
socket . emit ( 'agentRemove' ) ;
420
420
}
421
421
422
422
function socketOnEnd ( ) {
423
- var socket = this ;
424
- var req = this . _httpMessage ;
425
- var parser = this . parser ;
423
+ const socket = this ;
424
+ const req = this . _httpMessage ;
425
+ const parser = this . parser ;
426
426
427
427
if ( ! req . res && ! req . socket . _hadError ) {
428
428
// If we don't have a response then we know that the socket
@@ -438,13 +438,13 @@ function socketOnEnd() {
438
438
}
439
439
440
440
function socketOnData ( d ) {
441
- var socket = this ;
442
- var req = this . _httpMessage ;
443
- var parser = this . parser ;
441
+ const socket = this ;
442
+ const req = this . _httpMessage ;
443
+ const parser = this . parser ;
444
444
445
445
assert ( parser && parser . socket === socket ) ;
446
446
447
- var ret = parser . execute ( d ) ;
447
+ const ret = parser . execute ( d ) ;
448
448
if ( ret instanceof Error ) {
449
449
debug ( 'parse error' , ret ) ;
450
450
freeParser ( parser , req , socket ) ;
@@ -506,8 +506,8 @@ function statusIsInformational(status) {
506
506
507
507
// client
508
508
function parserOnIncomingClient ( res , shouldKeepAlive ) {
509
- var socket = this . socket ;
510
- var req = socket . _httpMessage ;
509
+ const socket = this . socket ;
510
+ const req = socket . _httpMessage ;
511
511
512
512
debug ( 'AGENT incoming response!' ) ;
513
513
@@ -557,7 +557,7 @@ function parserOnIncomingClient(res, shouldKeepAlive) {
557
557
// Add our listener first, so that we guarantee socket cleanup
558
558
res . on ( 'end' , responseOnEnd ) ;
559
559
req . on ( 'prefinish' , requestOnPrefinish ) ;
560
- var handled = req . emit ( 'response' , res ) ;
560
+ const handled = req . emit ( 'response' , res ) ;
561
561
562
562
// If the user did not listen for the 'response' event, then they
563
563
// can't possibly read the data, so we ._dump() it into the void
@@ -573,7 +573,7 @@ function parserOnIncomingClient(res, shouldKeepAlive) {
573
573
574
574
// client
575
575
function responseKeepAlive ( res , req ) {
576
- var socket = req . socket ;
576
+ const socket = req . socket ;
577
577
578
578
if ( ! req . shouldKeepAlive ) {
579
579
if ( socket . writable ) {
@@ -627,7 +627,7 @@ function emitFreeNT(socket) {
627
627
}
628
628
629
629
function tickOnSocket ( req , socket ) {
630
- var parser = parsers . alloc ( ) ;
630
+ const parser = parsers . alloc ( ) ;
631
631
req . socket = socket ;
632
632
req . connection = socket ;
633
633
parser . reinitialize ( HTTPParser . RESPONSE , parser [ is_reused_symbol ] ) ;
0 commit comments