File Explorer

1'use strict'2 3const DispatcherBase = require('./dispatcher-base')4const { kClose, kDestroy, kClosed, kDestroyed, kDispatch, kNoProxyAgent, kHttpProxyAgent, kHttpsProxyAgent } = require('../core/symbols')5const ProxyAgent = require('./proxy-agent')6const Agent = require('./agent')7 8const DEFAULT_PORTS = {9  'http:': 80,10  'https:': 44311}12 13let experimentalWarned = false14 15class EnvHttpProxyAgent extends DispatcherBase {16  #noProxyValue = null17  #noProxyEntries = null18  #opts = null19 20  constructor (opts = {}) {21    super()22    this.#opts = opts23 24    if (!experimentalWarned) {25      experimentalWarned = true26      process.emitWarning('EnvHttpProxyAgent is experimental, expect them to change at any time.', {27        code: 'UNDICI-EHPA'28      })29    }30 31    const { httpProxy, httpsProxy, noProxy, ...agentOpts } = opts32 33    this[kNoProxyAgent] = new Agent(agentOpts)34 35    const HTTP_PROXY = httpProxy ?? process.env.http_proxy ?? process.env.HTTP_PROXY36    if (HTTP_PROXY) {37      this[kHttpProxyAgent] = new ProxyAgent({ ...agentOpts, uri: HTTP_PROXY })38    } else {39      this[kHttpProxyAgent] = this[kNoProxyAgent]40    }41 42    const HTTPS_PROXY = httpsProxy ?? process.env.https_proxy ?? process.env.HTTPS_PROXY43    if (HTTPS_PROXY) {44      this[kHttpsProxyAgent] = new ProxyAgent({ ...agentOpts, uri: HTTPS_PROXY })45    } else {46      this[kHttpsProxyAgent] = this[kHttpProxyAgent]47    }48 49    this.#parseNoProxy()50  }51 52  [kDispatch] (opts, handler) {53    const url = new URL(opts.origin)54    const agent = this.#getProxyAgentForUrl(url)55    return agent.dispatch(opts, handler)56  }57 58  async [kClose] () {59    await this[kNoProxyAgent].close()60    if (!this[kHttpProxyAgent][kClosed]) {61      await this[kHttpProxyAgent].close()62    }63    if (!this[kHttpsProxyAgent][kClosed]) {64      await this[kHttpsProxyAgent].close()65    }66  }67 68  async [kDestroy] (err) {69    await this[kNoProxyAgent].destroy(err)70    if (!this[kHttpProxyAgent][kDestroyed]) {71      await this[kHttpProxyAgent].destroy(err)72    }73    if (!this[kHttpsProxyAgent][kDestroyed]) {74      await this[kHttpsProxyAgent].destroy(err)75    }76  }77 78  #getProxyAgentForUrl (url) {79    let { protocol, host: hostname, port } = url80 81    // Stripping ports in this way instead of using parsedUrl.hostname to make82    // sure that the brackets around IPv6 addresses are kept.83    hostname = hostname.replace(/:\d*$/, '').toLowerCase()84    port = Number.parseInt(port, 10) || DEFAULT_PORTS[protocol] || 085    if (!this.#shouldProxy(hostname, port)) {86      return this[kNoProxyAgent]87    }88    if (protocol === 'https:') {89      return this[kHttpsProxyAgent]90    }91    return this[kHttpProxyAgent]92  }93 94  #shouldProxy (hostname, port) {95    if (this.#noProxyChanged) {96      this.#parseNoProxy()97    }98 99    if (this.#noProxyEntries.length === 0) {100      return true // Always proxy if NO_PROXY is not set or empty.101    }102    if (this.#noProxyValue === '*') {103      return false // Never proxy if wildcard is set.104    }105 106    for (let i = 0; i < this.#noProxyEntries.length; i++) {107      const entry = this.#noProxyEntries[i]108      if (entry.port && entry.port !== port) {109        continue // Skip if ports don't match.110      }111      if (!/^[.*]/.test(entry.hostname)) {112        // No wildcards, so don't proxy only if there is not an exact match.113        if (hostname === entry.hostname) {114          return false115        }116      } else {117        // Don't proxy if the hostname ends with the no_proxy host.118        if (hostname.endsWith(entry.hostname.replace(/^\*/, ''))) {119          return false120        }121      }122    }123 124    return true125  }126 127  #parseNoProxy () {128    const noProxyValue = this.#opts.noProxy ?? this.#noProxyEnv129    const noProxySplit = noProxyValue.split(/[,\s]/)130    const noProxyEntries = []131 132    for (let i = 0; i < noProxySplit.length; i++) {133      const entry = noProxySplit[i]134      if (!entry) {135        continue136      }137      const parsed = entry.match(/^(.+):(\d+)$/)138      noProxyEntries.push({139        hostname: (parsed ? parsed[1] : entry).toLowerCase(),140        port: parsed ? Number.parseInt(parsed[2], 10) : 0141      })142    }143 144    this.#noProxyValue = noProxyValue145    this.#noProxyEntries = noProxyEntries146  }147 148  get #noProxyChanged () {149    if (this.#opts.noProxy !== undefined) {150      return false151    }152    return this.#noProxyValue !== this.#noProxyEnv153  }154 155  get #noProxyEnv () {156    return process.env.no_proxy ?? process.env.NO_PROXY ?? ''157  }158}159 160module.exports = EnvHttpProxyAgent161