Backend Progress

server/.gitignore

@@ -0,0 +1,2 @@
+.env
+node_modules

server/app.js

@@ -0,0 +1,25 @@
+const express = require('express');
+const bodyParser = require('body-parser');
+const mongoose = require('mongoose');
+mongoose.Promise = global.Promise;
+mongoose.connect('mongodb://localhost/hacktivoverflow');
+var cors = require('cors')
+
+var app = express();
+var users = require('./routes/users');
+var questions = require('./routes/questions');
+var answers = require('./routes/answers');
+var index = require('./routes/index');
+
+app.use(bodyParser.json());
+app.use(bodyParser.urlencoded({ extended: false}));
+
+app.use(cors())
+app.use('/api/users', users);
+app.use('/api/questions', questions);
+app.use('/api/answers', answers);
+app.use('/', index);
+
+app.listen(7000, () => {
+  console.log('Listening on port 7000');
+})

server/controllers/answerController.js

@@ -0,0 +1,175 @@
+var Answer = require('../models/answer');
+var Question = require('../models/question');
+var util = require('../helpers/util');
+var methods = {}
+
+methods.getAll = (req, res) => {
+  Answer.find({}, (err, answers) => {
+    res.send(answers)
+  })
+}
+
+methods.get = (req, res) => {
+  util.userInfo(req.headers.token, function(user){
+    Answer.find({creator: user.id}, (err, answers) => {
+      res.send(answers)
+    })
+  })
+}
+
+methods.create = (req, res) => {
+  var questionId = req.params.question_id
+  var answer = req.body.answer;
+  if (req.headers.token) {
+    util.userInfo(req.headers.token, function(user){
+      Question.findById(req.params.question_id)
+      .then(question => {
+        var newAnswer = new Answer({
+          answer: answer,
+          creator: user.id,
+          questionId: questionId,
+          upVote: [],
+          downVote: [],
+          createdAt: new Date(),
+          updatedAt: new Date()
+        })
+
+        newAnswer.save((err, result) => {
+          if(err) console.log(err)
+          else{
+            question.answer.push(result._id)
+            question.save((err, result) => {
+              res.send(err ? err : result)
+            })
+          }
+        })
+        // Answer.create({
+        //   answer: answer,
+        //   creator: user.id,
+        //   questionId: questionId,
+        //   upVote: [],
+        //   downVote: [],
+        //   createdAt: new Date(),
+        //   updatedAt: new Date()
+        // })
+        // .then(response => {
+        //   console.log(response);
+        //   res.send('Question submited')
+        // })
+        // .catch(err => console.log(err))
+      })
+    })
+  } else {
+    res.send('Please login first')
+  }
+}
+
+methods.getOne = (req, res) => {
+  if(req.headers.token) {
+    util.userInfo(req.headers.token, function(user) {
+      Answer.find({_id: req.params.answer_id, })
+      .then(answer => {
+        if(answer.creator == user._id){
+          res.send(answer)
+        } else {
+          res.send('not authorized')
+        }
+        res.send(answer)
+      })
+      .catch(err => console.log(err))
+    })
+  } else {
+    res.send('please login first')
+  }
+}
+
+methods.update = (req, res) => {
+  util.userInfo(req.headers.token, function(user) {
+    Answer.findById(req.params.answer_id)
+    .then(answer =>{
+      if(answer.creator == user.id){
+        var answer = req.body.answer;
+
+        Answer.update({_id:req.params.id}, {
+          answer: answer,
+          updatedAt: new Date()
+        })
+        .then(()=>{
+          res.send('answer has been updated')
+        })
+      } else {
+        res.send('not authorized')
+      }
+    })
+    .catch(err => console.log(err))
+  })
+}
+
+methods.delete = (req, res) => {
+  util.userInfo(req.headers.token, function(user){
+    Answer.findById(req.params.answer_id)
+    .then(answer => {
+      if(answer.creator == user.id){
+        answer.remove()
+        .then(()=>{
+          res.send('answer has been deleted')
+        })
+        .catch(err => console.log(err))
+      } else {
+        res.send('not authorized')
+      }
+    })
+  })
+}
+
+methods.upvote = (req, res) => {
+  util.userInfo(req.headers.token, function(user){
+    Answer.findById(req.params.answer_id)
+    .then(answer => {
+      let upvoteIdx = answer.upVote.indexOf(user.id)
+      let downvoteIdx = answer.downVote.indexOf(user.id)
+
+      if(upvoteIdx == -1 && downvoteIdx !== -1){
+        answer.downVote.splice(downvoteIdx, 1)
+        answer.save((err, result) => {
+          res.send(err ? err : result)
+        })
+      } else if (upvoteIdx == -1 && downvoteIdx == -1){
+        answer.upVote.push(user.id)
+        answer.save((err, result) => {
+          res.send(err ? err : result)
+        })
+      } else {
+        res.send('you already vote')
+      }
+    })
+    .catch(err => console.log(err))
+  })
+}
+
+methods.downvote = (req, res) => {
+  util.userInfo(req.headers.token, function(user){
+    Answer.findById(req.params.answer_id)
+    .then(answer => {
+      let upvoteIdx = answer.upVote.indexOf(user.id)
+      let downvoteIdx = answer.downVote.indexOf(user.id)
+
+      if(downvoteIdx == -1 && upvoteIdx !== -1){
+        answer.upVote.splice(upvoteIdx, 1)
+        answer.save((err, result) => {
+          res.send(err ? err : result)
+        })
+      } else if (downvoteIdx == -1 && upvoteIdx == -1){
+        answer.downVote.push(user.id)
+        answer.save((err, result) => {
+          res.send(err ? err : result)
+        })
+      } else {
+        res.send('you already vote')
+      }
+    })
+    .catch(err => console.log(err))
+  })
+}
+
+module.exports = methods

