Merge pull request #2 from ttntm/feature/cso

feature: createSalesforceObject()

README.md

@@ -82,6 +82,19 @@ Helper function for log row generation.
 
 _Object_
 
+## [createSalesforceObject](./src/createSalesforceObject.js)
+
+Used to update a record in an SF CRM object.
+
+### Params
+
+- `type`: _string_ - SF CRM object API name, i.e. "Contact", "ema_CustomObject__c"
+- `props`: _object_ - An object containing the new record's fields and values
+
+### Returns
+
+_Object | `undefined`_
+
 ## [deleteDataExtRow](./src/deleteDataExtRow.js)
 
 This function deletes a row in an SFMC data extension. 

include.txt

@@ -1,4 +1,5 @@
 ./src/createLogRow.js
+./src/createSalesforceObject.js
 ./src/deleteDataExtRow.js
 ./src/getAllRows.js
 ./src/getRowData.js

src/createSalesforceObject.js

@@ -0,0 +1,34 @@
+/**
+ * Create a record in an SF CRM object
+ * @param {string} type SF CRM object API name, i.e. 'Contact', 'ema_CustomObject__c'
+ * @param {object} props An object containing the new record's fields and values
+ * @returns {object | undefined}
+ */
+function createSalesforceObject(type, props) {
+  if (!props || !type) {
+    return undefined
+  }
+
+  var fieldsCount = 0
+  var recordData = []
+
+  for (var key in props) {
+    fieldsCount++
+    recordData.push(key)
+    recordData.push(props[key])
+  }
+
+  var createSFObject = "";
+    createSFObject += "\%\%[";
+    createSFObject += "set @SFCreate = CreateSalesforceObject('" + type + "',";
+    createSFObject += fieldsCount + ",'" + recordData.join("','") + "'";
+    createSFObject += ")";
+    createSFObject += "output(concat(@SFCreate))";
+    createSFObject += "]\%\%";
+
+  var execCreate = Platform.Function.TreatAsContent(createSFObject)
+
+  return execCreate && typeof execCreate === 'string' && execCreate.length === 18
+    ? { id: execCreate }
+    : { error: 'Error creating SF record' }
+}

src/updateSalesforceObject.js

@@ -21,13 +21,13 @@ function updateSalesforceObject(type, sfObjId, props) {
     updateSFObject += "\%\%[";
     updateSFObject += "set @SFUpdateResults = UpdateSingleSalesforceObject('" + type + "',";
     updateSFObject += "'" + sfObjId + "','" + updateData.join("','") + "'";
-    updateSFObject += ") ";
+    updateSFObject += ")";
     updateSFObject += "output(concat(@SFUpdateResults))";
     updateSFObject += "]\%\%";
 
   var execUpdate = Platform.Function.TreatAsContent(updateSFObject)
 
   return Number(execUpdate) > 0
     ? { success: type + ' updated' }
-    : { error: 'Error updating SF object' }
+    : { error: 'Error updating SF record' }
 }

utils_full.js

@@ -59,6 +59,41 @@ function sfmcUtils() {
     }
   }
 
+  /**
+   * Create a record in an SF CRM object
+   * @param {string} type SF CRM object API name, i.e. 'Contact', 'ema_CustomObject__c'
+   * @param {object} props An object containing the new record's fields and values
+   * @returns {object | undefined}
+   */
+  function createSalesforceObject(type, props) {
+    if (!props || !type) {
+      return undefined
+    }
+
+    var fieldsCount = 0
+    var recordData = []
+
+    for (var key in props) {
+      fieldsCount++
+      recordData.push(key)
+      recordData.push(props[key])
+    }
+
+    var createSFObject = "";
+    createSFObject += "\%\%[";
+    createSFObject += "set @SFCreate = CreateSalesforceObject('" + type + "',";
+    createSFObject += fieldsCount + ",'" + recordData.join("','") + "'";
+    createSFObject += ")";
+    createSFObject += "output(concat(@SFCreate))";
+    createSFObject += "]\%\%";
+
+    var execCreate = Platform.Function.TreatAsContent(createSFObject)
+
+    return execCreate && typeof execCreate === 'string' && execCreate.length === 18
+      ? { id: execCreate }
+      : { error: 'Error creating SF record' }
+  }
+
   /**
    * Delete a row in an SFMC data extension
    * @param {string} ext Data extensions external key
@@ -399,15 +434,15 @@ function sfmcUtils() {
     updateSFObject += "\%\%[";
     updateSFObject += "set @SFUpdateResults = UpdateSingleSalesforceObject('" + type + "',";
     updateSFObject += "'" + sfObjId + "','" + updateData.join("','") + "'";
-    updateSFObject += ") ";
+    updateSFObject += ")";
     updateSFObject += "output(concat(@SFUpdateResults))";
     updateSFObject += "]\%\%";
 
     var execUpdate = Platform.Function.TreatAsContent(updateSFObject)
 
     return Number(execUpdate) > 0
       ? { success: type + ' updated' }
-      : { error: 'Error updating SF object' }
+      : { error: 'Error updating SF record' }
   }
 
   /**
@@ -536,6 +571,7 @@ function sfmcUtils() {
 
   return {
     createLogRow: createLogRow
+    , createSalesforceObject: createSalesforceObject
     , deleteDataExtRow: deleteDataExtRow
     , getAllRows: getAllRows
     , getRowData: getRowData