Node.js : ระบบ Authentication ที่ทำงานร่วมกับฐานข้อมูล Mongo

{ _id:OjectId("5daa74efb50ece2f98643d35"), username:"anakin", password:"1234", fname:"Anakin", lname:"Skywalker" } { _id:OjectId("5daa748b1a5fc22f98b6db32"), username:"bhurisub", password:"1234", fname:"Bhurisub", lname:"Dejpipatpracha" } 

... ... <div class="container"> <div class="row"> <h1>:: Home ::</h1> </div> <div class="row"> Login Ok.<br/><br/> _id = <%=_id%> <br/> Username = <%=username%> <br/> Name = <%=fname%> <%=lname%> <br/><br/> </div> <div class="row"> <a href='./logout'>Logout</a> </div> </div> ... ... 

const MongoClient = require('mongodb').MongoClient const url = 'mongodb://localhost:27017' const dbName = 'webphuket' module.exports = new Promise((resolve, reject)=>{ MongoClient.connect(url, { useNewUrlParser: true,useUnifiedTopology: true },(err, client) => { if (err) throw err const mongo = client.db(dbName) console.log("Connected successfully to server") resolve(mongo) }) }) 

const express = require('express') const app = express() app.use(express.static(__dirname + '/public')) app.set('view engine', 'ejs') const MongoObjectID = require('mongodb').ObjectID const mongo = require('./config') const passport = require('passport') const LocalStrategy = require('passport-local').Strategy const bodyParser = require('body-parser') const cookieParser = require('cookie-parser') app.use(bodyParser.urlencoded({ extended: false })) app.use(bodyParser.json()) app.use(cookieParser()) const session = require('express-session') app.use(session({ secret: 'I am Anakin.', resave: true, saveUninitialized: true })) app.use(passport.initialize()) app.use(passport.session()) passport.use(new LocalStrategy((username, password, done) => { mongo.then((db) => { query = { username : username } db.collection('users').findOne(query,(err, user) => { if (err) return done(err) if (!user) { console.log('Incorrect username.') return done(null, false, { message: 'Incorrect username.' }) } else if (user.password == password ) { console.log('Correct password.') return done(null, user) } else { console.log('Incorrect password.') return done(null, false, { message: 'Incorrect password.' }) } }) }) })) passport.serializeUser((user, done) => { console.log('SerializeUser') done(null, user._id) }) passport.deserializeUser((id, done) => { mongo.then((db) => { query = { _id : new MongoObjectID.ObjectID(id) } db.collection('users').findOne(query,(err, user) => { if (err) return done(err) console.log('DeserializeUser') done(null, user) }) }) }) app.get('/', (req, res) => { res.render('login') }) app.get('/login', (req, res) => { res.render('login') }) app.post('/login', passport.authenticate('local', { successRedirect: '/home', failureRedirect: '/' })) function isLoggedIn(req, res, next) { if (req.isAuthenticated()) { return next() } else { res.redirect('/') } } app.get('/home',isLoggedIn,(req,res) => { res.render('home',req.user) }) app.get('/logout',(req,res) => { req.logout() res.redirect('/') }) app.listen(3000, () => { console.log('Server Started on localhost:3000...') }) 

const MongoObjectID = require('mongodb').ObjectID const mongo = require('./config') 

passport.use(new LocalStrategy((username, password, done) => { mongo.then((db) => { query = { username : username } db.collection('users').findOne(query,(err, user) => { if (err) return done(err) if (!user) { console.log('Incorrect username.') return done(null, false, { message: 'Incorrect username.' }) } else if (user.password == password ) { console.log('Incorrect password.') return done(null, user) } else { console.log('Incorrect password.') return done(null, false, { message: 'Incorrect password.' }) } }) }) })) 

passport.serializeUser((user, done) => { console.log('SerializeUser') done(null, user._id) }) 

passport.deserializeUser((id, done) => { mongo.then((db) => { query = { _id : new MongoObjectID.ObjectID(id) } db.collection('users').findOne(query,(err, user) => { if (err) return done(err) console.log('DeserializeUser') done(null, user) }) }) })