server/controllers/auth.js

@@ -0,0 +1,159 @@
+'use strict'
+require('dotenv').config();
+const secret = process.env.TOKEN_SECRET;
+const saltRounds = 10
+
+const nodemailer = require('nodemailer')
+const transporter = nodemailer.createTransport({
+  service: 'gmail.com',
+  auth:{
+    user: process.env.user_email,
+    pass: process.env.password
+  }
+})
+
+const jwt = require('jsonwebtoken');
+const bcrypt = require('bcrypt');
+var User = require('../models/user');
+var methods = {}
+
+// background job here
+// var CronJob = require('cron').CronJob;
+// var kue = require('kue')
+//   , queue = kue.createQueue();
+
+methods.login = (req, res) => {
+  var email = req.body.email;
+  var password = req.body.password;
+
+  User.findOne({email: email})
+  .then(user => {
+    if(user == null){
+      res.send('no such user')
+    } else {
+      bcrypt.compare(password, user.password)
+      .then(result => {
+        if(result) {
+          var token = jwt.sign({id: user.id, email: user.email, username: user.username}, secret);
+          res.send({"token": token});
+        } else {
+          console.log(result);
+          res.send("password is incorrect");
+        }
+      })
+      .catch(err => console.log(err))
+    }
+  })
+  .catch(err => console.log(err))
+}
+
+methods.signup = (req, res) => {
+  var salt = bcrypt.genSaltSync(saltRounds);
+  var hash = bcrypt.hashSync(req.body.password, salt);
+
+  User.create({
+    username: req.body.username,
+    password: hash,
+    email: req.body.email,
+    fb_account: false
+  })
+  .then(response => {
+    res.send('User created');
+
+    // var cronJobTime = new Date();
+    // cronJobTime = new Date(cronJobTime.getTime() + 1000*5);
+    //
+    // // run background job
+    // // send email
+    // var job = new CronJob(cronJobTime, function() {
+    //     welcomeEmail(response)
+    //     console.log(`Thanks for registering, ${response.username}`);
+    //     this.stop()
+    //   }, function () {
+    //     console.log('crown job is done!');
+    //   },
+    //   true, /* Start the job right now */
+    //   'Asia/Jakarta' /* Time zone of this job. */
+    // );
+
+  })
+  .catch(err => {
+    console.log(err);
+    if(/username/.test(err.message)){
+      res.send('username already taken')
+    }
+    else if(/email_1/.test(err.message)){
+      res.send('email is already registered')
+    }
+    else {
+      res.send(err.message)
+    }
+  })
+}
+
+methods.authUser = (req, res, next) => {
+  let token = req.headers.token
+  if(token){
+    jwt.verify(token, secret, (err, decoded) => {
+      if(decoded.id == req.params.id){
+        req.body.token = token;
+        next()
+      } else {
+        res.send('not authorized')
+      }
+    })
+  } else {
+    res.send('Please login first')
+  }
+}
+
+methods.allUser = (req, res, next) => {
+  let token = req.headers.token
+  if(token){
+    jwt.verify(token, secret, (err, decoded) => {
+      if(decoded){
+        req.body.token = token;
+        next()
+      } else {
+        res.send('not authorized')
+      }
+    })
+  } else {
+    res.send('Please login first')
+  }
+}
+
+function welcomeEmail(data){
+  var job = queue.create('email', {
+    username: data.username,
+    email: data.email
+  }).save( function(err){
+    if( !err ) console.log( job.id );
+  });
+
+  queue.process('email', function(job, done){
+    sendEmail(job.data);
+    done()
+  });
+}
+
+function sendEmail(data) {
+  var mailOptions = {
+    from: '"MyMemo App" <[email protected]>', // sender address
+    to: data.email, // list of receivers
+    subject: 'Welcome to MyMemo', // Subject line
+    text: 'congratulation you are registered', // plain text body
+    html: '<b>This is test email!</b>' // html body
+  }
+  transporter.sendMail(mailOptions,(err,info)=>{
+    if(err){
+      console.log(err);
+    }
+    else{
+      console.log(`Email has been send to ${data.email}`);
+    }
+  })
+}
+
+
+module.exports = methods