Debugging Custom Code in Hubspot Workflows

				
					const hubspot = require('@hubspot/api-client');
const https = require('follow-redirects').https;

exports.main = (event, callback) => {

    // Secrets can be accessed via environment variables.
    // Make sure to add your HAPIKEY under "Secrets" above.
    const hubspotClient = new hubspot.Client({
        apiKey: process.env.HAPIKEY
    });

    // First, we need to find the contact that's associated with this entity
    let currentContactID = event.object.objectId;

    console.log("******* Current contact ID is: " + currentContactID);

    fetchContactByObjectId(hubspotClient, currentContactID).then(currentContact => {

        let currentContactsEmail = currentContact.properties.email;

        console.log("****** Contact email for current contact: " + currentContactsEmail);

        unsubscribeInDotdigital(currentContactsEmail).then(unsubscribeResponse => {

            callback({
                outputFields: {
                    results: JSON.stringify(unsubscribeResponse)
                }
            });



        });


    });

}

function fetchContactByObjectId(hubspotClient, contactId) {
    console.log("ENTERING: fetchContactByObjectId");

    return new Promise(function (resolve, reject) {
        // Get associated contacts for the current deal
        hubspotClient.crm.contacts.basicApi.getById(contactId)
            .then(results => {
                resolve(results.body);
            })
            .catch(err => {
                console.error("***** Got an exception while attempting to load current contact: " + err.message);
                reject(err);
            });
    });

}


function unsubscribeInDotdigital(emailToUnsubscribe) {
    console.log("ENTERING: unsubscribeInDotdigital");

    return new Promise(function (resolve, reject) {

        let options = {
            'method': 'POST',
            'hostname': 'r2-api.dotmailer.com',
            'path': '/v2/contacts/unsubscribe',
            'headers': {
                'Content-Type': 'application/json',
                'Authorization' : 'Basic ' + process.env.DOTDIGITAL_CREDS_BASE64
            },
            'maxRedirects': 20
        };
        let req = https.request(options, function (res) {
            let chunks = [];
            res.on("data", function (chunk) {
                chunks.push(chunk);
            });
            res.on("end", function (chunk) {
                let body = Buffer.concat(chunks);
                console.log("****** Made API call to merge. Resulting body: " + body.toString());
                resolve(body);
            });
            res.on("error", function (error) {
                console.error(error);
                reject(error);
            });
        });

        let postData = JSON.stringify({
            "email": emailToUnsubscribe
        });
        req.write(postData);
        req.end();

    });

}