If you report this error, please also report this tracking ID which makes it possible to locate your session in the logs which are available to the system administrator: ${trackingId}
` ); logger.error( 'Express error handler dump with tracking ID: %s, error dump: %o', trackingId, err); }; // eslint-disable-next-line no-unused-vars app.use(errorHandler); } catch (error) { logger.error('run() [error:"%o"]', error); } } function statusLog() { if (statusLogger) { statusLogger.log({ rooms : rooms, peers : peers }); } } async function runHttpsServer() { app.use(compression()); // app.use('/.well-known/acme-challenge', express.static('public/.well-known/acme-challenge')); app.get('/ping', function (req, res, next) { res.send('PONG3') }) app.get('/api/sessions', function (req, res, next) { //TODO json.stringify res.json({ id : "testId" }) }) //Check if the room exists app.get('/api/sessions/:session_id', function (req, res, next) { console.warn("Checking for room") let room = rooms.get(req.params.session_id); if (!room) { console.warn("doesn't exist") res.status(404).send() } else { console.warn("exist") res.status(200).send() } }) // Create room and return id app.post('/api/sessions', async function (req, res, next) { console.warn("Creating new room", req.body.mediaMode, req.body.recordingMode) //FIXME we're truncating because of kolab4 database layout (should be fixed instead) const roomId = uuidv4().substring(0, 16) const room = await getOrCreateRoom({ roomId }); res.json({ id : roomId }) }) app.post('/api/signal', async function (req, res, next) { let data = req.body; const roomId = data['session']; const signalType = data['type']; const payload = data['data']; const peers = data['to']; if (peers) { for (const peerId of peers) { let peer = peers.get(peerId); peer.socket.emit( 'signal', data ); } } else { io.to(roomId).emit( 'signal', data ); } res.json({}) }); // Create connection in room (just wait for websocket instead? // $post = [ // 'json' => [ // 'role' => self::OV_ROLE_PUBLISHER, // 'data' => json_encode(['role' => $role]) // ] // ]; app.post('/api/sessions/:session_id/connection', function (req, res, next) { console.warn("Creating connection in session", req.params.session_id) roomId = req.params.session_id //FIXME we're truncating because of kolab4 database layout (should be fixed instnead) const peerId = uuidv4().substring(0, 16) //TODO create room already? peer = new Peer({ id: peerId, roomId }); peers.set(peerId, peer); peer.on('close', () => { peers.delete(peerId); statusLog(); }); peer.nickname = "Display Name"; // peer.picture = picture; peer.email = "email@test.com"; peer.authenticated = true; peer.addRole(userRoles.MODERATOR); peer.addRole(userRoles.AUTHENTICATED); hostname = "localhost" //TODO from config port = "12443" //TODO from config res.json({ id : peerId, //When the below get's passed to the socket.io client we end up with something like wss://localhost:12443/socket.io/?peerId=peer1&roomId=room1&EIO=3&transport=websocket, token : `ws://${hostname}:${port}/?peerId=${peerId}&roomId=${roomId}` }) }) // app.all('*', async (req, res, next) => // { // logger.error('Something is happening'); // if (req.secure || config.httpOnly) // { // let ltiURL; // try // { // ltiURL = new URL(`${req.protocol}://${req.get('host')}${req.originalUrl}`); // } // catch (error) // { // logger.error('Error parsing LTI url: %o', error); // } // if ( // req.isAuthenticated && // req.user && // req.user.nickname && // !ltiURL.searchParams.get('nickname') && // !isPathAlreadyTaken(req.url) // ) // { // ltiURL.searchParams.append('nickname', req.user.nickname); // res.redirect(ltiURL); // } // else // { // const specialChars = "<>@!^*()[]{}:;|'\"\\,~`"; // for (let i = 0; i < specialChars.length; i++) // { // if (req.url.substring(1).indexOf(specialChars[i]) > -1) // { // req.url = `/${encodeURIComponent(encodeURI(req.url.substring(1)))}`; // res.redirect(`${req.url}`); // } // } // return next(); // } // } // else // res.redirect(`https://${req.hostname}${req.url}`); // }); // Serve all files in the public folder as static files. // app.use(express.static('public')); // app.use((req, res) => res.sendFile(`${__dirname}/public/index.html`)); if (config.httpOnly === true) { // http mainListener = http.createServer(app); } else { // https mainListener = spdy.createServer(tls, app); // http const redirectListener = http.createServer(app); if (config.listeningHost) redirectListener.listen(config.listeningRedirectPort, config.listeningHost); else redirectListener.listen(config.listeningRedirectPort); } console.info(`Listening on ${config.listeningPort} ${config.listeningHost}`) // https or http if (config.listeningHost) mainListener.listen(config.listeningPort, config.listeningHost); else mainListener.listen(config.listeningPort); } /** * Create a WebSocketServer to allow WebSocket connections from browsers. */ async function runWebSocketServer() { io = require('socket.io')(mainListener, { cookie: false }); io.use( sharedSession(session, sharedCookieParser, { autoSave: true }) ); // Handle connections from clients. io.on('connection', (socket) => { logger.info("websocket connection") const { roomId, peerId } = socket.handshake.query; if (!roomId || !peerId) { logger.warn('connection request without roomId and/or peerId'); socket.disconnect(true); return; } logger.info( 'connection request [roomId:"%s", peerId:"%s"]', roomId, peerId); queue.push(async () => { const { token } = socket.handshake.session; const room = await getOrCreateRoom({ roomId }); let peer = peers.get(peerId); if (!peer) { logger.warn("Peer does not exist %s", peerId); socket.disconnect(true); return; } let returning = false; peer.socket = socket; //FIXME figure out to which extent we need to handle returning users // Returning user, remove if old peer exists // TODO maintain metadata? // if (peer) { // peer.close(); // returning = true; // } room.handlePeer({ peer, returning }); statusLog(); }) .catch((error) => { logger.error('room creation or room joining failed [error:"%o"]', error); if (socket) socket.disconnect(true); return; }); }); } /** * Launch as many mediasoup Workers as given in the configuration file. */ async function runMediasoupWorkers() { const { numWorkers } = config.mediasoup; logger.info('running %d mediasoup Workers...', numWorkers); for (let i = 0; i < numWorkers; ++i) { const worker = await mediasoup.createWorker( { logLevel : config.mediasoup.worker.logLevel, logTags : config.mediasoup.worker.logTags, rtcMinPort : config.mediasoup.worker.rtcMinPort, rtcMaxPort : config.mediasoup.worker.rtcMaxPort }); worker.on('died', () => { logger.error( 'mediasoup Worker died, exiting in 2 seconds... [pid:%d]', worker.pid); setTimeout(() => process.exit(1), 2000); }); mediasoupWorkers.push(worker); } } /** * Get a Room instance (or create one if it does not exist). */ async function getOrCreateRoom({ roomId }) { let room = rooms.get(roomId); // If the Room does not exist create a new one. if (!room) { logger.info('creating a new Room [roomId:"%s"]', roomId); room = await Room.create({ mediasoupWorkers, roomId, peers }); rooms.set(roomId, room); statusLog(); room.on('close', () => { rooms.delete(roomId); statusLog(); }); } return room; } run();