2015-08-12 23:25:52 +00:00
|
|
|
import { Observable } from 'rx';
|
|
|
|
import debugFactory from 'debug';
|
|
|
|
|
|
|
|
const debug = debugFactory('freecc:user:remote');
|
2015-06-11 23:46:31 +00:00
|
|
|
|
2015-06-12 18:58:31 +00:00
|
|
|
function destroyAllRelated(id, Model) {
|
2015-08-12 23:25:52 +00:00
|
|
|
return Observable.fromNodeCallback(
|
2015-06-12 18:58:31 +00:00
|
|
|
Model.destroyAll,
|
|
|
|
Model
|
|
|
|
)({ userId: id });
|
2015-06-11 23:46:31 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
module.exports = function(app) {
|
|
|
|
var User = app.models.User;
|
|
|
|
var UserIdentity = app.models.UserIdentity;
|
|
|
|
var UserCredential = app.models.UserCredential;
|
2015-06-15 22:43:12 +00:00
|
|
|
var Email = app.models.Email;
|
2015-06-12 18:58:31 +00:00
|
|
|
User.observe('before delete', function(ctx, next) {
|
2015-06-11 23:46:31 +00:00
|
|
|
debug('removing user', ctx.where);
|
|
|
|
var id = ctx.where && ctx.where.id ? ctx.where.id : null;
|
|
|
|
if (!id) {
|
|
|
|
return next();
|
|
|
|
}
|
2015-08-12 23:25:52 +00:00
|
|
|
Observable.combineLatest(
|
2015-06-12 18:58:31 +00:00
|
|
|
destroyAllRelated(id, UserIdentity),
|
|
|
|
destroyAllRelated(id, UserCredential),
|
|
|
|
function(identData, credData) {
|
|
|
|
return {
|
|
|
|
identData: identData,
|
|
|
|
credData: credData
|
|
|
|
};
|
|
|
|
}
|
2015-06-11 23:46:31 +00:00
|
|
|
).subscribe(
|
2015-06-12 18:58:31 +00:00
|
|
|
function(data) {
|
|
|
|
debug('deleted', data);
|
|
|
|
},
|
2015-06-11 23:46:31 +00:00
|
|
|
function(err) {
|
|
|
|
debug('error deleting user %s stuff', id, err);
|
|
|
|
next(err);
|
|
|
|
},
|
|
|
|
function() {
|
|
|
|
debug('user stuff deleted for user %s', id);
|
|
|
|
next();
|
|
|
|
}
|
|
|
|
);
|
|
|
|
});
|
2015-06-15 22:43:12 +00:00
|
|
|
|
|
|
|
// set email varified false on user email signup
|
|
|
|
// should not be set with oauth signin methods
|
|
|
|
User.beforeRemote('create', function(ctx, user, next) {
|
|
|
|
var body = ctx.req.body;
|
|
|
|
if (body) {
|
|
|
|
body.emailVerified = false;
|
|
|
|
}
|
|
|
|
next();
|
|
|
|
});
|
|
|
|
|
|
|
|
// send welcome email to new camper
|
|
|
|
User.afterRemote('create', function(ctx, user, next) {
|
|
|
|
debug('user created, sending email');
|
|
|
|
if (!user.email) { return next(); }
|
|
|
|
|
|
|
|
var mailOptions = {
|
|
|
|
type: 'email',
|
|
|
|
to: user.email,
|
|
|
|
from: 'Team@freecodecamp.com',
|
|
|
|
subject: 'Welcome to Free Code Camp!',
|
|
|
|
redirect: '/',
|
|
|
|
text: [
|
|
|
|
'Greetings from San Francisco!\n\n',
|
|
|
|
'Thank you for joining our community.\n',
|
|
|
|
'Feel free to email us at this address if you have ',
|
|
|
|
'any questions about Free Code Camp.\n',
|
|
|
|
'And if you have a moment, check out our blog: ',
|
2015-08-16 15:03:34 +00:00
|
|
|
'blog.freecodecamp.com.\n\n',
|
2015-06-15 22:43:12 +00:00
|
|
|
'Good luck with the challenges!\n\n',
|
|
|
|
'- the Free Code Camp Volunteer Team'
|
|
|
|
].join('')
|
|
|
|
};
|
|
|
|
|
|
|
|
debug('sending welcome email');
|
|
|
|
Email.send(mailOptions, function(err) {
|
|
|
|
if (err) { return next(err); }
|
|
|
|
ctx.req.logIn(user, function(err) {
|
|
|
|
if (err) { return next(err); }
|
|
|
|
|
|
|
|
ctx.req.flash('success', {
|
2015-08-16 15:03:34 +00:00
|
|
|
msg: [ "Welcome to Free Code Camp! We've created your account." ]
|
2015-06-15 22:43:12 +00:00
|
|
|
});
|
|
|
|
ctx.res.redirect('/');
|
|
|
|
});
|
|
|
|
});
|
|
|
|
});
|
2015-06-11 23:46:31 +00:00
|
|
|
};
|