updates for getting ticket info

Author: jfurfaro

.dockerignore

@@ -3,3 +3,4 @@
 .eslintrc.js
 README.md
 Dockerfile
+scripts/

Dockerfile

@@ -1,7 +1,7 @@
 FROM node:12.13-alpine
 RUN mkdir -p /mustachebash
 WORKDIR /mustachebash
-COPY package.json package-lock.json ./
+COPY package.json package-lock.json ticket-logo.png ./
 RUN npm install --production --no-optional && \
 	npm cache clean --force
 

lib/routes/index.js

@@ -16,6 +16,28 @@ const api = require('express').Router(),
 	guestsRouter = require('./guests'),
 	usersRouter = require('./users');
 
+const processTransactionToken = async (req, res, next) => {
+	if(!req.query.t) return next(400);
+
+	let transactionId;
+	try {
+		({ sub: transactionId } = validateTransactionToken(req.query.t));
+	} catch(e) {
+		next(e);
+	}
+
+	try {
+		// eslint-disable-next-line
+		req.ticketPairs = await getTransactionTickets(transactionId);
+	} catch(e) {
+		if (e.code === 'UNAUTHORIZED') return next(401);
+
+		next(e);
+	}
+
+	next();
+};
+
 api.use('/transactions', transactionsRouter);
 api.use('/sites', sitesRouter);
 api.use('/events', authorizeUser, eventsRouter);
@@ -24,30 +46,37 @@ api.use('/promos', promosRouter);
 api.use('/guests', authorizeUser, guestsRouter);
 api.use('/users', authorizeUser, usersRouter);
 
+api.use('/mytickets', processTransactionToken);
+
 api.route('/mytickets')
-	.get(async (req, res, next) => {
-		if(!req.query.t) return next(400);
+	.get((req, res) => {
+		res.json(req.ticketPairs.map(({ guest, ticket }) => {
+			const { confirmationId, firstName, lastName } = guest,
+				{ qrCode, name: eventName, date: eventDate } = ticket;
+
+			return {
+				confirmationId,
+				firstName,
+				lastName,
+				eventName,
+				eventDate,
+				qrCode
+			};
+		}));
+	});
 
-		let transactionId;
+api.route('/mytickets/pdf')
+	.get((req, res, next) => {
 		try {
-			({ sub: transactionId } = validateTransactionToken(req.query.t));
-		} catch(e) {
-			next(e);
-		}
+			const ticketsPDF = generateTicketsPDF(req.ticketPairs);
 
-		let tickets;
-		try {
-			tickets = await getTransactionTickets(transactionId);
+			res.setHeader('Content-disposition', 'attachment; filename="Mustache Bash 2020 Tickets.pdf"');
+			res.setHeader('Content-type', 'application/pdf');
+			ticketsPDF.pipe(res);
+			ticketsPDF.end();
 		} catch(e) {
-			if (e.code === 'UNAUTHORIZED') return next(401);
-
 			next(e);
 		}
-
-		const ticketsPDF = generateTicketsPDF(tickets);
-
-		ticketsPDF.pipe(res);
-		ticketsPDF.end();
 	});
 
 api.route('/authenticate')

lib/routes/transactions.js

@@ -22,15 +22,22 @@ transactionsRouter.route('/')
 
 		try {
 			const transaction = await createTransaction({...req.body}),
-				{ email, firstName, lastName } = transaction;
+				{ id, email, firstName, lastName } = transaction;
 
 			// Send a receipt email
 			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);
+			let transactionToken;
+			try {
+				transactionToken = await generateTransactionToken(id);
+			} catch(e) {
+				req.log.error(e, 'Error creating transaction token');
+			}
+
+			res.location(`https://${req.get('host')}${req.baseUrl}/${id}`);
+			res.status(201).json({confirmationId: transaction.braintreeTransactionId, token: transactionToken});
 		} catch(e) {
 			if(e.code === 'INVALID') {
 				req.log.error(e);

lib/services/email.js

@@ -24,6 +24,7 @@ module.exports = {
 	 * @return {Promise}
 	 */
 	async upsertEmailSubscriber(listId, { email, firstName, lastName, tags = [] }) {
+		return;
 		const memberHash = md5(email.toLowerCase());
 
 		try {

lib/services/guests.js

@@ -123,7 +123,7 @@ module.exports = {
 			.filter({transactionId})
 			.eqJoin('id', r.table('tickets'), {index: 'guestId'})
 			.filter({right: {status: 'active'}})
-			.map({guest: r.row('left'), ticket: r.row('right')});
+			.map({guest: r.row('left'), ticket: r.row('right').merge(row => r.table('events').get(row('eventId')).pluck('name', 'date'))});
 
 		const pairs = await run(query).then(cursor => cursor.toArray());
 

lib/services/pdf.js

@@ -3,23 +3,41 @@
  * @type {Object}
  */
 
-const PDFDocument = require('pdfkit');
+const path = require('path'),
+	PDFDocument = require('pdfkit');
 
 module.exports = {
 	generateTicketsPDF(guestsTicketsPairs) {
-		const doc = new PDFDocument({margin: 50, autoFirstPage: false});
+		const doc = new PDFDocument({
+			margins: {top: 20, left: 20, right: 20, bottom: 5},
+			autoFirstPage: false,
+			size: [280, 400],
+			info: {
+				Title: 'Mustache Bash 2020 Tickets',
+				Author: 'Mustache Bash'
+			}
+		});
 
 		guestsTicketsPairs.forEach(({ guest, ticket }) => {
 			doc.addPage();
 
-			const { firstName, lastName } = guest,
-				{ qrCode } = ticket;
+			const { firstName, lastName, confirmationId } = guest,
+				{ qrCode, id } = ticket;
 
-			doc.fontSize(20)
-				.text('Mustache Bash 2020 - Ticket', 0, 57, {align: 'center'})
-				.fontSize(14)
-				.text(`for ${firstName} ${lastName}`, 0, 97, {align: 'center'})
-				.image(qrCode, 0, 200);
+			doc.image(path.resolve(__dirname, '../../ticket-logo.png'), 68, 20, {width: 144})
+				.font('Helvetica')
+				.fontSize(18)
+				.moveDown(1)
+				.text('March 28th, 2020', {align: 'center'})
+				.moveDown(1)
+				.fontSize(12)
+				.text(`${firstName} ${lastName}`, {align: 'center'})
+				.fontSize(8)
+				.text(`confirmation #: ${confirmationId}`, {align: 'center'})
+				.image(qrCode, 40, 180, {width: 200})
+				.fontSize(8)
+				.font('Courier')
+				.text(id.slice(0, 8), 20, 380, {align: 'center'});
 		});
 
 		return doc;

lib/services/sites.js

@@ -37,7 +37,7 @@ module.exports = {
 			})
 			.merge({
 				products: r.table('products')
-					.getAll(r.args(r.row('events')('currentTicket')))
+					.getAll(r.args(r.row('events')('id')), {index: 'eventId'})
 					.pluck('description', 'id', 'name', 'price', 'status')
 					.coerceTo('array')
 			});