Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
23 changes: 0 additions & 23 deletions backend/package-lock.json

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

4 changes: 1 addition & 3 deletions backend/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -6,16 +6,14 @@
"scripts": {
"test": "echo \"Error: no test specified\" && exit 1",
"build": "tsc",
"dev": "node server.js",
"dev-ts": "node --loader ts-node/esm src/server.ts"
"dev": "nodemon dist/server.js"
},
"keywords": [],
"author": "",
"license": "ISC",
"type": "module",
"dependencies": {
"bcryptjs": "^3.0.2",
"cors": "^2.8.5",
"dotenv": "^17.2.3",
"express": "^5.1.0",
"jsonwebtoken": "^9.0.2",
Expand Down
68 changes: 0 additions & 68 deletions backend/server.js

This file was deleted.

17 changes: 0 additions & 17 deletions backend/src/models/chatMessageModel.ts

This file was deleted.

43 changes: 1 addition & 42 deletions backend/src/server.ts
Original file line number Diff line number Diff line change
@@ -1,8 +1,5 @@
import mongoose from "mongoose";
import { createServer } from "http";
import { Server as SocketIOServer } from "socket.io";
import app from "./app.js"
import { ChatMessage } from "./models/chatMessageModel.js";

import dotenv from "dotenv";
dotenv.config();
Expand All @@ -11,48 +8,10 @@ const PORT = process.env.PORT;
const MONGO_URI = process.env.MONGO_URI as string;
// console.log(MONGO_URI)

const httpServer = createServer(app);
const io = new SocketIOServer(httpServer, {
cors: { origin: "*" },
});

io.on("connection", (socket) => {
socket.on("join-room", async (roomId, userName) => {
socket.join(roomId);
// Send recent chat history to the user
try {
const recentMessages = await ChatMessage.find({ roomId })
.sort({ timestamp: -1 })
.limit(50)
.lean();
socket.emit("chat-history", recentMessages.reverse());
} catch (error) {
console.error("Error fetching chat history:", error);
}
});

socket.on("chat-message", async ({ roomId, user, text }) => {
try {
// Save message to database
const message = new ChatMessage({ roomId, user, text });
await message.save();

// Broadcast to all users in the room
io.to(roomId).emit("chat-message", {
user,
text,
time: new Date(),
});
} catch (error) {
console.error("Error saving message:", error);
}
});
});

mongoose
.connect(MONGO_URI)
.then(() => {
console.log(" MongoDB Connected");
httpServer.listen(PORT, () => console.log(`Server running on port ${PORT}`));
app.listen(PORT, () => console.log(`Server running on port ${PORT}`));
})
.catch((err) => console.error(" DB connection failed:", err));
Loading
Loading