1 | var assert = require('assert');
|
2 | var https = require('https');
|
3 | var http = require('http');
|
4 | var fs = require('fs');
|
5 | var WebSocketServer = require('ws').Server;
|
6 | var Websocket = require('../lib/web_socket');
|
7 |
|
8 | describe('Peer Client Websocket', function() {
|
9 |
|
10 | it('it should connect to ws:// server', function(done) {
|
11 | var server = http.createServer();
|
12 | var wss = new WebSocketServer({ server: server });
|
13 | server.listen(0, function(err) {
|
14 | if (err) {
|
15 | return done(err);
|
16 | }
|
17 | var address = 'ws://localhost:' + server.address().port;
|
18 | var ws = new Websocket(address);
|
19 | ws.on('error', done);
|
20 | ws.on('open', function() {
|
21 | done();
|
22 | });
|
23 |
|
24 | ws.start();
|
25 | });
|
26 | });
|
27 |
|
28 | it('it should connect to wss:// server', function(done) {
|
29 | var opts = {
|
30 | key: fs.readFileSync('./test/fixture/server.key'),
|
31 | cert: fs.readFileSync('./test/fixture/server.crt')
|
32 | };
|
33 |
|
34 | var server = https.createServer(opts);
|
35 | var wss = new WebSocketServer({ server: server });
|
36 | server.listen(0, function(err) {
|
37 | if (err) {
|
38 | return done(err);
|
39 | }
|
40 |
|
41 | var address = 'wss://localhost:' + server.address().port;
|
42 | var ws = new Websocket(address, { rejectUnauthorized: false});
|
43 | ws.on('error', done);
|
44 | ws.on('open', function() {
|
45 | done();
|
46 | });
|
47 |
|
48 | ws.start();
|
49 | });
|
50 | });
|
51 |
|
52 | });
|