DEV - create MVC

.gitignore

@@ -102,3 +102,6 @@ dist
 
 # TernJS port file
 .tern-port
+
+sandbox.js
+failed.zip

app.js

@@ -0,0 +1,20 @@
+if (process.env.NODE_ENV !== 'production') {
+  require('dotenv').config()
+}
+
+const express = require('express')
+const cors = require('cors')
+const route  = require('./routes/')
+const handleError = require('./middlewares/errHandler')
+const app = express()
+
+app.set('view engine','ejs')
+
+app.use(cors())
+app.use(express.urlencoded({ extended: true }))
+app.use(express.json())
+
+app.use(route)
+app.use(handleError)
+
+module.exports = app

bin/http.js

@@ -0,0 +1,4 @@
+const app = require('../app')
+const port = process.env.PORT || 4000
+
+app.listen(port, ()=> console.log('App run in port : ', port))

config/config.js

@@ -0,0 +1,28 @@
+const env = process.env.NODE_ENV || 'development'
+
+if (env == 'development' || env =='test') {
+    require('dotenv').config()
+}
+
+let capsEnv = env.toUpperCase()
+  let database = {
+      username : process.env["DB_USERNAME_" + capsEnv],
+      password : process.env["DB_PASSWORD_" + capsEnv],
+      database : process.env["DB_NAME_" + capsEnv],
+      host : process.env["DB_HOST_" + capsEnv],
+      dialect : process.env["DB_DIALECT_" + capsEnv],
+      logging: true
+  }
+
+module.exports = {
+  "development": database,
+  "test": database,
+  "production": {
+    "use_env_variable" : "DATABASE_URL",
+    "dialectOptions" : {
+      "ssl": {
+          "rejectUnauthorized": false
+      }
+    }
+  }
+}

controllers/adminController.js

@@ -0,0 +1,72 @@
+const { User, Village } = require('../models')
+const { comparePassword } = require('../helpers/useBcrypt')
+const { generateToken } = require('../helpers/useJwt')
+const createToken = require('../helpers/useToken')
+
+
+class AdminController {
+
+  static async registerAdmin(req, res, next) {
+    const { name, username, password, nameVillage, location, balance } = req.body
+
+    try {
+        const role = 'admin'
+        const invitation_code = createToken()
+        const user = await User.create({ name, username, password, role })
+
+        const village = await Village.create({ name: nameVillage, location, invitation_code, balance, UserId: user.id})
+
+        await User.update({ VillageId: village.id } ,{ where: { id: user.id }})
+
+        res.status(201).json({ message: 'Success Crete User and Village', invitation_code})
+    } catch (error) {
+      if (Array.isArray(error)) {
+        next({ name : 'SequelizeValidationError', errors: error })
+      } else {
+        next(error)
+      }
+    }
+  }
+
+  static async loginAdmin(req, res, next) {
+    const { username, password } = req.body
+    try {
+        const user = await User.findOne({ where: { username }})
+
+        if (user) {
+          const isPassword = comparePassword( password, user.password )
+
+          if (isPassword && user.role === 'admin') {
+            const access_token = generateToken({ id: user.id, username: user.username })
+
+            res.status(200).json(access_token)
+          } else {
+            next({ code: 404, message: "Invalid Username/Password" })
+          }
+        } else {
+          next({ code: 404, message: "Invalid Username/Password" })
+        }
+      } catch (error) {
+        next(error)
+      }
+    }
+
+  static async changeAdmin(req, res, next) {
+    const { id } = req.params
+    const { VillageId, id : AdminId } = req.currentUser
+
+    try {
+      await Village.update({ UserId: id }, { where: { id: VillageId }})
+
+      await User.update({ role: 'admin' }, { where: { id }})
+
+      await User.update({ role: 'member' }, { where: { id: AdminId }})
+
+      res.status(200).json({ message: "Successfully change role admin" })
+    } catch (error) {
+      next(error)
+    }
+  }
+}
+
+module.exports = AdminController

controllers/suggestionController.js

@@ -0,0 +1,47 @@
+const { Suggestion, Village, User } = require('../models')
+class SuggestionConroller {
+  static async fetchSuggestions(req, res, next){
+    try {
+      const { VillageId } = req.currentUser
+      const villageSuggestions = await Village.findOne({where : { id : VillageId}, 
+      include: {
+        model: Suggestion,
+        separate: true,
+        order: [['createdAt', 'DESC']],
+        include: User
+    }
+  })
+
+      res.status(200).json(villageSuggestions)
+    } catch (error) {
+      next(error)
+    }
+  }
+
+  static async addSuggestion(req, res, next){
+    const { title, description, type } = req.body
+    const { id, VillageId } = req.currentUser
+
+    try {
+      const suggestion = await Suggestion.create({title, description, type, UserId: id, VillageId})
+
+      res.status(201).json(suggestion)
+    } catch (error) {
+      next(error)
+    }
+  }
+
+  static async deleteSuggestion(req, res, next){
+    const { id } = req.params
+
+    try {
+      await Suggestion.destroy({ where : { id }, returning : true })
+
+      res.status(200).json({ message: 'Suggestion has been successfully deleted.'})
+    } catch (error) {
+      next(error)
+    }
+  }
+}
+
+module.exports = SuggestionConroller

controllers/transactionController.js

