add new files

Author: SaltyFish0308

app.js

@@ -0,0 +1,244 @@
+var express = require('express');
+var bodyParser = require('body-parser');
+var mysql = require('mysql2');
+var path = require('path');
+var session = require('express-session');
+
+var app = express();
+
+// Set up the database connection details
+var connection = mysql.createConnection({
+    host: '34.70.101.192',
+    user: 'sxianyu2',
+    password: '88888888',
+    database: '411_Smaller'
+});
+
+// Connect to the database
+connection.connect(function(err) {
+    if (err) {
+        console.error('error: ' + err.message);
+        process.exit(1); // Terminate the application with an error code
+    }
+    console.log('Connected to the MySQL server.');
+});
+
+app.set('view engine', 'ejs');
+app.set('views', path.join(__dirname, 'views'));
+
+// Middleware
+app.use(bodyParser.urlencoded({ extended: true }));
+app.use(bodyParser.json());
+app.use(session({
+    secret: 'secret',
+    resave: false,
+    saveUninitialized: false
+}));
+
+app.use((req, res, next) => {
+    res.locals.loggedin = req.session.loggedin || false;
+    res.locals.username = req.session.username || '';
+    res.locals.userId = req.session.userId || '';  // Ensure this line exists
+    next();
+});
+
+
+// Routes
+app.get('/', (req, res) => {
+    // Check if user is logged in
+    if (req.session.loggedin) {
+        res.render('index', { recipes: null, message: 'Welcome back, ' + req.session.username });
+    } else {
+        res.render('index', { recipes: null, message: '' });
+    }
+});
+
+app.get('/my-likes', function(req, res) {
+    if (!req.session.loggedin || !req.session.userId) {
+        res.redirect('/login'); // Redirect to login if not logged in
+        return;
+    }
+
+    const userId = req.session.userId;
+    const sql = `
+        SELECT Recipes.recipe_id, Recipes.recipe_name
+        FROM Recipes
+        JOIN UserLikeRecipe ON Recipes.recipe_id = UserLikeRecipe.recipe_id
+        WHERE UserLikeRecipe.user_id = ?`;
+
+    connection.query(sql, [userId], function(err, results) {
+        if (err) {
+            console.error("Error fetching liked recipes:", err);
+            res.render('index', { recipes: null, message: "Error fetching your liked recipes" });
+            return;
+        }
+        // Pass an additional variable to indicate no buttons should be displayed
+        res.render('index', { recipes: results, message: "", displayButtons: false });
+    });
+});
+
+
+
+app.post('/search-by-recipe', (req, res) => {
+    const keywords = req.body.keyword.split(',').map(k => k.trim());
+    let query = 'SELECT recipe_id, recipe_name FROM Recipes WHERE';
+    const conditions = keywords.map((keyword, index) => {
+        return ` recipe_name LIKE ?`;
+    }).join(' OR ');
+
+    query += conditions;
+    const params = keywords.map(keyword => `%${keyword}%`);
+
+    connection.query(query, params, (err, results) => {
+        if (err) {
+            console.error(err);
+            res.status(500).send('Database error occurred.');
+            return;
+        }
+        res.render('index', { recipes: results, message: '', displayButtons: true }); // Include message as an empty string
+    });
+});
+
+app.post('/search-by-ingredient', (req, res) => {
+    const ingredients = req.body.ingredient.split(',').map(ingredient => ingredient.trim());
+    let query = `
+        SELECT DISTINCT Recipes.recipe_id, Recipes.recipe_name 
+        FROM Recipes 
+        JOIN RecipeIncludesIngredients ON Recipes.recipe_id = RecipeIncludesIngredients.recipe_id
+        JOIN Ingredients ON RecipeIncludesIngredients.ingredient_id = Ingredients.ingredient_id
+        WHERE`;
+    const conditions = ingredients.map(ingredient => {
+        return ` Ingredients.ingredient_name LIKE ?`;
+    }).join(' OR ');
+
+    query += conditions;
+    const params = ingredients.map(ingredient => `%${ingredient}%`);
+
+    connection.query(query, params, (err, results) => {
+        if (err) {
+            console.error(err);
+            res.status(500).send('Database error occurred.');
+            return;
+        }
+        res.render('index', { recipes: results, message: '', displayButtons: true });
+    });
+});
+
+app.post('/login', (req, res) => {
+    const { useremail, password } = req.body;
+
+    connection.query('SELECT user_id, user_name FROM Users WHERE user_email = ? AND password = ?', [useremail, password], function(error, results) {
+        if (error) {
+            console.error('Database error:', error);
+            res.render('index', { recipes: null, message: 'Database error during login.' });
+            return;
+        }
+
+        if (results.length > 0) {
+            req.session.loggedin = true;
+            req.session.userId = results[0].user_id;  // Storing user_id in the session
+            req.session.username = results[0].user_name; // Storing username in the session
+            res.render('index', { recipes: null, message: 'Login successful!', loggedin: true });
+        } else {
+            res.render('index', { recipes: null, message: 'Incorrect Username and/or Password!', loggedin: false });
+        }
+    });
+});
+
+
+app.post('/register', (req, res) => {
+    const { useremail, username, password } = req.body;
+
+    connection.query('SELECT user_name FROM Users WHERE user_email = ?', useremail, function(error, results) {
+        if (error) {
+            console.error('Database error:', error);
+            res.render('index', { recipes: null, message: 'Database error during register.' });
+            return;
+        }
+
+        if (results.length > 0) {
+            // User email already exists
+            res.render('index', { recipes: null, message: 'Email already exists. Please login or use another email.' });
+        } else {
+            //Get maximum user id in the data base (INT)
+            connection.query('SELECT MAX(user_id) as max_id FROM Users', function(error, result){
+                if (error) {
+                    console.error('Database error:', error);
+                    res.render('index', { recipes: null, message: 'Database error during register.' });
+                    return;
+                }
+                const maxId = result[0].max_id; // || 0; // Handle the case where there are no users
+                const newUserId = maxId + 1;
+
+                connection.query('INSERT INTO Users (user_id, user_email, user_name, password) VALUES (?, ?, ?, ?)', 
+                [newUserId, useremail, username, password], function(insertError, insertResult) {
+                    if (insertError) {
+                        console.error('Database error when inserting new user:', insertError);
+                        res.render('index', { recipes: null, message: 'Failed to create account. Please try again.' });
+                        return;
+                    }
+                    // Successfully created the user
+                    res.render('index', { recipes: null, message: 'Account created successfully! Please log in.' });
+                })
+            })
+        }
+    });
+});
+
+app.post('/like-recipe', function(req, res) {
+    if (req.session.loggedin && req.session.userId) {
+        const userId = req.session.userId; // Use the userId from the session
+        const recipeId = req.body.recipeId;
+
+        // First, check if the like already exists
+        const checkSql = "SELECT * FROM UserLikeRecipe WHERE user_id = ? AND recipe_id = ?";
+        connection.query(checkSql, [userId, recipeId], function(checkErr, checkResults) {
+            if (checkErr) {
+                console.error("Error checking existing likes:", checkErr);
+                res.render('index', { recipes: null, message: "Error checking likes" });
+                return;
+            }
+
+            if (checkResults.length > 0) {
+                // If the like already exists, don't insert and send a message back
+                res.render('index', { recipes: null, message: "You have already liked this recipe" });
+            } else {
+                // Like does not exist, proceed with insertion
+                const insertSql = "INSERT INTO UserLikeRecipe (user_id, recipe_id) VALUES (?, ?)";
+                connection.query(insertSql, [userId, recipeId], function(insertErr, insertResult) {
+                    if (insertErr) {
+                        console.error("Error inserting into UserLikeRecipe:", insertErr);
+                        res.render('index', { recipes: null, message: "Error processing your like" });
+                    } else {
+                        console.log("Successfully inserted like into database");
+                        res.render('index', { recipes: null, message: "Recipe liked successfully!" });
+                    }
+                });
+            }
+        });
+    } else {
+        res.render('index', { recipes: null, message: "Please log in to like recipes" });
+    }
+});
+
+
+
+
+
+
+// Logout route
+app.get('/logout', (req, res) => {
+    req.session.destroy(err => {
+        if (err) {
+            return console.log(err);
+        }
+        res.redirect('/');
+    });
+});
+
+// Server setup
+var port = process.env.PORT || 80;
+app.listen(port, () => {
+    console.log(`Server running on port ${port}`);
+});
+

