webtasks/webtask-mailchimp.js

const express = require('express')
const Webtask = require('webtask-tools')
const cors = require('cors')
const crypto = require('crypto')
const bodyParser = require('body-parser')
const request = require('request')

const server = express()

server.listen(4430)
server.use(bodyParser.json())

//
// Allow requests from these domains only
//
const corsOptions = {
    origin: ['https://oceanprotocol.com', /\.oceanprotocol\.com$/],
    optionsSuccessStatus: 200 // some legacy browsers (IE11, various SmartTVs) choke on 204
}

server.use(cors(corsOptions))

const baseUrl = 'https://us16.api.mailchimp.com/3.0'
const listId = '3c6eed8b71'

const md5 = data =>
    crypto
        .createHash('md5')
        .update(data)
        .digest('hex')

server.post('/newsletter/:email', (req, res) => {
    const { email } = req.params
    const { MAILCHIMP_API_KEY } = req.webtaskContext.secrets
    const emailDecoded = decodeURIComponent(email)
    const subscriberHash = md5(emailDecoded)

    const baseOptions = {
        url: `${baseUrl}/lists/${listId}/members/${subscriberHash}`,
        auth: {
            user: 'oceanprotocol',
            pass: MAILCHIMP_API_KEY
        }
    }

    const optionsCreate = {
        ...baseOptions,
        json: {
            email_address: emailDecoded,
            status: 'pending', // double opt-in
            merge_fields: {
                // our GDPR fallback
                GDPR: 'yes'
            }
        }
    }

    const optionsMarketing = marketingPermissionId => ({
        ...baseOptions,
        json: {
            marketing_permissions: [
                {
                    marketing_permission_id: marketingPermissionId,
                    text: 'Email',
                    enabled: true
                }
            ]
        }
    })

    const addMarketingPermissions = (data, cb) => {
        const marketingPermissionId =
            data.marketing_permissions[0].marketing_permission_id

        request.patch(
            optionsMarketing(marketingPermissionId),
            (error, response, body) => {
                if (error) res.send(error)

                return cb(body)
            }
        )
    }

    // Check if user exists first
    request.get(baseOptions, (error, response, body) => {
        if (error) res.send(error)

        const data = JSON.parse(body)

        // Member exists and is subscribed
        if (data.status === 'subscribed') {
            // Patch in native GDPR permissions
            addMarketingPermissions(data, () => {
                res.send('{ "status": "exists" }')
            })
        } else {
            // Create user
            request.put(optionsCreate, (error2, response, body2) => {
                if (error2) res.send(error2)

                if (Number.isInteger(body2.status)) {
                    res.send(body2)
                }

                // Patch in native GDPR permissions
                addMarketingPermissions(body2, () => {
                    res.send('{ "status": "created" }')
                })
            })
        }
    })
})

module.exports = Webtask.fromExpress(server)