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
|
'use strict'
var request = require('../index')
var version = require('../lib/helpers').version
var http = require('http')
var ForeverAgent = require('forever-agent')
var tape = require('tape')
var s = http.createServer(function (req, res) {
res.statusCode = 200
res.end()
})
tape('setup', function (t) {
s.listen(0, function () {
s.port = this.address().port
s.url = 'http://localhost:' + s.port
t.end()
})
})
function httpAgent (t, options, req) {
var r = (req || request)(options, function (_err, res, body) {
t.ok(r.agent instanceof http.Agent, 'is http.Agent')
t.equal(r.agent.options.keepAlive, true, 'is keepAlive')
t.equal(Object.keys(r.agent.sockets).length, 1, '1 socket name')
var name = (typeof r.agent.getName === 'function')
? r.agent.getName({port: s.port})
: 'localhost:' + s.port // node 0.10-
t.equal(r.agent.sockets[name].length, 1, '1 open socket')
var socket = r.agent.sockets[name][0]
socket.on('close', function () {
t.equal(Object.keys(r.agent.sockets).length, 0, '0 open sockets')
t.end()
})
socket.end()
})
}
function foreverAgent (t, options, req) {
var r = (req || request)(options, function (_err, res, body) {
t.ok(r.agent instanceof ForeverAgent, 'is ForeverAgent')
t.equal(Object.keys(r.agent.sockets).length, 1, '1 socket name')
var name = 'localhost:' + s.port // node 0.10-
t.equal(r.agent.sockets[name].length, 1, '1 open socket')
var socket = r.agent.sockets[name][0]
socket.on('close', function () {
t.equal(Object.keys(r.agent.sockets[name]).length, 0, '0 open sockets')
t.end()
})
socket.end()
})
}
// http.Agent
tape('options.agent', function (t) {
httpAgent(t, {
uri: s.url,
agent: new http.Agent({keepAlive: true})
})
})
tape('options.agentClass + options.agentOptions', function (t) {
httpAgent(t, {
uri: s.url,
agentClass: http.Agent,
agentOptions: {keepAlive: true}
})
})
// forever-agent
tape('options.forever = true', function (t) {
var v = version()
var options = {
uri: s.url,
forever: true
}
if (v.major === 0 && v.minor <= 10) { foreverAgent(t, options) } else { httpAgent(t, options) }
})
tape('forever() method', function (t) {
var v = version()
var options = {
uri: s.url
}
var r = request.forever({maxSockets: 1})
if (v.major === 0 && v.minor <= 10) { foreverAgent(t, options, r) } else { httpAgent(t, options, r) }
})
tape('cleanup', function (t) {
s.close(function () {
t.end()
})
})
|
