[Fix #5] Verify user exists in authentication middleware
parent
a6cdbed50d
commit
ade50cb248
|
@ -0,0 +1,44 @@
|
||||||
|
const Joi = require('joi');
|
||||||
|
const jwt = require('jsonwebtoken');
|
||||||
|
const mongoose = require('mongoose');
|
||||||
|
|
||||||
|
const secret = require.main.require('./config/secret');
|
||||||
|
|
||||||
|
module.exports = (req, res, next) => {
|
||||||
|
const UserModel = mongoose.model('User');
|
||||||
|
|
||||||
|
const schema = Joi.object().keys({
|
||||||
|
access_token: Joi.string().required(),
|
||||||
|
});
|
||||||
|
|
||||||
|
Joi.validate({
|
||||||
|
access_token: req.headers.authorization,
|
||||||
|
},
|
||||||
|
schema, (validateErr) => {
|
||||||
|
if (validateErr) {
|
||||||
|
return next({ status: 401, error: validateErr.details });
|
||||||
|
}
|
||||||
|
|
||||||
|
return jwt.verify(req.headers.authorization, secret, (err, decoded) => {
|
||||||
|
if (err) {
|
||||||
|
return next({ status: 401, message: 'Token error.', error: [err] });
|
||||||
|
}
|
||||||
|
|
||||||
|
return UserModel.countDocuments(
|
||||||
|
{
|
||||||
|
_id: decoded.user.id,
|
||||||
|
}, (QueryError, count) => {
|
||||||
|
if (count !== 1) {
|
||||||
|
return next({
|
||||||
|
status: 403,
|
||||||
|
message: 'Your session is invalid. Please try sign in again.',
|
||||||
|
error: [],
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
return next();
|
||||||
|
},
|
||||||
|
);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
};
|
Loading…
Reference in New Issue