merged local and remote

Author: Wcoder547

Back-end/.gitignore

@@ -0,0 +1,13 @@
+node_modules
+/.env
+dist
+coverage
+logs
+*.log
+*.env
+.DS_Store
+.idea
+.vscode
+*.suo
+*.ntvs*
+*.njsproj

Back-end/app.js

@@ -0,0 +1,154 @@
+import express from "express";
+import { connectDB } from "./utils/features.js";
+import dotenv from "dotenv";
+import { errorMiddleware } from "./middlewares/error.js";
+import cookieParser from "cookie-parser";
+import { Server } from "socket.io"; 
+import { createServer } from "http"; 
+import { v4 as uuid } from "uuid";
+import cors from "cors";
+import { v2 as cloudinary } from "cloudinary";
+import {
+  CHAT_JOINED,
+  CHAT_LEAVED,
+  NEW_MESSAGE,
+  NEW_MESSAGE_ALERT,
+  ONLINE_USERS,
+  START_TYPING,
+  STOP_TYPING,
+} from "./constants/events.js";
+import { getSockets } from "./lib/helper.js";
+import { Message } from "./models/message.js";
+import { corsOptions } from "./constants/config.js";
+import { socketAuthenticator } from "./middlewares/auth.js";
+
+import userRoute from "./routes/user.js";
+import chatRoute from "./routes/chat.js";
+import adminRoute from "./routes/admin.js";
+
+dotenv.config({
+  path: "./.env",
+});
+
+const mongoURI = process.env.MONGO_URI;
+const port = process.env.PORT || 3000;
+const envMode = process.env.NODE_ENV.trim() || "PRODUCTION";
+const adminSecretKey = process.env.ADMIN_SECRET_KEY || "adsasdsdfsdfsdfd";
+const userSocketIDs = new Map();
+const onlineUsers = new Set();
+
+connectDB(mongoURI);
+
+cloudinary.config({
+  cloud_name: process.env.CLOUDINARY_CLOUD_NAME,
+  api_key: process.env.CLOUDINARY_API_KEY,
+  api_secret: process.env.CLOUDINARY_API_SECRET,
+});
+
+const app = express();
+const server = createServer(app);
+const io = new Server(server, {
+  cors: corsOptions,
+});
+
+app.set("io", io);
+
+// Using Middlewares Here
+app.use(express.json());
+app.use(cookieParser());
+app.use(cors(corsOptions));
+
+app.use("/api/v1/user", userRoute);
+app.use("/api/v1/chat", chatRoute);
+app.use("/api/v1/admin", adminRoute);
+
+app.get("/", (req, res) => {
+  res.send("Hello World");
+});
+
+//middleware for socket authentication
+io.use((socket, next) => {
+  cookieParser()(
+    //can read cookies).
+    socket.request,
+    socket.request.res,
+    async (err) => await socketAuthenticator(err, socket, next) //method for authenticating socket connections
+  );
+});
+
+io.on("connection", (socket) => {
+  console.log("New client connected:", socket.id);
+  const user = socket.user;
+  userSocketIDs.set(user._id.toString(), socket.id);
+  console.log(`User connected: ${user.name}`);
+
+  socket.on(NEW_MESSAGE, async ({ chatId, members, message }) => {
+    const messageForRealTime = {
+      content: message,
+      _id: uuid(),
+      sender: {
+        _id: user._id,
+        name: user.name,
+      },
+      chat: chatId,
+      createdAt: new Date().toISOString(),
+    };
+
+    const messageForDB = {
+      content: message,
+      sender: user._id,
+      chat: chatId,
+    };
+
+    const membersSocket = getSockets(members);
+    io.to(membersSocket).emit(NEW_MESSAGE, {
+      chatId,
+      message: messageForRealTime,
+    });
+    io.to(membersSocket).emit(NEW_MESSAGE_ALERT, { chatId });
+
+    try {
+      await Message.create(messageForDB);
+    } catch (error) {
+      throw new Error(error);
+    }
+  });
+
+  socket.on(START_TYPING, ({ members, chatId }) => {
+    const membersSockets = getSockets(members);
+    socket.to(membersSockets).emit(START_TYPING, { chatId });
+  });
+
+  socket.on(STOP_TYPING, ({ members, chatId }) => {
+    const membersSockets = getSockets(members);
+    socket.to(membersSockets).emit(STOP_TYPING, { chatId });
+  });
+
+  socket.on(CHAT_JOINED, ({ userId, members }) => {
+    onlineUsers.add(userId.toString());
+
+    const membersSocket = getSockets(members);
+    io.to(membersSocket).emit(ONLINE_USERS, Array.from(onlineUsers));
+  });
+
+  socket.on(CHAT_LEAVED, ({ userId, members }) => {
+    onlineUsers.delete(userId.toString());
+
+    const membersSocket = getSockets(members);
+    io.to(membersSocket).emit(ONLINE_USERS, Array.from(onlineUsers));
+  });
+
+  socket.on("disconnect", () => {
+    userSocketIDs.delete(user._id.toString());
+    onlineUsers.delete(user._id.toString());
+    socket.broadcast.emit(ONLINE_USERS, Array.from(onlineUsers));
+  });
+});
+
+app.use(errorMiddleware);
+
+server.listen(port, () => {
+  console.log(`Server is running on port ${port} in ${envMode} Mode`);
+});
+
+export { envMode, adminSecretKey, userSocketIDs };

Back-end/constants/config.js

@@ -0,0 +1,13 @@
+const corsOptions = {
+  origin: [
+    "http://localhost:5173",
+    "http://localhost:4173",
+    process.env.CLIENT_URL,
+  ],
+  methods: ["GET", "POST", "PUT", "DELETE"],
+  credentials: true,
+};
+
+const CHATTU_TOKEN = "chattu-token";
+
+export { corsOptions, CHATTU_TOKEN };

Back-end/constants/events.js

@@ -0,0 +1,30 @@
+const ALERT = "ALERT";
+const REFETCH_CHATS = "REFETCH_CHATS";
+
+const NEW_ATTACHMENT = "NEW_ATTACHMENT";
+const NEW_MESSAGE_ALERT = "NEW_MESSAGE_ALERT";
+
+const NEW_REQUEST = "NEW_REQUEST";
+const NEW_MESSAGE = "NEW_MESSAGE";
+
+const START_TYPING = "START_TYPING";
+const STOP_TYPING = "STOP_TYPING";
+
+const CHAT_JOINED = "CHAT_JOINED";
+const CHAT_LEAVED = "CHAT_LEAVED";
+
+const ONLINE_USERS = "ONLINE_USERS";
+
+export {
+  ALERT,
+  REFETCH_CHATS,
+  NEW_ATTACHMENT,
+  NEW_MESSAGE_ALERT,
+  NEW_REQUEST,
+  NEW_MESSAGE,
+  START_TYPING,
+  STOP_TYPING,
+  CHAT_JOINED,
+  CHAT_LEAVED,
+  ONLINE_USERS,
+};