@@ -0,0 +1,75 @@
+const { Transaction, Village, User } = require('../models')
+
+class TransactionController { 
+
+  static async fetchTransactions(req, res, next) {
+    try {
+      const { VillageId } = req.currentUser
+
+      const village = await Village.findOne({where : { id : VillageId }, include: {
+        model: Transaction,
+        separate: true,
+        order: [['createdAt', 'DESC']],
+        include: User
+    }})
+      res.status(200).json(village)
+    } catch (error) {
+      next(error)
+    }
+  }
+
+  static async fetchTransactionsUser(req, res, next) {
+    try {
+      const { id, VillageId } = req.currentUser
+
+      const transactions = await Transaction.findAll({ 
+        where: { UserId: id, VillageId },
+        order: [['id', 'DESC']]
+      })
+
+      res.status(200).json(transactions)
+    } catch (error) {
+      next(error)
+    }
+  }
+
+  static async addTransaction(req, res, next) {
+    const { title, amount, category, note, type, status } = req.body
+    const { id, VillageId } = req.currentUser
+
+    try {
+      if(+amount === 0){
+        next({
+          code: 400,
+          message: 'Invalid Input Payment'
+        })
+      }
+      if (type === 'expanse') {
+        const { balance } = await Village.findByPk(VillageId)
+        const newBalance = balance - +amount
+
+        await Village.update({ balance: newBalance }, { where: { id: VillageId }})
+
+        const dataCreate = await Transaction.create({ title, amount, category, note, type, VillageId, UserId: id, status })    
+        res.status(201).json(dataCreate)
+      } else if(type === 'income') {
+        const { balance } = await Village.findByPk(VillageId)
+        const newBalance = +balance + +amount
+
+        await Village.update({ balance: newBalance }, { where: { id: VillageId }})
+
+        const dataCreate = await Transaction.create({ title, amount, category, note, type, VillageId, UserId: id, status })
+        res.status(201).json(dataCreate)
+      } else {
+        next({
+          code: 400,
+          message: 'Invalid Data Type Payment'
+        })
+      }
+    } catch (error) {
+      next(error)
+    }
+  }
+}
+
+module.exports = TransactionController

controllers/userController.js

@@ -0,0 +1,73 @@
+const { User, Village } = require('../models/')
+const { comparePassword } = require('../helpers/useBcrypt')
+const { generateToken } = require('../helpers/useJwt')
+class UserController {
+
+  static async login(req, res, next) {
+    const { username, password, push_token } = req.body
+    try {
+      const user = await User.findOne({ where: { username } })
+
+      if (user) {
+        const isPassword = comparePassword( password, user.password )
+
+        if (isPassword) {
+          await User.update({ push_token }, { where: { username } })
+
+          const token = generateToken({ id: user.id, username: user.username })
+
+          res.status(200).json(token)
+        } else {
+          next({ code: 404, message: "Invalid Username/Password" })
+        }
+      } else {
+        next({ code: 404, message: "Invalid Username/Password" })
+      }
+    } catch (error) {
+      next(error)
+    }
+  }
+
+  static async getUser(req, res, next) {
+    const { id } = req.currentUser
+    try {
+      const user = await User.findByPk(id)
+      res.status(200).json(user)
+    } catch (error) {
+      next(error)
+    }
+  }
+
+  static async register(req, res, next) {
+    const { name, username, password, invitation_code } = req.body
+    try {
+      const role = 'member'
+
+      const village = await Village.findOne({ where: { invitation_code }})
+
+      if (village) {
+        const user = await User.create({ name, username, password, role, VillageId: village.id })
+
+        res.status(201).json(user)
+      } else {
+        next({ code: 404, message: 'Cannot Found Village' })
+      }
+    } catch (error) {
+      next(error)
+    }
+  }
+
+  static async deleteUser(req, res, next) {
+    const { id } = req.params
+
+    try {
+      await User.destroy({ where: { id } })
+
+      res.status(200).json({ message: "Successfully deleted user" })
+    } catch (error) {
+      next(error)      
+    }
+  }
+}
+
+module.exports = UserController

controllers/villageController.js

@@ -0,0 +1,29 @@
+const { Village, User } = require('../models/')
+class VillageController { 
+
+  static async getDataVillage(req, res, next) {
+    const { VillageId } = req.currentUser
+    try {
+
+      const data = await Village.findByPk(VillageId, { include: User })
+
+      res.status(200).json(data)
+    } catch (error) {
+      next(error)
+    }
+  }
+
+  static async updateVillage(req, res, next){
+    const { VillageId } = req.currentUser
+    const { location, name } = req.body
+    try {
+      await Village.update( { location, name } ,{ where : { id: VillageId }})
+
+      res.status(200).json({ message: "Success Update Village" })
+    } catch (error) {
+      next(error)
+    }
+  }
+}
+
+module.exports = VillageController

helpers/useBcrypt.js

@@ -0,0 +1,11 @@
+const bcrypt = require('bcryptjs')
+
+const hashPassword = (password) => {
+    return bcrypt.hashSync(password, 10)
+}
+
+const comparePassword =(password, hashedPass) => {
+    return bcrypt.compareSync(password, hashedPass)
+}
+
+module.exports = { hashPassword, comparePassword }

helpers/useJwt.js

@@ -0,0 +1,11 @@
+const jwt = require('jsonwebtoken')
+
+const generateToken = (payload) => {
+  return jwt.sign(payload, process.env.KEY)
+}
+
+const verifyToken = (token) => {
+  return jwt.verify(token, process.env.KEY)
+}
+
+module.exports = { generateToken, verifyToken }

helpers/useToken.js

@@ -0,0 +1,5 @@
+function createToken()  {
+  return Math.random().toString(36).substr(7); // remove `0.`
+};
+
+module.exports = createToken