fix: added back mailchimp as it is used in newsletter subscriptions

Author: hentrymartin

src/server/index.js

@@ -24,6 +24,7 @@ import { getRates as getExchangeRates } from 'services/money';
 import { toJson as xmlToJson } from 'utils/xml2json';
 
 import cdnRouter from './routes/cdn';
+import mailChimpRouter from './routes/mailchimp';
 import mockDocuSignFactory from './__mocks__/docu-sign-mock';
 import recruitCRMRouter from './routes/recruitCRM';
 import mmLeaderboardRouter from './routes/mmLeaderboard';
@@ -239,6 +240,7 @@ async function onExpressJsSetup(server) {
   });
 
   server.use('/api/cdn', cdnRouter);
+  server.use('/api/mailchimp', mailChimpRouter);
   server.use('/api/recruit', recruitCRMRouter);
   server.use('/api/mml', mmLeaderboardRouter);
 

src/server/routes/mailchimp.js

@@ -0,0 +1,34 @@
+/**
+ * The routes that expose our content to Content Delivery Networks.
+ */
+
+import express from 'express';
+import MailchimpService from '../services/mailchimp';
+import { sendEmail } from '../services/sendGrid';
+
+const routes = express.Router();
+/* Sets Access-Control-Allow-Origin header to avoid CORS error.
+ * TODO: Replace the wildcard value by an appropriate origin filtering. */
+routes.use((req, res, next) => {
+  res.set('Access-Control-Allow-Origin', '*');
+  res.set('Access-Control-Allow-Headers', 'authorization, content-type');
+  res.set('Access-Control-Allow-Methods', 'GET,POST,PUT,OPTIONS');
+  next();
+});
+
+/* do regist member to mailchimp server. */
+routes.post('/:listId/members', (req, res, next) => new MailchimpService().doRegistMember(req).then(res.send.bind(res), next));
+
+routes.get('/:listId/members/:emailHash', (req, res) => new MailchimpService().checkSubscription(req).then(res.send.bind(res)));
+
+routes.put('/:listId/members/:emailHash', (req, res) => new MailchimpService().updateMember(req).then(res.send.bind(res)));
+
+routes.post('/:listId/members/:emailHash/tags', (req, res) => new MailchimpService().subscribeTags(req).then(res.send.bind(res)));
+
+routes.get('/campaign-folders', (req, res) => new MailchimpService().getCampaignFolder(req).then(res.send.bind(res)));
+
+routes.get('/campaigns', (req, res) => new MailchimpService().getCampaigns(req).then(res.send.bind(res)));
+
+routes.post('/email', (req, res) => sendEmail(req, res).then(res.send.bind(res)));
+
+export default routes;

src/server/services/mailchimp.js

@@ -0,0 +1,111 @@
+/**
+ * Server-side functions necessary for effective integration with mailchimp
+ */
+import fetch from 'isomorphic-fetch';
+import config from 'config';
+import qs from 'qs';
+
+/**
+ * Auxiliary class that handles communication with mailchimp
+ * APIs in the same uniform manner.
+ */
+export default class MailchimpService {
+  /**
+   * Creates a new service instance.
+   * @param {String} baseUrl The base API endpoint.
+   */
+  constructor(baseUrl) {
+    this.private = { baseUrl };
+    const credentials = config.SECRET.MAILCHIMP.default;
+    this.mailchimpBaseUrl = credentials.MAILCHIMP_BASE_URL;
+    this.apiKey = credentials.API_KEY;
+    this.authorization = `Basic ${Buffer.from(`apikey:${this.apiKey}`).toString('base64')}`;
+  }
+
+  /**
+   * Gets data from the specified endpoint.
+   * @return {Promise}
+   * @param {Object} the request.
+   */
+  async checkSubscription(req) {
+    const res = await fetch(`${this.mailchimpBaseUrl}/lists/${req.params.listId}/members/${req.params.emailHash}`, {
+      method: 'GET',
+      headers: {
+        'Content-Type': req.headers['content-type'],
+        Authorization: this.authorization,
+      },
+    });
+    return res.json();
+  }
+
+  async doRegistMember(req) {
+    const formData = JSON.stringify(req.body);
+    const res = await fetch(`${this.mailchimpBaseUrl}/lists/${req.params.listId}/members`, {
+      method: 'POST',
+      headers: {
+        'Content-Type': req.headers['content-type'],
+        Authorization: this.authorization,
+      },
+      body: formData,
+    });
+    return res.json();
+  }
+
+  async updateMember(req) {
+    const formData = JSON.stringify(req.body);
+    const res = await fetch(`${this.mailchimpBaseUrl}/lists/${req.params.listId}/members/${req.params.emailHash}`, {
+      method: 'PUT',
+      headers: {
+        'Content-Type': req.headers['content-type'],
+        Authorization: this.authorization,
+      },
+      body: formData,
+    });
+    return res.json();
+  }
+
+  async subscribeTags(req) {
+    const formData = JSON.stringify(req.body);
+    const res = await fetch(`${this.mailchimpBaseUrl}/lists/${req.params.listId}/members/${req.params.emailHash}/tags`, {
+      method: 'POST',
+      headers: {
+        'Content-Type': req.headers['content-type'],
+        Authorization: this.authorization,
+      },
+      body: formData,
+    });
+    return { status: res.status };
+  }
+
+  /**
+   * Gets campaign-folders endpoint.
+   * @return {Promise}
+   * @param {Object} the request.
+   */
+  async getCampaignFolder(req) {
+    const res = await fetch(`${this.mailchimpBaseUrl}/campaign-folders?count=500`, {
+      method: 'GET',
+      headers: {
+        'Content-Type': req.headers['content-type'],
+        Authorization: this.authorization,
+      },
+    });
+    return res.json();
+  }
+
+  /**
+   * Gets campaigns endpoint.
+   * @return {Promise}
+   * @param {Object} the request.
+   */
+  async getCampaigns(req) {
+    const res = await fetch(`${this.mailchimpBaseUrl}/campaigns?${qs.stringify(req.query)}`, {
+      method: 'GET',
+      headers: {
+        'Content-Type': req.headers['content-type'],
+        Authorization: this.authorization,
+      },
+    });
+    return res.json();
+  }
+}