surveyRoutes.js

const _ = require("lodash");
const Path = require("path-parser").default;
const { URL } = require("url");
const mongoose = require("mongoose");
const checkUserLogin = require("../middlewares/checkUserLogin");
const checkUserCredits = require("../middlewares/checkUserCredits");
const Mailer = require("../services/Mailer");
const surveyTemplate = require("../services/emailTemplates/surveyTemplate");

const Survey = mongoose.model("surveys");
module.exports = app => {
	app.get("/api/survey/:surveyId/:choice", (req, res) => {
		res.send("Thanks for your feedback !");
	});

	app.get("/api/surveys", checkUserLogin, async (req, res) => {
		const surveys = await Survey.find({ _user: req.user.id }).select({
			recipients: false
		});
		res.send(surveys);
	});

	app.post("/api/surveys/webhooks", (req, res) => {
		const p = new Path("/api/survey/:surveyId/:choice");
		_.chain(req.body)
			.map(({ email, url }) => {
				const match = p.test(new URL(url).pathname);
				if (match) {
					return {
						email,
						surveyId: match.surveyId,
						choice: match.choice
					};
				}
			})
			.compact()
			.uniqBy("email", "surveyId")
			.each(({ surveyId, email, choice }) => {
				Survey.updateOne(
					{
						_id: surveyId,
						recipients: {
							$elemMatch: { email: email, responded: false }
						}
					},
					{
						$inc: { [choice]: 1 },
						$set: { "recipients.$.responded": true },
						lastResponded: new Date()
					}
				).exec();
			})
			.value();

		res.send({});
	});

	app.post(
		"/api/surveys",
		checkUserLogin,
		checkUserCredits,
		async (req, res) => {
			const { title, subject, body, recipients } = req.body;
			const survey = new Survey({
				title,
				subject,
				body,
				recipients: recipients
					.split(",")
					.map(email => ({ email: email.trim() })),
				_user: req.user.id,
				dateSent: Date.now()
			});
			const mailer = new Mailer(survey, surveyTemplate(survey));

			try {
				await mailer.send();
				await survey.save();
				req.user.credits -= 1;
				const user = await req.user.save();
				res.send(user);
			} catch (err) {
				res.status(422).send(err);
			}
		}
	);
};