index.ts

// import dependencies
import { Socket } from "socket.io";
import express from "express";
import morgan from "morgan";
import cors from "cors";


// import dotenv
import { config } from "dotenv";
config();

// database connection
import connnectDatabase from "./src/framework/database/config/dbConfig";

// import the route file
import userRoute from "./src/interface/routes/userRoutes";
import tokenRoute from "./src/interface/routes/tokenRoutes"
import { User } from "./src/domain/models/User";
import { Message } from "./src/domain/models/Message";
import { Chat } from "./src/domain/models/Chat";

// creat express application
const app = express();

// cors setting
const allowedOrigins =
  [
  "http://localhost:5173","http://localhost:4173",
  "http://localhost:3000","http://localhost:4000",
    process.env.CLIENT_ORIGIN_URL as string,
    process.env.DISTRIBUTED_ORIGIN_URL as string,
  ];
app.use(
  cors({
    origin: allowedOrigins,
    methods: ["GET", "POST", "PUT", "DELETE", "PATCH"],
  })
);

// middleware for json
app.use(express.json());
// middleware for handle form data
app.use(express.urlencoded({ extended: true }));
// middleware for log
app.use(morgan("dev"));

// user route
app.use('/', userRoute);
app.use('/refresh/token', tokenRoute);

// database connecting & app listen
const port = process.env.PORT || 8000;
connnectDatabase()
  .then((res) => {
    console.log(res);
    const server = app.listen(port, (): void => console.log(`Server running...`));
    const io = require("socket.io")(server, {
      pingTimeout: 60000,
      cors: {
        origin: allowedOrigins,
      },
    });
    io.on("connection", (socket: Socket) => {
      socket.on("connect-to-online", (roomId: string) => {
        socket.join(roomId.toString());
      });
      socket.on("join-to-chat", (roomId: string) => {
        socket.join(roomId.toString());
      });
      socket.on("new-message", (newMessage: Message) => {
         let chat = newMessage?.chat as Chat;
        if (!chat?.users) { return; }
          chat?.users.forEach((user: User) => {
             if (user?.toString() === newMessage?.sender?._id?.toString()) { return };
           socket.to(user.toString() as string).emit("message-recieved", newMessage);
          });
       });
    });
  })
  .catch((error) => console.log(`Failed to connect database`, error));