mirror of https://github.com/status-im/metro.git
42 lines
789 B
JavaScript
42 lines
789 B
JavaScript
/**
|
|
* Copyright 2004-present Facebook. All Rights Reserved.
|
|
*/
|
|
|
|
'use strict';
|
|
|
|
var WebSocketServer = require('ws').Server;
|
|
|
|
function attachToServer(server, path) {
|
|
var wss = new WebSocketServer({
|
|
server: server,
|
|
path: path
|
|
});
|
|
var clients = [];
|
|
|
|
wss.on('connection', function(ws) {
|
|
clients.push(ws);
|
|
|
|
var allClientsExcept = function(ws) {
|
|
return clients.filter(function(cn) { return cn !== ws; });
|
|
};
|
|
|
|
ws.onerror = function() {
|
|
clients = allClientsExcept(ws);
|
|
};
|
|
|
|
ws.onclose = function() {
|
|
clients = allClientsExcept(ws);
|
|
};
|
|
|
|
ws.on('message', function(message) {
|
|
allClientsExcept(ws).forEach(function(cn) {
|
|
cn.send(message);
|
|
});
|
|
});
|
|
});
|
|
}
|
|
|
|
module.exports = {
|
|
attachToServer: attachToServer
|
|
};
|