Add mailing list subscription

Author: tylermenezes

package.json

@@ -58,8 +58,9 @@
     "emoji-strip": "^1.0.1",
     "express": "^4.16.4",
     "extract-files": "^10.0.0",
-    "form-data": "^3.0.0",
+    "form-data": "^4.0.0",
     "graphql": "15.3.0",
+    "graphql-scalars": "^1.21.3",
     "graphql-upload": "^11.0.0",
     "graphql-ws": "^2.0.0",
     "husky": "^1.3.1",

src/remotes/email/index.js

@@ -0,0 +1,43 @@
+/* eslint-disable camelcase */
+import fs from 'fs';
+import path from 'path';
+import { makeExecutableSchema } from '@graphql-tools/schema';
+import fetch from 'node-fetch';
+import FormData from 'form-data';
+import {JSONObjectResolver, JSONObjectDefinition} from 'graphql-scalars';
+
+const typeDefs = [JSONObjectDefinition, fs.readFileSync(path.join(__dirname, 'schema.gql')).toString()];
+
+export default function createEmailSchema() {
+  const resolvers = {
+    JSONObject: JSONObjectResolver,
+
+    Query: {
+      status() { return true; },
+    },
+
+    Mutation: {
+      async subscribe(parent, args) {
+        const res = await fetch(`https://emailoctopus.com/api/1.6/lists/${args.list}/contacts`, {
+          method: 'POST',
+          headers: { 'Content-Type': 'application/json', },
+          body: JSON.stringify({
+            api_key: process.env.EMAIL_OCTOPUS_TOKEN,
+            email_address: args.email,
+            fields: { ...args.fields, FirstName: args.firstName, LastName: args.lastName },
+          }),
+        });
+        return true;
+      },
+    },
+  };
+
+  const schema = makeExecutableSchema({
+    typeDefs,
+    resolvers,
+  });
+
+  return {
+    schema,
+  };
+}

src/remotes/email/schema.gql

@@ -0,0 +1,7 @@
+type Query {
+  status: Boolean
+}
+
+type Mutation {
+  subscribe(list: String!, email: String!, firstName: String, lastName: String, fields: JSONObject): String
+}

src/server.js

@@ -14,6 +14,7 @@ import createCalendarSchema from './remotes/calendar';
 import createLabsSchema from './remotes/labs';
 import createAdvisorsSchema from './remotes/advisors';
 import createTwitchSchema from './remotes/twitch';
+import createEmailSchema from './remotes/email';
 import createGeoSchema from './remotes/geo';
 import createClearSchema from "./remotes/clear";
 import createAccountSchema from './remotes/account';
@@ -24,7 +25,7 @@ const port = process.env.PORT || 4000;
 
 async function buildSchema() {
   console.log('Fetching sub-schemas...');
-  const [blog, showYourWork, showcase, calendar, labs, advisors, clear, cms, account, geo, twitch, github] =
+  const [blog, showYourWork, showcase, calendar, labs, advisors, clear, cms, account, geo, email, twitch, github] =
     await Promise.all([
       await createWordpressSchema(process.env.WORDPRESS_URL || 'https://wp.codeday.org/graphql'),
       await createDiscordPostsSchema(process.env.SHOWYOURWORK_URL || 'http://discord-posts.codeday.cloud'),
@@ -42,6 +43,7 @@ async function buildSchema() {
         process.env.MAXMIND_ACCOUNT,
         process.env.MAXMIND_KEY
       ),
+      await createEmailSchema(),
       await createTwitchSchema(
         process.env.TWITCH_CHANNEL,
         process.env.TWITCH_CLIENT_ID,
@@ -60,6 +62,7 @@ async function buildSchema() {
     showYourWork,
     showcase,
     calendar,
+    email,
     twitch,
     labs,
     advisors,

yarn.lock

@@ -2688,7 +2688,7 @@ flatted@^3.1.0:
   resolved "https://registry.yarnpkg.com/flatted/-/flatted-3.1.0.tgz#a5d06b4a8b01e3a63771daa5cb7a1903e2e57067"
   integrity sha512-tW+UkmtNg/jv9CSofAKvgVcO7c2URjhTdW1ZTkcAritblu8tajiYy7YisnIflEwtKssCtOxpnBRoCB7iap0/TA==
 
-form-data@4.0.0:
+form-data@4.0.0, form-data@^4.0.0:
   version "4.0.0"
   resolved "https://registry.yarnpkg.com/form-data/-/form-data-4.0.0.tgz#93919daeaf361ee529584b9b31664dc12c9fa452"
   integrity sha512-ETEklSGi5t0QMZuiXoA/Q6vcnxcLQP5vdugSpuAyi6SVGi2clPPp+xgEhuMaHC+zGgn31Kd235W35f7Hykkaww==
@@ -2896,6 +2896,13 @@ graphql-extensions@^0.15.0:
     apollo-server-env "^3.1.0"
     apollo-server-types "^0.9.0"
 
+graphql-scalars@^1.21.3:
+  version "1.21.3"
+  resolved "https://registry.yarnpkg.com/graphql-scalars/-/graphql-scalars-1.21.3.tgz#21eb0b9349cc94ae62b40f40ebe87220d3a5f1b1"
+  integrity sha512-QLWw3BHmqHZMp9JeYmPpjq7JT9aw/H8TpwmWKJEuMSE3+O7Xe7TduQbOLFzbs1q9UxX6CVkc0O1JO/YfkP/pAw==
+  dependencies:
+    tslib "^2.5.0"
+
 graphql-subscriptions@^1.0.0:
   version "1.1.0"
   resolved "https://registry.yarnpkg.com/graphql-subscriptions/-/graphql-subscriptions-1.1.0.tgz#5f2fa4233eda44cf7570526adfcf3c16937aef11"
@@ -5020,7 +5027,7 @@ tslib@^1.10.0, tslib@^1.14.1, tslib@^1.9.3:
   resolved "https://registry.yarnpkg.com/tslib/-/tslib-1.14.1.tgz#cf2d38bdc34a134bcaf1091c41f6619e2f672d00"
   integrity sha512-Xni35NKzjgMrwevysHTCArtLDpPvye8zV/0E4EyYn43P7/7qvQwPh9BGkHewbMulVntbigmcT7rdX3BNo9wRJg==
 
-tslib@^2.0.3, tslib@^2.1.0:
+tslib@^2.0.3, tslib@^2.1.0, tslib@^2.5.0:
   version "2.5.0"
   resolved "https://registry.yarnpkg.com/tslib/-/tslib-2.5.0.tgz#42bfed86f5787aeb41d031866c8f402429e0fddf"
   integrity sha512-336iVw3rtn2BUK7ORdIAHTyxHGRIHVReokCR3XjbckJMK7ms8FysBfhLR8IXnAgy7T0PTPNBWKiH514FOW/WSg==