tweedr assignment

index.js

@@ -1,60 +1,140 @@
+console.log("starting up!!");
+
 const express = require('express');
 const methodOverride = require('method-override');
 const cookieParser = require('cookie-parser');
-
 const pg = require('pg');
 
-/**
- * ===================================
- * Configurations and set up
- * ===================================
- */
-
+// Initialise postgres client
 const configs = {
-  user: 'akira',
-  host: '127.0.0.1',
-  database: 'testdb',
-  port: 5432,
+    user: 'ronniechua',
+    host: '127.0.0.1',
+    database: 'tweedr',
+    port: 5432,
 };
 
 const pool = new pg.Pool(configs);
 
-pool.on('error', function (err) {
-  console.log('idle client error', err.message, err.stack);
+pool.on('error', function(err) {
+    console.log('idle client error', err.message, err.stack);
 });
 
+/**
+ * ===================================
+ * Configurations and set up
+ * ===================================
+ */
+
 // Init express app
 const app = express();
 
-// Set up middleware
-app.use(methodOverride('_method'));
-app.use(cookieParser());
+app.use(express.json());
 app.use(express.urlencoded({
-  extended: true
+    extended: true
 }));
+app.use(express.static(__dirname + '/public'));
+
+app.use(methodOverride('_method'));
+app.use(cookieParser());
+
 
 // Set react-views to be the default view engine
 const reactEngine = require('express-react-views').createEngine();
 app.set('views', __dirname + '/views');
 app.set('view engine', 'jsx');
 app.engine('jsx', reactEngine);
 
+
 /**
  * ===================================
  * Routes
  * ===================================
  */
 
 // Root GET request (it doesn't belong in any controller file)
-app.get('/', (request, response) => {
-  response.send('Welcome To Tweedr.');
+app.get('/', (req, res) => {
+    // query database for all pokemon
+    var loggedin = req.cookies['loggedin'];
+
+    // see if there is a cookie
+    if (loggedin === undefined) {
+        res.send("You are not logged in! <a href = '/user/login'>click here</a> to login");
+
+    } else {
+        pool.query('SELECT * FROM tweets JOIN users ON users.id = tweets.author_id', (err, queryResult) => {
+            if (err) {
+                console.log(err);
+            }
+            let tweet = {};
+            tweet.list = [];
+            tweet.list = queryResult.rows;
+
+            res.render('home', tweet);
+        });
+    }
+});
+
+app.get('/user/login', (request, response) => {
+     var loggedin = request.cookies['loggedin'];
+    if (loggedin === undefined){
+    response.render('login');
+}else{
+response.redirect('/');
+};
+})
+
+
+app.post('/user/login', (request, response) => {
+    // if the user name and password are the same as in the DB, log them in
+
+    let query = "SELECT * FROM users WHERE username= '" + request.body.name + "'";
+
+    pool.query(query, (err, queryResponse) => {
+
+
+        //response.send('hellooooo');
+
+
+        // if the user doesnt exist
+        if (queryResponse.rows.length === 0) {
+  response.send("User does not exist! <a href = '/user/login'> click here </a> to try again!");
+          } else {
+
+            const user = queryResponse.rows[0];
+
+            var password = user.password;
+            var username = user.username;
+            var userid = user.id;
+
+            if (password == request.body.password) {
+                //password is correct
+                response.cookie('loggedin', 'true');
+                response.cookie('username', username);
+                response.cookie('author_id',userid);
+                response.redirect('/');
+            } else {
+                // password is incorrect
+                console.log("password incorrect")
+                response.redirect('/user/login')
+            }
+        }
+    })
 });
 
-app.get('/users/new', (request, response) => {
-  response.render('user/newuser');
+app.get('/user/logout', (request, response) => {
+
+  response.clearCookie('loggedin');
+  response.clearCookie('username');
+  response.clearCookie('author_id');
+
+  response.send("Successfully logged out! <a href = '/user/login'> click here </a> to login");
+})
+
+app.get('/user/new', (request, response) => {
+    response.render('user/newuser');
 });
 
-app.post('/users', (request, response) => {
+app.post('/user', (request, response) => {
 
     const queryString = 'INSERT INTO users (name, password) VALUES ($1, $2)';
     const values = [
@@ -69,6 +149,40 @@ app.post('/users', (request, response) => {
     });
 });
 
+//see profile of user
+app.get('/user/:id', (req, res) => {
+    // console.log("inside id");
+    let id = req.params.id;
+    // console.log("inside the id req:", req.params.id);
+    pool.query('SELECT * FROM users WHERE ID =' + id, (err, queryResult) => {
+        // console.log("inside pool query of :id");
+        // console.log(artistId.rows);
+        let user = {};
+        user.list = [];
+        user.list = queryResult.rows;
+        res.render('display', user);
+
+    });
+});
+
+app.get("/tweet/new", (req,res) => {
+        res.render('newtweet');
+});
+
+app.post("/tweet", (req,res) => {
+// console.log(req.body);
+// console.log(req.cookies);
+let content = req.body.content;
+let author_id = parseInt(req.cookies.author_id);
+const queryText = `INSERT INTO tweets (content, author_id) VALUES ('${content}', '${author_id}')`;
+pool.query(queryText, (err, response) => {
+        if (err) {
+            console.log("query error", err.message);
+        } else {
+            res.send("Successfully created tweet! <a href = '/'>Click here</a> to reload the tweets!");
+        }
+    });
+});
 
 
 /**
@@ -79,13 +193,13 @@ app.post('/users', (request, response) => {
 
 const server = app.listen(3000, () => console.log('~~~ Tuning in to the waves of port 3000 ~~~'));
 
-let onClose = function(){
+let onClose = function() {
 
-  server.close(() => {
-    console.log('Process terminated')
-    pool.end( () => console.log('Shut down db connection pool'));
-  })
+    server.close(() => {
+        console.log('Process terminated')
+        pool.end(() => console.log('Shut down db connection pool'));
+    })
 };
 
 process.on('SIGTERM', onClose);
-process.on('SIGINT', onClose);
+process.on('SIGINT', onClose);

nodemon.json

@@ -0,0 +1,3 @@
+{
+    "ignore": ["*.json", "README"]
+}