File Explorer

/var/runtime/node_modules/@aws-sdk/node_modules/undici/lib/core
This explorer reads the filesystem of the server it runs on, so /workspace/user isn't present here. Browsing and the terminal still work against this server's own disk from /.
0 dirs
10 files
util.js25.4 KB · 993 lines
1'use strict'2 3const assert = require('node:assert')4const { kDestroyed, kBodyUsed, kListeners, kBody } = require('./symbols')5const { IncomingMessage } = require('node:http')6const stream = require('node:stream')7const net = require('node:net')8const { stringify } = require('node:querystring')9const { EventEmitter: EE } = require('node:events')10const timers = require('../util/timers')11const { InvalidArgumentError, ConnectTimeoutError } = require('./errors')12const { headerNameLowerCasedRecord } = require('./constants')13const { tree } = require('./tree')14 15const [nodeMajor, nodeMinor] = process.versions.node.split('.', 2).map(v => Number(v))16 17class BodyAsyncIterable {18  constructor (body) {19    this[kBody] = body20    this[kBodyUsed] = false21  }22 23  async * [Symbol.asyncIterator] () {24    assert(!this[kBodyUsed], 'disturbed')25    this[kBodyUsed] = true26    yield * this[kBody]27  }28}29 30function noop () {}31 32/**33 * @param {*} body34 * @returns {*}35 */36function wrapRequestBody (body) {37  if (isStream(body)) {38    // TODO (fix): Provide some way for the user to cache the file to e.g. /tmp39    // so that it can be dispatched again?40    // TODO (fix): Do we need 100-expect support to provide a way to do this properly?41    if (bodyLength(body) === 0) {42      body43        .on('data', function () {44          assert(false)45        })46    }47 48    if (typeof body.readableDidRead !== 'boolean') {49      body[kBodyUsed] = false50      EE.prototype.on.call(body, 'data', function () {51        this[kBodyUsed] = true52      })53    }54 55    return body56  } else if (body && typeof body.pipeTo === 'function') {57    // TODO (fix): We can't access ReadableStream internal state58    // to determine whether or not it has been disturbed. This is just59    // a workaround.60    return new BodyAsyncIterable(body)61  } else if (body && isFormDataLike(body)) {62    return body63  } else if (64    body &&65    typeof body !== 'string' &&66    !ArrayBuffer.isView(body) &&67    isIterable(body)68  ) {69    // TODO: Should we allow re-using iterable if !this.opts.idempotent70    // or through some other flag?71    return new BodyAsyncIterable(body)72  } else {73    return body74  }75}76 77/**78 * @param {*} obj79 * @returns {obj is import('node:stream').Stream}80 */81function isStream (obj) {82  return obj && typeof obj === 'object' && typeof obj.pipe === 'function' && typeof obj.on === 'function'83}84 85/**86 * @param {*} object87 * @returns {object is Blob}88 * based on https://github.com/node-fetch/fetch-blob/blob/8ab587d34080de94140b54f07168451e7d0b655e/index.js#L229-L241 (MIT License)89 */90function isBlobLike (object) {91  if (object === null) {92    return false93  } else if (object instanceof Blob) {94    return true95  } else if (typeof object !== 'object') {96    return false97  } else {98    const sTag = object[Symbol.toStringTag]99 100    return (sTag === 'Blob' || sTag === 'File') && (101      ('stream' in object && typeof object.stream === 'function') ||102      ('arrayBuffer' in object && typeof object.arrayBuffer === 'function')103    )104  }105}106 107/**108 * @param {string} url The path to check for query strings or fragments.109 * @returns {boolean} Returns true if the path contains a query string or fragment.110 */111function pathHasQueryOrFragment (url) {112  return (113    url.includes('?') ||114    url.includes('#')115  )116}117 118/**119 * @param {string} url The URL to add the query params to120 * @param {import('node:querystring').ParsedUrlQueryInput} queryParams The object to serialize into a URL query string121 * @returns {string} The URL with the query params added122 */123function serializePathWithQuery (url, queryParams) {124  if (pathHasQueryOrFragment(url)) {125    throw new Error('Query params cannot be passed when url already contains "?" or "#".')126  }127 128  const stringified = stringify(queryParams)129 130  if (stringified) {131    url += '?' + stringified132  }133 134  return url135}136 137/**138 * @param {number|string|undefined} port139 * @returns {boolean}140 */141function isValidPort (port) {142  const value = parseInt(port, 10)143  return (144    value === Number(port) &&145    value >= 0 &&146    value <= 65535147  )148}149 150/**151 * Check if the value is a valid http or https prefixed string.152 *153 * @param {string} value154 * @returns {boolean}155 */156function isHttpOrHttpsPrefixed (value) {157  return (158    value != null &&159    value[0] === 'h' &&160    value[1] === 't' &&161    value[2] === 't' &&162    value[3] === 'p' &&163    (164      value[4] === ':' ||165      (166        value[4] === 's' &&167        value[5] === ':'168      )169    )170  )171}172 173/**174 * @param {string|URL|Record<string,string>} url175 * @returns {URL}176 */177function parseURL (url) {178  if (typeof url === 'string') {179    /**180     * @type {URL}181     */182    url = new URL(url)183 184    if (!isHttpOrHttpsPrefixed(url.origin || url.protocol)) {185      throw new InvalidArgumentError('Invalid URL protocol: the URL must start with `http:` or `https:`.')186    }187 188    return url189  }190 191  if (!url || typeof url !== 'object') {192    throw new InvalidArgumentError('Invalid URL: The URL argument must be a non-null object.')193  }194 195  if (!(url instanceof URL)) {196    if (url.port != null && url.port !== '' && isValidPort(url.port) === false) {197      throw new InvalidArgumentError('Invalid URL: port must be a valid integer or a string representation of an integer.')198    }199 200    if (url.path != null && typeof url.path !== 'string') {201      throw new InvalidArgumentError('Invalid URL path: the path must be a string or null/undefined.')202    }203 204    if (url.pathname != null && typeof url.pathname !== 'string') {205      throw new InvalidArgumentError('Invalid URL pathname: the pathname must be a string or null/undefined.')206    }207 208    if (url.hostname != null && typeof url.hostname !== 'string') {209      throw new InvalidArgumentError('Invalid URL hostname: the hostname must be a string or null/undefined.')210    }211 212    if (url.origin != null && typeof url.origin !== 'string') {213      throw new InvalidArgumentError('Invalid URL origin: the origin must be a string or null/undefined.')214    }215 216    if (!isHttpOrHttpsPrefixed(url.origin || url.protocol)) {217      throw new InvalidArgumentError('Invalid URL protocol: the URL must start with `http:` or `https:`.')218    }219 220    const port = url.port != null221      ? url.port222      : (url.protocol === 'https:' ? 443 : 80)223    let origin = url.origin != null224      ? url.origin225      : `${url.protocol || ''}//${url.hostname || ''}:${port}`226    let path = url.path != null227      ? url.path228      : `${url.pathname || ''}${url.search || ''}`229 230    if (origin[origin.length - 1] === '/') {231      origin = origin.slice(0, origin.length - 1)232    }233 234    if (path && path[0] !== '/') {235      path = `/${path}`236    }237    // new URL(path, origin) is unsafe when `path` contains an absolute URL238    // From https://developer.mozilla.org/en-US/docs/Web/API/URL/URL:239    // If first parameter is a relative URL, second param is required, and will be used as the base URL.240    // If first parameter is an absolute URL, a given second param will be ignored.241    return new URL(`${origin}${path}`)242  }243 244  if (!isHttpOrHttpsPrefixed(url.origin || url.protocol)) {245    throw new InvalidArgumentError('Invalid URL protocol: the URL must start with `http:` or `https:`.')246  }247 248  return url249}250 251/**252 * @param {string|URL|Record<string, string>} url253 * @returns {URL}254 */255function parseOrigin (url) {256  url = parseURL(url)257 258  if (url.pathname !== '/' || url.search || url.hash) {259    throw new InvalidArgumentError('invalid url')260  }261 262  return url263}264 265/**266 * @param {string} host267 * @returns {string}268 */269function getHostname (host) {270  if (host[0] === '[') {271    const idx = host.indexOf(']')272 273    assert(idx !== -1)274    return host.substring(1, idx)275  }276 277  const idx = host.indexOf(':')278  if (idx === -1) return host279 280  return host.substring(0, idx)281}282 283/**284 * IP addresses are not valid server names per RFC6066285 * Currently, the only server names supported are DNS hostnames286 * @param {string|null} host287 * @returns {string|null}288 */289function getServerName (host) {290  if (!host) {291    return null292  }293 294  assert(typeof host === 'string')295 296  const servername = getHostname(host)297  if (net.isIP(servername)) {298    return ''299  }300 301  return servername302}303 304/**305 * @function306 * @template T307 * @param {T} obj308 * @returns {T}309 */310function deepClone (obj) {311  return JSON.parse(JSON.stringify(obj))312}313 314/**315 * @param {*} obj316 * @returns {obj is AsyncIterable}317 */318function isAsyncIterable (obj) {319  return !!(obj != null && typeof obj[Symbol.asyncIterator] === 'function')320}321 322/**323 * @param {*} obj324 * @returns {obj is Iterable}325 */326function isIterable (obj) {327  return !!(obj != null && (typeof obj[Symbol.iterator] === 'function' || typeof obj[Symbol.asyncIterator] === 'function'))328}329 330/**331 * Checks whether an object has a safe Symbol.iterator — i.e. one that is332 * either own or inherited from a non-Object.prototype chain.  This prevents333 * prototype-pollution attacks from injecting a fake iterator on334 * Object.prototype.335 * @param {object} obj336 * @returns {boolean}337 */338function hasSafeIterator (obj) {339  const prototype = Object.getPrototypeOf(obj)340  const ownIterator = Object.prototype.hasOwnProperty.call(obj, Symbol.iterator)341  return ownIterator || (prototype != null && prototype !== Object.prototype && typeof obj[Symbol.iterator] === 'function')342}343 344/**345 * @param {Blob|Buffer|import ('stream').Stream} body346 * @returns {number|null}347 */348function bodyLength (body) {349  if (body == null) {350    return 0351  } else if (isStream(body)) {352    const state = body._readableState353    return state && state.objectMode === false && state.ended === true && Number.isFinite(state.length)354      ? state.length355      : null356  } else if (isBlobLike(body)) {357    return body.size != null ? body.size : null358  } else if (isBuffer(body)) {359    return body.byteLength360  }361 362  return null363}364 365/**366 * @param {import ('stream').Stream} body367 * @returns {boolean}368 */369function isDestroyed (body) {370  return body && !!(body.destroyed || body[kDestroyed] || (stream.isDestroyed?.(body)))371}372 373/**374 * @param {import ('stream').Stream} stream375 * @param {Error} [err]376 * @returns {void}377 */378function destroy (stream, err) {379  if (stream == null || !isStream(stream) || isDestroyed(stream)) {380    return381  }382 383  if (typeof stream.destroy === 'function') {384    if (Object.getPrototypeOf(stream).constructor === IncomingMessage) {385      // See: https://github.com/nodejs/node/pull/38505/files386      stream.socket = null387    }388 389    stream.destroy(err)390  } else if (err) {391    queueMicrotask(() => {392      stream.emit('error', err)393    })394  }395 396  if (stream.destroyed !== true) {397    stream[kDestroyed] = true398  }399}400 401const KEEPALIVE_TIMEOUT_EXPR = /timeout=(\d+)/402/**403 * @param {string} val404 * @returns {number | null}405 */406function parseKeepAliveTimeout (val) {407  const m = val.match(KEEPALIVE_TIMEOUT_EXPR)408  return m ? parseInt(m[1], 10) * 1000 : null409}410 411/**412 * Retrieves a header name and returns its lowercase value.413 * @param {string | Buffer} value Header name414 * @returns {string}415 */416function headerNameToString (value) {417  return typeof value === 'string'418    ? headerNameLowerCasedRecord[value] ?? value.toLowerCase()419    : tree.lookup(value) ?? value.toString('latin1').toLowerCase()420}421 422/**423 * Receive the buffer as a string and return its lowercase value.424 * @param {Buffer} value Header name425 * @returns {string}426 */427function bufferToLowerCasedHeaderName (value) {428  return tree.lookup(value) ?? value.toString('latin1').toLowerCase()429}430 431/**432 * @param {(Buffer | string)[]} headers433 * @param {Record<string, string | string[]>} [obj]434 * @returns {Record<string, string | string[]>}435 */436function parseHeaders (headers, obj) {437  if (obj === undefined) obj = {}438 439  for (let i = 0; i < headers.length; i += 2) {440    const key = headerNameToString(headers[i])441    let val = obj[key]442 443    if (val !== undefined) {444      if (!Object.hasOwn(obj, key)) {445        const headersValue = typeof headers[i + 1] === 'string'446          ? headers[i + 1]447          : Array.isArray(headers[i + 1])448            ? headers[i + 1].map(x => x.toString('latin1'))449            : headers[i + 1].toString('latin1')450 451        if (key === '__proto__') {452          Object.defineProperty(obj, key, {453            value: headersValue,454            enumerable: true,455            configurable: true,456            writable: true457          })458        } else {459          obj[key] = headersValue460        }461      } else {462        if (typeof val === 'string') {463          val = [val]464          obj[key] = val465        }466        val.push(headers[i + 1].toString('latin1'))467      }468    } else {469      const headersValue = typeof headers[i + 1] === 'string'470        ? headers[i + 1]471        : Array.isArray(headers[i + 1])472          ? headers[i + 1].map(x => x.toString('latin1'))473          : headers[i + 1].toString('latin1')474 475      obj[key] = headersValue476    }477  }478 479  return obj480}481 482/**483 * @param {Buffer[]} headers484 * @returns {string[]}485 */486function parseRawHeaders (headers) {487  const headersLength = headers.length488  /**489   * @type {string[]}490   */491  const ret = new Array(headersLength)492 493  let key494  let val495 496  for (let n = 0; n < headersLength; n += 2) {497    key = headers[n]498    val = headers[n + 1]499 500    typeof key !== 'string' && (key = key.toString())501    typeof val !== 'string' && (val = val.toString('latin1'))502 503    ret[n] = key504    ret[n + 1] = val505  }506 507  return ret508}509 510/**511 * @param {string[]} headers512 * @param {Buffer[]} headers513 */514function encodeRawHeaders (headers) {515  if (!Array.isArray(headers)) {516    throw new TypeError('expected headers to be an array')517  }518  return headers.map(x => Buffer.from(x))519}520 521/**522 * @param {*} buffer523 * @returns {buffer is Buffer}524 */525function isBuffer (buffer) {526  // See, https://github.com/mcollina/undici/pull/319527  return buffer instanceof Uint8Array || Buffer.isBuffer(buffer)528}529 530/**531 * Asserts that the handler object is a request handler.532 *533 * @param {object} handler534 * @param {string} method535 * @param {string} [upgrade]536 * @returns {asserts handler is import('../api/api-request').RequestHandler}537 */538function assertRequestHandler (handler, method, upgrade) {539  if (!handler || typeof handler !== 'object') {540    throw new InvalidArgumentError('handler must be an object')541  }542 543  if (typeof handler.onRequestStart === 'function') {544    // TODO (fix): More checks...545    return546  }547 548  if (typeof handler.onConnect !== 'function') {549    throw new InvalidArgumentError('invalid onConnect method')550  }551 552  if (typeof handler.onError !== 'function') {553    throw new InvalidArgumentError('invalid onError method')554  }555 556  if (typeof handler.onBodySent !== 'function' && handler.onBodySent !== undefined) {557    throw new InvalidArgumentError('invalid onBodySent method')558  }559 560  if (upgrade || method === 'CONNECT') {561    if (typeof handler.onUpgrade !== 'function') {562      throw new InvalidArgumentError('invalid onUpgrade method')563    }564  } else {565    if (typeof handler.onHeaders !== 'function') {566      throw new InvalidArgumentError('invalid onHeaders method')567    }568 569    if (typeof handler.onData !== 'function') {570      throw new InvalidArgumentError('invalid onData method')571    }572 573    if (typeof handler.onComplete !== 'function') {574      throw new InvalidArgumentError('invalid onComplete method')575    }576  }577}578 579/**580 * A body is disturbed if it has been read from and it cannot be re-used without581 * losing state or data.582 * @param {import('node:stream').Readable} body583 * @returns {boolean}584 */585function isDisturbed (body) {586  // TODO (fix): Why is body[kBodyUsed] needed?587  return !!(body && (stream.isDisturbed(body) || body[kBodyUsed]))588}589 590/**591 * @typedef {object} SocketInfo592 * @property {string} [localAddress]593 * @property {number} [localPort]594 * @property {string} [remoteAddress]595 * @property {number} [remotePort]596 * @property {string} [remoteFamily]597 * @property {number} [timeout]598 * @property {number} bytesWritten599 * @property {number} bytesRead600 */601 602/**603 * @param {import('net').Socket} socket604 * @returns {SocketInfo}605 */606function getSocketInfo (socket) {607  return {608    localAddress: socket.localAddress,609    localPort: socket.localPort,610    remoteAddress: socket.remoteAddress,611    remotePort: socket.remotePort,612    remoteFamily: socket.remoteFamily,613    timeout: socket.timeout,614    bytesWritten: socket.bytesWritten,615    bytesRead: socket.bytesRead616  }617}618 619/**620 * @param {Iterable} iterable621 * @returns {ReadableStream}622 */623function ReadableStreamFrom (iterable) {624  // We cannot use ReadableStream.from here because it does not return a byte stream.625 626  let iterator627  return new ReadableStream(628    {629      start () {630        iterator = iterable[Symbol.asyncIterator]()631      },632      pull (controller) {633        return iterator.next().then(({ done, value }) => {634          if (done) {635            return queueMicrotask(() => {636              controller.close()637              controller.byobRequest?.respond(0)638            })639          } else {640            const buf = Buffer.isBuffer(value) ? value : Buffer.from(value)641            if (buf.byteLength) {642              return controller.enqueue(new Uint8Array(buf))643            } else {644              return this.pull(controller)645            }646          }647        })648      },649      cancel () {650        return iterator.return()651      },652      type: 'bytes'653    }654  )655}656 657/**658 * The object should be a FormData instance and contains all the required659 * methods.660 * @param {*} object661 * @returns {object is FormData}662 */663function isFormDataLike (object) {664  return (665    object &&666    typeof object === 'object' &&667    typeof object.append === 'function' &&668    typeof object.delete === 'function' &&669    typeof object.get === 'function' &&670    typeof object.getAll === 'function' &&671    typeof object.has === 'function' &&672    typeof object.set === 'function' &&673    object[Symbol.toStringTag] === 'FormData'674  )675}676 677function addAbortListener (signal, listener) {678  if ('addEventListener' in signal) {679    signal.addEventListener('abort', listener, { once: true })680    return () => signal.removeEventListener('abort', listener)681  }682  signal.once('abort', listener)683  return () => signal.removeListener('abort', listener)684}685 686const validTokenChars = new Uint8Array([687  0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, // 0-15688  0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, // 16-31689  0, 1, 0, 1, 1, 1, 1, 1, 0, 0, 1, 1, 0, 1, 1, 0, // 32-47 (!"#$%&'()*+,-./)690  1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 0, 0, 0, 0, 0, 0, // 48-63 (0-9:;<=>?)691  0, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, // 64-79 (@A-O)692  1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 0, 0, 0, 1, 1, // 80-95 (P-Z[\]^_)693  1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, // 96-111 (`a-o)694  1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 0, 1, 0, 1, 0, // 112-127 (p-z{|}~)695  0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, // 128-143696  0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, // 144-159697  0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, // 160-175698  0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, // 176-191699  0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, // 192-207700  0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, // 208-223701  0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, // 224-239702  0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0  // 240-255703])704 705/**706 * @see https://tools.ietf.org/html/rfc7230#section-3.2.6707 * @param {number} c708 * @returns {boolean}709 */710function isTokenCharCode (c) {711  return (validTokenChars[c] === 1)712}713 714const tokenRegExp = /^[\^_`a-zA-Z\-0-9!#$%&'*+.|~]+$/715 716/**717 * @param {string} characters718 * @returns {boolean}719 */720function isValidHTTPToken (characters) {721  if (characters.length >= 12) return tokenRegExp.test(characters)722  if (characters.length === 0) return false723 724  for (let i = 0; i < characters.length; i++) {725    if (validTokenChars[characters.charCodeAt(i)] !== 1) {726      return false727    }728  }729  return true730}731 732// headerCharRegex have been lifted from733// https://github.com/nodejs/node/blob/main/lib/_http_common.js734 735/**736 * Matches if val contains an invalid field-vchar737 *  field-value    = *( field-content / obs-fold )738 *  field-content  = field-vchar [ 1*( SP / HTAB ) field-vchar ]739 *  field-vchar    = VCHAR / obs-text740 */741const headerCharRegex = /[^\t\x20-\x7e\x80-\xff]/742 743/**744 * @param {string} characters745 * @returns {boolean}746 */747function isValidHeaderValue (characters) {748  return !headerCharRegex.test(characters)749}750 751const rangeHeaderRegex = /^bytes (\d+)-(\d+)\/(\d+)?$/752 753/**754 * @typedef {object} RangeHeader755 * @property {number} start756 * @property {number | null} end757 * @property {number | null} size758 */759 760/**761 * Parse accordingly to RFC 9110762 * @see https://www.rfc-editor.org/rfc/rfc9110#field.content-range763 * @param {string} [range]764 * @returns {RangeHeader|null}765 */766function parseRangeHeader (range) {767  if (range == null || range === '') return { start: 0, end: null, size: null }768 769  const m = range ? range.match(rangeHeaderRegex) : null770  return m771    ? {772        start: parseInt(m[1]),773        end: m[2] ? parseInt(m[2]) : null,774        size: m[3] ? parseInt(m[3]) : null775      }776    : null777}778 779/**780 * @template {import("events").EventEmitter} T781 * @param {T} obj782 * @param {string} name783 * @param {(...args: any[]) => void} listener784 * @returns {T}785 */786function addListener (obj, name, listener) {787  const listeners = (obj[kListeners] ??= [])788  listeners.push([name, listener])789  obj.on(name, listener)790  return obj791}792 793/**794 * @template {import("events").EventEmitter} T795 * @param {T} obj796 * @returns {T}797 */798function removeAllListeners (obj) {799  if (obj[kListeners] != null) {800    for (const [name, listener] of obj[kListeners]) {801      obj.removeListener(name, listener)802    }803    obj[kListeners] = null804  }805  return obj806}807 808/**809 * @param {import ('../dispatcher/client')} client810 * @param {import ('../core/request')} request811 * @param {Error} err812 */813function errorRequest (client, request, err) {814  try {815    request.onError(err)816    assert(request.aborted)817  } catch (err) {818    client.emit('error', err)819  }820}821 822/**823 * @param {WeakRef<net.Socket>} socketWeakRef824 * @param {object} opts825 * @param {number} opts.timeout826 * @param {string} opts.hostname827 * @param {number} opts.port828 * @returns {() => void}829 */830const setupConnectTimeout = process.platform === 'win32'831  ? (socketWeakRef, opts) => {832      if (!opts.timeout) {833        return noop834      }835 836      let s1 = null837      let s2 = null838      const fastTimer = timers.setFastTimeout(() => {839      // setImmediate is added to make sure that we prioritize socket error events over timeouts840        s1 = setImmediate(() => {841        // Windows needs an extra setImmediate probably due to implementation differences in the socket logic842          s2 = setImmediate(() => onConnectTimeout(socketWeakRef.deref(), opts))843        })844      }, opts.timeout)845      return () => {846        timers.clearFastTimeout(fastTimer)847        clearImmediate(s1)848        clearImmediate(s2)849      }850    }851  : (socketWeakRef, opts) => {852      if (!opts.timeout) {853        return noop854      }855 856      let s1 = null857      const fastTimer = timers.setFastTimeout(() => {858      // setImmediate is added to make sure that we prioritize socket error events over timeouts859        s1 = setImmediate(() => {860          onConnectTimeout(socketWeakRef.deref(), opts)861        })862      }, opts.timeout)863      return () => {864        timers.clearFastTimeout(fastTimer)865        clearImmediate(s1)866      }867    }868 869/**870 * @param {net.Socket} socket871 * @param {object} opts872 * @param {number} opts.timeout873 * @param {string} opts.hostname874 * @param {number} opts.port875 */876function onConnectTimeout (socket, opts) {877  // The socket could be already garbage collected878  if (socket == null) {879    return880  }881 882  let message = 'Connect Timeout Error'883  if (Array.isArray(socket.autoSelectFamilyAttemptedAddresses)) {884    message += ` (attempted addresses: ${socket.autoSelectFamilyAttemptedAddresses.join(', ')},`885  } else {886    message += ` (attempted address: ${opts.hostname}:${opts.port},`887  }888 889  message += ` timeout: ${opts.timeout}ms)`890 891  destroy(socket, new ConnectTimeoutError(message))892}893 894/**895 * @param {string} urlString896 * @returns {string}897 */898function getProtocolFromUrlString (urlString) {899  if (900    urlString[0] === 'h' &&901    urlString[1] === 't' &&902    urlString[2] === 't' &&903    urlString[3] === 'p'904  ) {905    switch (urlString[4]) {906      case ':':907        return 'http:'908      case 's':909        if (urlString[5] === ':') {910          return 'https:'911        }912    }913  }914  // fallback if none of the usual suspects915  return urlString.slice(0, urlString.indexOf(':') + 1)916}917 918const kEnumerableProperty = Object.create(null)919kEnumerableProperty.enumerable = true920 921const normalizedMethodRecordsBase = {922  delete: 'DELETE',923  DELETE: 'DELETE',924  get: 'GET',925  GET: 'GET',926  head: 'HEAD',927  HEAD: 'HEAD',928  options: 'OPTIONS',929  OPTIONS: 'OPTIONS',930  post: 'POST',931  POST: 'POST',932  put: 'PUT',933  PUT: 'PUT'934}935 936const normalizedMethodRecords = {937  ...normalizedMethodRecordsBase,938  patch: 'patch',939  PATCH: 'PATCH'940}941 942// Note: object prototypes should not be able to be referenced. e.g. `Object#hasOwnProperty`.943Object.setPrototypeOf(normalizedMethodRecordsBase, null)944Object.setPrototypeOf(normalizedMethodRecords, null)945 946module.exports = {947  kEnumerableProperty,948  isDisturbed,949  isBlobLike,950  parseOrigin,951  parseURL,952  getServerName,953  isStream,954  isIterable,955  hasSafeIterator,956  isAsyncIterable,957  isDestroyed,958  headerNameToString,959  bufferToLowerCasedHeaderName,960  addListener,961  removeAllListeners,962  errorRequest,963  parseRawHeaders,964  encodeRawHeaders,965  parseHeaders,966  parseKeepAliveTimeout,967  destroy,968  bodyLength,969  deepClone,970  ReadableStreamFrom,971  isBuffer,972  assertRequestHandler,973  getSocketInfo,974  isFormDataLike,975  pathHasQueryOrFragment,976  serializePathWithQuery,977  addAbortListener,978  isValidHTTPToken,979  isValidHeaderValue,980  isTokenCharCode,981  parseRangeHeader,982  normalizedMethodRecordsBase,983  normalizedMethodRecords,984  isValidPort,985  isHttpOrHttpsPrefixed,986  nodeMajor,987  nodeMinor,988  safeHTTPMethods: Object.freeze(['GET', 'HEAD', 'OPTIONS', 'TRACE']),989  wrapRequestBody,990  setupConnectTimeout,991  getProtocolFromUrlString992}993