Add Sendgrid Resolvers

server/.env.example

@@ -14,3 +14,9 @@ AUTH0_AUDIENCE=auth0-audience
 AUTH0_ISSUER=auth0-issuer
 
 AACLOUD_ID=aacloud-id
+
+RECAPTCHA=<RECAPTCHA_KEY>
+
+SG_APIKEY=<SENDGRID_API_KEY>
+SG_SIGNUP_EMAILID=<SENDGRID_SIGNUP_EMAILID>
+SG_CONTACT_EMAILID=<SENDGRID_CONTACT_EMAILID>

server/src/resolvers/mutation/sendgrid.js

@@ -1,5 +1,8 @@
 import axios from 'axios'
 import jwt from 'jsonwebtoken')
+import { ApolloError } from 'apollo-server-express'
+
+import logger from '../../logger'
 
 const API_KEY = process.env.SG_APIKEY
 
@@ -10,12 +13,226 @@ if (dev){
 }
 
 export default {
-  async sendgrid_NewsletterSignup(parent, { token }, ctx, info) {
-    
-  },
-  async sendgrid_NewsletterSignupVerify(parent, { email }, ctx, info){
+  async sendgrid_NewsletterSignup(parent, { email }, ctx, info) {
+    const token = jwt.sign({ email: email }, API_KEY, { expiresIn: '1d' })
+    let origin = 'https://advancedalgos.net'
+    const params = '/email-verification?token='
+    if (dev){
+      origin = 'http://localhost:4100'
+    }
 
+    var headers = {
+      'Content-Type': 'application/json',
+      'Access-Control-Allow-Origin' : origin,
+      'Access-Control-Allow-Credentials': 'true'
+    };
+
+    var data = JSON.stringify({
+      "personalizations": [
+          {
+            "to": [
+              {
+                "email": email
+              }
+            ],
+            dynamic_template_data: {
+              "aaverifylink": origin + params + token,
+              "subject": 'VERIFY YOUR INTEREST in Advanced Algos'
+            },
+            "subject": 'VERIFY YOUR INTEREST in Advanced Algos'
+          }
+        ],
+        "from": {
+          "email": "feedback@advancedalgos.net",
+          "name": "Advanced Algos Team"
+        },
+        "reply_to": {
+          "email": "feedback@advancedalgos.net",
+          "name": "Advanced Algos Team"
+        },
+        "template_id": process.env.SG_EMAILID
+      })
+
+    const sendVerify = axios({
+        method: 'post',
+        url: 'https://api.sendgrid.com/v3/mail/send',
+        data: data,
+        headers:{
+            'content-type': 'application/json',
+            'authorization': 'Bearer ' + API_KEY
+        }
+    })
+    .then(function (response) {
+        if (response.status >= 200 && response.status < 300) {
+          context.res = {
+            status: response.status,
+            body: "Email verification sent \n",
+            headers
+          }
+          return context
+        } else {
+          throw response.data.errors[0].message
+        }
+    })
+    .catch(function (error) {
+      throw new ApolloError(error.response.data.errors[0].message, 404)
+    })
+    return sendVerify
   },
-  async sendgrid_Contact(parent, { email, subject, message }, ctx, info) {
+  async sendgrid_NewsletterSignupVerify(parent, { token }, ctx, info){
+    let origin = 'https://app.advancedalgos.net'
+    if (dev){
+      origin = 'http://localhost:4100'
+    }
+    const headers = {
+      'Content-Type': 'application/json',
+      'Access-Control-Allow-Origin' : origin,
+      'Access-Control-Allow-Credentials': 'true'
+    }
+
+    let token;
+    try {
+        verifiedToken = jwt.verify(token, API_KEY, {maxAge: '1d'})
+    } catch(err) {
+        if (err.name === 'TokenExpiredError'){
+          throw new ApolloError('Error: Token Expired. Please resubmit email address.', 400)
+        } else {
+          throw new ApolloError(`Error: ${err.message}`, 400)
+        }
+    }
+
+    const email = verifiedToken.email
+
+    const subscribe = axios({
+        method: 'post',
+        url: 'https://api.sendgrid.com/v3/contactdb/recipients',
+        data: [{"email": email}],
+        headers:{
+          'content-type': 'application/json',
+          'authorization': 'Bearer ' + API_KEY
+        }
+    })
+    .then(response => {
+        const recipients = response.data.persisted_recipients
+
+        if (recipients.length > 0 ){
+          const addToList = axios({
+              method: 'post',
+              url: 'https://api.sendgrid.com/v3/contactdb/lists/4068018/recipients/' + recipients[0],
+              headers:{
+                  'content-type': 'application/json',
+                  'authorization': 'Bearer ' + API_KEY
+              }
+          })
+          .then(response => {
+              if (response.status >= 200 && response.status < 300) {
+                return { email }
+              } else {
+                throw response.data.errors[0].message
+              }
+          })
+          .catch(error => {
+            throw `Email SignUp Error: ${error}`
+          })
+          return addToList;
+        } else{
+          return response.data.errors[0].message
+        }
+
+    })
+    .then(response => {
+      return `Success: Added ${response.email} to General List`
+    })
+    .catch(error => {
+      throw new ApolloError(error.response.data.errors[0].message, 404)
+    })
+    return subscribe
   },
+  async sendgrid_Contact(parent, { email, subject, message, recaptcha }, ctx, info) {
+    let origin = 'https://advancedalgos.net'
+    if (dev){
+      origin = 'http://localhost:4000'
+    }
+    const headers = {
+      'Content-Type': 'application/json',
+      'Access-Control-Allow-Origin' : origin,
+      'Access-Control-Allow-Credentials': 'true'
+    }
+
+    const toEmail = 'feedback@advancedalgos.net'
+
+    const data = JSON.stringify({
+        "personalizations": [
+            {
+              "to": [
+                {
+                  "email": email
+                }
+              ],
+              dynamic_template_data: {
+                "aacontactname": name,
+                "aacontactemail": email,
+                "aacontactbody": message
+              },
+              "subject": `AA Corporate Site Contact - Message from ${name}`
+            }
+          ],
+        "from": {
+          "email": email,
+          "name": name
+        },
+        "reply_to": {
+          "email": email,
+          "name": name
+        },
+        "template_id": process.env.SG_CONTACT_EMAILID
+      })
+
+      const checkCaptcha = axios({
+          method: 'post',
+          url: 'https://www.google.com/recaptcha/api/siteverify',
+          params: {
+            secret: process.env.RECAPTCHA,
+            response: recaptcha
+          }
+      })
+      .then(function (response) {
+        logger.info(response.data)
+        if (response.status >= 200 && response.status < 300 && response.data.success) {
+            context.log('presend SendGrid');
+            return axios({
+              method: 'post',
+              url: 'https://api.sendgrid.com/v3/mail/send',
+              data: data,
+              headers:{
+                'content-type': 'application/json',
+                'authorization': 'Bearer ' + API_KEY
+              }
+            })
+            .then(function (response) {
+                context.log('sendgrid response: ', response)
+                if (response.status >= 200 && response.status < 300) {
+                  return `Contact email sent`
+                } else {
+                  throw response.data.errors[0].message
+                }
+            })
+            .catch(function (error) {
+                logger.error(`sendgrid Error: ${JSON.stringify(error)}`)
+                throw `Contact email send error: ${error.response.data.errors[0].message}`
+            })
+          }else{
+            throw response.data
+          }
+      })
+      .then(function(response){
+        return response
+      })
+      .catch(function (error) {
+        context.log('function error: ', error, JSON.stringify(error.Error))
+        throw new ApolloError(JSON.stringify(error.response), 404)
+      })
+  }
+  return
+  }
 }

server/src/schema/index.js

@@ -2,7 +2,7 @@ export const typeDef = `
   type Mutation {
     sendgrid_NewsletterSignup(email: String!): String
     sendgrid_NewsletterSignupVerify(email: String!): String
-    sendgrid_Contact(email: String!, subject: String!, Message: String!): String
+    sendgrid_Contact(email: String!, subject: String!, Message: String!, recaptcha: String!): String
   }
 
   schema {