MinnPost / object-sync-for-salesforce

classes/salesforce_push.php

Spacing +292 added lines, -292 removed lines

@@ -5,7 +5,7 @@ 
  * @file
  */
 
-if ( ! class_exists( 'Object_Sync_Salesforce' ) ) {
+if ( ! class_exists('Object_Sync_Salesforce')) {
 	die();
 }
 
@@ -42,7 +42,7 @@ 
 	* @param array $schedulable_classes
 	* @throws \Object_Sync_Sf_Exception
 	*/
-	public function __construct( $wpdb, $version, $login_credentials, $slug, $wordpress, $salesforce, $mappings, $logging, $schedulable_classes ) {
+	public function __construct($wpdb, $version, $login_credentials, $slug, $wordpress, $salesforce, $mappings, $logging, $schedulable_classes) {
 		$this->wpdb                = $wpdb;
 		$this->version             = $version;
 		$this->login_credentials   = $login_credentials;
@@ -57,7 +57,7 @@ 
 		$this->schedule      = $this->schedule();
 		$this->add_actions();
 
-		$this->debug = get_option( 'object_sync_for_salesforce_debug_mode', false );
+		$this->debug = get_option('object_sync_for_salesforce_debug_mode', false);
 
 	}
 
@@ -67,31 +67,31 @@ 
 	*
 	*/
 	private function add_actions() {
-		$db_version = get_option( 'object_sync_for_salesforce_db_version', false );
-		if ( $db_version === $this->version ) {
-			foreach ( $this->mappings->get_fieldmaps() as $mapping ) {
+		$db_version = get_option('object_sync_for_salesforce_db_version', false);
+		if ($db_version === $this->version) {
+			foreach ($this->mappings->get_fieldmaps() as $mapping) {
 				$object_type = $mapping['wordpress_object'];
-				if ( 'user' === $object_type ) {
-					add_action( 'user_register', array( $this, 'add_user' ), 11, 1 );
-					add_action( 'profile_update', array( $this, 'edit_user' ), 11, 2 );
-					add_action( 'delete_user', array( $this, 'delete_user' ) );
-				} elseif ( 'post' === $object_type ) {
-					add_action( 'save_post', array( $this, 'post_actions' ), 11, 2 );
-				} elseif ( 'attachment' === $object_type ) {
-					add_action( 'add_attachment', array( $this, 'add_attachment' ) );
-					add_action( 'edit_attachment', array( $this, 'edit_attachment' ) );
-					add_action( 'delete_attachment', array( $this, 'delete_attachment' ) );
-				} elseif ( 'category' === $object_type || 'tag' === $object_type || 'post_tag' === $object_type ) {
-					add_action( 'create_term', array( $this, 'add_term' ), 11, 3 );
-					add_action( 'edit_terms', array( $this, 'edit_term' ), 11, 2 );
-					add_action( 'delete_term', array( $this, 'delete_term' ), 10, 4 );
-				} elseif ( 'comment' === $object_type ) {
-					add_action( 'comment_post', array( $this, 'add_comment' ), 11, 3 );
-					add_action( 'edit_comment', array( $this, 'edit_comment' ) );
-					add_action( 'delete_comment', array( $this, 'delete_comment' ) ); // to be clear: this only runs when the comment gets deleted from the trash, either manually or automatically
+				if ('user' === $object_type) {
+					add_action('user_register', array($this, 'add_user'), 11, 1);
+					add_action('profile_update', array($this, 'edit_user'), 11, 2);
+					add_action('delete_user', array($this, 'delete_user'));
+				} elseif ('post' === $object_type) {
+					add_action('save_post', array($this, 'post_actions'), 11, 2);
+				} elseif ('attachment' === $object_type) {
+					add_action('add_attachment', array($this, 'add_attachment'));
+					add_action('edit_attachment', array($this, 'edit_attachment'));
+					add_action('delete_attachment', array($this, 'delete_attachment'));
+				} elseif ('category' === $object_type || 'tag' === $object_type || 'post_tag' === $object_type) {
+					add_action('create_term', array($this, 'add_term'), 11, 3);
+					add_action('edit_terms', array($this, 'edit_term'), 11, 2);
+					add_action('delete_term', array($this, 'delete_term'), 10, 4);
+				} elseif ('comment' === $object_type) {
+					add_action('comment_post', array($this, 'add_comment'), 11, 3);
+					add_action('edit_comment', array($this, 'edit_comment'));
+					add_action('delete_comment', array($this, 'delete_comment')); // to be clear: this only runs when the comment gets deleted from the trash, either manually or automatically
 				} else { // this is for custom post types
 					// we still have to use save_post because save_post_type fails to pull in the metadata
-					add_action( 'save_post', array( $this, 'post_actions' ), 11, 2 );
+					add_action('save_post', array($this, 'post_actions'), 11, 2);
 				}
 			}
 		}
@@ -104,8 +104,8 @@ 
 	* @param string $type
 	*
 	*/
-	public function manual_object_update( $object, $type ) {
-		$this->salesforce_push_object_crud( $type, $object, $this->mappings->sync_wordpress_update, true );
+	public function manual_object_update($object, $type) {
+		$this->salesforce_push_object_crud($type, $object, $this->mappings->sync_wordpress_update, true);
 	}
 
 	/**
@@ -113,9 +113,9 @@ 
 	*
 	* @param string $user_id
 	*/
-	public function add_user( $user_id ) {
-		$user = $this->wordpress->get_wordpress_object_data( 'user', $user_id );
-		$this->object_insert( $user, 'user' );
+	public function add_user($user_id) {
+		$user = $this->wordpress->get_wordpress_object_data('user', $user_id);
+		$this->object_insert($user, 'user');
 	}
 
 	/**
@@ -124,9 +124,9 @@ 
 	* @param string $user_id
 	* @param object $old_user_data
 	*/
-	public function edit_user( $user_id, $old_user_data ) {
-		$user = $this->wordpress->get_wordpress_object_data( 'user', $user_id );
-		$this->object_update( $user, 'user' );
+	public function edit_user($user_id, $old_user_data) {
+		$user = $this->wordpress->get_wordpress_object_data('user', $user_id);
+		$this->object_update($user, 'user');
 	}
 
 	/**
@@ -134,9 +134,9 @@ 
 	*
 	* @param string $user_id
 	*/
-	public function delete_user( $user_id ) {
-		$user = $this->wordpress->get_wordpress_object_data( 'user', $user_id );
-		$this->object_delete( $user, 'user' );
+	public function delete_user($user_id) {
+		$user = $this->wordpress->get_wordpress_object_data('user', $user_id);
+		$this->object_delete($user, 'user');
 	}
 
 	/**
@@ -146,48 +146,48 @@ 
 	* @param string $post_id
 	* @param object $post
 	*/
-	public function post_actions( $post_id, $post ) {
+	public function post_actions($post_id, $post) {
 
 		$post_type = $post->post_type;
 
-		if ( isset( $post->post_status ) && 'auto-draft' === $post->post_status ) {
+		if (isset($post->post_status) && 'auto-draft' === $post->post_status) {
 			return;
 		}
 		// this plugin does not sync log or revision posts with salesforce
-		if ( isset( $post->post_type ) && in_array( $post->post_type, array( 'wp_log', 'revision' ), true ) ) {
+		if (isset($post->post_type) && in_array($post->post_type, array('wp_log', 'revision'), true)) {
 			return;
 		}
-		if ( $post->post_modified_gmt === $post->post_date_gmt && 'trash' !== $post->post_status ) {
+		if ($post->post_modified_gmt === $post->post_date_gmt && 'trash' !== $post->post_status) {
 			$update = 0;
 			$delete = 0;
-		} elseif ( 'trash' !== $post->post_status ) {
+		} elseif ('trash' !== $post->post_status) {
 			$update = 1;
 			$delete = 0;
-		} elseif ( 'trash' === $post->post_status ) {
+		} elseif ('trash' === $post->post_status) {
 			$update = 0;
 			$delete = 1;
 		}
 
 		// add support for woocommerce if it is installed
-		if ( defined( 'WC_VERSION' ) ) {
+		if (defined('WC_VERSION')) {
 			// statuses to ignore
-			if ( isset( $post->post_status ) && in_array( $post->post_status, array( 'wc-pending' ), true ) ) {
+			if (isset($post->post_status) && in_array($post->post_status, array('wc-pending'), true)) {
 				return;
 			}
 			// statuses to count as new. note that the api will also check to see if it already has been mapped before saving.
-			if ( isset( $post->post_status ) && in_array( $post->post_status, array( 'wc-on-hold', 'wc-processing' ), true ) ) {
+			if (isset($post->post_status) && in_array($post->post_status, array('wc-on-hold', 'wc-processing'), true)) {
 				$update = 0;
 				$delete = 0;
 			}
 		}
 
-		$post = $this->wordpress->get_wordpress_object_data( $post->post_type, $post_id );
-		if ( 1 === $update ) {
-			$this->object_update( $post, $post_type );
-		} elseif ( 1 === $delete ) {
-			$this->object_delete( $post, $post_type );
+		$post = $this->wordpress->get_wordpress_object_data($post->post_type, $post_id);
+		if (1 === $update) {
+			$this->object_update($post, $post_type);
+		} elseif (1 === $delete) {
+			$this->object_delete($post, $post_type);
 		} else {
-			$this->object_insert( $post, $post_type );
+			$this->object_insert($post, $post_type);
 		}
 	}
 
@@ -196,9 +196,9 @@ 
 	*
 	* @param string $post_id
 	*/
-	public function add_attachment( $post_id ) {
-		$attachment = $this->wordpress->get_wordpress_object_data( 'attachment', $post_id );
-		$this->object_insert( $attachment, 'attachment' );
+	public function add_attachment($post_id) {
+		$attachment = $this->wordpress->get_wordpress_object_data('attachment', $post_id);
+		$this->object_insert($attachment, 'attachment');
 	}
 
 	/**
@@ -206,9 +206,9 @@ 
 	*
 	* @param string $post_id
 	*/
-	public function edit_attachment( $post_id ) {
-		$attachment = $this->wordpress->get_wordpress_object_data( 'attachment', $post_id );
-		$this->object_update( $attachment, 'attachment' );
+	public function edit_attachment($post_id) {
+		$attachment = $this->wordpress->get_wordpress_object_data('attachment', $post_id);
+		$this->object_update($attachment, 'attachment');
 	}
 
 	/**
@@ -216,9 +216,9 @@ 
 	*
 	* @param string $post_id
 	*/
-	public function delete_attachment( $post_id ) {
-		$attachment = $this->wordpress->get_wordpress_object_data( 'attachment', $post_id );
-		$this->object_delete( $attachment, 'attachment' );
+	public function delete_attachment($post_id) {
+		$attachment = $this->wordpress->get_wordpress_object_data('attachment', $post_id);
+		$this->object_delete($attachment, 'attachment');
 	}
 
 	/**
@@ -228,9 +228,9 @@ 
 	* @param string $tt_id
 	* @param string $taxonomy
 	*/
-	public function add_term( $term_id, $tt_id, $taxonomy ) {
-		$term = $this->wordpress->get_wordpress_object_data( $taxonomy, $term_id );
-		$this->object_insert( $term, $taxonomy );
+	public function add_term($term_id, $tt_id, $taxonomy) {
+		$term = $this->wordpress->get_wordpress_object_data($taxonomy, $term_id);
+		$this->object_insert($term, $taxonomy);
 	}
 
 	/**
@@ -239,9 +239,9 @@ 
 	* @param string $term_id
 	* @param string $taxonomy
 	*/
-	public function edit_term( $term_id, $taxonomy ) {
-		$term = $this->wordpress->get_wordpress_object_data( $taxonomy, $term_id );
-		$this->object_update( $term, $taxonomy );
+	public function edit_term($term_id, $taxonomy) {
+		$term = $this->wordpress->get_wordpress_object_data($taxonomy, $term_id);
+		$this->object_update($term, $taxonomy);
 	}
 
 	/**
@@ -252,10 +252,10 @@ 
 	* @param string $taxonomy (slug)
 	* @param object $deleted_term
 	*/
-	public function delete_term( $term, $tt_id, $taxonomy, $deleted_term ) {
+	public function delete_term($term, $tt_id, $taxonomy, $deleted_term) {
 		$deleted_term = (array) $deleted_term;
 		$type         = $deleted_term['taxonomy'];
-		$this->object_delete( $deleted_term, $type );
+		$this->object_delete($deleted_term, $type);
 	}
 
 	/**
@@ -265,9 +265,9 @@ 
 	* @param int|string comment_approved
 	* @param array $commentdata
 	*/
-	public function add_comment( $comment_id, $comment_approved, $commentdata = array() ) {
-		$comment = $this->wordpress->get_wordpress_object_data( 'comment', $comment_id );
-		$this->object_insert( $comment, 'comment' );
+	public function add_comment($comment_id, $comment_approved, $commentdata = array()) {
+		$comment = $this->wordpress->get_wordpress_object_data('comment', $comment_id);
+		$this->object_insert($comment, 'comment');
 	}
 
 	/**
@@ -275,9 +275,9 @@ 
 	*
 	* @param string $comment_id
 	*/
-	public function edit_comment( $comment_id ) {
-		$comment = $this->wordpress->get_wordpress_object_data( 'comment', $comment_id );
-		$this->object_update( $comment, 'comment' );
+	public function edit_comment($comment_id) {
+		$comment = $this->wordpress->get_wordpress_object_data('comment', $comment_id);
+		$this->object_update($comment, 'comment');
 	}
 
 	/**
@@ -285,33 +285,33 @@ 
 	*
 	* @param string $comment_id
 	*/
-	public function delete_comment( $comment_id ) {
-		$comment = $this->wordpress->get_wordpress_object_data( 'comment', $comment_id );
-		$this->object_delete( $comment, 'comment' );
+	public function delete_comment($comment_id) {
+		$comment = $this->wordpress->get_wordpress_object_data('comment', $comment_id);
+		$this->object_delete($comment, 'comment');
 	}
 
 	/**
 	* Insert a new object
 	* This calls the overall push crud method, which controls queuing and sending data to the Salesforce class
 	*/
-	private function object_insert( $object, $type ) {
-		$this->salesforce_push_object_crud( $type, $object, $this->mappings->sync_wordpress_create );
+	private function object_insert($object, $type) {
+		$this->salesforce_push_object_crud($type, $object, $this->mappings->sync_wordpress_create);
 	}
 
 	/**
 	* Update an existing object
 	* This calls the overall push crud method, which controls queuing and sending data to the Salesforce class
 	*/
-	private function object_update( $object, $type ) {
-		$this->salesforce_push_object_crud( $type, $object, $this->mappings->sync_wordpress_update );
+	private function object_update($object, $type) {
+		$this->salesforce_push_object_crud($type, $object, $this->mappings->sync_wordpress_update);
 	}
 
 	/**
 	* Delete an existing object
 	* This calls the overall push crud method, which controls queuing and sending data to the Salesforce class
 	*/
-	private function object_delete( $object, $type ) {
-		$this->salesforce_push_object_crud( $type, $object, $this->mappings->sync_wordpress_delete );
+	private function object_delete($object, $type) {
+		$this->salesforce_push_object_crud($type, $object, $this->mappings->sync_wordpress_delete);
 	}
 
 	/**
@@ -328,50 +328,50 @@ 
 	*   Are we calling this manually?
 	*
 	*/
-	private function salesforce_push_object_crud( $object_type, $object, $sf_sync_trigger, $manual = false ) {
+	private function salesforce_push_object_crud($object_type, $object, $sf_sync_trigger, $manual = false) {
 
-		$structure       = $this->wordpress->get_wordpress_table_structure( $object_type );
+		$structure       = $this->wordpress->get_wordpress_table_structure($object_type);
 		$object_id_field = $structure['id_field'];
 
 		// there is a WordPress object to push
-		if ( isset( $object[ $object_id_field ] ) ) {
-			$mapping_object = $this->mappings->load_by_wordpress( $object_type, $object[ $object_id_field ] );
+		if (isset($object[$object_id_field])) {
+			$mapping_object = $this->mappings->load_by_wordpress($object_type, $object[$object_id_field]);
 
 			// there is already a mapping object for this WordPress object
-			if ( isset( $mapping_object['id'] ) ) {
+			if (isset($mapping_object['id'])) {
 				$mapping_object_id_transient = $mapping_object['id'];
 			} else {
 				// there is not a mapping object for this WordPress object id yet
 				// check for that transient with the currently pulling id
-				$mapping_object_id_transient = (int) get_transient( 'salesforce_pulling_object_id' );
+				$mapping_object_id_transient = (int) get_transient('salesforce_pulling_object_id');
 			}
 
-			$salesforce_pulling = (int) get_transient( 'salesforce_pulling_' . $mapping_object_id_transient );
-			if ( 1 === $salesforce_pulling ) {
-				delete_transient( 'salesforce_pulling_' . $mapping_object_id_transient );
-				$pulling_id = get_transient( 'salesforce_pulling_object_id' );
-				if ( $pulling_id === $mapping_object_id_transient ) {
-					delete_transient( 'salesforce_pulling_object_id' );
+			$salesforce_pulling = (int) get_transient('salesforce_pulling_' . $mapping_object_id_transient);
+			if (1 === $salesforce_pulling) {
+				delete_transient('salesforce_pulling_' . $mapping_object_id_transient);
+				$pulling_id = get_transient('salesforce_pulling_object_id');
+				if ($pulling_id === $mapping_object_id_transient) {
+					delete_transient('salesforce_pulling_object_id');
 				}
 				return false;
 			}
 		} else {
 			// if we don't have a WordPress object id, we've got no business doing stuff in Salesforce
 			$status = 'error';
-			if ( isset( $this->logging ) ) {
+			if (isset($this->logging)) {
 				$logging = $this->logging;
-			} elseif ( class_exists( 'Object_Sync_Sf_Logging' ) ) {
-				$logging = new Object_Sync_Sf_Logging( $this->wpdb, $this->version );
+			} elseif (class_exists('Object_Sync_Sf_Logging')) {
+				$logging = new Object_Sync_Sf_Logging($this->wpdb, $this->version);
 			}
 
 			// translators: placeholder is the name of the WordPress id field
-			$title = sprintf( esc_html__( 'Error: Salesforce Push: unable to process queue item because it has no WordPress %1$s.', 'object-sync-for-salesforce' ),
-				esc_attr( $object_id_field )
+			$title = sprintf(esc_html__('Error: Salesforce Push: unable to process queue item because it has no WordPress %1$s.', 'object-sync-for-salesforce'),
+				esc_attr($object_id_field)
 			);
 
 			$logging->setup(
 				$title,
-				print_r( $object, true ), // print this array because if this happens, something weird has happened and we want to log whatever we have
+				print_r($object, true), // print this array because if this happens, something weird has happened and we want to log whatever we have
 				$sf_sync_trigger,
 				0, // parent id goes here but we don't have one, so make it 0
 				$status
@@ -388,14 +388,14 @@ 
 			)
 		);
 
-		foreach ( $sf_mappings as $mapping ) { // for each mapping of this object
+		foreach ($sf_mappings as $mapping) { // for each mapping of this object
 			$map_sync_triggers = $mapping['sync_triggers'];
 
 			// these are bit operators, so we leave out the strict
-			if ( isset( $map_sync_triggers ) && isset( $sf_sync_trigger ) && in_array( $sf_sync_trigger, $map_sync_triggers ) ) { // wp or sf crud event
+			if (isset($map_sync_triggers) && isset($sf_sync_trigger) && in_array($sf_sync_trigger, $map_sync_triggers)) { // wp or sf crud event
 
 				// hook to allow other plugins to prevent a push per-mapping.
-				$push_allowed = apply_filters( 'object_sync_for_salesforce_push_object_allowed', true, $object_type, $object, $sf_sync_trigger, $mapping );
+				$push_allowed = apply_filters('object_sync_for_salesforce_push_object_allowed', true, $object_type, $object, $sf_sync_trigger, $mapping);
 
 				// example to keep from pushing the user with id of 1
 				/*
@@ -408,17 +408,17 @@ 
 				}
 				*/
 
-				if ( false === $push_allowed ) {
+				if (false === $push_allowed) {
 					continue;
 				}
 
 				// push drafts if the setting says so
 				// post status is draft, or post status is inherit and post type is not attachment
-				if ( ( ! isset( $mapping['push_drafts'] ) || '1' !== $mapping['push_drafts'] ) && isset( $object['post_status'] ) && ( 'draft' === $object['post_status'] || ( 'inherit' === $object['post_status'] && 'attachment' !== $object['post_type'] ) ) ) {
+				if (( ! isset($mapping['push_drafts']) || '1' !== $mapping['push_drafts']) && isset($object['post_status']) && ('draft' === $object['post_status'] || ('inherit' === $object['post_status'] && 'attachment' !== $object['post_type']))) {
 					// skip this object if it is a draft and the fieldmap settings told us to ignore it
 					continue;
 				}
-				if ( isset( $mapping['push_async'] ) && ( '1' === $mapping['push_async'] ) && false === $manual ) {
+				if (isset($mapping['push_async']) && ('1' === $mapping['push_async']) && false === $manual) {
 					// this item is async and we want to save it to the queue
 					$data = array(
 						'object_type'     => $object_type,
@@ -429,24 +429,24 @@ 
 
 					// create new schedule based on the options for this current class
 					// this will use the existing schedule if it already exists; otherwise it'll create one
-					$this->schedule->use_schedule( $this->schedule_name );
-					$this->schedule->push_to_queue( $data );
+					$this->schedule->use_schedule($this->schedule_name);
+					$this->schedule->push_to_queue($data);
 					$this->schedule->save()->dispatch();
 
 				} else {
 					// this one is not async. do it immediately.
-					$push = $this->salesforce_push_sync_rest( $object_type, $object, $mapping, $sf_sync_trigger );
+					$push = $this->salesforce_push_sync_rest($object_type, $object, $mapping, $sf_sync_trigger);
 				} // End if().
 			} // End if(). if the trigger does not match our requirements, skip it
 		} // End foreach().
 	}
 
 	private function schedule() {
-		if ( ! class_exists( 'Object_Sync_Sf_Schedule' ) && file_exists( plugin_dir_path( __FILE__ ) . '../vendor/autoload.php' ) ) {
-			require_once plugin_dir_path( __FILE__ ) . '../vendor/autoload.php';
-			require_once plugin_dir_path( __FILE__ ) . '../classes/schedule.php';
+		if ( ! class_exists('Object_Sync_Sf_Schedule') && file_exists(plugin_dir_path(__FILE__) . '../vendor/autoload.php')) {
+			require_once plugin_dir_path(__FILE__) . '../vendor/autoload.php';
+			require_once plugin_dir_path(__FILE__) . '../classes/schedule.php';
 		}
-		$schedule       = new Object_Sync_Sf_Schedule( $this->wpdb, $this->version, $this->login_credentials, $this->slug, $this->wordpress, $this->salesforce, $this->mappings, $this->schedule_name, $this->logging, $this->schedulable_classes );
+		$schedule       = new Object_Sync_Sf_Schedule($this->wpdb, $this->version, $this->login_credentials, $this->slug, $this->wordpress, $this->salesforce, $this->mappings, $this->schedule_name, $this->logging, $this->schedulable_classes);
 		$this->schedule = $schedule;
 		return $schedule;
 	}
@@ -466,25 +466,25 @@ 
 	* @return true or exit the method
 	*
 	*/
-	public function salesforce_push_sync_rest( $object_type, $object, $mapping, $sf_sync_trigger ) {
+	public function salesforce_push_sync_rest($object_type, $object, $mapping, $sf_sync_trigger) {
 
 		// If Salesforce is not authorized, don't do anything.
 		// it's unclear to me if we need to do something else here or if this is sufficient. This is all Drupal does.
-		if ( true !== $this->salesforce['is_authorized'] ) {
+		if (true !== $this->salesforce['is_authorized']) {
 			return;
 		}
 
 		$sfapi = $this->salesforce['sfapi'];
 
 		// we need to get the WordPress id here so we can check to see if the object already has a map
-		$structure = $this->wordpress->get_wordpress_table_structure( $object_type );
+		$structure = $this->wordpress->get_wordpress_table_structure($object_type);
 		$object_id = $structure['id_field'];
 
 		// this returns the row that maps the individual WordPress row to the individual Salesfoce row
-		$mapping_object = $this->mappings->load_by_wordpress( $object_type, $object[ "$object_id" ] );
+		$mapping_object = $this->mappings->load_by_wordpress($object_type, $object["$object_id"]);
 
 		// hook to allow other plugins to define or alter the mapping object
-		$mapping_object = apply_filters( 'object_sync_for_salesforce_push_mapping_object', $mapping_object, $object, $mapping );
+		$mapping_object = apply_filters('object_sync_for_salesforce_push_mapping_object', $mapping_object, $object, $mapping);
 
 		// we already have the data from WordPress at this point; we just need to work with it in Salesforce
 		$synced_object = array(
@@ -498,84 +498,84 @@ 
 
 		// deleting mapped objects
 		// these are bit operators, so we leave out the strict
-		if ( $sf_sync_trigger == $this->mappings->sync_wordpress_delete ) {
-			if ( isset( $mapping_object['id'] ) ) {
+		if ($sf_sync_trigger == $this->mappings->sync_wordpress_delete) {
+			if (isset($mapping_object['id'])) {
 				$op = 'Delete';
 
-				$salesforce_check = $this->mappings->load_by_salesforce( $mapping_object['salesforce_id'] );
+				$salesforce_check = $this->mappings->load_by_salesforce($mapping_object['salesforce_id']);
 
-				if ( count( $salesforce_check ) === count( $salesforce_check, COUNT_RECURSIVE ) ) {
+				if (count($salesforce_check) === count($salesforce_check, COUNT_RECURSIVE)) {
 					try {
-						$result = $sfapi->object_delete( $mapping['salesforce_object'], $mapping_object['salesforce_id'] );
-					} catch ( Object_Sync_Sf_Exception $e ) {
+						$result = $sfapi->object_delete($mapping['salesforce_object'], $mapping_object['salesforce_id']);
+					} catch (Object_Sync_Sf_Exception $e) {
 						$status = 'error';
 						// create log entry for failed delete
-						if ( isset( $this->logging ) ) {
+						if (isset($this->logging)) {
 							$logging = $this->logging;
-						} elseif ( class_exists( 'Object_Sync_Sf_Logging' ) ) {
-							$logging = new Object_Sync_Sf_Logging( $this->wpdb, $this->version );
+						} elseif (class_exists('Object_Sync_Sf_Logging')) {
+							$logging = new Object_Sync_Sf_Logging($this->wpdb, $this->version);
 						}
 
 						// translators: placeholders are: 1) what operation is happening, 2) the name of the Salesforce object, 3) the Salesforce Id value, 4) the name of the WordPress object type, 5) the WordPress id field name, 6) the WordPress object id value
-						$title = sprintf( esc_html__( 'Error: %1$s %2$s %3$s (WordPress %4$s with %5$s of %6$s)', 'object-sync-for-salesforce' ),
-							esc_attr( $op ),
-							esc_attr( $mapping['salesforce_object'] ),
-							esc_attr( $mapping_object['salesforce_id'] ),
-							esc_attr( $mapping['wordpress_object'] ),
-							esc_attr( $object_id ),
-							esc_attr( $object[ "$object_id" ] )
+						$title = sprintf(esc_html__('Error: %1$s %2$s %3$s (WordPress %4$s with %5$s of %6$s)', 'object-sync-for-salesforce'),
+							esc_attr($op),
+							esc_attr($mapping['salesforce_object']),
+							esc_attr($mapping_object['salesforce_id']),
+							esc_attr($mapping['wordpress_object']),
+							esc_attr($object_id),
+							esc_attr($object["$object_id"])
 						);
 
 						$logging->setup(
 							$title,
 							$e->getMessage(),
 							$sf_sync_trigger,
-							$object[ "$object_id" ],
+							$object["$object_id"],
 							$status
 						);
 
 						// hook for push fail
-						do_action( 'object_sync_for_salesforce_push_fail', $op, $sfapi->response, $synced_object, $object_id );
+						do_action('object_sync_for_salesforce_push_fail', $op, $sfapi->response, $synced_object, $object_id);
 
 					}
 
-					if ( ! isset( $e ) ) {
+					if ( ! isset($e)) {
 						// create log entry for successful delete if the result had no errors
 						$status = 'success';
-						if ( isset( $this->logging ) ) {
+						if (isset($this->logging)) {
 							$logging = $this->logging;
-						} elseif ( class_exists( 'Object_Sync_Sf_Logging' ) ) {
-							$logging = new Object_Sync_Sf_Logging( $this->wpdb, $this->version );
+						} elseif (class_exists('Object_Sync_Sf_Logging')) {
+							$logging = new Object_Sync_Sf_Logging($this->wpdb, $this->version);
 						}
 
 						// translators: placeholders are: 1) what operation is happening, 2) the name of the Salesforce object, 3) the Salesforce Id value, 4) the name of the WordPress object type, 5) the WordPress id field name, 6) the WordPress object id value
-						$title = sprintf( esc_html__( 'Success: %1$s %2$s %3$s (WordPress %4$s with %5$s of %6$s)', 'object-sync-for-salesforce' ),
-							esc_attr( $op ),
-							esc_attr( $mapping['salesforce_object'] ),
-							esc_attr( $mapping_object['salesforce_id'] ),
-							esc_attr( $mapping['wordpress_object'] ),
-							esc_attr( $object_id ),
-							esc_attr( $object[ "$object_id" ] )
+						$title = sprintf(esc_html__('Success: %1$s %2$s %3$s (WordPress %4$s with %5$s of %6$s)', 'object-sync-for-salesforce'),
+							esc_attr($op),
+							esc_attr($mapping['salesforce_object']),
+							esc_attr($mapping_object['salesforce_id']),
+							esc_attr($mapping['wordpress_object']),
+							esc_attr($object_id),
+							esc_attr($object["$object_id"])
 						);
 
 						$logging->setup(
 							$title,
 							'',
 							$sf_sync_trigger,
-							$object[ "$object_id" ],
+							$object["$object_id"],
 							$status
 						);
 
 						// hook for push success
-						do_action( 'object_sync_for_salesforce_push_success', $op, $sfapi->response, $synced_object, $object_id );
+						do_action('object_sync_for_salesforce_push_success', $op, $sfapi->response, $synced_object, $object_id);
 					}
 				} else {
 					$more_ids = '<p>The Salesforce record was not deleted because there are multiple WordPress IDs that match this Salesforce ID. They are: ';
 					$i        = 0;
-					foreach ( $salesforce_check as $match ) {
+					foreach ($salesforce_check as $match) {
 						$i++;
 						$more_ids .= $match['wordpress_id'];
-						if ( count( $salesforce_check ) !== $i ) {
+						if (count($salesforce_check) !== $i) {
 							$more_ids .= ', ';
 						} else {
 							$more_ids .= '.</p>';
@@ -585,34 +585,34 @@ 
 					$more_ids .= '<p>The map row between this WordPress object and the Salesforce object, as stored in the WordPress database, will be deleted, and this WordPress object has been deleted, but Salesforce will remain untouched.</p>';
 
 					$status = 'notice';
-					if ( isset( $this->logging ) ) {
+					if (isset($this->logging)) {
 						$logging = $this->logging;
-					} elseif ( class_exists( 'Object_Sync_Sf_Logging' ) ) {
-						$logging = new Object_Sync_Sf_Logging( $this->wpdb, $this->version );
+					} elseif (class_exists('Object_Sync_Sf_Logging')) {
+						$logging = new Object_Sync_Sf_Logging($this->wpdb, $this->version);
 					}
 
 					// translators: placeholders are: 1) what operation is happening, 2) the name of the Salesforce object, 3) the Salesforce Id value, 4) the name of the WordPress object type, 5) the WordPress id field name, 6) the WordPress object id value
-					$title = sprintf( esc_html__( 'Notice: %1$s %2$s %3$s (WordPress %4$s with %5$s of %6$s did not delete the Salesforce item.)', 'object-sync-for-salesforce' ),
-						esc_attr( $op ),
-						esc_attr( $mapping['salesforce_object'] ),
-						esc_attr( $mapping_object['salesforce_id'] ),
-						esc_attr( $mapping['wordpress_object'] ),
-						esc_attr( $object_id ),
-						esc_attr( $object[ "$object_id" ] )
+					$title = sprintf(esc_html__('Notice: %1$s %2$s %3$s (WordPress %4$s with %5$s of %6$s did not delete the Salesforce item.)', 'object-sync-for-salesforce'),
+						esc_attr($op),
+						esc_attr($mapping['salesforce_object']),
+						esc_attr($mapping_object['salesforce_id']),
+						esc_attr($mapping['wordpress_object']),
+						esc_attr($object_id),
+						esc_attr($object["$object_id"])
 					);
 
 					$logging->setup(
 						$title,
 						$more_ids,
 						$sf_sync_trigger,
-						$object[ "$object_id" ],
+						$object["$object_id"],
 						$status
 					);
 				} // End if().
 
 				// delete the map row from WordPress after the Salesforce row has been deleted
 				// we delete the map row even if the Salesforce delete failed, because the WordPress object is gone
-				$this->mappings->delete_object_map( $mapping_object['id'] );
+				$this->mappings->delete_object_map($mapping_object['id']);
 
 			} // End if(). there is no map row
 
@@ -620,51 +620,51 @@ 
 		} // End if().
 
 		// are these objects already connected in WordPress?
-		if ( isset( $mapping_object['id'] ) ) {
+		if (isset($mapping_object['id'])) {
 			$is_new = false;
 		} else {
 			$is_new = true;
 		}
 
 		// map the WordPress values to salesforce fields
-		$params = $this->mappings->map_params( $mapping, $object, $sf_sync_trigger, false, $is_new );
+		$params = $this->mappings->map_params($mapping, $object, $sf_sync_trigger, false, $is_new);
 
 		// hook to allow other plugins to modify the $params array
 		// use hook to map fields between the WordPress and Salesforce objects
 		// returns $params.
-		$params = apply_filters( 'object_sync_for_salesforce_push_params_modify', $params, $mapping, $object, $sf_sync_trigger, false, $is_new );
+		$params = apply_filters('object_sync_for_salesforce_push_params_modify', $params, $mapping, $object, $sf_sync_trigger, false, $is_new);
 
 		// if we don't get any params, there are no fields that should be sent to Salesforce
-		if ( empty( $params ) ) {
+		if (empty($params)) {
 			return;
 		}
 
 		// if there is a prematch WordPress field - ie email - on the fieldmap object
-		if ( isset( $params['prematch'] ) && is_array( $params['prematch'] ) ) {
+		if (isset($params['prematch']) && is_array($params['prematch'])) {
 			$prematch_field_wordpress  = $params['prematch']['wordpress_field'];
 			$prematch_field_salesforce = $params['prematch']['salesforce_field'];
 			$prematch_value            = $params['prematch']['value'];
-			unset( $params['prematch'] );
+			unset($params['prematch']);
 		}
 
 		// if there is an external key field in Salesforce - ie mailchimp user id - on the fieldmap object
-		if ( isset( $params['key'] ) && is_array( $params['key'] ) ) {
+		if (isset($params['key']) && is_array($params['key'])) {
 			$key_field_wordpress  = $params['key']['wordpress_field'];
 			$key_field_salesforce = $params['key']['salesforce_field'];
 			$key_value            = $params['key']['value'];
-			unset( $params['key'] );
+			unset($params['key']);
 		}
 
-		$seconds = $this->schedule->get_schedule_frequency_seconds( $this->schedule_name ) + 60;
+		$seconds = $this->schedule->get_schedule_frequency_seconds($this->schedule_name) + 60;
 
-		if ( true === $is_new ) {
+		if (true === $is_new) {
 
 			// right here we should set the pushing transient
 			// this means we have to create the mapping object here as well, and update it with the correct IDs after successful response
 			// create the mapping object between the rows
-			$mapping_object_id = $this->create_object_map( $object, $object_id, $this->mappings->generate_temporary_id( 'push' ), $mapping, true );
-			set_transient( 'salesforce_pushing_' . $mapping_object_id, 1, $seconds );
-			set_transient( 'salesforce_pushing_object_id', $mapping_object_id );
+			$mapping_object_id = $this->create_object_map($object, $object_id, $this->mappings->generate_temporary_id('push'), $mapping, true);
+			set_transient('salesforce_pushing_' . $mapping_object_id, 1, $seconds);
+			set_transient('salesforce_pushing_object_id', $mapping_object_id);
 			$mapping_object = $this->mappings->get_object_maps(
 				array(
 					'id' => $mapping_object_id,
@@ -673,7 +673,7 @@ 
 
 			// setup SF record type. CampaignMember objects get their Campaign's type
 			// i am still a bit confused about this
-			if ( $mapping['salesforce_record_type_default'] !== $this->mappings->salesforce_default_record_type && empty( $params['RecordTypeId'] ) && ( 'CampaignMember' !== $mapping['salesforce_object'] ) ) {
+			if ($mapping['salesforce_record_type_default'] !== $this->mappings->salesforce_default_record_type && empty($params['RecordTypeId']) && ('CampaignMember' !== $mapping['salesforce_object'])) {
 				$params['RecordTypeId'] = $mapping['salesforce_record_type_default'];
 			}
 
@@ -685,61 +685,61 @@ 
 				// returns a $salesforce_id.
 				// it should keep NULL if there is no match
 				// the function that calls this hook needs to check the mapping to make sure the WordPress object is the right type
-				$salesforce_id = apply_filters( 'object_sync_for_salesforce_find_sf_object_match', null, $object, $mapping, 'push' );
+				$salesforce_id = apply_filters('object_sync_for_salesforce_find_sf_object_match', null, $object, $mapping, 'push');
 
 				// hook to allow other plugins to do something right before Salesforce data is saved
 				// ex: run WordPress methods on an object if it exists, or do something in preparation for it if it doesn't
-				do_action( 'object_sync_for_salesforce_pre_push', $salesforce_id, $mapping, $object, $object_id, $params );
+				do_action('object_sync_for_salesforce_pre_push', $salesforce_id, $mapping, $object, $object_id, $params);
 
 				// hook to allow other plugins to change params on update actions only
 				// use hook to map fields between the WordPress and Salesforce objects
 				// returns $params.
-				$params = apply_filters( 'object_sync_for_salesforce_push_update_params_modify', $params, $salesforce_id, $mapping, $object );
+				$params = apply_filters('object_sync_for_salesforce_push_update_params_modify', $params, $salesforce_id, $mapping, $object);
 
-				if ( isset( $prematch_field_wordpress ) || isset( $key_field_wordpress ) || null !== $salesforce_id ) {
+				if (isset($prematch_field_wordpress) || isset($key_field_wordpress) || null !== $salesforce_id) {
 
 					// if either prematch criteria exists, make the values queryable
 
-					if ( isset( $prematch_field_wordpress ) ) {
+					if (isset($prematch_field_wordpress)) {
 						// a prematch has been specified, attempt an upsert().
 						// prematch values with punctuation need to be escaped
-						$encoded_prematch_value = rawurlencode( $prematch_value );
+						$encoded_prematch_value = rawurlencode($prematch_value);
 						// for at least 'email' fields, periods also need to be escaped:
 						// https://developer.salesforce.com/forums?id=906F000000099xPIAQ
-						$encoded_prematch_value = str_replace( '.', '%2E', $encoded_prematch_value );
+						$encoded_prematch_value = str_replace('.', '%2E', $encoded_prematch_value);
 					}
 
-					if ( isset( $key_field_wordpress ) ) {
+					if (isset($key_field_wordpress)) {
 						// an external key has been specified, attempt an upsert().
 						// external key values with punctuation need to be escaped
-						$encoded_key_value = rawurlencode( $key_value );
+						$encoded_key_value = rawurlencode($key_value);
 						// for at least 'email' fields, periods also need to be escaped:
 						// https://developer.salesforce.com/forums?id=906F000000099xPIAQ
-						$encoded_key_value = str_replace( '.', '%2E', $encoded_key_value );
+						$encoded_key_value = str_replace('.', '%2E', $encoded_key_value);
 					}
 
-					if ( isset( $prematch_field_wordpress ) ) {
+					if (isset($prematch_field_wordpress)) {
 						$upsert_key   = $prematch_field_salesforce;
 						$upsert_value = $encoded_prematch_value;
-					} elseif ( isset( $key_field_wordpress ) ) {
+					} elseif (isset($key_field_wordpress)) {
 						$upsert_key   = $key_field_salesforce;
 						$upsert_value = $encoded_key_value;
 					}
 
-					if ( null !== $salesforce_id ) {
+					if (null !== $salesforce_id) {
 						$upsert_key   = 'Id';
 						$upsert_value = $salesforce_id;
 					}
 
 					$op = 'Upsert';
 
-					$result = $sfapi->object_upsert( $mapping['salesforce_object'], $upsert_key, $upsert_value, $params );
+					$result = $sfapi->object_upsert($mapping['salesforce_object'], $upsert_key, $upsert_value, $params);
 
 					// Handle upsert responses.
-					switch ( $sfapi->response['code'] ) {
+					switch ($sfapi->response['code']) {
 						// On Upsert:update retrieved object.
 						case '204':
-							$sf_object             = $sfapi->object_readby_external_id( $mapping['salesforce_object'], $upsert_key, $upsert_value );
+							$sf_object             = $sfapi->object_readby_external_id($mapping['salesforce_object'], $upsert_key, $upsert_value);
 							$salesforce_data['id'] = $sf_object['data']['Id'];
 							break;
 						// Handle duplicate records.
@@ -750,43 +750,43 @@ 
 				} else {
 					// No key or prematch field exists on this field map object, create a new object in Salesforce.
 					$op     = 'Create';
-					$result = $sfapi->object_create( $mapping['salesforce_object'], $params );
+					$result = $sfapi->object_create($mapping['salesforce_object'], $params);
 				} // End if().
-			} catch ( Object_Sync_Sf_Exception $e ) {
+			} catch (Object_Sync_Sf_Exception $e) {
 				// create log entry for failed create or upsert
 				$status = 'error';
 
-				if ( isset( $this->logging ) ) {
+				if (isset($this->logging)) {
 					$logging = $this->logging;
-				} elseif ( class_exists( 'Object_Sync_Sf_Logging' ) ) {
-					$logging = new Object_Sync_Sf_Logging( $this->wpdb, $this->version );
+				} elseif (class_exists('Object_Sync_Sf_Logging')) {
+					$logging = new Object_Sync_Sf_Logging($this->wpdb, $this->version);
 				}
 
 				// translators: placeholders are: 1) what operation is happening, 2) the name of the Salesforce object, 3) the Salesforce Id value if there is one, 4) the name of the WordPress object type, 5) the WordPress id field name, 6) the WordPress object id value
-				$title = sprintf( esc_html__( 'Error: %1$s %2$s %3$s (WordPress %4$s with %5$s of %6$s)', 'object-sync-for-salesforce' ),
-					esc_attr( $op ),
-					esc_attr( $mapping['salesforce_object'] ),
-					isset( $salesforce_id ) ? ' ' . esc_attr( $salesforce_id ) : '',
-					esc_attr( $mapping['wordpress_object'] ),
-					esc_attr( $object_id ),
-					esc_attr( $object[ "$object_id" ] )
+				$title = sprintf(esc_html__('Error: %1$s %2$s %3$s (WordPress %4$s with %5$s of %6$s)', 'object-sync-for-salesforce'),
+					esc_attr($op),
+					esc_attr($mapping['salesforce_object']),
+					isset($salesforce_id) ? ' ' . esc_attr($salesforce_id) : '',
+					esc_attr($mapping['wordpress_object']),
+					esc_attr($object_id),
+					esc_attr($object["$object_id"])
 				);
 
 				$logging->setup(
 					$title,
 					$e->getMessage(),
 					$sf_sync_trigger,
-					$object[ "$object_id" ],
+					$object["$object_id"],
 					$status
 				);
 
 				// hook for push fail
-				do_action( 'object_sync_for_salesforce_push_fail', $op, $sfapi->response, $synced_object );
+				do_action('object_sync_for_salesforce_push_fail', $op, $sfapi->response, $synced_object);
 
 				return;
 			} // End try().
 
-			if ( ! isset( $salesforce_data ) ) {
+			if ( ! isset($salesforce_data)) {
 				// if we didn't set $salesforce_data already, set it now to api call result
 				$salesforce_data = $result['data'];
 			}
@@ -795,78 +795,78 @@ 
 			// this means the object has already been created/updated in Salesforce
 			// this is not redundant because this is where it creates the object mapping rows in WordPress if the object does not already have one (we are still inside $is_new === TRUE here)
 
-			if ( empty( $result['errorCode'] ) ) {
+			if (empty($result['errorCode'])) {
 				$salesforce_id = $salesforce_data['id'];
 				$status        = 'success';
 
-				if ( isset( $this->logging ) ) {
+				if (isset($this->logging)) {
 					$logging = $this->logging;
-				} elseif ( class_exists( 'Object_Sync_Sf_Logging' ) ) {
-					$logging = new Object_Sync_Sf_Logging( $this->wpdb, $this->version );
+				} elseif (class_exists('Object_Sync_Sf_Logging')) {
+					$logging = new Object_Sync_Sf_Logging($this->wpdb, $this->version);
 				}
 
 				// translators: placeholders are: 1) what operation is happening, 2) the name of the Salesforce object, 3) the Salesforce Id value, 4) the name of the WordPress object type, 5) the WordPress id field name, 6) the WordPress object id value
-				$title = sprintf( esc_html__( 'Success: %1$s %2$s %3$s (WordPress %4$s with %5$s of %6$s)', 'object-sync-for-salesforce' ),
-					esc_attr( $op ),
-					esc_attr( $mapping['salesforce_object'] ),
-					esc_attr( $salesforce_id ),
-					esc_attr( $mapping['wordpress_object'] ),
-					esc_attr( $object_id ),
-					esc_attr( $object[ "$object_id" ] )
+				$title = sprintf(esc_html__('Success: %1$s %2$s %3$s (WordPress %4$s with %5$s of %6$s)', 'object-sync-for-salesforce'),
+					esc_attr($op),
+					esc_attr($mapping['salesforce_object']),
+					esc_attr($salesforce_id),
+					esc_attr($mapping['wordpress_object']),
+					esc_attr($object_id),
+					esc_attr($object["$object_id"])
 				);
 
 				$logging->setup(
 					$title,
 					'',
 					$sf_sync_trigger,
-					$object[ "$object_id" ],
+					$object["$object_id"],
 					$status
 				);
 
 				// update that mapping object
 				$mapping_object['salesforce_id']     = $salesforce_id;
-				$mapping_object['last_sync_message'] = esc_html__( 'Mapping object updated via function: ', 'object-sync-for-salesforce' ) . __FUNCTION__;
-				$mapping_object                      = $this->mappings->update_object_map( $mapping_object, $mapping_object['id'] );
+				$mapping_object['last_sync_message'] = esc_html__('Mapping object updated via function: ', 'object-sync-for-salesforce') . __FUNCTION__;
+				$mapping_object                      = $this->mappings->update_object_map($mapping_object, $mapping_object['id']);
 
 				// hook for push success
-				do_action( 'object_sync_for_salesforce_push_success', $op, $sfapi->response, $synced_object, $object_id );
+				do_action('object_sync_for_salesforce_push_success', $op, $sfapi->response, $synced_object, $object_id);
 			} else {
 
 				// create log entry for failed create or upsert
 				// this is part of the drupal module but i am failing to understand when it would ever fire, since the catch should catch the errors
 				// if we see this in the log entries, we can understand what it does, but probably not until then
 				$status = 'error';
-				if ( isset( $this->logging ) ) {
+				if (isset($this->logging)) {
 					$logging = $this->logging;
-				} elseif ( class_exists( 'Object_Sync_Sf_Logging' ) ) {
-					$logging = new Object_Sync_Sf_Logging( $this->wpdb, $this->version );
+				} elseif (class_exists('Object_Sync_Sf_Logging')) {
+					$logging = new Object_Sync_Sf_Logging($this->wpdb, $this->version);
 				}
 
 				// translators: placeholders are: 1) error code the Salesforce API returned, 2) what operation is happening, 3) the name of the WordPress object type, 4) the WordPress id field name, 5) the WordPress object id value
-				$title = sprintf( esc_html__( '%1$s error syncing: %2$s to Salesforce (WordPress %3$s with %4$s of %5$s)', 'object-sync-for-salesforce' ),
-					absint( $salesforce_data['errorCode'] ),
-					esc_attr( $op ),
-					esc_attr( $mapping['wordpress_object'] ),
-					esc_attr( $object_id ),
-					esc_attr( $object[ "$object_id" ] )
+				$title = sprintf(esc_html__('%1$s error syncing: %2$s to Salesforce (WordPress %3$s with %4$s of %5$s)', 'object-sync-for-salesforce'),
+					absint($salesforce_data['errorCode']),
+					esc_attr($op),
+					esc_attr($mapping['wordpress_object']),
+					esc_attr($object_id),
+					esc_attr($object["$object_id"])
 				);
 
 				// translators: placeholders are 1) the name of the Salesforce object type, 2) the error message returned from the Salesforce APIs
-				$body = sprintf( '<p>' . esc_html__( 'Object: %1$s', 'object-sync-for-salesforce' ) . '</p><p>' . esc_html__( 'Message: %2$s', 'object-sync-for-salesforce' ) . '</p>',
-					esc_attr( $mapping['salesforce_object'] ),
-					esc_html( $salesforce_data['message'] )
+				$body = sprintf('<p>' . esc_html__('Object: %1$s', 'object-sync-for-salesforce') . '</p><p>' . esc_html__('Message: %2$s', 'object-sync-for-salesforce') . '</p>',
+					esc_attr($mapping['salesforce_object']),
+					esc_html($salesforce_data['message'])
 				);
 
 				$logging->setup(
 					$title,
 					$body,
 					$sf_sync_trigger,
-					$object[ "$object_id" ],
+					$object["$object_id"],
 					$status
 				);
 
 				// hook for push fail
-				do_action( 'object_sync_for_salesforce_push_fail', $op, $sfapi->response, $synced_object );
+				do_action('object_sync_for_salesforce_push_fail', $op, $sfapi->response, $synced_object);
 
 				return;
 			} // End if().
@@ -874,41 +874,41 @@ 
 			// $is_new is false here; we are updating an already mapped object
 
 			// right here we should set the pushing transient
-			set_transient( 'salesforce_pushing_' . $mapping_object['id'], 1, $seconds );
-			set_transient( 'salesforce_pushing_object_id', $mapping_object['id'] );
+			set_transient('salesforce_pushing_' . $mapping_object['id'], 1, $seconds);
+			set_transient('salesforce_pushing_object_id', $mapping_object['id']);
 
 			// there is an existing object link
 			// if the last sync is greater than the last time this object was updated, skip it
 			// this keeps us from doing redundant syncs
-			$mapping_object['object_updated'] = current_time( 'mysql' );
-			if ( $mapping_object['last_sync'] > $mapping_object['object_updated'] ) {
+			$mapping_object['object_updated'] = current_time('mysql');
+			if ($mapping_object['last_sync'] > $mapping_object['object_updated']) {
 				$status = 'notice';
-				if ( isset( $this->logging ) ) {
+				if (isset($this->logging)) {
 					$logging = $this->logging;
-				} elseif ( class_exists( 'Object_Sync_Sf_Logging' ) ) {
-					$logging = new Object_Sync_Sf_Logging( $this->wpdb, $this->version );
+				} elseif (class_exists('Object_Sync_Sf_Logging')) {
+					$logging = new Object_Sync_Sf_Logging($this->wpdb, $this->version);
 				}
 
 				// translators: placeholders are: 1) what operation is happening, 2) the name of the WordPress object type, 3) the WordPress id field name, 4) the WordPress object id value, 5) the Salesforce Id value
-				$title = sprintf( esc_html__( 'Notice: %1$s: Did not sync WordPress %2$s with %3$s of %4$s with Salesforce Id %5$s because the last sync timestamp was greater than the object updated timestamp.', 'object-sync-for-salesforce' ),
-					esc_attr( $op ),
-					esc_attr( $mapping['wordpress_object'] ),
-					esc_attr( $object_id ),
-					esc_attr( $object[ "$object_id" ] ),
-					esc_attr( $mapping_object['salesforce_id'] )
+				$title = sprintf(esc_html__('Notice: %1$s: Did not sync WordPress %2$s with %3$s of %4$s with Salesforce Id %5$s because the last sync timestamp was greater than the object updated timestamp.', 'object-sync-for-salesforce'),
+					esc_attr($op),
+					esc_attr($mapping['wordpress_object']),
+					esc_attr($object_id),
+					esc_attr($object["$object_id"]),
+					esc_attr($mapping_object['salesforce_id'])
 				);
 
 				// translators: placeholders are 1) when a sync on this mapping last occured, 2) when the object was last updated
-				$body = sprintf( '<p>' . esc_html__( 'Last sync time: %1$s', 'object-sync-for-salesforce' ) . '</p><p>' . esc_html__( 'Object updated time: %2$s', 'object-sync-for-salesforce' ) . '</p>',
-					esc_attr( $mapping_object['last_sync'] ),
-					esc_html( $mapping_object['object_updated'] )
+				$body = sprintf('<p>' . esc_html__('Last sync time: %1$s', 'object-sync-for-salesforce') . '</p><p>' . esc_html__('Object updated time: %2$s', 'object-sync-for-salesforce') . '</p>',
+					esc_attr($mapping_object['last_sync']),
+					esc_html($mapping_object['object_updated'])
 				);
 
 				$logging->setup(
 					$title,
 					$body,
 					$sf_sync_trigger,
-					$object[ "$object_id" ],
+					$object["$object_id"],
 					$status
 				);
 				return;
@@ -919,71 +919,71 @@ 
 
 				// hook to allow other plugins to do something right before Salesforce data is saved
 				// ex: run WordPress methods on an object if it exists, or do something in preparation for it if it doesn't
-				do_action( 'object_sync_for_salesforce_pre_push', $mapping_object['salesforce_id'], $mapping, $object, $object_id, $params );
+				do_action('object_sync_for_salesforce_pre_push', $mapping_object['salesforce_id'], $mapping, $object, $object_id, $params);
 
 				// hook to allow other plugins to change params on update actions only
 				// use hook to map fields between the WordPress and Salesforce objects
 				// returns $params.
-				$params = apply_filters( 'object_sync_for_salesforce_push_update_params_modify', $params, $mapping_object['salesforce_id'], $mapping, $object );
+				$params = apply_filters('object_sync_for_salesforce_push_update_params_modify', $params, $mapping_object['salesforce_id'], $mapping, $object);
 
 				$op     = 'Update';
-				$result = $sfapi->object_update( $mapping['salesforce_object'], $mapping_object['salesforce_id'], $params );
+				$result = $sfapi->object_update($mapping['salesforce_object'], $mapping_object['salesforce_id'], $params);
 
 				$mapping_object['last_sync_status']  = $this->mappings->status_success;
-				$mapping_object['last_sync_message'] = esc_html__( 'Mapping object updated via function: ', 'object-sync-for-salesforce' ) . __FUNCTION__;
+				$mapping_object['last_sync_message'] = esc_html__('Mapping object updated via function: ', 'object-sync-for-salesforce') . __FUNCTION__;
 
 				$status = 'success';
-				if ( isset( $this->logging ) ) {
+				if (isset($this->logging)) {
 					$logging = $this->logging;
-				} elseif ( class_exists( 'Object_Sync_Sf_Logging' ) ) {
-					$logging = new Object_Sync_Sf_Logging( $this->wpdb, $this->version );
+				} elseif (class_exists('Object_Sync_Sf_Logging')) {
+					$logging = new Object_Sync_Sf_Logging($this->wpdb, $this->version);
 				}
 
 				// translators: placeholders are: 1) what operation is happening, 2) the name of the Salesforce object, 3) the Salesforce Id value, 4) the name of the WordPress object type, 5) the WordPress id field name, 6) the WordPress object id value
-				$title = sprintf( esc_html__( 'Success: %1$s %2$s %3$s (WordPress %4$s with %5$s of %6$s)', 'object-sync-for-salesforce' ),
-					esc_attr( $op ),
-					esc_attr( $mapping['salesforce_object'] ),
-					esc_attr( $mapping_object['salesforce_id'] ),
-					esc_attr( $mapping['wordpress_object'] ),
-					esc_attr( $object_id ),
-					esc_attr( $object[ "$object_id" ] )
+				$title = sprintf(esc_html__('Success: %1$s %2$s %3$s (WordPress %4$s with %5$s of %6$s)', 'object-sync-for-salesforce'),
+					esc_attr($op),
+					esc_attr($mapping['salesforce_object']),
+					esc_attr($mapping_object['salesforce_id']),
+					esc_attr($mapping['wordpress_object']),
+					esc_attr($object_id),
+					esc_attr($object["$object_id"])
 				);
 
 				$logging->setup(
 					$title,
 					'',
 					$sf_sync_trigger,
-					$object[ "$object_id" ],
+					$object["$object_id"],
 					$status
 				);
 
 				// hook for push success
-				do_action( 'object_sync_for_salesforce_push_success', $op, $sfapi->response, $synced_object, $object_id );
+				do_action('object_sync_for_salesforce_push_success', $op, $sfapi->response, $synced_object, $object_id);
 
-			} catch ( Object_Sync_Sf_Exception $e ) {
+			} catch (Object_Sync_Sf_Exception $e) {
 				// create log entry for failed update
 				$status = 'error';
-				if ( isset( $this->logging ) ) {
+				if (isset($this->logging)) {
 					$logging = $this->logging;
-				} elseif ( class_exists( 'Object_Sync_Sf_Logging' ) ) {
-					$logging = new Object_Sync_Sf_Logging( $this->wpdb, $this->version );
+				} elseif (class_exists('Object_Sync_Sf_Logging')) {
+					$logging = new Object_Sync_Sf_Logging($this->wpdb, $this->version);
 				}
 
 				// translators: placeholders are: 1) what operation is happening, 2) the name of the Salesforce object, 3) the Salesforce Id value, 4) the name of the WordPress object type, 5) the WordPress id field name, 6) the WordPress object id value
-				$title = sprintf( esc_html__( 'Error: %1$s %2$s %3$s (WordPress %4$s with %5$s of %6$s)', 'object-sync-for-salesforce' ),
-					esc_attr( $op ),
-					esc_attr( $mapping['salesforce_object'] ),
-					esc_attr( $mapping_object['salesforce_id'] ),
-					esc_attr( $mapping['wordpress_object'] ),
-					esc_attr( $object_id ),
-					esc_attr( $object[ "$object_id" ] )
+				$title = sprintf(esc_html__('Error: %1$s %2$s %3$s (WordPress %4$s with %5$s of %6$s)', 'object-sync-for-salesforce'),
+					esc_attr($op),
+					esc_attr($mapping['salesforce_object']),
+					esc_attr($mapping_object['salesforce_id']),
+					esc_attr($mapping['wordpress_object']),
+					esc_attr($object_id),
+					esc_attr($object["$object_id"])
 				);
 
 				$logging->setup(
 					$title,
 					$e->getMessage(),
 					$sf_sync_trigger,
-					$object[ "$object_id" ],
+					$object["$object_id"],
 					$status
 				);
 
@@ -991,16 +991,16 @@ 
 				$mapping_object['last_sync_message'] = $e->getMessage();
 
 				// hook for push fail
-				do_action( 'object_sync_for_salesforce_push_fail', $op, $sfapi->response, $synced_object );
+				do_action('object_sync_for_salesforce_push_fail', $op, $sfapi->response, $synced_object);
 
 			} // End try().
 
 			// tell the mapping object - whether it is new or already existed - how we just used it
 			$mapping_object['last_sync_action'] = 'push';
-			$mapping_object['last_sync']        = current_time( 'mysql' );
+			$mapping_object['last_sync']        = current_time('mysql');
 
 			// update that mapping object
-			$result = $this->mappings->update_object_map( $mapping_object, $mapping_object['id'] );
+			$result = $this->mappings->update_object_map($mapping_object, $mapping_object['id']);
 
 		} // End if(). this is the end of the if is_new stuff
 
@@ -1022,9 +1022,9 @@ 
 	*   This is the database row for the map object
 	*
 	*/
-	private function create_object_map( $wordpress_object, $id_field_name, $salesforce_id, $field_mapping, $pending = false ) {
+	private function create_object_map($wordpress_object, $id_field_name, $salesforce_id, $field_mapping, $pending = false) {
 
-		if ( true === $pending ) {
+		if (true === $pending) {
 			$action = 'pending';
 		} else {
 			$action = 'created';
@@ -1033,15 +1033,15 @@ 
 		// Create object map and save it
 		$mapping_object = $this->mappings->create_object_map(
 			array(
-				'wordpress_id'      => $wordpress_object[ $id_field_name ], // wordpress unique id
+				'wordpress_id'      => $wordpress_object[$id_field_name], // wordpress unique id
 				'salesforce_id'     => $salesforce_id, // salesforce unique id. we don't care what kind of object it is at this point
 				'wordpress_object'  => $field_mapping['wordpress_object'], // keep track of what kind of wp object this is
-				'last_sync'         => current_time( 'mysql' ),
+				'last_sync'         => current_time('mysql'),
 				'last_sync_action'  => 'push',
 				'last_sync_status'  => $this->mappings->status_success,
 				// translators: placeholder is for the action that occurred on the mapping object (pending or created)
-				'last_sync_message' => sprintf( esc_html__( 'Mapping object %1$s via function: ', 'object-sync-for-salesforce' ) . __FUNCTION__,
-					esc_attr( $action )
+				'last_sync_message' => sprintf(esc_html__('Mapping object %1$s via function: ', 'object-sync-for-salesforce') . __FUNCTION__,
+					esc_attr($action)
 				),
 				'action'            => $action,
 			)