Send email

package.json

@@ -27,6 +27,7 @@
   },
   "homepage": "https://github.com/foundersandcoders/open-tourism-platform#readme",
   "dependencies": {
+    "@sendgrid/mail": "^6.2.1",
     "bcrypt": "^1.0.3",
     "body-parser": "^1.17.2",
     "boom": "^5.2.0",

src/controllers/event.js

@@ -2,6 +2,7 @@ const Event = require('../models/Event')
 const { rejectIfNull } = require('../db/utils')
 const { messages: errMessages } = require('../constants/errors')
 const roles = require('../constants/roles')
+const sendEmail = require('../helpers/sendEmail')
 
 const eventController = module.exports = {}
 
@@ -50,7 +51,7 @@ eventController.create = (req, res, next) => {
 
   const newEvent = new Event(newEventDetails)
   newEvent.save()
-  // TODO: .then(event => req.user.role !== roles.BASIC ? event : sendEmail(event))
+    .then(event => req.user.role !== roles.BASIC ? event : sendEmail(event))
     .then(event => res.status(201).send(event))
     .catch(next)
 }

src/controllers/place.js

@@ -2,6 +2,7 @@ const Place = require('../models/Place')
 const { rejectIfNull } = require('../db/utils')
 const { messages: errMessages } = require('../constants/errors')
 const roles = require('../constants/roles')
+const sendEmail = require('../helpers/sendEmail')
 
 const placeController = module.exports = {}
 
@@ -35,6 +36,7 @@ placeController.create = (req, res, next) => {
 
   const newPlace = new Place(newPlaceDetails)
   newPlace.save()
+    .then(place => req.user.role !== roles.BASIC ? place : sendEmail(place))
     .then(place => res.status(201).send(place))
     .catch(next)
 }

src/helpers/sendEmail.js

@@ -0,0 +1,26 @@
+const sgMail = require('@sendgrid/mail')
+const User = require('../models/User')
+sgMail.setApiKey(process.env.SENDGRID_API_KEY)
+sgMail.setSubstitutionWrappers('{{', '}}')
+
+const sendEmails = (emails, content) => {
+  const msg = {
+    to: emails,
+    from: '[email protected]',
+    templateId: '0839aec2-dd34-459d-9493-4fd9682b9073',
+    substitutions: {
+      name: content.en.name,
+      id: content._id
+    }
+  }
+
+  sgMail
+    .sendMultiple(msg)
+}
+
+module.exports = content =>
+  new Promise((resolve, reject) =>
+    User.find({ role: { $not: /BASIC/ } }, 'email')
+      .then(emails => sendEmails(emails, content))
+      .then(() => resolve(content))
+      .catch(reject))

tests/controllers/event.test.js

@@ -168,8 +168,8 @@ tape('POST /events adding event with invalid place field', t => {
 
 tape('POST /events adding valid event', t => {
   Promise.all([
-    User.create(superUser),
-    makeLoggedInToken(superUser)
+    User.create([validBasicUser, superUser]), // superUser for sending emails
+    makeLoggedInToken(validBasicUser)
   ]).then(([ _, token ]) =>
   supertest(server)
     .post('/api/v1/events')
@@ -184,7 +184,7 @@ tape('POST /events adding valid event', t => {
       Event.findById(res.body._id)
         .then(event => {
           t.equal(event.categories[0], res.body.categories[0], 'Event is in the database')
-          dropCollectionAndEnd(Event, t)
+          dropCollectionsAndEnd([Event, User], t)
         })
         .catch(err => {
           t.fail(err)
@@ -297,7 +297,7 @@ tape('PUT /events/:id with invalid id', t => {
   )
   .then(res => {
     t.equal(res.body.message, 'Invalid id', 'Correct message is sent back')
-    dropCollectionAndEnd(Event, t)
+    dropCollectionsAndEnd([Event, User], t)
   })
   .catch(err => t.end(err))
 })

tests/controllers/place.test.js

@@ -99,7 +99,7 @@ tape('GET /places/:id with id of something in the database', t => {
 // Tests for: POST /places
 tape('POST /places with valid place data', t => {
   Promise.all([
-    User.create(validBasicUser),
+    User.create([validBasicUser, superUser]), // superUser for sending emails
     makeLoggedInToken(validBasicUser)
   ]).then(([ _, token ]) => supertest(server)
     .post('/api/v1/places')
@@ -118,7 +118,7 @@ tape('POST /places with valid place data', t => {
         })
         .catch(err => {
           t.fail(err)
-          dropCollectionAndEnd(Place, t)
+          dropCollectionsAndEnd([Place, User], t)
         })
     }).catch(err => t.end(err))
 })

tests/fixtures/users.json

@@ -62,7 +62,7 @@
     "_id": "5986abad5e2d852cb1ee6bce",
     "username": "mantagen",
     "password": "pword",
-    "email": "xxx",
+    "email": "xxx@xxx.com",
     "role": "SUPER",
     "isPublic": false,
     "en": {