diff options
Diffstat (limited to 'node_modules/got/source/utils')
-rw-r--r-- | node_modules/got/source/utils/deep-freeze.js | 12 | ||||
-rw-r--r-- | node_modules/got/source/utils/get-body-size.js | 32 | ||||
-rw-r--r-- | node_modules/got/source/utils/is-form-data.js | 4 | ||||
-rw-r--r-- | node_modules/got/source/utils/timed-out.js | 160 | ||||
-rw-r--r-- | node_modules/got/source/utils/url-to-options.js | 25 |
5 files changed, 0 insertions, 233 deletions
diff --git a/node_modules/got/source/utils/deep-freeze.js b/node_modules/got/source/utils/deep-freeze.js deleted file mode 100644 index 5052b71..0000000 --- a/node_modules/got/source/utils/deep-freeze.js +++ /dev/null @@ -1,12 +0,0 @@ -'use strict'; -const is = require('@sindresorhus/is'); - -module.exports = function deepFreeze(object) { - for (const [key, value] of Object.entries(object)) { - if (is.plainObject(value) || is.array(value)) { - deepFreeze(object[key]); - } - } - - return Object.freeze(object); -}; diff --git a/node_modules/got/source/utils/get-body-size.js b/node_modules/got/source/utils/get-body-size.js deleted file mode 100644 index 0df5af2..0000000 --- a/node_modules/got/source/utils/get-body-size.js +++ /dev/null @@ -1,32 +0,0 @@ -'use strict'; -const fs = require('fs'); -const util = require('util'); -const is = require('@sindresorhus/is'); -const isFormData = require('./is-form-data'); - -module.exports = async options => { - const {body} = options; - - if (options.headers['content-length']) { - return Number(options.headers['content-length']); - } - - if (!body && !options.stream) { - return 0; - } - - if (is.string(body)) { - return Buffer.byteLength(body); - } - - if (isFormData(body)) { - return util.promisify(body.getLength.bind(body))(); - } - - if (body instanceof fs.ReadStream) { - const {size} = await util.promisify(fs.stat)(body.path); - return size; - } - - return null; -}; diff --git a/node_modules/got/source/utils/is-form-data.js b/node_modules/got/source/utils/is-form-data.js deleted file mode 100644 index 0033618..0000000 --- a/node_modules/got/source/utils/is-form-data.js +++ /dev/null @@ -1,4 +0,0 @@ -'use strict'; -const is = require('@sindresorhus/is'); - -module.exports = body => is.nodeStream(body) && is.function(body.getBoundary); diff --git a/node_modules/got/source/utils/timed-out.js b/node_modules/got/source/utils/timed-out.js deleted file mode 100644 index 33611a7..0000000 --- a/node_modules/got/source/utils/timed-out.js +++ /dev/null @@ -1,160 +0,0 @@ -'use strict'; -const net = require('net'); - -class TimeoutError extends Error { - constructor(threshold, event) { - super(`Timeout awaiting '${event}' for ${threshold}ms`); - this.name = 'TimeoutError'; - this.code = 'ETIMEDOUT'; - this.event = event; - } -} - -const reentry = Symbol('reentry'); - -const noop = () => {}; - -module.exports = (request, delays, options) => { - /* istanbul ignore next: this makes sure timed-out isn't called twice */ - if (request[reentry]) { - return; - } - - request[reentry] = true; - - let stopNewTimeouts = false; - - const addTimeout = (delay, callback, ...args) => { - // An error had been thrown before. Going further would result in uncaught errors. - // See https://github.com/sindresorhus/got/issues/631#issuecomment-435675051 - if (stopNewTimeouts) { - return noop; - } - - // Event loop order is timers, poll, immediates. - // The timed event may emit during the current tick poll phase, so - // defer calling the handler until the poll phase completes. - let immediate; - const timeout = setTimeout(() => { - immediate = setImmediate(callback, delay, ...args); - /* istanbul ignore next: added in node v9.7.0 */ - if (immediate.unref) { - immediate.unref(); - } - }, delay); - - /* istanbul ignore next: in order to support electron renderer */ - if (timeout.unref) { - timeout.unref(); - } - - const cancel = () => { - clearTimeout(timeout); - clearImmediate(immediate); - }; - - cancelers.push(cancel); - - return cancel; - }; - - const {host, hostname} = options; - const timeoutHandler = (delay, event) => { - request.emit('error', new TimeoutError(delay, event)); - request.once('error', () => {}); // Ignore the `socket hung up` error made by request.abort() - - request.abort(); - }; - - const cancelers = []; - const cancelTimeouts = () => { - stopNewTimeouts = true; - cancelers.forEach(cancelTimeout => cancelTimeout()); - }; - - request.once('error', cancelTimeouts); - request.once('response', response => { - response.once('end', cancelTimeouts); - }); - - if (delays.request !== undefined) { - addTimeout(delays.request, timeoutHandler, 'request'); - } - - if (delays.socket !== undefined) { - const socketTimeoutHandler = () => { - timeoutHandler(delays.socket, 'socket'); - }; - - request.setTimeout(delays.socket, socketTimeoutHandler); - - // `request.setTimeout(0)` causes a memory leak. - // We can just remove the listener and forget about the timer - it's unreffed. - // See https://github.com/sindresorhus/got/issues/690 - cancelers.push(() => request.removeListener('timeout', socketTimeoutHandler)); - } - - if (delays.lookup !== undefined && !request.socketPath && !net.isIP(hostname || host)) { - request.once('socket', socket => { - /* istanbul ignore next: hard to test */ - if (socket.connecting) { - const cancelTimeout = addTimeout(delays.lookup, timeoutHandler, 'lookup'); - socket.once('lookup', cancelTimeout); - } - }); - } - - if (delays.connect !== undefined) { - request.once('socket', socket => { - /* istanbul ignore next: hard to test */ - if (socket.connecting) { - const timeConnect = () => addTimeout(delays.connect, timeoutHandler, 'connect'); - - if (request.socketPath || net.isIP(hostname || host)) { - socket.once('connect', timeConnect()); - } else { - socket.once('lookup', error => { - if (error === null) { - socket.once('connect', timeConnect()); - } - }); - } - } - }); - } - - if (delays.secureConnect !== undefined && options.protocol === 'https:') { - request.once('socket', socket => { - /* istanbul ignore next: hard to test */ - if (socket.connecting) { - socket.once('connect', () => { - const cancelTimeout = addTimeout(delays.secureConnect, timeoutHandler, 'secureConnect'); - socket.once('secureConnect', cancelTimeout); - }); - } - }); - } - - if (delays.send !== undefined) { - request.once('socket', socket => { - const timeRequest = () => addTimeout(delays.send, timeoutHandler, 'send'); - /* istanbul ignore next: hard to test */ - if (socket.connecting) { - socket.once('connect', () => { - request.once('upload-complete', timeRequest()); - }); - } else { - request.once('upload-complete', timeRequest()); - } - }); - } - - if (delays.response !== undefined) { - request.once('upload-complete', () => { - const cancelTimeout = addTimeout(delays.response, timeoutHandler, 'response'); - request.once('response', cancelTimeout); - }); - } -}; - -module.exports.TimeoutError = TimeoutError; diff --git a/node_modules/got/source/utils/url-to-options.js b/node_modules/got/source/utils/url-to-options.js deleted file mode 100644 index 848ef30..0000000 --- a/node_modules/got/source/utils/url-to-options.js +++ /dev/null @@ -1,25 +0,0 @@ -'use strict'; -const is = require('@sindresorhus/is'); - -module.exports = url => { - const options = { - protocol: url.protocol, - hostname: url.hostname.startsWith('[') ? url.hostname.slice(1, -1) : url.hostname, - hash: url.hash, - search: url.search, - pathname: url.pathname, - href: url.href - }; - - if (is.string(url.port) && url.port.length > 0) { - options.port = Number(url.port); - } - - if (url.username || url.password) { - options.auth = `${url.username}:${url.password}`; - } - - options.path = is.null(url.search) ? url.pathname : `${url.pathname}${url.search}`; - - return options; -}; |