server.js

const app = require('express')();
const server = require('http').createServer(app);
const cors = require('cors');

const io = require('socket.io')(server, {
  cors: {
    origin: '*',
    methods: ['GET', 'POST'],
  },
});

app.use(cors());

const PORT = process.env.PORT || 5000;

app.get('/', (req, res) => {
  res.send('Server is running.');
});

io.on('connection', (socket) => {
  socket.emit('me', socket.id);

  socket.on('callUser', ({ userToCall, signalData, from, name }) => {
    io.to(userToCall).emit('callUser', {
      signal: signalData,
      from,
      name,
    });
  });

  socket.on('updateMyMedia', ({ type, currentMediaStatus }) => {
    socket.broadcast.emit('updateUserMedia', { type, currentMediaStatus });
  });

  socket.on('msgUser', ({ name, to, msg, sender }) => {
    io.to(to).emit('msgRcv', { name, msg, sender });
  });

  socket.on('answerCall', (data) => {
    socket.broadcast.emit('updateUserMedia', {
      type: data.type,
      currentMediaStatus: data.myMediaStatus,
    });
    io.to(data.to).emit('callAccepted', data);
  });

  socket.on('declineCall', ({ id }) => {
    io.to(id).emit('declineCall');
  });

  socket.on('endCall', ({ id }) => {
    io.to(id).emit('endCall');
  });
});

server.listen(PORT, () => console.log(`Server is running on port ${PORT}.`));