From a003bcdef0bf474fe93a62adff29e9acb84e19c8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?H=C3=A5var=20Aamb=C3=B8=20Fosstveit?= Date: Mon, 28 Oct 2019 12:11:47 +0100 Subject: [PATCH] Remove unused file. --- server/mediasoup.js | 321 -------------------------------------------- 1 file changed, 321 deletions(-) delete mode 100644 server/mediasoup.js diff --git a/server/mediasoup.js b/server/mediasoup.js deleted file mode 100644 index 99a4862..0000000 --- a/server/mediasoup.js +++ /dev/null @@ -1,321 +0,0 @@ -const mediasoup = require('mediasoup'); -const readline = require('readline'); -const colors = require('colors/safe'); -const repl = require('repl'); -const homer = require('./lib/homer'); -const config = require('./config/config'); - -// mediasoup server. -const mediaServer = mediasoup.Server( - { - numWorkers : null, - logLevel : config.mediasoup.logLevel, - logTags : config.mediasoup.logTags, - rtcIPv4 : config.mediasoup.rtcIPv4, - rtcIPv6 : config.mediasoup.rtcIPv6, - rtcAnnouncedIPv4 : config.mediasoup.rtcAnnouncedIPv4, - rtcAnnouncedIPv6 : config.mediasoup.rtcAnnouncedIPv6, - rtcMinPort : config.mediasoup.rtcMinPort, - rtcMaxPort : config.mediasoup.rtcMaxPort - }); - -// Do Homer stuff. -if (process.env.MEDIASOUP_HOMER_OUTPUT) - homer(mediaServer); - -global.SERVER = mediaServer; - -mediaServer.on('newroom', (room) => -{ - global.ROOM = room; - - room.on('newpeer', (peer) => - { - global.PEER = peer; - - if (peer.consumers.length > 0) - global.CONSUMER = peer.consumers[peer.consumers.length - 1]; - - peer.on('newtransport', (transport) => - { - global.TRANSPORT = transport; - }); - - peer.on('newproducer', (producer) => - { - global.PRODUCER = producer; - }); - - peer.on('newconsumer', (consumer) => - { - global.CONSUMER = consumer; - }); - }); -}); - -// Listen for keyboard input. - -let cmd; -let terminal; - -openCommandConsole(); - -function openCommandConsole() -{ - stdinLog('[opening Readline Command Console...]'); - - closeCommandConsole(); - closeTerminal(); - - cmd = readline.createInterface( - { - input : process.stdin, - output : process.stdout - }); - - cmd.on('SIGINT', () => - { - process.exit(); - }); - - readStdin(); - - function readStdin() - { - cmd.question('cmd> ', (answer) => - { - switch (answer) - { - case '': - { - readStdin(); - break; - } - - case 'h': - case 'help': - { - stdinLog(''); - stdinLog('available commands:'); - stdinLog('- h, help : show this message'); - stdinLog('- sd, serverdump : execute server.dump()'); - stdinLog('- rd, roomdump : execute room.dump() for the latest created mediasoup Room'); - stdinLog('- pd, peerdump : execute peer.dump() for the latest created mediasoup Peer'); - stdinLog('- td, transportdump : execute transport.dump() for the latest created mediasoup Transport'); - stdinLog('- prd, producerdump : execute producer.dump() for the latest created mediasoup Producer'); - stdinLog('- cd, consumerdump : execute consumer.dump() for the latest created mediasoup Consumer'); - stdinLog('- t, terminal : open REPL Terminal'); - stdinLog(''); - readStdin(); - - break; - } - - case 'sd': - case 'serverdump': - { - mediaServer.dump() - .then((data) => - { - stdinLog(`server.dump() succeeded:\n${JSON.stringify(data, null, ' ')}`); - readStdin(); - }) - .catch((error) => - { - stdinError(`mediaServer.dump() failed: ${error}`); - readStdin(); - }); - - break; - } - - case 'rd': - case 'roomdump': - { - if (!global.ROOM) - { - readStdin(); - break; - } - - global.ROOM.dump() - .then((data) => - { - stdinLog(`room.dump() succeeded:\n${JSON.stringify(data, null, ' ')}`); - readStdin(); - }) - .catch((error) => - { - stdinError(`room.dump() failed: ${error}`); - readStdin(); - }); - - break; - } - - case 'pd': - case 'peerdump': - { - if (!global.PEER) - { - readStdin(); - break; - } - - global.PEER.dump() - .then((data) => - { - stdinLog(`peer.dump() succeeded:\n${JSON.stringify(data, null, ' ')}`); - readStdin(); - }) - .catch((error) => - { - stdinError(`peer.dump() failed: ${error}`); - readStdin(); - }); - - break; - } - - case 'td': - case 'transportdump': - { - if (!global.TRANSPORT) - { - readStdin(); - break; - } - - global.TRANSPORT.dump() - .then((data) => - { - stdinLog(`transport.dump() succeeded:\n${JSON.stringify(data, null, ' ')}`); - readStdin(); - }) - .catch((error) => - { - stdinError(`transport.dump() failed: ${error}`); - readStdin(); - }); - - break; - } - - case 'prd': - case 'producerdump': - { - if (!global.PRODUCER) - { - readStdin(); - break; - } - - global.PRODUCER.dump() - .then((data) => - { - stdinLog(`producer.dump() succeeded:\n${JSON.stringify(data, null, ' ')}`); - readStdin(); - }) - .catch((error) => - { - stdinError(`producer.dump() failed: ${error}`); - readStdin(); - }); - - break; - } - - case 'cd': - case 'consumerdump': - { - if (!global.CONSUMER) - { - readStdin(); - break; - } - - global.CONSUMER.dump() - .then((data) => - { - stdinLog(`consumer.dump() succeeded:\n${JSON.stringify(data, null, ' ')}`); - readStdin(); - }) - .catch((error) => - { - stdinError(`consumer.dump() failed: ${error}`); - readStdin(); - }); - - break; - } - - case 't': - case 'terminal': - { - openTerminal(); - - break; - } - - default: - { - stdinError(`unknown command: ${answer}`); - stdinLog('press \'h\' or \'help\' to get the list of available commands'); - - readStdin(); - } - } - }); - } -} - -function openTerminal() -{ - stdinLog('[opening REPL Terminal...]'); - - closeCommandConsole(); - closeTerminal(); - - terminal = repl.start( - { - prompt : 'terminal> ', - useColors : true, - useGlobal : true, - ignoreUndefined : false - }); - - terminal.on('exit', () => openCommandConsole()); -} - -function closeCommandConsole() -{ - if (cmd) - { - cmd.close(); - cmd = undefined; - } -} - -function closeTerminal() -{ - if (terminal) - { - terminal.removeAllListeners('exit'); - terminal.close(); - terminal = undefined; - } -} - -function stdinLog(msg) -{ - // eslint-disable-next-line no-console - console.log(colors.green(msg)); -} - -function stdinError(msg) -{ - // eslint-disable-next-line no-console - console.error(colors.red.bold('ERROR: ') + colors.red(msg)); -} - -module.exports = mediaServer;