เข้ารหัส Password ด้วย ฺbcrypt ใน Express สำหรับ ระบบสมาชิก

npm install bcrypt --save

const db = require('../config/db')

const Users = {
    email_exists:((req, res) => {
        return new Promise((resolve, reject)=>{
 
        })
    }),
    login:((req, res) => {
        return new Promise((resolve, reject)=>{
     
        })
    }),
    register:((req, res) => {
        return new Promise((resolve, reject)=>{

        })
    }),
    userinfo:((req, res) => {
        return new Promise((resolve, reject)=>{  
      
        })
    })         
}

module.exports = Users

// จะส่งกลับแค่กรณีใด กรณีหนึ่งเท่านั้น คือ resolve หรือ ไม่ก็ reject
var promise = new Promise(function(resolve, reject) {
    if(!error){ 
      	resolve(value1)
    }else{
    	reject(value2)
    }
})

promise.then(
  function(result) { /* successful result */ },
  function(error) { /* error */ }
)

promise.then(
  (value1)=>{
    console.log("completion " + value1)
  },
  (value2)=>{
    console.log("failure " + value2)   
  }
)

const db = require('../config/db')

const Users = {
    email_exists:((req, res) => {
        return new Promise((resolve, reject)=>{
            res.locals.user = req.body        
            db.then((db)=>{ // ใช้งานฐานข้อมูล เมื่อพร้อม
                db.collection('users') 
                .find({
                    email:req.body.email // ตรวจสอบอีเมล
                })
                .toArray( (error, results) => {
                    if(!error){ // ไม่มี error
                        if(results.length==0){  // ไม่มีอีเมลนี้ในระบบ ใช้สมัครสมาชิกได้
                            resolve(true)
                        }else{
                            reject('อีเมลนี้ถูกใช้งานแล้ว')
                        }
                    }else{
                        reject('เกิดข้อผิดพลาด กรุณาลองใหม่')
                    }
                })
            })
        })
    }),
    login:((req, res) => {
        return new Promise((resolve, reject)=>{
            res.locals.user = req.body        
            db.then((db)=>{ 
                db.collection('users') 
                .find({ // ตรวจสอบข้อมูลสำหรับล็อกอิน ด้วย email และ password ในฐานข้อมูล
                    email:req.body.email,  
                    password:req.body.password
                })
                .toArray( (error, results) => {
                    if(!error){ // ถ้าไม่มี error
                        if(results.length > 0){ // มีข้อมูล
                            resolve(results) // ส่งข้อมูลกลับออกไปใช้งาน
                        }else{
                            reject('อีเมล หรือ รห้สผ่านไม่ถูกต้อง กรุณาลองใหม่')
                        }
                    }else{
                        reject('เกิดข้อผิดพลาด กรุณาลองใหม่')
                    }
                })
            })            
        })
    }),
    register:((req, res) => {
        return new Promise((resolve, reject)=>{
            res.locals.user = req.body   
            db.then((db)=>{  
                db.collection('lastid')  // ดึงข้อมูล user_id ล่าสุดที่บันทึกไว้ใน "lastid" 
                .findOneAndUpdate({id:1},// เงื่อนไขที่ id = 1
                { $inc: { user_id: 1 }},(error, results)=>{  // แล้วให้เพิ่มค่า +1 เข้าไปให้กับ user_id
                    if(!error){ // ถ้าไม่มี error
                        let insertID = results.value.user_id+1 // เอาไอดีค่าล่าสุดมาบวกเพิ่ม แล้วไว้ในตัวแปร insertID
                        let user = { // ชุดข้อมูลที่จะบันทึก สำหรับสมัครสมาชิก
                            "_id": insertID, 
                            "name": req.body.name, 
                            "email": req.body.email, 
                            "password": req.body.password
                        }            
                        db.collection('users')
                        .insertOne(user, (error, results) => {  // เพิ่มข้อมูลสมาชิกใหม่
                            if(!error){ // ถ้าไม่มี error
                                resolve(results) // ส่งข้อมูลที่บันทึก กลับไปไว้ใช้งาน
                            }else{
                                reject('เกิดข้อผิดพลาด กรุณาลองใหม่')
                            }                          
                        })                             
                    }else{
                        reject('เกิดข้อผิดพลาด กรุณาลองใหม่')
                    }                                 
                })
            }) 
        })
    }),
    userinfo:((req, res) => {
        return new Promise((resolve, reject)=>{  
            db.then((db)=>{ 
                db.collection('users') 
                .find({
                    _id:req.session.userID  // แสดงข้อมูลผู้ใช้ที่ล็อกอิน และมี _id เท่ากับ session userID
                })
                .toArray( (error, results) => {
                    if(!error){ // ถ้าไม่มี error
                        if(results.length > 0){ // พบข้อมูล
                            resolve(results) // ส่งข้อมูลผู้ที่ล็อกอินกลับไป
                        }else{
                            reject('ไม่พบข้อมูลผู้ใช้')
                        }
                    }else{
                        reject('เกิดข้อผิดพลาด กรุณาลองใหม่')
                    }
                })
            })            
        })
    })         
}

