server.js

const express = require('express')
const fs = require('fs');
const http = require('http');
const https = require('https');
const app = express()


var server = null
if (fs.existsSync('/etc/letsencrypt/live/bubblz.space/privkey.pem')) {
  // Certificate
  const privateKey = fs.readFileSync('/etc/letsencrypt/live/bubblz.space/privkey.pem', 'utf8');
  const certificate = fs.readFileSync('/etc/letsencrypt/live/bubblz.space/cert.pem', 'utf8');
  const ca = fs.readFileSync('/etc/letsencrypt/live/bubblz.space/chain.pem', 'utf8');

  const credentials = {
    key: privateKey,
    cert: certificate,
    ca: ca
  };
  server = https.createServer(credentials, app);
} else {
  server = http.createServer(app);
}


const io = require('socket.io')(server)
const { v4: uuidV4 } = require('uuid')



let openRooms = {}; // Stores arrays of open roomIds in each room 

app.set('view engine', 'ejs')
app.use(express.static('public'))

app.get('/', (req, res) => {
  res.redirect(`/${uuidV4()}`)
})

app.get('/:room', (req, res) => {
  res.render('room', { roomId: req.params.room })
})

io.on('connection', socket => {
  socket.on('mute', (roomId, userId) => {
    console.log("MUTE")
    socket.to(roomId).broadcast.emit('user-muted', userId)
  })
  socket.on('unmute', (roomId, userId) => {
    socket.to(roomId).broadcast.emit('user-unmuted', userId)
  })
  socket.on('get-rooms', (roomId) => {
    if (!openRooms[roomId]) {
      openRooms[roomId] = [0];
    }

    console.log("Client requesting valid rooms: " + roomId);
    socket.emit('valid-rooms', openRooms[roomId]);
  });
  socket.on('disconnect', (roomId, userId) => {
    socket.to(roomId).broadcast.emit('user-disconnected', userId)
  });

  socket.on('join-group', (msg, roomId, userId) => {
    socket.to(roomId).broadcast.emit('join-group', msg);
  });

  socket.on('move', (msg, roomId, userId) => {
    console.log(`User with id ${msg.userId} requesting move to ${msg.group}`);

    socket.to(roomId).broadcast.emit('move', msg);
  });

  socket.on('create-room', (msg, roomId, userId) => {
    console.log("Client created new room with id: " + msg);
    if (!openRooms[roomId]) {
      openRooms[roomId] = [0];
    }
    openRooms[roomId].push(msg);
    console.log("New valid rooms: " + openRooms[roomId]);

    socket.to(roomId).broadcast.emit('create-room', msg)
  });

  socket.on('delete-room', (msg, roomId) => {
    console.log("Client deleted room with id: " + msg);
    const removalIndex = openRooms[roomId].indexOf(msg);
    openRooms[roomId].splice(removalIndex, 1);
    console.log("New valid rooms: " + openRooms[roomId]);

    socket.to(roomId).broadcast.emit('delete-room', msg);
  })

  socket.on('join-room', (roomId, userId) => {
    socket.join(roomId)
    socket.to(roomId).broadcast.emit('user-connected', userId)

  });
});

server.listen(3000)