sei-24-alvis-tweedr p1.

controllers/tweets.js

@@ -0,0 +1,79 @@
+module.exports = (db) => {
+
+let allTweets = (request, response) => {
+      db.tweets.getAllTweets((error, allTweets) => {
+        response.render('login', { allTweets });
+      });
+  };
+
+  let register = (request,response)=>{
+      let {username,password} = request.body;
+      db.tweets.getRegister(username,password,(error,result)=>{
+        response.redirect('/')
+      })
+  }
+
+  let login = (request,response)=>{
+    let {username,password} = request.body;
+    db.tweets.getLogin(username,password,(err,result)=>{
+      if (result === "too short" || result === "wrong password"){
+        res.status(404).send(result)
+      } else{
+        response.cookie('username',result.username);
+        response.cookie('id',result.id);
+        response.cookie('logIn', 'true');
+        response.redirect('/home')
+      }
+    })
+  }
+
+  let logout = (request,response) =>{
+    response.clearCookie('username');
+    response.clearCookie('id');
+    response.cookie('logIn','false');
+    response.send('logged out of tweedr')
+  }
+
+  let tweet = (request,response) =>{
+    let tweet = request.body.tweets;
+    let id = request.cookies.id;
+    let username = request.cookies.username
+    db.tweets.getTweet(tweet,id,username,(err,result)=>{
+      if (err){
+        console.log("err in tweet controller", err.message)
+      } else {
+        response.redirect('/home')
+      }
+    })
+  }
+
+  let home = (request,response)=>{
+    if(request.cookies.logIn === 'true'){
+       let id = request.cookies.id
+       db.tweets.getHome(id,(err,result)=>{
+         if (err){
+           response.status(404).send('error!')
+         } else {
+            console.log(result.rows)
+            response.render('home',{tweets:result.rows})
+        }
+       })
+    }
+  }
+
+  /**
+   * ===========================================
+   * Export controller functions as a module
+   * ===========================================
+   */
+  return {
+    allTweets,
+    register,
+    login,
+    logout,
+    home,
+    tweet,
+
+  };
+
+}

db.js

@@ -33,9 +33,9 @@ if( process.env.DATABASE_URL ){
 
 }else{
   configs = {
-    user: 'akira',
+    user: 'alvischew',
     host: '127.0.0.1',
-    database: 'testdb',
+    database: 'tweedr-db',
     port: 5432
   };
 }
@@ -62,9 +62,9 @@ pool.on('error', function (err) {
  */
 
 
-const allPokemonModelsFunction = require('./models/pokemon');
+const allTweetsModelsFunction = require('./models/tweets');
 
-const pokemonModelsObject = allPokemonModelsFunction( pool );
+const tweetsModelsObject = allTweetsModelsFunction( pool );
 
 
 
@@ -95,5 +95,5 @@ module.exports = {
    */
 
   // users: userModelsObject,
-  pokemon: pokemonModelsObject
+  tweets: tweetsModelsObject
 };

models/tweets.js

@@ -0,0 +1,84 @@
+module.exports = (dbPoolInstance) => {
+
+
+let getAllTweets = (callback) => {
+
+    let query = 'SELECT * FROM tweets';
+
+    dbPoolInstance.query(query, (error, queryResult) => {
+      if( error ){
+        // invoke callback function with results after query has executed
+        callback(error, null);
+
+      }else{
+
+        // invoke callback function with results after query has executed
+
+        if( queryResult.rows.length > 0 ){
+          callback(null, queryResult.rows);
+
+        }else{
+          callback(null, null);
+        }
+      }
+    });
+  };
+
+  let getRegister = (username,password,callback)=>{
+    let query = `INSERT INTO users (username,password) VALUES ('${username}','${password}')`
+    dbPoolInstance.query(query, (err,res)=>{
+      if(err){
+        console.log("err in getLogin models", err.message)
+      } else {
+        callback(err,res)
+      }
+    })
+  }
+
+  let getLogin = (username,password,callback) =>{
+
+    let query = `SELECT * FROM users where username = '${username}'`
+    dbPoolInstance.query(query,(err,queryResult)=>{
+      if(err){
+
+        callback(err,null)
+      } else {
+        if( queryResult.rows.length<1){
+
+          callback(err,"too short")
+        } else{
+          if(queryResult.rows[0].password !== `${password}`){
+
+            callback(err,"wrong password")
+          } else{callback(err,queryResult.rows[0]);}
+        }
+      }
+    })
+  }
+
+  let getTweet = (tweet,id,username,callback) =>{
+    let values = [id,username,tweet];
+    let query = `INSERT INTO tweets (userid,username,tweets) VALUES ($1,$2,$3)`
+    dbPoolInstance.query(query,values,(err,results)=>{
+      callback(err,results)
+    })
+  }
+
+  let getHome = (id,callback) =>{
+    let query = `SELECT users.id, tweets.username, tweets.tweets FROM users INNER JOIN tweets ON (users.id = tweets.userid) WHERE users.id = $1`
+    let values = [id]
+    dbPoolInstance.query(query,values,(err,result)=>{
+      callback(err,result)
+    })
+  }
+
+  return {
+    getAllTweets,
+    getRegister,
+    getLogin,
+    getHome,
+    getTweet
+  };
+
+
+}