index.js

import express from "express";
import { Server } from "socket.io";
import { createServer } from "http";
import bodyParser from "body-parser";
import path from "path";
const __dirname = path.resolve();
const PORT = 3000;
const app = express();
const httpServer = createServer(app);
const io = new Server(httpServer);

app.set("view engine", "ejs");
app.set("views", "views");

//serving static files css and javascript
app.use(express.static(path.join(__dirname, "public")));

app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: true }));

//logging method and routes
app.use((req, res, next) => {
  console.info(`${req.method} --> ${req.originalUrl}`);
  next();
});
//HOME ROUTE /

app.get("/", (req, res) => {
  res.render("index", { title: "Web chat🗨️" });
});
app.get("/tech", (req, res) => {
  res.render("tech", { title: "tech-chat🗨️" });
});
app.get("/social", (req, res) => {
  res.render("social", { title: "social-chat🗨️" });
});
app.get("/cricket", (req, res) => {
  res.render("cricket", { title: "cricket-chat🗨️" });
});
//name space for different rooms
const tech = io.of("/tech");
//events and listeners for socket.io
tech.on("connect", (socket) => {
  console.info("user has joined the chat");
  socket.on("userConnected", (data) => {
    socket.join(data.room);
    socket.broadcast
      .to(data.room)
      .emit("newUserMessage", "A new user has joined!");
  });
  socket.on("getMessage", (data) => {
    const room = data.room;
    const value = data.value;

    tech.to(room).emit("postMessage", value);
  });
  socket.on("disconnect", () => {
    console.log("user has been disconnected");
  });
});

httpServer.listen(PORT, () => {
  console.info(`The server is up and running on ${PORT}`);
});