Spaces:
Paused
Paused
| ; | |
| var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) { | |
| if (k2 === undefined) k2 = k; | |
| var desc = Object.getOwnPropertyDescriptor(m, k); | |
| if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) { | |
| desc = { enumerable: true, get: function() { return m[k]; } }; | |
| } | |
| Object.defineProperty(o, k2, desc); | |
| }) : (function(o, m, k, k2) { | |
| if (k2 === undefined) k2 = k; | |
| o[k2] = m[k]; | |
| })); | |
| var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) { | |
| Object.defineProperty(o, "default", { enumerable: true, value: v }); | |
| }) : function(o, v) { | |
| o["default"] = v; | |
| }); | |
| var __importStar = (this && this.__importStar) || function (mod) { | |
| if (mod && mod.__esModule) return mod; | |
| var result = {}; | |
| if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k); | |
| __setModuleDefault(result, mod); | |
| return result; | |
| }; | |
| var __importDefault = (this && this.__importDefault) || function (mod) { | |
| return (mod && mod.__esModule) ? mod : { "default": mod }; | |
| }; | |
| Object.defineProperty(exports, "__esModule", { value: true }); | |
| exports.HttpProxyAgent = void 0; | |
| const net = __importStar(require("net")); | |
| const tls = __importStar(require("tls")); | |
| const debug_1 = __importDefault(require("debug")); | |
| const events_1 = require("events"); | |
| const agent_base_1 = require("agent-base"); | |
| const url_1 = require("url"); | |
| const debug = (0, debug_1.default)('http-proxy-agent'); | |
| /** | |
| * The `HttpProxyAgent` implements an HTTP Agent subclass that connects | |
| * to the specified "HTTP proxy server" in order to proxy HTTP requests. | |
| */ | |
| class HttpProxyAgent extends agent_base_1.Agent { | |
| constructor(proxy, opts) { | |
| super(opts); | |
| this.proxy = typeof proxy === 'string' ? new url_1.URL(proxy) : proxy; | |
| this.proxyHeaders = opts?.headers ?? {}; | |
| debug('Creating new HttpProxyAgent instance: %o', this.proxy.href); | |
| // Trim off the brackets from IPv6 addresses | |
| const host = (this.proxy.hostname || this.proxy.host).replace(/^\[|\]$/g, ''); | |
| const port = this.proxy.port | |
| ? parseInt(this.proxy.port, 10) | |
| : this.proxy.protocol === 'https:' | |
| ? 443 | |
| : 80; | |
| this.connectOpts = { | |
| ...(opts ? omit(opts, 'headers') : null), | |
| host, | |
| port, | |
| }; | |
| } | |
| addRequest(req, opts) { | |
| req._header = null; | |
| this.setRequestProps(req, opts); | |
| // @ts-expect-error `addRequest()` isn't defined in `@types/node` | |
| super.addRequest(req, opts); | |
| } | |
| setRequestProps(req, opts) { | |
| const { proxy } = this; | |
| const protocol = opts.secureEndpoint ? 'https:' : 'http:'; | |
| const hostname = req.getHeader('host') || 'localhost'; | |
| const base = `${protocol}//${hostname}`; | |
| const url = new url_1.URL(req.path, base); | |
| if (opts.port !== 80) { | |
| url.port = String(opts.port); | |
| } | |
| // Change the `http.ClientRequest` instance's "path" field | |
| // to the absolute path of the URL that will be requested. | |
| req.path = String(url); | |
| // Inject the `Proxy-Authorization` header if necessary. | |
| const headers = typeof this.proxyHeaders === 'function' | |
| ? this.proxyHeaders() | |
| : { ...this.proxyHeaders }; | |
| if (proxy.username || proxy.password) { | |
| const auth = `${decodeURIComponent(proxy.username)}:${decodeURIComponent(proxy.password)}`; | |
| headers['Proxy-Authorization'] = `Basic ${Buffer.from(auth).toString('base64')}`; | |
| } | |
| if (!headers['Proxy-Connection']) { | |
| headers['Proxy-Connection'] = this.keepAlive | |
| ? 'Keep-Alive' | |
| : 'close'; | |
| } | |
| for (const name of Object.keys(headers)) { | |
| const value = headers[name]; | |
| if (value) { | |
| req.setHeader(name, value); | |
| } | |
| } | |
| } | |
| async connect(req, opts) { | |
| req._header = null; | |
| if (!req.path.includes('://')) { | |
| this.setRequestProps(req, opts); | |
| } | |
| // At this point, the http ClientRequest's internal `_header` field | |
| // might have already been set. If this is the case then we'll need | |
| // to re-generate the string since we just changed the `req.path`. | |
| let first; | |
| let endOfHeaders; | |
| debug('Regenerating stored HTTP header string for request'); | |
| req._implicitHeader(); | |
| if (req.outputData && req.outputData.length > 0) { | |
| debug('Patching connection write() output buffer with updated header'); | |
| first = req.outputData[0].data; | |
| endOfHeaders = first.indexOf('\r\n\r\n') + 4; | |
| req.outputData[0].data = | |
| req._header + first.substring(endOfHeaders); | |
| debug('Output buffer: %o', req.outputData[0].data); | |
| } | |
| // Create a socket connection to the proxy server. | |
| let socket; | |
| if (this.proxy.protocol === 'https:') { | |
| debug('Creating `tls.Socket`: %o', this.connectOpts); | |
| socket = tls.connect(this.connectOpts); | |
| } | |
| else { | |
| debug('Creating `net.Socket`: %o', this.connectOpts); | |
| socket = net.connect(this.connectOpts); | |
| } | |
| // Wait for the socket's `connect` event, so that this `callback()` | |
| // function throws instead of the `http` request machinery. This is | |
| // important for i.e. `PacProxyAgent` which determines a failed proxy | |
| // connection via the `callback()` function throwing. | |
| await (0, events_1.once)(socket, 'connect'); | |
| return socket; | |
| } | |
| } | |
| HttpProxyAgent.protocols = ['http', 'https']; | |
| exports.HttpProxyAgent = HttpProxyAgent; | |
| function omit(obj, ...keys) { | |
| const ret = {}; | |
| let key; | |
| for (key in obj) { | |
| if (!keys.includes(key)) { | |
| ret[key] = obj[key]; | |
| } | |
| } | |
| return ret; | |
| } | |
| //# sourceMappingURL=index.js.map |