Skip to content

Instantly share code, notes, and snippets.

@cweems

cweems/salesforce.js

Created May 15, 2019 23:11
Show Gist options
  • Save cweems/3f9867809e12080b7323915a96696c89 to your computer and use it in GitHub Desktop.
Save cweems/3f9867809e12080b7323915a96696c89 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. cweems created this gist May 15, 2019.
    181 changes: 181 additions & 0 deletions salesforce.js
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,181 @@
    exports.handler = function(context, event, callback) {

    //================================================================================
    // Modules
    //================================================================================

    var querystring = require('querystring');
    var request = require('request');

    //================================================================================
    // Context Variables
    //================================================================================

    // Are we using a sandbox or not
    var isSandbox = (context.SF_IS_SANDBOX == 'true');

    //Consumer Key from Salesforce Connected app
    var clientId = context.SF_CONSUMER_KEY;

    //Consumer Secrect from Salesforce Connected app
    var clientSecret = context.SF_CONSUMER_SECRET;

    //The salesforce username;
    var sfUserName = context.SF_USERNAME;

    //The salesforce password
    var sfPassword = context.SF_PASSWORD;

    //The salesforce user token
    var sfToken = context.SF_TOKEN;

    //================================================================================
    // End Context Variables
    //================================================================================


    // Use namespace is to tell the code to apply the package namespace or not.
    // The default should be true. If you are getting the requested resource
    // does not exist then try setting value to false.
    var useNameSpace = true;

    //The salesforce managed package namespace
    var nameSpace = 'TwilioSF__';

    //The login url
    var salesforceUrl = 'https://login.salesforce.com';

    if(isSandbox === true) {
    salesforceUrl = 'https://test.salesforce.com';
    }

    run();

    /**
    * Attempts to login with password
    * and then posts platform event
    */
    function run(){
    var form = {
    grant_type: 'password',
    client_id: clientId,
    client_secret: clientSecret,
    username: sfUserName,
    password:sfPassword+sfToken
    };

    var formData = querystring.stringify(form);
    var contentLength = formData.length;

    request({
    headers: {
    'Content-Length': contentLength,
    'Content-Type': 'application/x-www-form-urlencoded'
    },
    uri: salesforceUrl +'/services/oauth2/token',
    body: formData,
    method: 'POST'
    }, function (err, res, body) {
    if(res.statusCode == 200){
    console.log('Success Getting Token');
    var sfAuthReponse = JSON.parse(body);
    var platformEvent = buildPlatformEvent(event);
    postPlatformEvent(sfAuthReponse,platformEvent);
    } else{
    finishWithError('Error Getting Token:'+body);
    }
    });
    }

    /**
    * Posts Platform Event To Salesforce
    * @param sfAuthReponse
    * @param platformEvent
    */
    function postPlatformEvent(sfAuthReponse,platformEvent){

    console.log('Posting Platform Event:',platformEvent);

    var options = {
    uri: sfAuthReponse.instance_url + getPlatformEventUrl(),
    headers: {
    'Authorization': 'Bearer ' + sfAuthReponse.access_token,
    },
    body: platformEvent,
    json:true,
    method: 'POST'
    };

    request(options, processEventResponse);
    }

    /**
    * Processes Platform Event Response
    * @param error
    * @param response
    * @param body
    */
    function processEventResponse(error, response, body) {
    if (!error && response.statusCode == 201) {
    console.log('Success Posting Platform Event: Server responded with:', body);
    finishSuccess();
    } else{
    console.error('Error Posting Platform Event:', body);
    finishWithError('Error Posting Platform Event:'+body);
    }

    }

    /**
    * Builds the platform event request
    * @param event
    */
    function buildPlatformEvent(event){
    //Object map that maps Twilio Field to Salesforce Field
    var eventToPEMap = {
    "Body":"Body__c",
    "To":"To__c",
    "From":"From__c",
    "AccountSid":"AccountSid__c",
    "SmsSid":"MessageSid__c",
    "MessagingServiceSid":"MessagingServiceSid__c",
    "SmsStatus":"SmsStatus__c",
    "ErrorCode":"ErrorCode__c"
    };

    var platformEvent = {};

    //Loop through event and build platform event
    for (var property in event) {
    if (eventToPEMap.hasOwnProperty(property)) {
    var eventProp;
    if(useNameSpace){
    eventProp = nameSpace + eventToPEMap[property];
    } else{
    eventProp = eventToPEMap[property];
    }
    platformEvent[eventProp] = event[property];
    }
    }
    return platformEvent;
    }

    /**
    * Gets the Salesforce services url for the platform event
    * @returns {string}
    */
    function getPlatformEventUrl(){
    if(useNameSpace){
    return '/services/data/v43.0/sobjects/' + nameSpace + 'Twilio_Message_Status__e';
    } else{
    return '/services/data/v43.0/sobjects/Twilio_Message_Status__e';
    }
    }

    function finishSuccess(body){
    callback();
    }
    function finishWithError(body){
    callback(body);
    }
    };