2015-10-06 19:27:53 +00:00
|
|
|
import _ from 'lodash';
|
2015-10-07 00:52:57 +00:00
|
|
|
import { Observable } from 'rx';
|
2015-10-06 19:27:53 +00:00
|
|
|
import debugFactory from 'debug';
|
2015-10-06 07:13:51 +00:00
|
|
|
import dedent from 'dedent';
|
2015-10-07 02:49:38 +00:00
|
|
|
|
2015-10-06 19:27:53 +00:00
|
|
|
import nonprofits from '../utils/commit.json';
|
2015-10-07 04:08:24 +00:00
|
|
|
import {
|
|
|
|
commitGoals,
|
|
|
|
completeCommitment$
|
|
|
|
} from '../utils/commit';
|
2015-10-06 19:27:53 +00:00
|
|
|
|
|
|
|
import {
|
|
|
|
unDasherize
|
|
|
|
} from '../utils';
|
|
|
|
|
|
|
|
import {
|
|
|
|
observeQuery,
|
|
|
|
saveInstance
|
|
|
|
} from '../utils/rx';
|
|
|
|
|
2015-10-06 07:13:51 +00:00
|
|
|
import {
|
|
|
|
ifNoUserRedirectTo
|
|
|
|
} from '../utils/middleware';
|
|
|
|
|
|
|
|
const sendNonUserToFront = ifNoUserRedirectTo('/');
|
2015-10-07 01:22:12 +00:00
|
|
|
const sendNonUserToCommit = ifNoUserRedirectTo(
|
|
|
|
'/commit',
|
|
|
|
'Must be signed in to update commit'
|
|
|
|
);
|
2015-10-06 19:27:53 +00:00
|
|
|
const debug = debugFactory('freecc:commit');
|
2015-10-06 07:13:51 +00:00
|
|
|
|
2015-10-06 21:54:59 +00:00
|
|
|
function findNonprofit(name) {
|
|
|
|
let nonprofit;
|
|
|
|
if (name) {
|
|
|
|
nonprofit = _.find(nonprofits, (nonprofit) => {
|
|
|
|
return name === nonprofit.name;
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
nonprofit = nonprofit || nonprofits[0];
|
|
|
|
return nonprofit;
|
|
|
|
}
|
|
|
|
|
2015-10-06 04:13:11 +00:00
|
|
|
export default function commit(app) {
|
|
|
|
const router = app.loopback.Router();
|
2015-10-06 19:27:53 +00:00
|
|
|
const { Pledge } = app.models;
|
|
|
|
|
2015-10-06 04:13:11 +00:00
|
|
|
router.get(
|
|
|
|
'/commit',
|
|
|
|
commitToNonprofit
|
|
|
|
);
|
2015-10-06 19:27:53 +00:00
|
|
|
|
2015-10-06 07:13:51 +00:00
|
|
|
router.get(
|
|
|
|
'/commit/pledge',
|
|
|
|
sendNonUserToFront,
|
|
|
|
pledge
|
|
|
|
);
|
2015-10-06 04:13:11 +00:00
|
|
|
|
2015-10-07 07:05:26 +00:00
|
|
|
router.get(
|
|
|
|
'/commit/directory',
|
|
|
|
renderDirectory
|
|
|
|
);
|
|
|
|
|
2015-10-07 01:22:12 +00:00
|
|
|
router.post(
|
|
|
|
'/commit/stop-commitment',
|
|
|
|
sendNonUserToCommit,
|
|
|
|
stopCommit
|
|
|
|
);
|
|
|
|
|
2015-10-07 02:49:38 +00:00
|
|
|
router.post(
|
|
|
|
'/commit/complete-goal',
|
|
|
|
sendNonUserToCommit,
|
|
|
|
completeCommitment
|
|
|
|
);
|
|
|
|
|
2015-10-06 04:13:11 +00:00
|
|
|
app.use(router);
|
|
|
|
|
2015-10-07 00:52:57 +00:00
|
|
|
function commitToNonprofit(req, res, next) {
|
|
|
|
const { user } = req;
|
2015-10-06 19:27:53 +00:00
|
|
|
let nonprofitName = unDasherize(req.query.nonprofit);
|
|
|
|
|
|
|
|
debug('looking for nonprofit', nonprofitName);
|
2015-10-07 00:52:57 +00:00
|
|
|
const nonprofit = findNonprofit(nonprofitName);
|
|
|
|
|
|
|
|
Observable.just(user)
|
|
|
|
.flatMap(user => {
|
|
|
|
if (user) {
|
|
|
|
debug('getting user pledge');
|
|
|
|
return observeQuery(user, 'pledge');
|
|
|
|
}
|
|
|
|
return Observable.just();
|
|
|
|
})
|
|
|
|
.subscribe(
|
|
|
|
pledge => {
|
|
|
|
if (pledge) {
|
|
|
|
debug('found previous pledge');
|
|
|
|
req.flash('info', {
|
|
|
|
msg: dedent`
|
|
|
|
Looks like you already have a pledge to ${pledge.displayName}.
|
|
|
|
Hitting commit here will replace your old commitment.
|
|
|
|
`
|
|
|
|
});
|
|
|
|
}
|
|
|
|
res.render(
|
|
|
|
'commit/',
|
|
|
|
Object.assign(
|
|
|
|
{
|
|
|
|
title: 'Commit to a nonprofit. Commit to your goal.',
|
2015-12-09 22:19:37 +00:00
|
|
|
pledge
|
2015-10-07 00:52:57 +00:00
|
|
|
},
|
2015-12-09 22:19:37 +00:00
|
|
|
commitGoals,
|
2015-10-07 00:52:57 +00:00
|
|
|
nonprofit
|
|
|
|
)
|
|
|
|
);
|
|
|
|
},
|
|
|
|
next
|
|
|
|
);
|
2015-10-06 19:27:53 +00:00
|
|
|
|
2015-10-06 04:13:11 +00:00
|
|
|
}
|
2015-10-06 07:13:51 +00:00
|
|
|
|
2015-10-06 19:27:53 +00:00
|
|
|
function pledge(req, res, next) {
|
2015-10-06 07:13:51 +00:00
|
|
|
const { user } = req;
|
|
|
|
const {
|
2015-10-06 21:54:59 +00:00
|
|
|
nonprofit: nonprofitName = 'girl develop it',
|
2015-10-06 07:13:51 +00:00
|
|
|
amount = '5',
|
2015-10-07 04:08:24 +00:00
|
|
|
goal = commitGoals.frontEndCert
|
2015-10-06 07:13:51 +00:00
|
|
|
} = req.query;
|
|
|
|
|
2015-10-06 21:54:59 +00:00
|
|
|
const nonprofit = findNonprofit(nonprofitName);
|
|
|
|
|
2015-10-06 19:27:53 +00:00
|
|
|
observeQuery(user, 'pledge')
|
|
|
|
.flatMap(oldPledge => {
|
|
|
|
// create new pledge for user
|
2015-10-06 21:54:59 +00:00
|
|
|
const pledge = Pledge(
|
|
|
|
Object.assign(
|
|
|
|
{
|
|
|
|
amount,
|
|
|
|
goal,
|
|
|
|
userId: user.id
|
|
|
|
},
|
|
|
|
nonprofit
|
|
|
|
)
|
|
|
|
);
|
2015-10-06 19:27:53 +00:00
|
|
|
|
|
|
|
if (oldPledge) {
|
|
|
|
debug('user already has pledge, creating a new one');
|
|
|
|
// we orphan last pledge since a user only has one pledge at a time
|
|
|
|
oldPledge.userId = '';
|
|
|
|
oldPledge.formerUser = user.id;
|
|
|
|
oldPledge.endDate = new Date();
|
|
|
|
oldPledge.isOrphaned = true;
|
|
|
|
return saveInstance(oldPledge)
|
|
|
|
.flatMap(() => {
|
|
|
|
return saveInstance(pledge);
|
|
|
|
});
|
|
|
|
}
|
|
|
|
return saveInstance(pledge);
|
|
|
|
})
|
|
|
|
.subscribe(
|
2015-10-07 09:11:23 +00:00
|
|
|
({ displayName, goal, amount }) => {
|
2015-10-06 19:27:53 +00:00
|
|
|
req.flash('success', {
|
|
|
|
msg: dedent`
|
|
|
|
Congratulations, you have committed to giving
|
2015-10-07 09:11:23 +00:00
|
|
|
${displayName} $${amount} each month until you have completed
|
2015-10-06 19:27:53 +00:00
|
|
|
your ${goal}.
|
|
|
|
`
|
|
|
|
});
|
|
|
|
res.redirect('/' + user.username);
|
|
|
|
},
|
|
|
|
next
|
|
|
|
);
|
2015-10-06 07:13:51 +00:00
|
|
|
}
|
2015-10-07 01:22:12 +00:00
|
|
|
|
2015-10-07 07:05:26 +00:00
|
|
|
function renderDirectory(req, res) {
|
|
|
|
res.render('commit/directory', {
|
|
|
|
title: 'Commit Directory',
|
|
|
|
nonprofits
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
2015-10-07 02:49:38 +00:00
|
|
|
function completeCommitment(req, res, next) {
|
|
|
|
const { user } = req;
|
|
|
|
|
2015-10-07 04:08:24 +00:00
|
|
|
return completeCommitment$(user)
|
2015-10-07 02:49:38 +00:00
|
|
|
.subscribe(
|
|
|
|
msgOrPledge => {
|
|
|
|
if (typeof msgOrPledge === 'string') {
|
|
|
|
return res.send(msgOrPledge);
|
|
|
|
}
|
|
|
|
return res.send(true);
|
|
|
|
},
|
|
|
|
next
|
|
|
|
);
|
|
|
|
}
|
|
|
|
|
2015-10-07 01:22:12 +00:00
|
|
|
function stopCommit(req, res, next) {
|
|
|
|
const { user } = req;
|
|
|
|
|
|
|
|
observeQuery(user, 'pledge')
|
|
|
|
.flatMap(pledge => {
|
|
|
|
if (!pledge) {
|
|
|
|
return Observable.just();
|
|
|
|
}
|
|
|
|
|
|
|
|
pledge.formerUserId = pledge.userId;
|
|
|
|
pledge.userId = null;
|
|
|
|
pledge.isOrphaned = true;
|
|
|
|
pledge.dateEnded = new Date();
|
|
|
|
return saveInstance(pledge);
|
|
|
|
})
|
|
|
|
.subscribe(
|
|
|
|
pledge => {
|
|
|
|
let msg = `You have successfully stopped your pledge.`;
|
|
|
|
if (!pledge) {
|
|
|
|
msg = `No pledge found for user ${user.username}.`;
|
|
|
|
}
|
|
|
|
req.flash('errors', { msg });
|
2015-10-07 06:33:17 +00:00
|
|
|
return res.redirect(`/${user.username}`);
|
2015-10-07 01:22:12 +00:00
|
|
|
},
|
|
|
|
next
|
|
|
|
);
|
|
|
|
}
|
2015-10-06 04:13:11 +00:00
|
|
|
}
|