Kyle

controllers/authController.js

@@ -0,0 +1,100 @@
+// authController.js
+
+const path = require('path');
+const { MongoClient } = require("mongodb");
+const crypto = require('crypto');
+const uri = "mongodb+srv://lillaundry:Antib7iotics!@sethcluster.lbpora8.mongodb.net/?retryWrites=true&w=majority&appName=SethCluster";
+
+// Function to render the register form
+function renderRegisterForm(req, res) {
+    res.sendFile(path.join(__dirname, '..', 'views', 'register.html'));
+}
+
+// Function to render the login form
+function renderLoginForm(req, res) {
+    res.sendFile(path.join(__dirname, '..', 'views', 'login.html'));
+}
+
+// Function to handle user registration
+async function registerUser(req, res) {
+    try {
+        // Extract user details from request body
+        const { user_ID, password } = req.body;
+
+        // Hash the password using custom hashing function
+        const hashedPassword = hashPassword(password);
+
+        // Connect to MongoDB
+        const client = new MongoClient(uri);
+        await client.connect();
+        const db = client.db('Sethdb'); // Change to your database name
+        const users = db.collection('users'); // Create a collection named 'users'
+
+        // Check if the user already exists
+        const existingUser = await users.findOne({ user_ID });
+        if (existingUser) {
+            return res.status(400).json({ error: 'User already exists' });
+        }
+
+        // Insert the new user into the database
+        await users.insertOne({ user_ID, password: hashedPassword });
+        await client.close();
+
+        // Redirect to homepage after successful registration
+        res.redirect('/');
+    } catch (error) {
+        console.error('Error registering user:', error);
+        res.status(500).json({ error: 'Internal Server Error' });
+    }
+}
+
+// Function to handle user login
+async function loginUser(req, res) {
+    try {
+        // Extract user details from request body
+        const { user_ID, password } = req.body;
+
+        // Connect to MongoDB
+        const client = new MongoClient(uri);
+        await client.connect();
+        const db = client.db('Sethdb'); // Change to your database name
+        const users = db.collection('users'); // Create a collection named 'users'
+
+        // Find the user in the database
+        const user = await users.findOne({ user_ID });
+        if (!user) {
+            // User not found
+            return res.status(401).json({ error: 'Invalid credentials' });
+        }
+
+        // Hash the provided password and compare with the stored hashed password
+        const hashedPassword = hashPassword(password);
+        if (hashedPassword !== user.password) {
+            // Incorrect password
+            return res.status(401).json({ error: 'Invalid credentials' });
+        }
+
+        // Set cookie
+        res.cookie('authToken', user_ID, { httpOnly: true });
+
+        // Redirect to homepage after successful login
+        res.redirect('/');
+    } catch (error) {
+        console.error('Error logging in:', error);
+        res.status(500).json({ error: 'Internal Server Error' });
+    }
+}
+
+// Custom hashing function using SHA-256
+function hashPassword(password) {
+    const hash = crypto.createHash('sha256');
+    hash.update(password);
+    return hash.digest('hex');
+}
+
+module.exports = {
+    renderRegisterForm,
+    renderLoginForm,
+    registerUser,
+    loginUser
+};

controllers/topicsController.js

