socketServer.js

const { Server } = require("socket.io");

const socketServer = (server, port) => {
  const io = new Server(server, {
    cors: {
      origin: "*",
    },
  });
  console.log(`Server started on port ${port}`);

  const users = [];
  const chat = [];
  let entryArray = [];
  let loaderArray = [];

  io.on("connection", (socket) => {
    console.log("socket connect successful");

    socket.on("newConnect", () => {
      users.push(socket.id);
      io.to(socket.id).emit("currentId", socket.id);
      users.length < 2 ? io.to(socket.id).emit("videoData") : socket.broadcast.emit("echo");
    });

    socket.on("requestChat", () => {
      socket.emit("updateChat", chat);
    })

    socket.on("newJoined", (videoObject) => {
      entryArray.push({ user: socket.id, videoData: videoObject });
      if (entryArray.length === users.length - 1) {
        const missingUser = users.find(
          (el) => !entryArray.some((obj) => obj.user === el)
        );
        io.to(missingUser).emit('videoData', entryArray[0].videoData);

        entryArray = [];
      }
    });

    socket.on("newIsReady", () => {
      io.emit("avengersAssemble");
    });

    socket.on("videoVariant", (videoObject) => {
      io.emit("newVideo", {
        video: videoObject.video,
        poster: videoObject.poster,
        time: videoObject.time,
      });
    });

    socket.on("play", () => {
      io.emit("playConfirm");
    });

    socket.on("pause", () => {
      io.emit("pauseConfirm");
    });

    socket.on("sendMessage", (message) => {
      chat.push({ message: message, id: socket.id });
      io.emit("updateChat", chat);
    });

    socket.on("ping", () => {
      loaderArray.push(socket.id);
      if (loaderArray.length === users.length) {
        io.emit("pong");

        loaderArray = [];
      }
    });

    socket.on("disconnect", () => {
      const index = users.indexOf(socket.id);
      if (index !== -1) {
        users.splice(index, 1);
      }
      console.log(`now users are ${users}`);
    });
  });
};

module.exports = socketServer;