58 lines
1.7 KiB
JavaScript
58 lines
1.7 KiB
JavaScript
|
const LocalStrategy = require('passport-local').Strategy;
|
||
|
|
const bcrypt = require('bcrypt-nodejs');
|
||
|
|
const flash = require('connect-flash');
|
||
|
|
const passport = require('passport');
|
||
|
|
const express = require('express');
|
||
|
|
const PouchDB = require('pouchdb');
|
||
|
|
|
||
|
|
const config = require('./config');
|
||
|
|
|
||
|
|
const logger = require('./logger');
|
||
|
|
|
||
|
|
const app = express();
|
||
|
|
|
||
|
|
const db = new PouchDB(config.dbUrl);
|
||
|
|
|
||
|
|
passport.use('local', new LocalStrategy(
|
||
|
|
(username, password, done) => {
|
||
|
|
db.get(username)
|
||
|
|
.then(doc => {
|
||
|
|
bcrypt.compare(password, doc.password, (err, correct) => {
|
||
|
|
if (err) return done(err);
|
||
|
|
if (!correct) return done(null, false, { message: 'Incorrect password' });
|
||
|
|
if (correct) return done(null, doc);
|
||
|
|
});
|
||
|
|
})
|
||
|
|
.catch(err => {
|
||
|
|
if (err.message === 'missing') return done(null, false, { message: 'Incorrect username.' });
|
||
|
|
return done(err);
|
||
|
|
});
|
||
|
|
}
|
||
|
|
));
|
||
|
|
|
||
|
|
passport.serializeUser((user, callback) => callback(null, user._id));
|
||
|
|
|
||
|
|
passport.deserializeUser((user, callback) => {
|
||
|
|
db.get(user)
|
||
|
|
.then(dbUser => callback(null, dbUser))
|
||
|
|
.catch(err => callback(err));
|
||
|
|
});
|
||
|
|
|
||
|
|
app.use(require('body-parser').urlencoded({ extended: true }));
|
||
|
|
app.use(require('express-session')({ secret: config.secret, resave: false, saveUninitialized: true }));
|
||
|
|
app.use(flash());
|
||
|
|
app.use(passport.initialize());
|
||
|
|
app.use(passport.session());
|
||
|
|
|
||
|
|
app.use(require('./middlewares/locals'));
|
||
|
|
|
||
|
|
app.use((req, res, next) => {
|
||
|
|
logger.log('express', `${req.ip} - ${req.method} ${req.originalUrl}`);
|
||
|
|
next();
|
||
|
|
});
|
||
|
|
|
||
|
|
app.set('view engine', 'pug');
|
||
|
|
app.use('/', require('./routes')(db));
|
||
|
|
|
||
|
|
app.listen(config.port, () => logger.success('express', `Express server started on port ${config.port}!`))
|