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
|
import { createServer } from 'http'
import tap from 'tap'
import {
Agent,
Client,
errors,
pipeline,
Pool,
request,
connect,
upgrade,
setGlobalDispatcher,
getGlobalDispatcher,
stream
} from '../../index.js'
const { test } = tap
test('imported Client works with basic GET', (t) => {
t.plan(10)
const server = createServer((req, res) => {
t.equal('/', req.url)
t.equal('GET', req.method)
t.equal(`localhost:${server.address().port}`, req.headers.host)
t.equal(undefined, req.headers.foo)
t.equal('bar', req.headers.bar)
t.equal(undefined, req.headers['content-length'])
res.setHeader('Content-Type', 'text/plain')
res.end('hello')
})
t.teardown(server.close.bind(server))
const reqHeaders = {
foo: undefined,
bar: 'bar'
}
server.listen(0, () => {
const client = new Client(`http://localhost:${server.address().port}`)
t.teardown(client.close.bind(client))
client.request({
path: '/',
method: 'GET',
headers: reqHeaders
}, (err, data) => {
t.error(err)
const { statusCode, headers, body } = data
t.equal(statusCode, 200)
t.equal(headers['content-type'], 'text/plain')
const bufs = []
body.on('data', (buf) => {
bufs.push(buf)
})
body.on('end', () => {
t.equal('hello', Buffer.concat(bufs).toString('utf8'))
})
})
})
})
test('imported errors work with request args validation', (t) => {
t.plan(2)
const client = new Client('http://localhost:5000')
client.request(null, (err) => {
t.type(err, errors.InvalidArgumentError)
})
try {
client.request(null, 'asd')
} catch (err) {
t.type(err, errors.InvalidArgumentError)
}
})
test('imported errors work with request args validation promise', (t) => {
t.plan(1)
const client = new Client('http://localhost:5000')
client.request(null).catch((err) => {
t.type(err, errors.InvalidArgumentError)
})
})
test('named exports', (t) => {
t.equal(typeof Client, 'function')
t.equal(typeof Pool, 'function')
t.equal(typeof Agent, 'function')
t.equal(typeof request, 'function')
t.equal(typeof stream, 'function')
t.equal(typeof pipeline, 'function')
t.equal(typeof connect, 'function')
t.equal(typeof upgrade, 'function')
t.equal(typeof setGlobalDispatcher, 'function')
t.equal(typeof getGlobalDispatcher, 'function')
t.end()
})
|
