1 | var assert = require('assert');
|
2 | var http = require('http');
|
3 | var WebSocket = require('ws');
|
4 | var zetta = require('../');
|
5 | var zettacluster = require('zetta-cluster');
|
6 | var Scout = require('./fixture/example_scout');
|
7 |
|
8 | describe('Peer Connection Events in Pubsub', function() {
|
9 | var cluster = null;
|
10 | var device = null;
|
11 | beforeEach(function(done) {
|
12 | cluster = zettacluster({ zetta: zetta })
|
13 | .server('cloud')
|
14 | .server('detroit1', [Scout], ['cloud']);
|
15 | done();
|
16 | });
|
17 |
|
18 | afterEach(function(done) {
|
19 | cluster.stop();
|
20 | setTimeout(done, 10);
|
21 | });
|
22 |
|
23 | describe('Initiator Events', function() {
|
24 | it('should recieve a _peer/connect event', function(done) {
|
25 |
|
26 | var recv = 0;
|
27 | cluster.servers['detroit1'].pubsub.subscribe('_peer/connect',function() {
|
28 | recv++;
|
29 | });
|
30 |
|
31 | cluster.on('ready', function(err) {
|
32 | assert.equal(recv, 1);
|
33 | done();
|
34 | });
|
35 |
|
36 | cluster.run(function(err) {
|
37 | if (err) {
|
38 | return done(err);
|
39 | }
|
40 | });
|
41 |
|
42 | });
|
43 | });
|
44 |
|
45 | describe('Acceptor Events', function() {
|
46 | it('should recieve a _peer/connect event', function(done) {
|
47 |
|
48 | var recv = 0;
|
49 | cluster.servers['cloud'].pubsub.subscribe('_peer/connect',function() {
|
50 | recv++;
|
51 | });
|
52 |
|
53 | cluster.on('ready', function(err) {
|
54 | assert.equal(recv, 1);
|
55 | done();
|
56 | });
|
57 |
|
58 | cluster.run(function(err) {
|
59 | if (err) {
|
60 | return done(err);
|
61 | }
|
62 | });
|
63 |
|
64 | });
|
65 | });
|
66 | });
|