channelManager.js
3.59 KB
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
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
// Generated by CoffeeScript 1.8.0
var ChannelManager, WeinreClientEvents, WeinreTargetEvents, channelManager, serviceManager, utils, _;
_ = require('underscore');
utils = require('./utils');
serviceManager = require('./serviceManager');
WeinreClientEvents = null;
WeinreTargetEvents = null;
channelManager = null;
utils.registerClass(ChannelManager = (function() {
function ChannelManager() {
this.channels = {};
}
ChannelManager.prototype.initialize = function() {
WeinreClientEvents = serviceManager.get('WeinreClientEvents');
WeinreTargetEvents = serviceManager.get('WeinreTargetEvents');
if (!WeinreClientEvents) {
utils.exit('WeinreClientEvents service not registered');
}
if (!WeinreTargetEvents) {
return utils.exit('WeinreTargetEvents service not registered');
}
};
ChannelManager.prototype.created = function(channel) {
return this.channels[channel.name] = channel;
};
ChannelManager.prototype.destroyed = function(channel) {
var clients, connection, _i, _j, _len, _len1, _ref, _ref1;
if (channel.isClient) {
_ref = channel.connections;
for (_i = 0, _len = _ref.length; _i < _len; _i++) {
connection = _ref[_i];
this.disconnectChannels(channel, connection);
}
} else {
_ref1 = channel.connections;
for (_j = 0, _len1 = _ref1.length; _j < _len1; _j++) {
connection = _ref1[_j];
this.disconnectChannels(connection, channel);
}
}
clients = this.getClientChannels(channel.id);
if (channel.isClient) {
WeinreClientEvents.clientUnregistered(clients, channel.name);
} else {
WeinreClientEvents.targetUnregistered(clients, channel.name);
}
return delete this.channels[channel.name];
};
ChannelManager.prototype.getChannel = function(name, remoteAddress) {
var channel;
if (!_.has(this.channels, name)) {
return null;
}
channel = this.channels[name];
if (!channel) {
return null;
}
return channel;
};
ChannelManager.prototype.connectChannels = function(client, target) {
var clients;
if (client.isClosed || target.isClosed) {
return;
}
if (client.connections.length) {
this.disconnectChannels(client, client.connections[0]);
}
client.connections.push(target);
target.connections.push(client);
clients = this.getClientChannels(client.id);
WeinreClientEvents.connectionCreated(clients, client.name, target.name);
return WeinreTargetEvents.connectionCreated(target, client.name, target.name);
};
ChannelManager.prototype.disconnectChannels = function(client, target) {
var clients;
clients = this.getClientChannels(client.id);
WeinreClientEvents.connectionDestroyed(clients, client.name, target.name);
WeinreTargetEvents.connectionDestroyed(target, client.name, target.name);
client.connections = _.without(client.connections, target);
return target.connections = _.without(target.connections, client);
};
ChannelManager.prototype.getChannels = function(id) {
if (id != null) {
return _.filter(this.channels, function(item) {
return item.id === id;
});
} else {
return _.values(this.channels);
}
};
ChannelManager.prototype.getClientChannels = function(id) {
return _.filter(this.channels, function(item) {
return item.isClient && item.id === id;
});
};
ChannelManager.prototype.getTargetChannels = function(id) {
return _.filter(this.channels, function(item) {
return item.isTarget && item.id === id;
});
};
return ChannelManager;
})());
module.exports = new ChannelManager;