server.js

const express = require('express');
const app = express();
const server = require('http').Server(app);
const path = require('path'); 
const { v4: uuidv4 } = require('uuid');
const io = require('socket.io')(server);
const dotenv = require('dotenv');
const PORT = process.env.PORT || 443;
// Peer
const { ExpressPeerServer } = require('peer');
const peerServer = ExpressPeerServer(server, {
  debug: true,
});
//configuring environment variables
dotenv.config();
// server side realtime database 
const admin = require('firebase-admin');
var serviceAccount = require(process.env.MY_CREDENTIAL);

admin.initializeApp({
  credential: admin.credential.cert(serviceAccount),
  databaseURL: process.env.databaseURL
});



// app started
app.set('view engine', 'ejs');
app.use(express.static('public'));
app.use('/peerjs', peerServer);

app.get( '/', (req, res) => {
  res.render('homepage');
});

app.get( '/teams-webrtc', (req, res) => {
  res.redirect(`/${uuidv4()}`);
});

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

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

io.on('connection', (socket) => {
  socket.on('join-room', (roomId, userId ,userName,state) => {
    socket.join(roomId);
    socket.broadcast.to(roomId).emit('user-connected', userId , state);
          
    var userRooms= admin.database().ref(`users/${userName}/rooms/${roomId}`);
    if((roomId+"").length===36)
    userRooms.push().set({
     "name": roomId
  });  
  
    socket.on('message', (message) => {
      io.to(roomId).emit('createMessage', message , userName, userId);
    });
    
    if(state ==="in-meet")
    { 
      // firebase code
      var meetParticipantsRef =admin.database().ref(roomId).child("meetParticipants").child(userName);
      var arrival_time = (new Date()).getTime();
  
      
    var currentParticipants= admin.database().ref(`${roomId}/currentParticipants/${userName}`);
    currentParticipants.push().set({
     "name": userName
  });
      //firebase code
      socket.on("disconnect", (reason)=>{
        meetParticipantsRef.push().set({
          "tempo_id": userId,
          "arrival_time": arrival_time,
          "disconnected_time": (new Date()).getTime()
      });
        socket.broadcast.emit("user-disconnected", userId , userName ); 
        admin.database().ref(`${roomId}/currentParticipants/${userName}`).remove();
    });
     
      socket.on('waved', (myName) => {
      io.to(roomId).emit('toggleWave', myName);
    });

    socket.on('change-filter', (videoId,filter) => {
      io.to(roomId).emit('change-filter', videoId,filter);
    });
    
    
     /**
   * Whiteboard actions for all user in the same room
   */
  socket.on("wb", (config) => {
    io.to(roomId).emit("wb", config);
  });



    socket.on('screen-closed', (screenId) => {
      io.to(roomId).emit('remove-screen', screenId);
    });

  }
  
  });
});

server.listen( PORT , () => console.log(`Server listening to port ${PORT}`));