diff --git a/lib/request.js b/lib/request.js index 1b4eb14..2072289 100644 --- a/lib/request.js +++ b/lib/request.js @@ -13,7 +13,8 @@ function buildRequest (opts) { const isUndici = !!opts.undici const requests = { 'http:': opts.requests && opts.requests.http ? opts.requests.http : http, - 'https:': opts.requests && opts.requests.https ? opts.requests.https : https + 'https:': + opts.requests && opts.requests.https ? opts.requests.https : https } const baseUrl = opts.base const rejectUnauthorized = opts.rejectUnauthorized @@ -26,7 +27,7 @@ function buildRequest (opts) { if (semver.lt(process.version, '9.0.0')) { throw new Error('Http2 support requires Node version >= 9.0.0') } - if (!opts.base) throw new Error('Option base is required when http2 is true') + if (!opts.base) { throw new Error('Option base is required when http2 is true') } } else { agents = { 'http:': new http.Agent(agentOption(opts)), @@ -71,25 +72,37 @@ function buildRequest (opts) { if (err) { done(err) } else { - setImmediate(() => done(null, { statusCode: res.statusCode, headers: res.headers, stream: res.body })) + setImmediate(() => + done(null, { + statusCode: res.statusCode, + headers: res.headers, + stream: res.body + }) + ) } }) } function handleHttp1Req (opts, done) { const req = requests[opts.url.protocol].request({ - ...opts.request, method: opts.method, port: opts.url.port, path: opts.url.pathname + opts.qs, hostname: opts.url.hostname, headers: opts.headers, - agent: agents[opts.url.protocol] + agent: agents[opts.url.protocol], + ...opts.request }) req.on('error', done) req.on('timeout', () => req.abort()) - req.on('response', res => { - setImmediate(() => done(null, { statusCode: res.statusCode, headers: res.headers, stream: res })) + req.on('response', (res) => { + setImmediate(() => + done(null, { + statusCode: res.statusCode, + headers: res.headers, + stream: res + }) + ) }) end(req, opts.body, done) } @@ -121,7 +134,7 @@ function buildRequest (opts) { if (!isGet) { end(req, opts.body, done) } - eos(req, err => { + eos(req, (err) => { if (err) done(err) }) req.on('timeout', () => { @@ -130,7 +143,7 @@ function buildRequest (opts) { req.destroy(err) }) - req.on('response', headers => { + req.on('response', (headers) => { setImmediate(() => { const statusCode = headers[':status'] done(null, { statusCode, headers, stream: req }) @@ -155,7 +168,7 @@ function end (req, body, cb) { if (!body || typeof body === 'string') { req.end(body) } else { - pump(body, req, err => { + pump(body, req, (err) => { if (err) cb(err) }) }