app.js

const express = require("express");
const app = express();
const path = require('path');
const {createServer} = require('http');
const {Server} = require('socket.io');
const httpServer = createServer(app);
const io = new Server(httpServer);
const PORT = 8080;
const ejsMate = require('ejs-mate');
const mongoose = require("mongoose");
const session = require("express-session");
const userRoute = require("./routes/user");
const rootRoute = require("./routes/root");

connectDb()
    .then(()=>{
        console.log("conected successfully")
    })
    .catch((err)=>{
        console.log(err);
    })

async function connectDb(){
    mongoose.connect("mongodb://127.0.0.1:27017/chatApp")
}



app.use(express.static(path.join(__dirname, 'public')));
app.use(express.json());
app.use(express.urlencoded({extended: true}));
app.set('view engine', 'ejs');
app.set("views",path.join(__dirname,'views'));
app.engine('ejs', ejsMate);

let sessionOptions = {
    secret: "superSecetKey",
    resave: false,
    saveUninitialized: false,
    cookie: {
        httpOnly: true,
        maxAge: 10*24*60*60
    }
}

app.use(session(sessionOptions));

app.use("/user",userRoute);
app.use("/chat",rootRoute);

io.on("connection", (socket) => {
    console.log("Connection id :",socket.id);

    socket.on("joinRoom",(roomId)=>{
        socket.join(roomId); //Conversation id will be new roomID
        console.log("Joined Room :",roomId);
    })

    socket.on("sendMessage", async (data) => {
        let {sender,receiverUsername,newMsg,convoId} = data;
        // console.log(sender,receiver,newMsg,convoId)
        io.to(convoId).emit("newMessage",{sender,receiverUsername,newMsg,convoId});
    })

})


app.use((err,req,res,next)=>{
    let {statusCode=500, message="Something went wrong !"} = err;
    console.log(err);
    res.status(statusCode).send(message);
})

httpServer.listen(PORT,()=>{
    console.log(`Listening at port : ${PORT}`);
})