@@ -0,0 +1,164 @@
+const { MongoClient, ObjectId } = require("mongodb");
+const uri = "mongodb+srv://lillaundry:Antib7iotics!@sethcluster.lbpora8.mongodb.net/?retryWrites=true&w=majority&appName=SethCluster";
+
+async function getAllTopicsWithMessages() {
+    try {
+        const client = new MongoClient(uri);
+        await client.connect();
+        const db = client.db('Sethdb');
+        const topics = db.collection('topics');
+
+        // Find all topics
+        const allTopics = await topics.find({}).toArray();
+
+        // Fetch messages for each topic
+        const topicsWithMessages = await Promise.all(allTopics.map(async topic => {
+            topic.messages = await getMessagesByTopicName(topic.name); // Corrected here
+            return topic;
+        }));
+
+        await client.close(); // Close the client connection
+
+        return topicsWithMessages;
+    } catch (error) {
+        console.error('Error fetching topics with messages:', error);
+        throw new Error('Internal Server Error');
+    }
+}
+
+async function getMessagesByTopicName(topicName) {
+    try {
+        const client = new MongoClient(uri);
+        await client.connect();
+        const db = client.db('Sethdb');
+        const topics = db.collection('topics');
+
+        // Find messages for the given topic name
+        const topic = await topics.findOne({ name: topicName });
+
+        await client.close(); // Close the client connection
+
+        return topic ? topic.messages : [];
+    } catch (error) {
+        console.error(`Error fetching messages for topic ${topicName}:`, error);
+        throw new Error('Internal Server Error');
+    }
+}
+
+async function createTopic(req, res) {
+    try {
+        // Extract topic details from request body
+        const { name, message } = req.body;
+
+        // Connect to MongoDB
+        const client = new MongoClient(uri);
+        await client.connect();
+        const db = client.db('Sethdb');
+        const topics = db.collection('topics');
+
+        // Check if topic with the given name already exists
+        const existingTopic = await topics.findOne({ name });
+
+        if (existingTopic) {
+            // Update existing topic by adding the new message
+            await topics.updateOne({ name }, { $push: { messages: message } });
+        } else {
+            // Create a new topic with the message
+            await topics.insertOne({ name, messages: [message] });
+        }
+
+        await client.close();
+
+        res.redirect('/topics');
+    } catch (error) {
+        console.error('Error creating topic:', error);
+        res.status(500).json({ error: 'Internal Server Error' });
+    }
+}
+async function subscribeToTopic(req, res) {
+    try {
+        const { topicName } = req.body;
+        const userId = req.cookies.authToken; // Assuming user ID is available in cookies
+
+        // Connect to MongoDB
+        const client = new MongoClient(uri);
+        await client.connect();
+        const db = client.db('Sethdb');
+        const topics = db.collection('topics');
+
+        // Find the topic by name
+        const topic = await topics.findOne({ name: topicName });
+
+        if (!topic) {
+            // Topic not found
+            return res.status(404).json({ error: 'Topic not found' });
+        }
+
+        // Check if the user is already subscribed to the topic
+        if (topic.subscribers.includes(userId)) {
+            return res.status(400).json({ error: 'User is already subscribed to this topic' });
+        }
+
+        // Add the user to the list of subscribers for the topic
+        await topics.updateOne(
+            { name: topicName },
+            { $push: { subscribers: userId } }
+        );
+
+        await client.close(); // Close the client connection
+
+        res.redirect('/topics');
+    } catch (error) {
+        console.error('Error subscribing to topic:', error);
+        res.status(500).json({ error: 'Internal Server Error' });
+    }
+}
+
+async function unsubscribeFromTopic(req, res) {
+    try {
+        const { topicName } = req.body;
+        const user_ID = req.cookies.authToken; // Assuming user ID is available in cookies
+
+        // Connect to MongoDB
+        const client = new MongoClient(uri);
+        await client.connect();
+        const db = client.db('Sethdb');
+        const users = db.collection('users');
+
+        // Find the user by ID
+        const user = await users.findOne({ user_ID });
+
+        if (!user) {
+            // User not found
+            return res.status(404).json({ error: 'User not found' });
+        }
+
+        // Remove the topic name from the user's subscribed topics array
+        user.subscribedTopics = user.subscribedTopics.filter(topic => topic !== topicName);
+
+        // Update the user document
+        await users.updateOne({ user_ID }, { $set: { subscribedTopics: user.subscribedTopics } });
+
+        await client.close(); // Close the client connection
+
+        res.redirect('/topics');
+    } catch (error) {
+        console.error('Error unsubscribing from topic:', error);
+        res.status(500).json({ error: 'Internal Server Error' });
+    }
+}
+
+
+
+module.exports = {
+    getAllTopicsWithMessages,
+    createTopic,
+    subscribeToTopic,
+    unsubscribeFromTopic,
+};
+
+module.exports = {
+    getAllTopicsWithMessages,
+    createTopic,
+    subscribeToTopic
+};

models/message.js

@@ -0,0 +1,14 @@
+// models/Message.jss
+const { Schema, model } = require('mongoose');
+
+const messageSchema = new Schema({
+    content: { type: String, required: true },
+    userId: { type: Schema.Types.ObjectId, ref: 'User', required: true },
+    topicId: { type: Schema.Types.ObjectId, ref: 'Topic', required: true },
+    createdAt: { type: Date, default: Date.now },
+    updatedAt: { type: Date, default: Date.now }
+});
+
+const Message = model('Message', messageSchema);
+
+module.exports = Message;

models/topic.js

@@ -0,0 +1,11 @@
+// models/Topic.js
+const { Schema, model } = require('mongoose');
+
+const topicSchema = new Schema({
+    name: { type: String, required: true, unique: true },
+    messages: [{ type: String, required: true }] // Define messages as an array of strings
+});
+
+const Topic = model('Topic', topicSchema);
+
+module.exports = Topic;

models/user.js

@@ -0,0 +1,13 @@
+// models/User.js
+
+const { Schema, model } = require('mongoose');
+
+const userSchema = new Schema({
+    user_ID: { type: String, required: true, unique: true },
+    password: { type: String, required: true },
+    subscribedTopics: [{ type: Schema.Types.ObjectId, ref: 'Topic' }] // Array of subscribed topics
+});
+
+const User = model('User', userSchema);
+
+module.exports = User;