1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
'use strict';
// this module will either get a regular http keepalive agent or
// a proxying agent if `HTTP_PROXY` or `HTTPS_PROXY` environment variables
// are set
// request/request module could have been used but it does not do any
// keepalive on POST requests https://github.com/request/request/issues/236#issuecomment-94587587
module.exports = getAgent;
function getAgent(protocol) {
var agent;
if (protocol !== 'http:' && protocol !== 'https:') {
throw new Error('get-agent: `protocol` must be `http:` or `https:`');
}
var parsedProxy = getParsedProxy();
if (parsedProxy.protocol) {
agent = getProxyingAgent(protocol, parsedProxy);
} else {
// no proxy given, let's use regular keepalived agents
agent = getKeepaliveAgent(protocol);
}
return agent;
}
function getParsedProxy() {
var url = require('url');
var proxy = process.env.HTTP_PROXY ||
process.env.HTTPS_PROXY ||
'';
return url.parse(proxy);
}
function getKeepaliveAgent(protocol) {
var http = require('http');
var https = require('https');
var HttpsAgent = require('agentkeepalive').HttpsAgent;
var HttpAgent = require('agentkeepalive');
var semver = require('semver');
var keepAliveAgent;
// node 0.10 => agentkeepalive
// node >= 0.12 => native keepalive
// iojs => native keepalive
// node >= 0.11.4 has good keepAlive https://github.com/joyent/node/commit/b5b841
if (semver.satisfies(process.version, '<0.11.4')) {
if (protocol === 'http:') {
keepAliveAgent = new HttpAgent({
maxSockets: Infinity
});
} else if (protocol === 'https:') {
keepAliveAgent = new HttpsAgent({
maxSockets: Infinity
});
}
} else if (protocol === 'http:') {
keepAliveAgent = new http.Agent({
keepAlive: true,
maxSockets: Infinity
});
} else if (protocol === 'https:') {
keepAliveAgent = new https.Agent({
keepAlive: true,
maxSockets: Infinity
});
}
return keepAliveAgent;
}
function getProxyingAgent(protocol, parsedProxy) {
var tunnel = require('tunnel-agent');
var agentSettings = {
maxSockets: Infinity,
proxy: {
host: parsedProxy.hostname,
port: parseInt(parsedProxy.port, 10),
proxyAuth: parsedProxy.auth
}
};
// httpOverHttps
// httpsOverHttps
// https://github.com/mikeal/tunnel-agent/blob/912a7a6d00e10ec76baf9c9369de280fa5badef3/index.js#L12-L15
var tunnelType = protocol.replace(':', '') +
'Over' +
parsedProxy.protocol.replace(':', '').replace('h', 'H');
var agent = new tunnel[tunnelType](agentSettings);
// `tunnel-agent` does not have a destroy method
agent.destroy = function() {
this.sockets.forEach(function(socket) {
socket.destroy();
});
};
return agent;
}
|