bin/www

@@ -0,0 +1,90 @@
+#!/usr/bin/env node
+
+/**
+ * Module dependencies.
+ */
+
+var app = require('../app');
+var debug = require('debug')('myproj:server');
+var http = require('http');
+
+/**
+ * Get port from environment and store in Express.
+ */
+
+var port = normalizePort(process.env.PORT || '3000');
+app.set('port', port);
+
+/**
+ * Create HTTP server.
+ */
+
+var server = http.createServer(app);
+
+/**
+ * Listen on provided port, on all network interfaces.
+ */
+
+server.listen(port);
+server.on('error', onError);
+server.on('listening', onListening);
+
+/**
+ * Normalize a port into a number, string, or false.
+ */
+
+function normalizePort(val) {
+  var port = parseInt(val, 10);
+
+  if (isNaN(port)) {
+    // named pipe
+    return val;
+  }
+
+  if (port >= 0) {
+    // port number
+    return port;
+  }
+
+  return false;
+}
+
+/**
+ * Event listener for HTTP server "error" event.
+ */
+
+function onError(error) {
+  if (error.syscall !== 'listen') {
+    throw error;
+  }
+
+  var bind = typeof port === 'string'
+    ? 'Pipe ' + port
+    : 'Port ' + port;
+
+  // handle specific listen errors with friendly messages
+  switch (error.code) {
+    case 'EACCES':
+      console.error(bind + ' requires elevated privileges');
+      process.exit(1);
+      break;
+    case 'EADDRINUSE':
+      console.error(bind + ' is already in use');
+      process.exit(1);
+      break;
+    default:
+      throw error;
+  }
+}
+
+/**
+ * Event listener for HTTP server "listening" event.
+ */
+
+function onListening() {
+  var addr = server.address();
+  var bind = typeof addr === 'string'
+    ? 'pipe ' + addr
+    : 'port ' + addr.port;
+  debug('Listening on ' + bind);
+}