module.exports = Users

const express = require('express')
const router = express.Router()
const { validation, schema } = require('../validator/users')
const Users = require('../models/users') // ใช้งาน Users model

router.route('/')
    .all((req, res, next) => { 
        // ตัวแปรที่กำหนดด้วย res.locals คือค่าจะส่งไปใช้งานใน template
        res.locals.pageData = {
            title:'Register Page'
        }
        // ค่าที่จะไปใช้งาน ฟอร์ม ใน template 
        res.locals.user = {
            name:'',
            email:'',
            password:'',
            confirm_password:''
        }
        // กำหนดหน้าที่ render กรณี error ไม่ผ่านการตรวจสอบข้อมูล
        req.renderPage = "pages/register"        
        next()
    })
    .get((req, res, next) => { 
        res.render('pages/register')    
    })
    .post(validation(schema.register), (req, res, next) => { 
        // เมื่อส่งข้อมูลมาสมัครสมาชิก ตรวจสอบอีเมล
        Users.email_exists(req, res).then(
            (validEmail)=>{ // ถ้าอีเมลยังว่าง ยังไม่ถูกใช้งาน
				// ทำการส่งข้อมูลไปบันทึกลงฐานข้อมูล
                Users.register(req, res).then(
                    (results)=>{ // บันทึกข้อมูลเรียบร้อย
						// ส่ง ข้อมูลไปแสดงในหน้า login ให้ผู้ใช้ล็อกอินเพื่อเข้าสู่ระบบ โค้ดด้านล่างตัดบรรทัดใหม่ไม่ให้ยาว
                        res.cookie('flash_message', 
                        	'Register Complete!! Please Login to access',
                        	{maxAge:3000})
                        res.redirect('/login')    
                    },
                    (error)=>{ // เกิด error แจ้ง error ในหน้า สมัครสมาชิก ส่งค่าเข้าไปด้วย res.locals.errors
                        res.locals.errors = {
                            "message": error
                        }
                        res.render('pages/register')    
                    }
                )  
            },
            (error)=>{ // เกิด error หรือ อีเมลไม่ว่าง ถูกใช้งานแล่้ว โค้ดด้านล่าง รวมให้อยู่บรรทัดเดียว ทำให้ดูเป็นตัวอย่าง
                res.locals.errors = { "message": error }
                res.render('pages/register')    
            }
        )
    })

module.exports = router

const express = require('express')
const router = express.Router()
const { validation, schema } = require('../validator/users')
const Users = require('../models/users') // ใช้งาน Users model

router.route('/')
    .all((req, res, next) => { 
        // ตัวแปรที่กำหนดด้วย res.locals คือค่าจะส่งไปใช้งานใน template
        res.locals.pageData = {
            title:'Login Page'
        }
        // ค่าที่จะไปใช้งาน ฟอร์ม ใน template 
        res.locals.user = {
            email:req.session.email || '',
            password:req.session.password || '',
            remember:req.session.remember || ''
        }
        // กำหนดหน้าที่ render กรณี error ไม่ผ่านการตรวจสอบข้อมูล
        req.renderPage = "pages/login"
        next()
    })
    .get((req, res, next) => { 
        // ตรวจสอบว่ามี ค่า cookie ค่านี้หรือไม่
        if(req.cookies.flash_message){
            // ถ้ามี นำค่าไปใกำหนดในตัวแปร res.locals เพื่อใช้งานใน template
            res.locals.success = {
                message:req.cookies.flash_message
            }
        } 
        res.render('pages/login')    
    })
    .post(validation(schema.login), (req, res, next) => { 
        // สมมติเรากำหนดเป็น 15 วัน
        let MAX_AGE = 1000 * 60 * 60 * 24 * 15
        if(req.body.remember){
            req.session.email = req.body.email
            req.session.password = req.body.password
            req.session.remember = req.body.remember
            req.session.cookie.maxAge = MAX_AGE
        }else{
            delete req.session.email
            delete req.session.password
            delete req.session.remember
        }
		// ส่งข้อมูลไปตรวจสอบในฐานข้อมูล สำหรับทำการล็อกอินเข้าใช้งาน
        Users.login(req, res).then(
            (results)=>{ // ล็อกอินสำเร็จ พบข้อมูลผู้ใช้ตาม email และ password ที่แจ้ง
                console.log(results)
                req.session.userID = results[0]._id  // กำหนดตัวแปร session userID
                req.session.isLogined = true  // กำหนดตัวแปร session สถานะการล็อกอิน
                res.redirect('/me') // ไปยังหน้าสมาชิก
            },
            (error)=>{ // ล็อกอินไม่ผ่าน แจ้ง error หน้า ล็อกอิน
                console.log(error)
                res.locals.errors = {
                    "message": error
                }                
                res.render('pages/login')    
            }
        )

    })

