Briq
/
multiparty-meeting
7
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Make sure the interactive server can never crash server

master
Håvar Aambø Fosstveit 2020-03-18 15:30:04 +01:00
parent 0f793e1d02
commit 545beb70ec
1 changed files with 29 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
server/lib/interactiveServer.js
View File

@ -663,32 +663,37 @@ function runMediasoupObserver()
module.exports = async function(rooms, peers)
{
// Run the mediasoup observer API.
runMediasoupObserver();
// Make maps global so they can be used during the REPL terminal.
global.rooms = rooms;
global.peers = peers;
global.workers = workers;
global.routers = routers;
global.transports = transports;
global.producers = producers;
global.consumers = consumers;
global.dataProducers = dataProducers;
global.dataConsumers = dataConsumers;
const server = net.createServer((socket) =>
try
{
const interactive = new Interactive(socket);
// Run the mediasoup observer API.
runMediasoupObserver();
interactive.openCommandConsole();
});
// Make maps global so they can be used during the REPL terminal.
global.rooms = rooms;
global.peers = peers;
global.workers = workers;
global.routers = routers;
global.transports = transports;
global.producers = producers;
global.consumers = consumers;
global.dataProducers = dataProducers;
global.dataConsumers = dataConsumers;
await new Promise((resolve) =>
{
try { fs.unlinkSync(SOCKET_PATH); }
catch (error) {}
const server = net.createServer((socket) =>
{
const interactive = new Interactive(socket);
server.listen(SOCKET_PATH, resolve);
});
interactive.openCommandConsole();
});
await new Promise((resolve) =>
{
try { fs.unlinkSync(SOCKET_PATH); }
catch (error) {}
server.listen(SOCKET_PATH, resolve);
});
}
catch (error)
{}
};