aboutsummaryrefslogtreecommitdiff
path: root/deps/npm/node_modules/npm-profile/node_modules/make-fetch-happen/node_modules/socks-proxy-agent/node_modules/socks/lib/socks-agent.js
diff options
context:
space:
mode:
authorMyles Borins <myles.borins@gmail.com>2017-10-26 22:35:25 -0400
committerMyles Borins <myles.borins@gmail.com>2017-10-29 21:32:15 -0400
commitace4fe566fc3af4876c7458f983feeb5eae3df26 (patch)
tree458d847e9bd56199cd0d8b34cec126c7410fb6ca /deps/npm/node_modules/npm-profile/node_modules/make-fetch-happen/node_modules/socks-proxy-agent/node_modules/socks/lib/socks-agent.js
parent64168eb9b43e30e4c0b986c9b29c41be63e85df6 (diff)
downloadandroid-node-v8-ace4fe566fc3af4876c7458f983feeb5eae3df26.tar.gz
android-node-v8-ace4fe566fc3af4876c7458f983feeb5eae3df26.tar.bz2
android-node-v8-ace4fe566fc3af4876c7458f983feeb5eae3df26.zip
deps: update npm to 5.5.1
Closes: https://github.com/nodejs/node/pull/16280 PR-URL: https://github.com/nodejs/node/pull/16509 Fixes: https://github.com/nodejs/node/issues/14161 Reviewed-By: Daijiro Wachi <daijiro.wachi@gmail.com> Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: Michaƫl Zasso <targos@protonmail.com>
Diffstat (limited to 'deps/npm/node_modules/npm-profile/node_modules/make-fetch-happen/node_modules/socks-proxy-agent/node_modules/socks/lib/socks-agent.js')
-rw-r--r--deps/npm/node_modules/npm-profile/node_modules/make-fetch-happen/node_modules/socks-proxy-agent/node_modules/socks/lib/socks-agent.js108
1 files changed, 108 insertions, 0 deletions
diff --git a/deps/npm/node_modules/npm-profile/node_modules/make-fetch-happen/node_modules/socks-proxy-agent/node_modules/socks/lib/socks-agent.js b/deps/npm/node_modules/npm-profile/node_modules/make-fetch-happen/node_modules/socks-proxy-agent/node_modules/socks/lib/socks-agent.js
new file mode 100644
index 0000000000..db1c301ec9
--- /dev/null
+++ b/deps/npm/node_modules/npm-profile/node_modules/make-fetch-happen/node_modules/socks-proxy-agent/node_modules/socks/lib/socks-agent.js
@@ -0,0 +1,108 @@
+var tls = require('tls');
+var inherits = require('util').inherits;
+var EventEmitter = require('events').EventEmitter;
+var SocksClient = require('./socks-client.js');
+
+function SocksAgent(options, secure, rejectUnauthorized) {
+ this.options = options;
+ this.secure = secure || false;
+ this.rejectUnauthorized = rejectUnauthorized;
+
+ if (this.rejectUnauthorized === undefined) {
+ this.rejectUnauthorized = true;
+ }
+}
+
+inherits(SocksAgent, EventEmitter);
+
+SocksAgent.prototype.createConnection = function(req, opts, fn) {
+ var handler = fn, host, self = this;
+
+ this.options.target = this.options.target || {};
+
+ if (!this.options.target.host) {
+ this.options.target.host = opts.host;
+ }
+
+ if (!this.options.target.port) {
+ this.options.target.port = opts.port;
+ }
+
+ host = this.options.target.host;
+
+ if (this.secure) {
+ handler = function(err, socket, info) {
+ var options, cleartext;
+
+ if (err) {
+ return fn(err);
+ }
+
+ // save encrypted socket
+ self.encryptedSocket = socket;
+
+ options = {
+ socket: socket,
+ servername: host,
+ rejectUnauthorized: self.rejectUnauthorized
+ };
+
+ cleartext = tls.connect(options, function (err) {
+ return fn(err, this);
+ });
+ cleartext.on('error', fn);
+
+ socket.resume();
+ }
+ }
+
+ SocksClient.createConnection(this.options, handler);
+};
+
+/**
+ * @see https://www.npmjs.com/package/agent-base
+ */
+SocksAgent.prototype.addRequest = function(req, host, port, localAddress) {
+ var opts;
+ if ('object' === typeof host) {
+ // >= v0.11.x API
+ opts = host;
+ if (opts.host && opts.path) {
+ // if both a `host` and `path` are specified then it's most likely the
+ // result of a `url.parse()` call... we need to remove the `path` portion so
+ // that `net.connect()` doesn't attempt to open that as a unix socket file.
+ delete opts.path;
+ }
+ } else {
+ // <= v0.10.x API
+ opts = { host: host, port: port };
+ if (null !== localAddress) {
+ opts.localAddress = localAddress;
+ }
+ }
+
+ var sync = true;
+
+ this.createConnection(req, opts, function (err, socket) {
+ function emitErr () {
+ req.emit('error', err);
+ }
+ if (err) {
+ if (sync) {
+ // need to defer the "error" event, when sync, because by now the `req`
+ // instance hasn't event been passed back to the user yet...
+ process.nextTick(emitErr);
+ } else {
+ emitErr();
+ }
+ } else {
+ req.onSocket(socket);
+ //have to resume this socket when node 12
+ socket.resume();
+ }
+ });
+
+ sync = false;
+};
+
+exports.Agent = SocksAgent;