FilesExpand file tree

master

/

server_error.js

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

77 lines (69 loc) · 1.99 KB

master

/

server_error.js

Copy path

Top

File metadata and controls

• Code
• Blame

77 lines (69 loc) · 1.99 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

var steed = require('steed');

var assert = chai.assert;

var moscaSettings = function () {

return {

port: 1883,

http: {

port: 8000

}

};

};

var moscaSettings2 = function () {

return {

port: 1884,

http: {

port: 8000

}

};

};

describe('mosca.Server.error', function () {

var instance;

var secondInstance;

beforeEach(function (done) {

instance = null;

secondInstance = null;

done();

});

afterEach(function (done) {

this.instance = instance;

var instances = [this.instance];

if (secondInstance) {

instances.push(secondInstance);

}

steed.each(instances, function (instance, cb) {

instance.close(cb);

}, function () {

setImmediate(done);

});

});

it('should get MQTT port Error: listen EADDRINUSE', function (done) {

this.timeout(10000); // have to wait for the inject with delay of two seconds

instance = new mosca.Server(moscaSettings(), function (err, server) {

assert.ifError(err);

expect(server === instance).to.be.true;

});

secondInstance = new mosca.Server(moscaSettings(), function (err, server) {

assert.ifError(err);

expect(server === secondInstance).to.be.true;

});

secondInstance.on('error', function (err) {

expect(err.toString().substr(0, 24)).to.be.equal('Error: listen EADDRINUSE');

done();

});

});

it('should get HTTP port Error: listen EADDRINUSE', function (done) {

this.timeout(10000); // have to wait for the inject with delay of two seconds

instance = new mosca.Server(moscaSettings(), function (err, server) {

assert.ifError(err);

expect(server === instance).to.be.true;

});

secondInstance = new mosca.Server(moscaSettings2(), function (err, server) {

assert.ifError(err);

expect(server === secondInstance).to.be.true;

});

secondInstance.on('error', function (err) {

expect(err.toString().substr(0, 24)).to.be.equal('Error: listen EADDRINUSE');

done();

});

});

});