module.exports = router

const express = require('express')
const router = express.Router()
const Users = require('../models/users') // ใช้งาน Users model

router.route('/')
    .get((req, res, next) => { 
        res.locals.pageData = {
            title:'Dashboard Page'
        }     
		// ดึงข้อมูลสมาชิก จาก session userID
        Users.userinfo(req, res).then(
            (user)=>{  // มีข้อมูล
			   // ส่งข้อมูลไว้ในตัวแปร สำหรับใช้งานใน template
                res.locals.user = user[0]   
                res.render('pages/dashboard')                 
            }
        )       
    })

router.route('/logout')
    .get((req, res, next) => { 
	    // กรณี logout ลบ session ค่าที่เกี่ยวข้องกับระบบสมาชิก แล้วลิ้งค์ไปหน้าล็อกอิน
        delete req.session.isLogined
        delete req.session.userID
        res.cookie('flash_message', 'Logout Complete!!',{maxAge:3000})
        res.redirect('/login')    
    })    

module.exports = router

<!doctype html>
<html>
    <?- include('../partials/head') -?>
<body>
<?- include('../partials/header') -?>
<?- include('../partials/nav') -?>

<div class="container">
    <h1 class="text-center">Hello</h1>
    <div class="text-center my-3 border border-success">
        <?= user.name ?>
        <br/>
        <?= user.email ?>
    </div>
    <div class="text-center">

    </div>
</div>

<?- include('../partials/footer') -?>
</body>
</html>

bcrypt.hash(myPlaintextPassword, saltRounds).then(function(hash) {
    // นำค่า hash ไปใช้งาน เช่น บันทึกค่า hash ที่ได้ลงฐานข้อมูล
})

// ดึงค่า hash จากฐานข้อมูล แล้วนำค่ามาตรวนสอบ กับข้อมูลที่ต้องการ
bcrypt.compare(myPlaintextPassword, hash).then(function(result) {
    // result == true ถ้าข้อมูลถูกต้อง และ เป็น false ถ้าไม่ถูกต้อง
})

const db = require('../config/db')
const bcrypt = require('bcrypt') // ใช้งาน bcrypt module
const saltRounds = 10 // กำหนดค่า salt

