-
Notifications
You must be signed in to change notification settings - Fork 0
/
connectionpool.test.js
96 lines (73 loc) · 2.51 KB
/
connectionpool.test.js
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
/*globals expect, TESTNUMBER, net */
describe('connectionpool', function () {
'use strict';
var ConnectionPool = require('../lib/connectionpool')
, port = TESTNUMBER
, host = 'localhost'
, server;
before(function before(done) {
server = net.createServer(function create(socket) {
socket.write('<3');
});
server.listen(port, host, done);
});
it('should exported as a function', function () {
expect(ConnectionPool).to.be.a('function');
});
it('should be an instance of EventEmitter', function () {
expect(new ConnectionPool).to.be.instanceof(process.EventEmitter);
});
describe('initialize', function () {
it('should update the limit if its supplied', function () {
var pool = new ConnectionPool(100);
expect(pool.limit).to.eql(100);
});
it('should also update the generator if its supplied', function () {
function test() {}
var pool = new ConnectionPool(100, test);
expect(pool.generator).to.eql(test);
});
});
describe('#factory', function () {
it('should throw an error if the supplied factory is not a function', function () {
var pool = new ConnectionPool();
expect(pool.factory).to.throw(Error);
});
it('should not throw an error if a function is supplied', function () {
var pool = new ConnectionPool();
function test() {}
expect(pool.factory.bind(pool, test)).to.not.throw(Error);
});
});
describe('#allocate', function () {
it('should give an error when no #factory is specified', function (done) {
var pool = new ConnectionPool();
pool.allocate(function allocate(err, conn) {
expect(err).to.be.an.instanceof(Error);
expect(err.message).to.contain('#factory');
done();
});
});
it('should emit an error when we cannot establish a connection', function (done) {
var pool = new ConnectionPool()
, differentport = TESTNUMBER;
pool.once('error', function error(err) {
expect(err).to.be.an.instanceof(Error);
});
pool.factory(function factory() {
return net.connect(differentport, host);
});
// make sure the port is different
expect(differentport).to.not.eql(port);
pool.allocate(function allocate(err, connection) {
expect(err).to.be.an.instanceof(Error);
done();
});
});
});
after(function after(done) {
// in 0.7, we can supply the server with the done callback
server.once('close', done);
server.close();
});
});