server.js

const express = require('express');
const app = express();

const server = require('http').Server(app);
const io = require('socket.io')(server);

const { ExpressPeerServer } = require('peer');
const peerServer = ExpressPeerServer(server, {
  debug: true
});

app.use('/peerjs', peerServer);
const { v4: uuidV4 } = require('uuid')


const {
    enterUser,
    getAllRoomUsers,
	getCurrentUser,
    userLeave
  } = require("./routes/users");


// middlewares
app.use(express.urlencoded({extended: true}));
app.use(express.json());
app.set('view engine', 'ejs');

app.use("/", express.static(__dirname + '/public'));

// request to create a call
app.get('/create_call', (req, res) => {
    res.redirect(`/${uuidV4()}`);
})
  
app.get('/:room', (req, res) => {
    res.render('room', { roomId: req.params.room } );
})

// socket connection
io.on('connection', (socket) => {
    socket.on('join-room', (roomId, userId, userName) => {
        socket.join(roomId);
        let user = enterUser(userId, userName, roomId, socket.id);
        console.log(user);
        // let roomUsers = getAllRoomUsers(roomId);
        // if (roomUsers.length>1) {
        //     socket.to(roomUsers[0].socketId).emit("data_dijiye", socket.id);
        //     console.log("apna time");
        // }

        socket.to(roomId).emit('user-connected', userId);
        console.log("A user is connected:", userName, "User ID:", userId, "Room ID:", roomId);

        // socket.on("data_lijiye", (data, socketId) => {
        //     console.log("hum hain yaha");
        //     socket.to(socketId).emit("init", data);
        // });
        
        
        socket.on('drawing', (data) => socket.broadcast.emit('drawing', data));
        socket.on('clearBoard', () => {
            socket.to(roomId).emit('clearBoard');
        });

        socket.on('editor-change', (saamaan)=>{
            socket.to(roomId).emit('editor-update-kar-rey', saamaan);
        })

        // messages functionality
        socket.on('message', (message, username) => {
            //send message to the same room
            io.to(roomId).emit('createMessage', message, username);
        }); 
      
        socket.on('disconnect', () => {
            let user = userLeave(socket.id);
            socket.broadcast.emit('user-disconnected', userId);
            console.log("Nikal gaya");
        })
    })
})

const port = process.env.PORT || 3000;
server.listen(port, ()=>{
    console.log("Server started at: http://localhost:"+port);
});