const Users = {
    email_exists:((req, res) => {
        return new Promise((resolve, reject)=>{
            res.locals.user = req.body        
            db.then((db)=>{ 
                db.collection('users') 
                .find({
                    email:req.body.email
                })
                .toArray( (error, results) => {
                    if(!error){
                        if(results.length==0){
                            resolve(true)
                        }else{
                            reject('อีเมลนี้ถูกใช้งานแล้ว')
                        }
                    }else{
                        reject('เกิดข้อผิดพลาด กรุณาลองใหม่')
                    }
                })
            })
        })
    }),
    login:((req, res) => {
        return new Promise((resolve, reject)=>{
            res.locals.user = req.body        
            db.then((db)=>{ 
                db.collection('users') 
                .find({
                    email:req.body.email
                })
                .toArray( (error, results) => {
                    if(!error){
                        if(results.length > 0){
                            let hash = results[0].password
                            let password = req.body.password
                            bcrypt.compare(password, hash).then((result)=>{
                                if(result == true) resolve(results)
                                if(result == false) reject('รห้สผ่านไม่ถูกต้อง กรุณาลองใหม่')
                            })                            
                        }else{
                            reject('อีเมล หรือ รห้สผ่านไม่ถูกต้อง กรุณาลองใหม่')
                        }
                    }else{
                        reject('เกิดข้อผิดพลาด กรุณาลองใหม่')
                    }
                })
            })            
        })
    }),
    register:((req, res) => {
        return new Promise((resolve, reject)=>{
            res.locals.user = req.body   
            db.then((db)=>{  
                db.collection('lastid')  
                .findOneAndUpdate({id:1},
                { $inc: { user_id: 1 }},(error, results)=>{ 
                    if(!error){
                        let password = req.body.password
                        bcrypt.hash(password, saltRounds).then((hash)=>{
                            let insertID = results.value.user_id+1
                            let user = {
                                "_id": insertID, 
                                "name": req.body.name, 
                                "email": req.body.email, 
                                "password": hash
                            }            
                            db.collection('users')
                            .insertOne(user, (error, results) => { 
                                if(!error){
                                    resolve(results)
                                }else{
                                    reject('เกิดข้อผิดพลาด กรุณาลองใหม่')
                                }                          
                            })       
                        })                                              
                    }else{
                        reject('เกิดข้อผิดพลาด กรุณาลองใหม่')
                    }                                 
                })
            }) 
        })
    }),
    userinfo:((req, res) => {
        return new Promise((resolve, reject)=>{  
            db.then((db)=>{ 
                db.collection('users') 
                .find({
                    _id:req.session.userID
                })
                .toArray( (error, results) => {
                    if(!error){
                        if(results.length > 0){
                            resolve(results)
                        }else{
                            reject('ไม่พบข้อมูลผู้ใช้')
                        }
                    }else{
                        reject('เกิดข้อผิดพลาด กรุณาลองใหม่')
                    }
                })
            })            
        })
    })         
}

module.exports = Users

if(typeof req.session !== 'undefined'){
	res.locals.session = req.session
}

module.exports = {
    useSession:(req, rew, next)=>{
        // ถ้ามีตัวแปร sewsion 
        if(typeof req.session !== 'undefined'){
            // ให้กำหนดต่าให้กับ app.locals ใน property ชื่อ session
            // ให้มีค่าเท่ากับ session object 
            req.app.locals.session = req.session
        }    
        next()
    }
}

const express = require('express')  // ใช้งาน module express
const app = express()  // สร้างตัวแปร app เป็น instance ของ express
const path = require('path') // เรียกใช้งาน path module
const cookieParser = require('cookie-parser')
const session = require('express-session')
const store = require('./config/storeDb')
const { authorize } = require('./config/auth')
const { useSession } = require('./config/session')
const createError = require('http-errors') // เรียกใช้งาน http-errors module
const port = 3000  // port 
 
// ส่วนของการใช้งาน router module ต่างๆ 
const indexRouter = require('./routes/index')
const loginRouter = require('./routes/login')
const registerRouter = require('./routes/register')
const dashboardRouter = require('./routes/dashboard')
 
// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'ejs');
app.set('view options', {delimiter: '?'});
// app.set('env','production')
 
app.use(express.json())
app.use(express.urlencoded({ extended: false }))
app.use(cookieParser())
app.use(express.static(path.join(__dirname, 'public')))

//app.set('trust proxy', 1) // trust first proxy
app.use(session({
    name:'sid', // ถ้าไม่กำหนด ค่าเริ่มต้นเป็น 'connect.sid'
    secret: 'my ses secret',
    store:store,
    resave: true,
    saveUninitialized: true
}))
app.use(useSession)

 
// เรียกใช้งาน indexRouters
app.use('/', indexRouter)
app.use('/login', authorize('/me', false), loginRouter)
app.use('/register', authorize('/me', false), registerRouter)
app.use('/me', authorize('/login', true), dashboardRouter)

// ทำงานทุก request ที่เข้ามา 
app.use(function(req, res, next) {
    var err = createError(404)
    next(err)
})
 
// ส่วนจัดการ error
app.use(function (err, req, res, next) {
    // กำหนด response local variables 
    res.locals.pageData = {
        title:'Error Page'
    }    
    res.locals.message = err.message
    res.locals.error = req.app.get('env') === 'development' ? err : {}
 
    // กำหนด status และ render หน้า error page
    res.status(err.status || 500) // ถ้ามี status หรือถ้าไม่มีใช้เป็น 500
    res.render('pages/error') 
})
 
app.listen(port, function() {
    console.log(`Example app listening on port ${port}!`)
})

<nav class="text-center">
THIS IS NAV <br>
<? if(!session.isLogined || session.isLogined == false){ ?>
<a href="/login">Login</a> | <a href="/register">Register</a>
<? }else{ ?>
 <a href="/me/logout">Logout</a>
<? } ?>
</nav>