server.js

import dotenv from "dotenv/config";
import express from "express";
import Router from "./routes/route.js";
import cors from "cors";
import bodyParser from "body-parser";
import cookieParser from "cookie-parser";

import { Connection } from "./database/db.js";
import { Server } from "socket.io";
const app = express();


app.use(
  cors({
    origin: ["http://localhost:3000"],
    credentials: true,
  })
);

app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());
app.use(cookieParser());
app.use("/", Router);
const PORT = process.env.PORT || 8000;

app.get("/", (req, res) => {
  res.send("Hello");
});

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

Connection();

/////////////////////////////////////////////////////////////////////////////////
const io = new Server(server,{
  pingTimeout: 60000,
  cors: {
    origin: ["http://localhost:3000"],
    // credentials: true,
  },
});

io.on("connection", (socket) => {
  console.log("someone is connected");
  
  // console.log(`${socket.handshake.query.name} joined room : ${socket.handshake.query.id}`);
  // socket.join(socket.handshake.query.id);
  
  socket.on("setup" , ({sender}) => {
    // console.log(sender._id);
    socket.join(sender._id);
    console.log(`${sender.name} joined room : ${sender._id}`);
    
  })
  
  socket.on("sendNotification", ({sender , receiver , type}) => {
    // console.log(receiver)
      socket.in(receiver._id).emit("getNotification", {sender: sender , type: type});
  })
  socket.on("send message",({content,id,sender}) => {
      // console.log(content,id);
      socket.in(id).emit("new message",{content:content , sender:sender});
  })

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