controllers/github.js
var Models = require('../models');
var User = Models.User;
var authMiddleWare = require('../middlewares/auth');
var tools = require('../common/tools');
var EventProxy = require('eventproxy');
var uuid = require('node-uuid');
var validator = require('validator');
exports.callback = function (req, res, next) {
var profile = req.user;
var email = profile.emails && profile.emails[0] && profile.emails[0].value;
User.findOne({githubId: profile.id}, function (err, user) {
if (err) {
return next(err);
}
// 当用户已经是 cnode 用户时,通过 github 登陆将会更新他的资料
if (user) {
user.githubUsername = profile.username;
user.githubId = profile.id;
user.githubAccessToken = profile.accessToken;
// user.loginname = profile.username;
user.avatar = profile._json.avatar_url;
user.email = email || user.email;
user.save(function (err) {
if (err) {
// 根据 err.err 的错误信息决定如何回应用户,这个地方写得很难看
if (err.message.indexOf('duplicate key error') !== -1) {
if (err.message.indexOf('email') !== -1) {
return res.status(500)
.render('sign/no_github_email');
}
if (err.message.indexOf('loginname') !== -1) {
return res.status(500)
.send('您 GitHub 账号的用户名与之前在 本站 注册的用户名重复了');
}
}
return next(err);
}
authMiddleWare.gen_session(user, res);
return res.redirect('/');
});
} else {
// 如果用户还未存在,则建立新用户
req.session.profile = profile;
return res.redirect('/auth/github/new');
}
});
};
exports.new = function (req, res, next) {
res.render('sign/new_oauth', {actionPath: '/auth/github/create'});
};
exports.create = function (req, res, next) {
var profile = req.session.profile;
var isnew = req.body.isnew;
var loginname = validator.trim(req.body.name || '').toLowerCase();
var password = validator.trim(req.body.pass || '');
var ep = new EventProxy();
ep.fail(next);
if (!profile) {
return res.redirect('/signin');
}
delete req.session.profile;
var email = profile.emails && profile.emails[0] && profile.emails[0].value;
if (isnew) { // 注册新账号
var user = new User({
loginname: profile.username,
pass: profile.accessToken,
email: email,
avatar: profile._json.avatar_url,
githubId: profile.id,
githubUsername: profile.username,
githubAccessToken: profile.accessToken,
active: true,
accessToken: uuid.v4(),
});
user.save(function (err) {
if (err) {
// 根据 err.err 的错误信息决定如何回应用户,这个地方写得很难看
if (err.message.indexOf('duplicate key error') !== -1) {
if (err.message.indexOf('email') !== -1) {
return res.status(500)
.render('sign/no_github_email');
}
if (err.message.indexOf('loginname') !== -1) {
return res.status(500)
.render('sign/new_oauth', {
actionPath: '/auth/github/create',
error: '您 GitHub 账号的用户名与之前在 本站 注册的用户名重复了'
});
}
}
return next(err);
// END 根据 err.err 的错误信息决定如何回应用户,这个地方写得很难看
}
authMiddleWare.gen_session(user, res);
res.redirect('/');
});
} else { // 关联老账号
ep.on('login_error', function (login_error) {
res.status(403);
res.render('sign/signin', {error: '账号名或密码错误。', page: 'signin'});
});
User.findOne({loginname: loginname},
ep.done(function (user) {
if (!user) {
return ep.emit('login_error');
}
tools.bcompare(password, user.pass, ep.done(function (bool) {
if (!bool) {
return ep.emit('login_error');
}
user.githubUsername = profile.username;
user.githubId = profile.id;
// user.loginname = profile.username;
user.avatar = profile._json.avatar_url;
user.githubAccessToken = profile.accessToken;
user.save(function (err) {
if (err) {
return next(err);
}
authMiddleWare.gen_session(user, res);
res.redirect('/');
});
}));
}));
}
};