server.js

const express = require("express");
const app = express();
const { db_sync } = require("./config/db");
const models = require("./models");
const router = require("./routes/index");
const volleyball = require("volleyball");
require("dotenv").config();
const { PORT, FRONT } = process.env;
const cookiesParser = require("cookie-parser");
const cors = require("cors");
const multer = require("multer");
const { createServer } = require("http");
const { Server } = require("socket.io");

const httpServer = createServer(app);

const io = new Server(httpServer, {
  cors: {
    origin: FRONT,
  },
});

io.on("connection", (socket) => {
  console.log(`Socket ${socket.id} connected`);

  socket.on("join_room", async(data) => {
    console.log(`Socket ${socket.id} joined room ${data}`);
    socket.join(data);
    const numSockets = await io.in(data).fetchSockets();   
   
    for (const socket of numSockets) {
      console.log(socket.id);
      console.log(numSockets.length)
    }
  
  });

  socket.on("message_sent", (msg, user, room) => {
    console.log(`Socket ${socket.id} sent a message to room ${room}`);
    const currentDate = new Date(Date.now());
    const messageToSend = {
      user: { name: user },
      content: msg,
      date: currentDate,
    };
    socket.to(room).emit("message_received", messageToSend);
  });

  socket.on("disconnect", () => {
    console.log("A user has disconnected.");
  });
});

const multerMid = multer({
  storage: multer.memoryStorage(),
  limits: {
    fileSize: 2 * 1024 * 1024,
  },
});

app.use(multerMid.single("file"));

app.use(cookiesParser());

app.use(
  cors({
    origin: FRONT,
    credentials: true,
  })
);

app.use(volleyball);

app.use(express.json());

app.use("/", router);

app.use((err, req, res, next) => {
  console.error(err);
  res.status(500).send(err.message);
});

db_sync()
  .then(() => {
    httpServer.listen(PORT, () => console.log(`Server ON PORT: ${PORT}`));
  })
  .catch((err) => {
    console.error(err);
  });