adminRequired.js 953 B

123456789101112131415161718192021222324
  1. const cache = require('../../cache');
  2. const db = require('../../db');
  3. module.exports = function(next) {
  4. return function(sessionId) {
  5. let args = [];
  6. for (let prop in arguments) {
  7. args.push(arguments[prop]);
  8. }
  9. let cb = args[args.length - 1];
  10. cache.hget('sessions', sessionId, (err, session) => {
  11. if (err || !session || !session.userSessionId) return cb({ status: 'failure', message: 'Login required.' });
  12. cache.hget('userSessions', session.userSessionId, (err, userSession) => {
  13. if (err || !userSession || !userSession.userId) return cb({ status: 'failure', message: 'Login required.' });
  14. db.models.user.findOne({_id: userSession.userId}, (err, user) => {
  15. if (err || !user) return cb({ status: 'failure', message: 'Login required.' });
  16. if (user.role !== 'admin') return cb({ status: 'failure', message: 'Admin required.' });
  17. args.push(userSession.userId);
  18. next.apply(null, args);
  19. });
  20. });
  21. });
  22. }
  23. };