Added email list methods, create guest ticket upon transaction, added mailing list endpoint, add email to list on transaction

Author: jfurfaro

lib/routes/sites.js

@@ -1,6 +1,12 @@
 const sitesRouter = require('express').Router(),
 	{ authorizeUser } = require('../middleware/auth'),
-	{ getSites, getSite, getSiteSettings } = require('../services/sites');
+	{ getSites, getSite, getSiteSettings } = require('../services/sites'),
+	{ upsertEmailSubscriber } = require('../services/email');
+
+// TODO: make this configurable at some point
+const EMAIL_LIST = {
+	'mustachebash.com': '90392ecd5e'
+};
 
 sitesRouter.route('/')
 	.get(authorizeUser, async (req, res, next) => {
@@ -26,6 +32,19 @@ sitesRouter.route('/:id')
 		}
 	});
 
+sitesRouter.route('/:id/mailing-list')
+	.post(async (req, res, next) => {
+		if(!req.body.email || !req.body.firstName || !req.body.lastName) return next(400);
+
+		try {
+			await upsertEmailSubscriber(EMAIL_LIST[req.params.id], {...req.body, tags: [`Site '${req.params.id}' Form Opt-In`]});
+
+			res.status(204).end();
+		} catch(e) {
+			next(e);
+		}
+	});
+
 sitesRouter.route('/:id/settings')
 	.get(async (req, res, next) => {
 		try {

lib/routes/transactions.js

@@ -1,7 +1,11 @@
 const transactionsRouter = require('express').Router(),
 	{ authorizeUser } = require('../middleware/auth'),
 	{ createTransaction, getTransactions, getTransaction } = require('../services/transactions'),
-	{ sendReceipt } = require('../services/email');
+	{ sendReceipt, upsertEmailSubscriber } = require('../services/email');
+
+// TODO: make this configurable at some point
+const EMAIL_LIST = '90392ecd5e',
+	EMAIL_TAG = 'Mustache Bash 2020 Attendee';
 
 transactionsRouter.route('/')
 	.get(authorizeUser, async (req, res, next) => {
@@ -17,10 +21,13 @@ transactionsRouter.route('/')
 		if(!req.body) return next(400);
 
 		try {
-			const transaction = await createTransaction({...req.body});
+			const transaction = await createTransaction({...req.body}),
+				{ email, firstName, lastName } = transaction;
 
 			// Send a receipt email
-			sendReceipt(transaction.firstName, transaction.lastName, transaction.email, transaction.braintreeTransactionId, transaction.amount);
+			sendReceipt(firstName, lastName, email, transaction.braintreeTransactionId, transaction.amount);
+			// Add them to the mailing list and tag as an attendee
+			upsertEmailSubscriber(EMAIL_LIST, {email, firstName, lastName, tags: [EMAIL_TAG]});
 
 			res.location(`https://${req.get('host')}${req.baseUrl}/${transaction.id}`);
 			res.status(201).json(transaction.braintreeTransactionId);

lib/services/email.js

@@ -3,10 +3,51 @@
  * @type {Object}
  */
 
-const config = require('../config'),
-	mailgun = require('mailgun-js')({apiKey: config.mailgun.apiKey, domain: config.mailgun.domain});
+const crypto = require('crypto'),
+	config = require('../config'),
+	mailgun = require('mailgun-js')({apiKey: config.mailgun.apiKey, domain: config.mailgun.domain}),
+	MailChimpClient = require('mailchimp-api-v3');
+
+const mailchimp = new MailChimpClient(config.mailchimp.apiKey),
+	md5 = string => crypto.createHash('md5').update(string).digest('hex');
+
 /* eslint-disable max-len */
 module.exports = {
+	/**
+	 * This will upsert a member into a list with first and last names, subscribe by default (but leave existing statuses in place)
+	 * then apply all tags listed
+	 * @param  {string}  listId    Mailchimp list id
+	 * @param  {string}  email     subscriber email
+	 * @param  {string}  firstName subscriber first name
+	 * @param  {string}  lastName  subscriber last name
+	 * @param  {Array}   [tags=[] string }]   tags to apply to member
+	 * @return {Promise}
+	 */
+	async upsertEmailSubscriber(listId, { email, firstName, lastName, tags = [] }) {
+		const memberHash = md5(email.toLowerCase());
+
+		try {
+			const member = await mailchimp.put(`/lists/${listId}/members/${memberHash}`, {
+				email_address: email,
+				status_if_new: 'subscribed',
+				merge_fields: {
+					FNAME: firstName,
+					LNAME: lastName
+				}
+			});
+
+			if(tags.length) {
+				await mailchimp.post(`/lists/${listId}/members/${memberHash}/tags`, {
+					tags: tags.map(tag => ({name: tag, status: 'active'}))
+				});
+			}
+
+			console.log(member);
+		} catch(e) {
+			console.error(e);
+		}
+	},
+
 	sendReceipt(guestFirstName, guestLastName, guestEmail, confirmation, amount) {
 		mailgun.messages().send({
 			from: 'Mustache Bash Tickets <[email protected]>',

lib/services/guests.js

@@ -87,7 +87,7 @@ module.exports = {
 		return generateQRDataURI(JSON.stringify(createTicketToken(ticket)));
 	},
 
-	async createGuestTicket(guestId, { createdBy }) {
+	async createGuestTicket(guestId, { createdBy = 'purchase' } = {}) {
 		const guest = await run(r.table('guests').get(guestId));
 
 		if(guest.checkedIn) throw new GuestsServiceError('Could not create ticket - guest already checked in', 'LOCKED');

lib/services/transactions.js

@@ -4,7 +4,7 @@
  */
 const braintree = require('braintree'),
 	{ run, r } = require('../utils/db'),
-	{ createGuest } = require('../services/guests'),
+	{ createGuest, createGuestTicket } = require('../services/guests'),
 	{ braintree: btConfig, donationProductId } = require('../config');
 
 const gateway = braintree.connect({
@@ -182,13 +182,21 @@ module.exports = {
 		orderDetails.forEach(i => {
 			if(i.product.type === 'ticket') {
 				for (let j = 0; j < i.quantity; j++) {
-					createGuest({
-						firstName: customer.firstName,
-						lastName: customer.lastName  + (j > 0 ? ` Guest ${j}` : ''),
-						eventId: i.product.eventId,
-						transactionId: changes[0].new_val.id,
-						confirmationId: braintreeTransaction.id
-					}).catch(console.error);
+					(async () => {
+						try {
+							const { id: guestId } = await createGuest({
+								firstName: customer.firstName,
+								lastName: customer.lastName  + (j > 0 ? ` Guest ${j}` : ''),
+								eventId: i.product.eventId,
+								transactionId: changes[0].new_val.id,
+								confirmationId: braintreeTransaction.id
+							});
+
+							await createGuestTicket(guestId);
+						} catch(e) {
+							console.error(e);
+						}
+					})();
 				}
 			}
 		});