index.js

const express = require("express");
const cors = require("cors");
require("dotenv").config();
const socketio = require("socket.io");
const http = require("http");

const user = require("./server/routes/user.router");
const chatRoom = require("./server/routes/chatRoom.router");
const message = require("./server/routes/message.router");
const search = require("./server/routes/search.router");
const {
    routeNotFound,
} = require("./server/middlewares/route-not-found.middleware");
const {
    errorHandler,
} = require("./server/middlewares/error-handler.middleware");
const { initializeDBConnection } = require("./server/db/db.connect");
const { generateSearchIndex } = require("./server/utils/generateSearchIndex");
const { addUser, removeUser, getReceiver } = require("./server/utils/socket");

const port = process.env.PORT || 4444;

const app = express();
const server = http.createServer(app);
const io = socketio(server);

io.on("connection", (socket) => {
    socket.on("saveUser", (userId) => addUser(userId, socket.id));
    socket.on("disconnect", () => removeUser(socket.id));
    socket.on("sendMessage", ({ message, receiverId, room }) => {
        const receiverSocketId = getReceiver(receiverId);
        if (message) {
            io.to(receiverSocketId).emit("getMessage", { message });
        }
        if (room) {
            io.to(receiverSocketId).emit("getMessage", { room });
        }
    });
});

app.use(express.json());
app.use(cors());
initializeDBConnection();

app.use("/user", user);
app.use("/room", chatRoom);
app.use("/message", message);
app.use("/search", search);

/* Error handlers do not move should be at the end*/
app.use(routeNotFound);
app.use(errorHandler);

server.listen(port, () => {
    console.log("server started on port " + port);
});

generateSearchIndex();