Object_Sync_Sf_Mapping::update_object_map() - Code Metrics - MinnPost/object-sync-for-salesforce - Measure and Improve Code Quality continuously with Scrutinizer

Object_Sync_Sf_Mapping::update_object_map() A
last analyzed 2024-10-09 02:21 UTC

↳ Parent: Object_Sync_Sf_Mapping
Complexity

Conditions	4
Paths	8
Size

Total Lines	19
Code Lines	14
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
cc	4
eloc	14
c	0
b	0
f	0
nc	8
nop	2
dl	0
loc	19
rs	9.7998
<?php
/**
 * Map objects and records between WordPress and Salesforce
 *
 * @class   Object_Sync_Sf_Mapping
 * @package Object_Sync_Salesforce
 */

defined( 'ABSPATH' ) || exit;

/**
 * Object_Sync_Sf_Mapping class.
 */
class Object_Sync_Sf_Mapping {

	/**
	 * Current version of the plugin
	 *
	 * @var string
	 */
	public $version;

	/**
	 * The main plugin file
	 *
	 * @var string
	 */
	public $file;

	/**
	 * Global object of `$wpdb`, the WordPress database
	 *
	 * @var object
	 */
	public $wpdb;

	/**
	 * The plugin's slug so we can include it when necessary
	 *
	 * @var string
	 */
	public $slug;

	/**
	 * The plugin's prefix when saving options to the database
	 *
	 * @var string
	 */
	public $option_prefix;

	/**
	 * Object_Sync_Sf_Logging class
	 *
	 * @var object
	 */
	public $logging;

	/**
	 * The database table for fieldmaps
	 *
	 * @var string
	 */
	public $fieldmap_table;

	/**
	 * The database table for object maps
	 *
	 * @var string
	 */
	public $object_map_table;

	/**
	 * Possible status values for fieldmaps
	 *
	 * @var array
	 */
	public $fieldmap_statuses;

	/**
	 * The active status values for fieldmaps
	 *
	 * @var string
	 */
	public $active_fieldmap_conditions;

	/**
	 * Bitmap value for when sync is off
	 *
	 * @var string
	 */
	public $sync_off;

	/**
	 * Bitmap value for when sync is is on for WordPress create events
	 *
	 * @var string
	 */
	public $sync_wordpress_create;

	/**
	 * Bitmap value for when sync is is on for WordPress update events
	 *
	 * @var string
	 */
	public $sync_wordpress_update;

	/**
	 * Bitmap value for when sync is is on for WordPress delete events
	 *
	 * @var string
	 */
	public $sync_wordpress_delete;

	/**
	 * Bitmap value for when sync is is on for Salesforce create events
	 *
	 * @var string
	 */
	public $sync_sf_create;

	/**
	 * Bitmap value for when sync is is on for Salesforce update events
	 *
	 * @var string
	 */
	public $sync_sf_update;

	/**
	 * Bitmap value for when sync is is on for Salesforce delete events
	 *
	 * @var string
	 */
	public $sync_sf_delete;

	/**
	 * Which events are run by WordPress
	 *
	 * @var array
	 */
	public $wordpress_events;

	/**
	 * Which events are run by Salesforce
	 *
	 * @var array
	 */
	public $salesforce_events;

	/**
	 * The direction from WordPress to Salesforce
	 *
	 * @var string
	 */
	public $direction_wordpress_sf;

	/**
	 * The direction from Salesforce to WordPress
	 *
	 * @var string
	 */
	public $direction_sf_wordpress;

	/**
	 * The direction to sync both ways
	 *
	 * @var string
	 */
	public $direction_sync;

	/**
	 * WordPress directions, including sync
	 *
	 * @var array
	 */
	public $direction_wordpress;

	/**
	 * Salesforce directions, including sync
	 *
	 * @var array
	 */
	public $direction_salesforce;

	/**
	 * Default record type when using a Salesforce object that has a default or Master record type
	 *
	 * @var string
	 */
	public $salesforce_default_record_type;

	/**
	 * Delimiter for arrays coming from Salesforce
	 *
	 * @var string
	 */
	public $array_delimiter;

	/**
	 * Data in Salesforce that is stored as an array
	 *
	 * @var array
	 */
	public $array_types_from_salesforce;

	/**
	 * Data in Salesforce that is stored as a date
	 *
	 * @var array
	 */
	public $date_types_from_salesforce;

	/**
	 * Data in Salesforce that is stored as an integer
	 *
	 * @var array
	 */
	public $int_types_from_salesforce;

	/**
	 * How long can a mapping field be
	 *
	 * @var int
	 */
	public $name_length;

	/**
	 * Status flag for success
	 *
	 * @var int
	 */
	public $status_success;

	/**
	 * Status flag for error
	 *
	 * @var int
	 */
	public $status_error;

	/**
	 * Option value for whether the plugin is in debug mode
	 *
	 * @var bool
	 */
	public $debug;

	/**
	 * Deprecated hex parameter which defines when syncing should occur on each field map.
	 *
	 * @var int
	 */
	public $sync_off_v1;

	/**
	 * Deprecated hex parameter which defines when syncing should occur on each field map.
	 *
	 * @var int
	 */
	public $sync_wordpress_create_v1;

	/**
	 * Deprecated hex parameter which defines when syncing should occur on each field map.
	 *
	 * @var int
	 */
	public $sync_wordpress_update_v1;

	/**
	 * Deprecated hex parameter which defines when syncing should occur on each field map.
	 *
	 * @var int
	 */
	public $sync_wordpress_delete_v1;

	/**
	 * Deprecated hex parameter which defines when syncing should occur on each field map.
	 *
	 * @var int
	 */
	public $sync_sf_create_v1;

	/**
	 * Deprecated hex parameter which defines when syncing should occur on each field map.
	 *
	 * @var int
	 */
	public $sync_sf_update_v1;

	/**
	 * Deprecated hex parameter which defines when syncing should occur on each field map.
	 *
	 * @var int
	 */
	public $sync_sf_delete_v1;

	/**
	 * Deprecated hex event values.
	 *
	 * @var array
	 */
	public $wordpress_events_v1;

	/**
	 * Deprecated hex event values.
	 *
	 * @var array
	 */
	public $salesforce_events_v1;

	/**
	 * Constructor for mapping class
	 */
	public function __construct() {
		$this->version       = object_sync_for_salesforce()->version;
		$this->file          = object_sync_for_salesforce()->file;
		$this->wpdb          = object_sync_for_salesforce()->wpdb;
		$this->slug          = object_sync_for_salesforce()->slug;
		$this->option_prefix = object_sync_for_salesforce()->option_prefix;

		$this->logging = object_sync_for_salesforce()->logging;

		$this->fieldmap_table   = $this->wpdb->prefix . 'object_sync_sf_field_map';
		$this->object_map_table = $this->wpdb->prefix . 'object_sync_sf_object_map';

		$this->fieldmap_statuses          = array(
			'active'   => esc_html__( 'Active', 'object-sync-for-salesforce' ),
			'active'   => /** @scrutinizer ignore-call */ esc_html__( 'Active', 'object-sync-for-salesforce' ),
			'inactive' => esc_html__( 'Inactive', 'object-sync-for-salesforce' ),
			'any'      => '',
		);
		$this->active_fieldmap_conditions = array(

			'fieldmap_status' => 'active',
		);

		/*
		 * These parameters are how we define when syncing should occur on each field map.
		 * They get used in the admin settings, as well as the push/pull methods to see if something should happen.
		*/
		$this->sync_off              = 'off';
		$this->sync_wordpress_create = 'wp_create';
		$this->sync_wordpress_update = 'wp_update';
		$this->sync_wordpress_delete = 'wp_delete';
		$this->sync_sf_create        = 'sf_create';
		$this->sync_sf_update        = 'sf_update';
		$this->sync_sf_delete        = 'sf_delete';

		// deprecated bit flags from version 1.x. Deprecated since 2.0.0.
		$this->sync_off_v1              = 0x0000;
		$this->sync_wordpress_create_v1 = 0x0001;
		$this->sync_wordpress_update_v1 = 0x0002;
		$this->sync_wordpress_delete_v1 = 0x0004;
		$this->sync_sf_create_v1        = 0x0008;
		$this->sync_sf_update_v1        = 0x0010;
		$this->sync_sf_delete_v1        = 0x0020;

		// Define which events are initialized by which system.
		$this->wordpress_events  = array( $this->sync_wordpress_create, $this->sync_wordpress_update, $this->sync_wordpress_delete );
		$this->salesforce_events = array( $this->sync_sf_create, $this->sync_sf_update, $this->sync_sf_delete );

		// deprecated bit flags from version 1.x. Deprecated since 2.0.0.
		$this->wordpress_events_v1  = array( $this->sync_wordpress_create_v1, $this->sync_wordpress_update_v1, $this->sync_wordpress_delete_v1 );
		$this->salesforce_events_v1 = array( $this->sync_sf_create_v1, $this->sync_sf_update_v1, $this->sync_sf_delete_v1 );

		// Constants for the directions to map things.
		$this->direction_wordpress_sf = 'wp_sf';
		$this->direction_sf_wordpress = 'sf_wp';
		$this->direction_sync         = 'sync';

		$this->direction_wordpress  = array( $this->direction_wordpress_sf, $this->direction_sync );
		$this->direction_salesforce = array( $this->direction_sf_wordpress, $this->direction_sync );

		// This is used when we map a record with default or Master.
		$this->salesforce_default_record_type = 'default';

		// Salesforce has multipicklists and they have a delimiter.
		$this->array_delimiter = ';';
		// What data types in Salesforce should be an array?
		$this->array_types_from_salesforce = array( 'multipicklist' );
		// What data types in Salesforce should be a date field?
		$this->date_types_from_salesforce = array( 'date', 'datetime' );
		// What data types in Salesforce should be an integer?
		$this->int_types_from_salesforce = array( 'integer', 'boolean' );

		// Max length for a mapping field.
		$this->name_length = 128;

		// Statuses for object sync.
		$this->status_success = 1;
		$this->status_error   = 0;

		// use the option value for whether we're in debug mode.
		$this->debug = filter_var( get_option( $this->option_prefix . 'debug_mode', false ), FILTER_VALIDATE_BOOLEAN );
		$this->debug = filter_var( /** @scrutinizer ignore-call */ get_option( $this->option_prefix . 'debug_mode', false ), FILTER_VALIDATE_BOOLEAN );

	}

	/**
	 * Create a fieldmap row between a WordPress and Salesforce object
	 *
	 * @param array $posted The results of $_POST.
	 * @param array $wordpress_fields The fields for the WordPress side of the mapping.
	 * @param array $salesforce_fields The fields for the Salesforce side of the mapping.
	 * @return int  the last inserted ID.
	 */
	public function create_fieldmap( $posted = array(), $wordpress_fields = array(), $salesforce_fields = array() ) {
		$data = $this->setup_fieldmap_data( $posted, $wordpress_fields, $salesforce_fields );
		if ( ! isset( $posted['version'] ) && version_compare( $this->version, '1.2.5', '>=' ) ) {
			$data['version'] = $this->version;
		}
		$insert = $this->wpdb->insert( $this->fieldmap_table, $data );
		if ( 1 === $insert ) {
			return $this->wpdb->insert_id;
		} else {
			return false;
		}
	}

	/**
	 * Get one or more fieldmap rows between a WordPress and Salesforce object
	 *
	 * @param int   $id The ID of a desired mapping.
	 * @param array $conditions Array of key=>value to match the mapping by.
	 * @param bool  $reset Unused parameter.
	 * @return array $map a single mapping or $mappings, an array of mappings.
	 */
	public function get_fieldmaps( $id = null, $conditions = array(), $reset = false ) {
	public function get_fieldmaps( $id = null, $conditions = array(), /** @scrutinizer ignore-unused */ $reset = false ) {
		$table = $this->fieldmap_table;
		if ( null !== $id ) { // get one fieldmap.
			$map        = $this->wpdb->get_row( 'SELECT * FROM ' . $table . ' WHERE id = ' . $id, ARRAY_A );

			$mappings   = array();
			$mappings[] = $map;
			$mappings   = $this->prepare_fieldmap_data( $mappings );
			$map        = $mappings[0];
			return $map;
		} elseif ( ! empty( $conditions ) ) { // get multiple but with a limitation.
			$mappings    = array();
			$record_type = '';

			// Assemble the SQL.
			if ( ! empty( $conditions ) ) {
				$where = '';
				$i     = 0;
				foreach ( $conditions as $key => $value ) {
					// if 'any' is the value for fieldmap status, we keep it off the WHERE statement.
					if ( 'fieldmap_status' === $key && 'any' === $value ) {
						continue;
					}
					if ( 'salesforce_record_type' === $key ) {
						$record_type = sanitize_text_field( $value );
						$record_type = /** @scrutinizer ignore-call */ sanitize_text_field( $value );
					} else {
						$i++;
						if ( $i > 1 ) {
							$where .= ' AND ';
						}
						$where .= '`' . $key . '` = "' . $value . '"';
					}
				}
				if ( '' !== $where ) {

					$where = ' WHERE ' . $where;
				}
			} else {
				$where = '';
			}

			$mappings = $this->wpdb->get_results( 'SELECT * FROM ' . $table . $where . ' ORDER BY `fieldmap_status`, `weight`', ARRAY_A );

			if ( ! empty( $mappings ) ) {
				$mappings = $this->prepare_fieldmap_data( $mappings, $record_type );
			}

			return $mappings;

		} else { // get all of the mappings. ALL THE MAPPINGS.

			// This is the default query for loading fieldmaps.
			$mappings = $this->wpdb->get_results( "SELECT * FROM $table ORDER BY `fieldmap_status`", ARRAY_A );

			// lower than 2.0.0 versions.
			// @deprecated
			// will be removed in version 3.0.0.
			if ( version_compare( $this->version, '2.0.0', '<' ) ) {
				// if the version is greater than or equal to 1.5.0, the fieldmap table has a pull_to_drafts column.
				if ( version_compare( $this->version, '1.5.0', '>=' ) ) {
					$mappings = $this->wpdb->get_results( "SELECT `id`, `label`, `wordpress_object`, `salesforce_object`, `salesforce_record_types_allowed`, `salesforce_record_type_default`, `fields`, `pull_trigger_field`, `sync_triggers`, `push_async`, `push_drafts`, `pull_to_drafts`, `weight`, `version` FROM $table", ARRAY_A );
				} elseif ( version_compare( $this->version, '1.2.5', '>=' ) ) {
					// if the version is greater than or equal to 1.2.5, the fieldmap table has a version column.
					$mappings = $this->wpdb->get_results( "SELECT `id`, `label`, `wordpress_object`, `salesforce_object`, `salesforce_record_types_allowed`, `salesforce_record_type_default`, `fields`, `pull_trigger_field`, `sync_triggers`, `push_async`, `push_drafts`, `weight`, `version` FROM $table", ARRAY_A );
				} else {
					$mappings = $this->wpdb->get_results( "SELECT `id`, `label`, `wordpress_object`, `salesforce_object`, `salesforce_record_types_allowed`, `salesforce_record_type_default`, `fields`, `pull_trigger_field`, `sync_triggers`, `push_async`, `push_drafts`, `weight` FROM $table", ARRAY_A );
				}
			}

			if ( ! empty( $mappings ) ) {
				$mappings = $this->prepare_fieldmap_data( $mappings );
			}

			return $mappings;
		} // End if statement.
	}

	/**
	 * For a mapping, get the fieldmaps associated with it.
	 *
	 * @param array $mapping The mapping for which we are getting the fieldmaps.
	 * @param array $directions The direction of the mapping: from WP to SF or vice-versa.
	 * @see Object_Sync_Sf_Salesforce_Pull::get_pull_query()
	 * @return array of mapped fields
	 */
	public function get_mapped_fields( $mapping, $directions = array() ) {
		$mapped_fields = array();
		foreach ( $mapping['fields'] as $fields ) {
			if ( empty( $directions ) || in_array( $fields['direction'], $directions, true ) ) {

				// in version 1.2.0, we provided an option for API name vs label for Salesforce fields.
				if ( version_compare( $this->version, '1.2.0', '>=' ) && isset( $fields['salesforce_field']['name'] ) ) {
					$array_key = 'name';
				} else {
					$array_key = 'label';
				}

				// Some field map types (Relation) store a collection of SF objects.
				if ( is_array( $fields['salesforce_field'] ) && ! isset( $fields['salesforce_field'][ $array_key ] ) ) {
					foreach ( $fields['salesforce_field'] as $sf_field ) {
						$mapped_fields[ $sf_field[ $array_key ] ] = $sf_field[ $array_key ];
					}
				} else { // The rest are just a name/value pair.
					$mapped_fields[ $fields['salesforce_field'][ $array_key ] ] = $fields['salesforce_field'][ $array_key ];
				}
			}
		}

		if ( ! empty( $this->get_mapped_record_types ) ) {
			$mapped_fields['RecordTypeId'] = 'RecordTypeId';
		}

		return $mapped_fields;
	}

	/**
	 * Get the mapped record types for a given mapping.
	 *
	 * @param array $mapping A mapping from which we wish to estract the record type.
	 * @return array of mappings. Empty if the mapping's record type is default, else full of the record types.
	 */
	public function get_mapped_record_types( $mapping ) {
		return $mapping['salesforce_record_type_default'] === $this->salesforce_default_record_type ? array() : array_filter( maybe_unserialize( $mapping['salesforce_record_types_allowed'] ) );
		return $mapping['salesforce_record_type_default'] === $this->salesforce_default_record_type ? array() : array_filter( /** @scrutinizer ignore-call */ maybe_unserialize( $mapping['salesforce_record_types_allowed'] ) );
	}

	/**
	 * Update a fieldmap row between a WordPress and Salesforce object
	 *
	 * @param array $posted It's $_POST.
	 * @param array $wordpress_fields The fields for the WordPress side of the mapping.
	 * @param array $salesforce_fields The fields for the Salesforce side of the mapping.
	 * @param int   $id The ID of the mapping.
	 * @return boolean whether it was updated
	 */
	public function update_fieldmap( $posted = array(), $wordpress_fields = array(), $salesforce_fields = array(), $id = '' ) {
		$data = $this->setup_fieldmap_data( $posted, $wordpress_fields, $salesforce_fields );
		if ( version_compare( $this->version, '1.2.5', '>=' ) && ! isset( $data['updated'] ) ) {
			$data['version'] = $this->version;
		}
		$update = $this->wpdb->update(
			$this->fieldmap_table,
			$data,
			array(
				'id' => $id,
			)
		);
		if ( false === $update ) {
			return false;
		} else {
			return true;
		}
	}

	/**
	 * Setup fieldmap data
	 * Sets up the database entry for mapping the object types between Salesforce and WordPress
	 *
	 * @param array $posted It's $_POST.
	 * @param array $wordpress_fields The fields for the WordPress side of the mapping.
	 * @param array $salesforce_fields The fields for the Salesforce side of the mapping.
	 * @return array $data the fieldmap's data for the database
	 */
	private function setup_fieldmap_data( $posted = array(), $wordpress_fields = array(), $salesforce_fields = array() ) {
		$data = array(
			'label'             => $posted['label'],
			'name'              => sanitize_title( $posted['label'] ),
			'name'              => /** @scrutinizer ignore-call */ sanitize_title( $posted['label'] ),
			'salesforce_object' => $posted['salesforce_object'],
			'wordpress_object'  => $posted['wordpress_object'],
		);
		// when importing a fieldmap, there might already be a saved version. if there is, keep it.
		$data['version'] = isset( $posted['version'] ) ? $posted['version'] : $this->version;
		if ( isset( $posted['wordpress_field'] ) && is_array( $posted['wordpress_field'] ) && isset( $posted['salesforce_field'] ) && is_array( $posted['salesforce_field'] ) ) {
			$setup['fields'] = array();
			foreach ( $posted['wordpress_field'] as $key => $value ) {
				$method_key = array_search( $value, array_column( $wordpress_fields, 'key' ), true );
				if ( ! isset( $posted['direction'][ $key ] ) ) {
					$posted['direction'][ $key ] = 'sync';
				}
				if ( ! isset( $posted['is_prematch'][ $key ] ) ) {
					$posted['is_prematch'][ $key ] = false;
				}
				if ( ! isset( $posted['is_key'][ $key ] ) ) {
					$posted['is_key'][ $key ] = false;
				}
				if ( ! isset( $posted['is_delete'][ $key ] ) ) {
					$posted['is_delete'][ $key ] = false;
				}
				if ( false === $posted['is_delete'][ $key ] ) {
					// I think it's good to over-mention that updateable is really how the Salesforce api spells it.
					$updateable_key = array_search( $posted['salesforce_field'][ $key ], array_column( $salesforce_fields, 'name' ), true );

					$salesforce_field_attributes = array();
					foreach ( $salesforce_fields[ $updateable_key ] as $sf_key => $sf_value ) {
						if ( isset( $sf_value ) && ! is_array( $sf_value ) ) {
							$salesforce_field_attributes[ $sf_key ] = esc_attr( $sf_value );
							$salesforce_field_attributes[ $sf_key ] = /** @scrutinizer ignore-call */ esc_attr( $sf_value );
						} elseif ( ! empty( $sf_value ) && is_array( $sf_value ) ) {
							$salesforce_field_attributes[ $sf_key ] = maybe_unserialize( $sf_value );
							$salesforce_field_attributes[ $sf_key ] = /** @scrutinizer ignore-call */ maybe_unserialize( $sf_value );
						} else {
							$salesforce_field_attributes[ $sf_key ] = '';
						}
					}

					$setup['fields'][ $key ] = array(
						'wordpress_field'  => array(
							'label'    => sanitize_text_field( $posted['wordpress_field'][ $key ] ),
							'label'    => /** @scrutinizer ignore-call */ sanitize_text_field( $posted['wordpress_field'][ $key ] ),
							'methods'  => maybe_unserialize( $wordpress_fields[ $method_key ]['methods'] ),
							'type'     => isset( $wordpress_fields[ $method_key ]['type'] ) ? sanitize_text_field( $wordpress_fields[ $method_key ]['type'] ) : 'text',
							'editable' => isset( $wordpress_fields[ $method_key ]['editable'] ) ? (bool) $wordpress_fields[ $method_key ]['editable'] : true,
						),
						'salesforce_field' => $salesforce_field_attributes,
						'is_prematch'      => sanitize_text_field( $posted['is_prematch'][ $key ] ),
						'is_key'           => sanitize_text_field( $posted['is_key'][ $key ] ),
						'direction'        => sanitize_text_field( $posted['direction'][ $key ] ),
						'is_delete'        => sanitize_text_field( $posted['is_delete'][ $key ] ),
					);

					// If the WordPress key or the Salesforce key are blank, remove this incomplete mapping.
					// This prevents https://github.com/MinnPost/object-sync-for-salesforce/issues/82 .
					if (
						empty( $setup['fields'][ $key ]['wordpress_field']['label'] )
						||
						empty( $setup['fields'][ $key ]['salesforce_field']['name'] )
					) {
						unset( $setup['fields'][ $key ] );
					}
				}
			} // End foreach() on WordPress fields.
			$data['fields'] = maybe_serialize( $setup['fields'] );
			$data['fields'] = /** @scrutinizer ignore-call */ maybe_serialize( $setup['fields'] );
		} elseif ( isset( $posted['fields'] ) && is_array( $posted['fields'] ) ) {
			// if $posted['fields'] is already set, use that.
			$data['fields'] = maybe_serialize( $posted['fields'] );
		} // End if() WordPress fields are present.

		if ( isset( $posted['salesforce_record_types_allowed'] ) ) {
			$data['salesforce_record_types_allowed'] = maybe_serialize( $posted['salesforce_record_types_allowed'] );
		} else {
			$data['salesforce_record_types_allowed'] = maybe_serialize(
				array(
					$this->salesforce_default_record_type => $this->salesforce_default_record_type,
				)
			);
		}
		if ( isset( $posted['salesforce_record_type_default'] ) ) {
			$data['salesforce_record_type_default'] = $posted['salesforce_record_type_default'];
		} else {
			$data['salesforce_record_type_default'] = maybe_serialize( $this->salesforce_default_record_type );
		}
		if ( isset( $posted['pull_trigger_field'] ) ) {
			$data['pull_trigger_field'] = $posted['pull_trigger_field'];
		}
		if ( isset( $posted['sync_triggers'] ) && is_array( $posted['sync_triggers'] ) ) {
			$setup['sync_triggers'] = array();
			foreach ( $posted['sync_triggers'] as $key => $value ) {
				$setup['sync_triggers'][ $key ] = esc_html( $posted['sync_triggers'][ $key ] );
				$setup['sync_triggers'][ $key ] = /** @scrutinizer ignore-call */ esc_html( $posted['sync_triggers'][ $key ] );
			}
			// format the sync triggers. if necessary, update the database.
			$sync_triggers          = $this->maybe_upgrade_sync_triggers( $setup['sync_triggers'], $data['version'] );
			$setup['sync_triggers'] = $sync_triggers;
		} else {
			$setup['sync_triggers'] = array();
		}
		$data['sync_triggers'] = maybe_serialize( $setup['sync_triggers'] );
		if ( isset( $posted['pull_trigger_field'] ) ) {
			$data['pull_trigger_field'] = $posted['pull_trigger_field'];
		}
		$data['fieldmap_status']                     = isset( $posted['fieldmap_status'] ) ? $posted['fieldmap_status'] : 'active';
		$data['push_async']                          = isset( $posted['push_async'] ) ? $posted['push_async'] : '';
		$data['push_drafts']                         = isset( $posted['push_drafts'] ) ? $posted['push_drafts'] : '';
		$data['pull_to_drafts']                      = isset( $posted['pull_to_drafts'] ) ? $posted['pull_to_drafts'] : '';
		$data['weight']                              = isset( $posted['weight'] ) ? $posted['weight'] : '';
		$data['always_delete_object_maps_on_delete'] = isset( $posted['always_delete_object_maps_on_delete'] ) ? $posted['always_delete_object_maps_on_delete'] : '0';
		return $data;
	}

	/**
	 * Delete a fieldmap row between a WordPress and Salesforce object
	 *
	 * @param int $id The ID of a field mapping.
	 * @return bool whether it was deleted
	 */
	public function delete_fieldmap( $id = '' ) {
		$data   = array(
			'id' => $id,
		);
		$delete = $this->wpdb->delete( $this->fieldmap_table, $data );
		if ( 1 === $delete ) {
			return true;
		} else {
			return false;
		}
	}

	/**
	 * Create an object map row between a WordPress and Salesforce object
	 *
	 * @param array $posted It's $_POST.
	 * @return false|int of field mapping between WordPress and Salesforce objects
	 */
	public function create_object_map( $posted = array() ) {
		$data            = $this->setup_object_map_data( $posted );
		$data['created'] = current_time( 'mysql' );
		$data['created'] = /** @scrutinizer ignore-call */ current_time( 'mysql' );
		// Check to see if we don't know the salesforce id and it is not a temporary id, or if this is pending.
		// If it is using a temporary id, the map will get updated after it finishes running; it won't call this method unless there's an error, which we should log.
		if ( substr( $data['salesforce_id'], 0, 7 ) !== 'tmp_sf_' || ( isset( $data['action'] ) && 'pending' === $data['action'] ) ) {
			unset( $data['action'] );
			$insert = $this->wpdb->insert( $this->object_map_table, $data );
		} else {
			$status = 'error';
			$this->logging->setup(
				sprintf(
					// translators: %1$s is the log status, %2$s is the name of a WordPress object. %3$s is the id of that object.
					esc_html__( '%1$s Mapping: error caused by trying to map the WordPress %2$s with ID of %3$s to Salesforce ID starting with "tmp_sf_", which is invalid.', 'object-sync-for-salesforce' ),
     esc_html__( '%1$s Mapping: error caused by trying to map the WordPress %2$s with ID of %3$s to Salesforce ID starting with "tmp_sf_", which is invalid.', 'object-sync-for-salesforce' ),
					ucfirst( esc_attr( $status ) ),
					ucfirst( /** @scrutinizer ignore-call */ esc_attr( $status ) ),
					esc_attr( $data['wordpress_object'] ),
					absint( $data['wordpress_id'] )
     absint( $data['wordpress_id'] )
				),
				'',
				0,
				0,
				$status
			);
			return false;
		}
		if ( 1 === $insert ) {
			return $this->wpdb->insert_id;
		} elseif ( false !== strpos( $this->wpdb->last_error, 'Duplicate entry' ) ) {
			// this error should never happen now, I think. But let's watch and see.
			$mapping = $this->load_object_maps_by_salesforce_id( $data['salesforce_id'] )[0];
			$id      = $mapping['id'];
			$status  = 'error';
			$this->logging->setup(
				sprintf(
					// translators: %1$s is the status word "Error". %2$s is the Id of a Salesforce object. %3$s is the ID of a mapping object.
					esc_html__( '%1$s: Mapping: there is already a WordPress object mapped to the Salesforce object %2$s and the mapping object ID is %3$s', 'object-sync-for-salesforce' ),
					ucfirst( esc_attr( $status ) ),
					esc_attr( $data['salesforce_id'] ),
					absint( $id )
				),
				print_r( $mapping, true ), // phpcs:ignore WordPress.PHP.DevelopmentFunctions.error_log_print_r
				0,
				0,
				$status
			);
			return $id;
		} else {
			return false;
		}
	}

	/**
	 * Get all object map rows between WordPress and Salesforce objects.
	 *
	 * This replaces previous functionality that would return a single object map if there was only one, rather than a multi-dimensional array.
	 *
	 * @param array $conditions Limitations on the SQL query for object mapping rows.
	 * @param bool  $reset Unused parameter.
	 * @return $mappings

	 */
	public function get_all_object_maps( $conditions = array(), $reset = false ) {
	public function get_all_object_maps( $conditions = array(), /** @scrutinizer ignore-unused */ $reset = false ) {
		$table = $this->object_map_table;
		$order = ' ORDER BY object_updated, created';
		if ( ! empty( $conditions ) ) { // get multiple but with a limitation.
			$mappings = array();

			if ( ! empty( $conditions ) ) {
				$where = ' WHERE ';
				$i     = 0;
				foreach ( $conditions as $key => $value ) {
					$i++;
					if ( $i > 1 ) {
						$where .= ' AND ';
					}
					$where .= '`' . $key . '` = "' . $value . '"';
				}
			} else {
				$where = '';
			}

			$mappings = $this->wpdb->get_results( 'SELECT * FROM ' . $table . $where . $order, ARRAY_A );

		} else { // get all of the mappings. ALL THE MAPPINGS.
			$mappings = $this->wpdb->get_results( 'SELECT * FROM ' . $table . $order, ARRAY_A );
		}

		return $mappings;

	}

	/**
	 * Get one or more object map rows between WordPress and Salesforce objects
	 *
	 * @param array $conditions Limitations on the SQL query for object mapping rows.
	 * @param bool  $reset Unused parameter.
	 * @return array $map or $mappings
	 * @deprecated since 1.8.0
	 */
	public function get_object_maps( $conditions = array(), $reset = false ) {
	public function get_object_maps( $conditions = array(), /** @scrutinizer ignore-unused */ $reset = false ) {
		$table = $this->object_map_table;
		$order = ' ORDER BY object_updated, created';
		if ( ! empty( $conditions ) ) { // get multiple but with a limitation.
			$mappings = array();

			if ( ! empty( $conditions ) ) {
				$where = ' WHERE ';
				$i     = 0;
				foreach ( $conditions as $key => $value ) {
					$i++;
					if ( $i > 1 ) {
						$where .= ' AND ';
					}
					$where .= '`' . $key . '` = "' . $value . '"';
				}
			} else {
				$where = '';
			}

			$mappings = $this->wpdb->get_results( 'SELECT * FROM ' . $table . $where . $order, ARRAY_A );

			if ( ! empty( $mappings ) && 1 === $this->wpdb->num_rows ) {
				$mappings = $mappings[0];
			}
		} else { // get all of the mappings. ALL THE MAPPINGS.
			$mappings = $this->wpdb->get_results( 'SELECT * FROM ' . $table . $order, ARRAY_A );
			if ( ! empty( $mappings ) && 1 === $this->wpdb->num_rows ) {
				$mappings = $mappings[0];
			}
		}

		return $mappings;

	}

	/**
	 * Update an object map row between a WordPress and Salesforce object
	 *
	 * @param array $posted It's $_POST.
	 * @param array $id The ID of the object map row.
	 * @return boolean whether it was updated
	 */
	public function update_object_map( $posted = array(), $id = '' ) {
		$data = $this->setup_object_map_data( $posted );
		if ( ! isset( $data['object_updated'] ) ) {
			$data['object_updated'] = current_time( 'mysql' );
			$data['object_updated'] = /** @scrutinizer ignore-call */ current_time( 'mysql' );
		}
		if ( isset( $data['action'] ) ) {
			unset( $data['action'] );
		}
		$update = $this->wpdb->update(
			$this->object_map_table,
			$data,
			array(
				'id' => $id,
			)
		);
		if ( false === $update ) {
			return false;
		} else {
			return true;
		}
	}

	/**
	 * Setup the data for the object map
	 *
	 * @param array $posted It's $_POST.
	 * @return array $data Filtered array with only the keys that are in the object map database table. Strips out things from WordPress form if they're present.
	 */
	private function setup_object_map_data( $posted = array() ) {
		$allowed_fields   = $this->wpdb->get_col( "DESC {$this->object_map_table}", 0 );
		$allowed_fields[] = 'action'; // we use this in both directions even though it isn't in the database; we remove it from the array later if it is present.

		$data = array_intersect_key( $posted, array_flip( $allowed_fields ) );
		return $data;
	}

	/**
	 * Delete an object map row between a WordPress and Salesforce object
	 *
	 * @param int|array $id The ID or IDs of the object map row(s).
	 * @return bool whether it was deleted
	 */
	public function delete_object_map( $id = '' ) {
		if ( is_string( $id ) || is_int( $id ) ) {
			$data   = array(
				'id' => $id,
			);
			$delete = $this->wpdb->delete( $this->object_map_table, $data );
			if ( 1 === $delete ) {
				return true;
			} else {
				return false;
			}
		} elseif ( is_array( $id ) ) {

			$ids    = implode( ',', array_map( 'absint', $id ) );
			$delete = $this->wpdb->query( "DELETE FROM $this->object_map_table WHERE ID IN ($ids)" );
			if ( false !== $delete ) {
				return true;
			} else {
				return false;
			}
		}
	}

	/**
	 * Generate a temporary ID to store while waiting for a push or pull to complete, before the record has been assigned a new ID
	 *
	 * @param string $direction Whether this is part of a push or pull action.
	 * @return string $id is a temporary string that will be replaced if the modification is successful.
	 */
	public function generate_temporary_id( $direction ) {
		if ( 'push' === $direction ) {
			$prefix = 'tmp_sf_';
		} elseif ( 'pull' === $direction ) {
			$prefix = 'tmp_wp_';
		}
		$id = uniqid( $prefix, true );
		return $id;
	}

	/**
	 * Returns Salesforce object mappings for a given WordPress object.
	 *
	 * @param string $object_type Type of object to load.
	 * @param int    $object_id Unique identifier of the target object to load.
	 * @param bool   $reset Whether or not the cache should be cleared and fetch from current data.
	 *
	 * @return array of object maps
	 */
	public function load_all_by_wordpress( $object_type, $object_id, $reset = false ) {
		$conditions = array(
			'wordpress_id'     => $object_id,
			'wordpress_object' => $object_type,
		);
		return $this->get_all_object_maps( $conditions, $reset );
	}

	/**
	 * Returns Salesforce object mappings for a given Salesforce object.
	 *
	 * @param string $salesforce_id Type of object to load.
	 * @param array  $fieldmap the fieldmap this object map works with.
	 * @param bool   $reset Whether or not the cache should be cleared and fetch from current data.
	 *
	 * @return array $maps all the object maps that match the Salesforce Id
	 */
	public function load_object_maps_by_salesforce_id( $salesforce_id, $fieldmap = array(), $reset = false ) {
		$conditions = array(
			'salesforce_id' => $salesforce_id,
		);
		if ( is_array( $fieldmap ) && ! empty( $fieldmap ) ) {
			$conditions['wordpress_object'] = $fieldmap['wordpress_object'];
		}
		$maps = $this->get_all_object_maps( $conditions, $reset );

		return $maps;
	}

	/**
	 * Returns Salesforce object mappings for a given Salesforce object.
	 *
	 * @param string $salesforce_id Type of object to load.
	 * @param bool   $reset Whether or not the cache should be cleared and fetch from current data.
	 *
	 * @return array $maps all the object maps that match the Salesforce Id
	 * @deprecated since 2.1.0. Will be removed in 3.0.0.
	 */
	public function load_all_by_salesforce( $salesforce_id, $reset = false ) {
		$maps = $this->load_object_maps_by_salesforce_id( $salesforce_id, array(), $reset );
		return $maps;
	}

	/**
	 * Map values between WordPress and Salesforce objects.
	 *
	 * @param array  $mapping Mapping object.
	 * @param array  $object WordPress or Salesforce object data.
	 * @param array  $trigger The thing that triggered this mapping.
	 * @param bool   $use_soap Flag to enforce use of the SOAP API.
	 * @param bool   $is_new Indicates whether a mapping object for this entity already exists.
	 * @param string $object_id_field optionally pass the object id field name.
	 * @return array Associative array of key value pairs.
	 */
	public function map_params( $mapping, $object, $trigger, $use_soap = false, $is_new = true, $object_id_field = '' ) {
	public function map_params( $mapping, $object, $trigger, $use_soap = false, /** @scrutinizer ignore-unused */ $is_new = true, $object_id_field = '' ) {

		$params = array();

		$has_missing_required_salesforce_field = false;
		foreach ( $mapping['fields'] as $fieldmap ) {

			$wordpress_haystack  = array_values( $this->wordpress_events );
			$salesforce_haystack = array_values( $this->salesforce_events );

			$fieldmap['wordpress_field']['methods'] = maybe_unserialize( $fieldmap['wordpress_field']['methods'] );
			$fieldmap['wordpress_field']['methods'] = /** @scrutinizer ignore-call */ maybe_unserialize( $fieldmap['wordpress_field']['methods'] );

			$wordpress_field = $fieldmap['wordpress_field']['label'];

			if ( version_compare( $this->version, '1.2.0', '>=' ) && isset( $fieldmap['salesforce_field']['name'] ) ) {
				$salesforce_field = $fieldmap['salesforce_field']['name'];
				// Load the type of the Salesforce field. We can use this to handle Salesforce field value issues that come up based on what the field sends into WordPress or expects from WordPress.
				$salesforce_field_type = $fieldmap['salesforce_field']['type'];
			} else {
				$salesforce_field = $fieldmap['salesforce_field']['label'];
			}

			// A WordPress event caused this.
			if ( in_array( $trigger, array_values( $wordpress_haystack ), true ) ) {

				// Is the field in WordPress an array, if we unserialize it? Salesforce wants it to be an imploded string.
				if ( is_array( maybe_unserialize( $object[ $wordpress_field ] ) ) ) {
					// if the WordPress field is a list of capabilities (the source field is wp_capabilities), we need to get the array keys from WordPress to send them to Salesforce.
					if ( $this->wpdb->prefix . 'capabilities' === $wordpress_field ) {
						$object[ $wordpress_field ] = implode( $this->array_delimiter, array_keys( $object[ $wordpress_field ] ) );
					} else {
						$object[ $wordpress_field ] = implode( $this->array_delimiter, $object[ $wordpress_field ] );
					}
				}

				if ( isset( $salesforce_field_type ) ) {
					// Is the Salesforce field a date, and is the WordPress value a valid date?
					// According to https://salesforce.stackexchange.com/questions/57032/date-format-with-salesforce-rest-api.
					if ( in_array( $salesforce_field_type, $this->date_types_from_salesforce, true ) ) {
						if ( '' === $object[ $wordpress_field ] ) {
							$object[ $wordpress_field ] = null;
						} else {
							if ( false !== strtotime( $object[ $wordpress_field ] ) ) {
								$timestamp = strtotime( $object[ $wordpress_field ] );
							} else {
								$timestamp = $object[ $wordpress_field ];
							}
							if ( 'datetime' === $salesforce_field_type ) {
								$object[ $wordpress_field ] = date_i18n( 'c', $timestamp );
								$object[ $wordpress_field ] = /** @scrutinizer ignore-call */ date_i18n( 'c', $timestamp );
							} else {
								$object[ $wordpress_field ] = date_i18n( 'Y-m-d', $timestamp );
							}
						}
					}

					// Boolean SF fields only want real boolean values. NULL is also not allowed.
					if ( 'boolean' === $salesforce_field_type ) {
						$object[ $wordpress_field ] = (bool) $object[ $wordpress_field ];
					}
				}

				$params[ $salesforce_field ] = $object[ $wordpress_field ];

				// If the field is a key in Salesforce, remove it from $params to avoid upsert errors from Salesforce,
				// but still put its name in the params array so we can check for it later.
				if ( '1' === $fieldmap['is_key'] ) {
					if ( ! $use_soap ) {
						unset( $params[ $salesforce_field ] );
					}
					$params['key'] = array(
						'salesforce_field' => $salesforce_field,
						'wordpress_field'  => $wordpress_field,
						'value'            => $object[ $wordpress_field ],
					);
				}

				// If the field is a prematch in Salesforce, put its name in the params array so we can check for it later.
				if ( '1' === $fieldmap['is_prematch'] ) {
					$params['prematch'] = array(
						'salesforce_field' => $salesforce_field,
						'wordpress_field'  => $wordpress_field,
						'value'            => $object[ $wordpress_field ],
					);
				}

				// Skip fields that aren't being pushed to Salesforce.
				if ( ! in_array( $fieldmap['direction'], array_values( $this->direction_wordpress ), true ) ) {
					// The trigger is a WordPress trigger, but the fieldmap direction is not a WordPress direction.
					unset( $params[ $salesforce_field ] );
				}

				// I think it's good to over-mention that updateable is really how the Salesforce api spells it.
				// Skip fields that aren't updateable when mapping params because Salesforce will error otherwise.
				// This happens after dealing with the field types because key and prematch should still be available to the plugin, even if the values are not updateable in Salesforce.
				if ( 1 !== (int) $fieldmap['salesforce_field']['updateable'] ) {
					unset( $params[ $salesforce_field ] );
				}

				// This case means the following:
				// this field is expected by the fieldmap
				// Salesforce's api reports that this field is required
				// we do not have a WordPress value for this field, or it's empty
				// it also means the field has not been unset by prematch, updateable, key, or directional flags prior to this check.
				// When this happens, we should flag that we're missing a required Salesforce field.
				if ( in_array( $salesforce_field, $params, true ) && false === filter_var( $fieldmap['salesforce_field']['nillable'], FILTER_VALIDATE_BOOLEAN ) && ( ! isset( $object[ $wordpress_field ] ) || '' === $object[ $wordpress_field ] ) ) {
					$has_missing_required_salesforce_field = true;
				}

				// we don't need a continue with the unset methods because there's no array being created down here.
			} elseif ( in_array( $trigger, $salesforce_haystack, true ) ) {

				// A Salesforce event caused this.

				if ( isset( $salesforce_field_type ) && isset( $object[ $salesforce_field ] ) && ! is_null( $object[ $salesforce_field ] ) ) {
					// Salesforce provides multipicklist values as a delimited string. If the
					// destination field in WordPress accepts multiple values, explode the string into an array and then serialize it.
					if ( in_array( $salesforce_field_type, $this->array_types_from_salesforce, true ) ) {
						$object[ $salesforce_field ] = explode( $this->array_delimiter, $object[ $salesforce_field ] );
						// if the WordPress field is a list of capabilities (the destination field is wp_capabilities), we need to set the array for WordPress to save it.
						if ( $this->wpdb->prefix . 'capabilities' === $wordpress_field ) {
							$capabilities = array();
							foreach ( $object[ $salesforce_field ] as $capability ) {
								$capabilities[ $capability ] = true;
							}
							$object[ $salesforce_field ] = $capabilities;
						}
					}

					// Handle specific data types from Salesforce.
					switch ( $salesforce_field_type ) {
						case ( in_array( $salesforce_field_type, $this->date_types_from_salesforce, true ) ):
							$format = get_option( 'date_format', 'U' );
							$format = /** @scrutinizer ignore-call */ get_option( 'date_format', 'U' );
							if ( isset( $fieldmap['wordpress_field']['type'] ) && 'datetime' === $fieldmap['wordpress_field']['type'] ) {
								$format = 'Y-m-d H:i:s';
							}
							if ( 'tribe_events' === $mapping['wordpress_object'] && class_exists( 'Tribe__Events__Main' ) ) {
								$format = 'Y-m-d H:i:s';
							}
							if ( 'datetime' === $salesforce_field_type ) {
								// Note: the Salesforce REST API appears to always return datetimes as GMT values. We should retrieve them that way, then format them to deal with them in WordPress appropriately.
								// We should not do any converting unless it's a datetime, because if it's a date, Salesforce stores it as midnight. We don't want to convert that.
								$object[ $salesforce_field ] = get_date_from_gmt( $object[ $salesforce_field ], 'Y-m-d\TH:i:s\Z' ); // convert from GMT to local date/time based on WordPress time zone setting.
								$object[ $salesforce_field ] = /** @scrutinizer ignore-call */ get_date_from_gmt( $object[ $salesforce_field ], 'Y-m-d\TH:i:s\Z' ); // convert from GMT to local date/time based on WordPress time zone setting.
							}
							$object[ $salesforce_field ] = date_i18n( $format, strtotime( $object[ $salesforce_field ] ) );
							break;
						case ( in_array( $salesforce_field_type, $this->int_types_from_salesforce, true ) ):
							$object[ $salesforce_field ] = isset( $object[ $salesforce_field ] ) ? (int) $object[ $salesforce_field ] : 0;
							break;
						case 'text':
							$object[ $salesforce_field ] = (string) $object[ $salesforce_field ];
							break;
						case 'url':
							$object[ $salesforce_field ] = esc_url_raw( $object[ $salesforce_field ] );
							$object[ $salesforce_field ] = /** @scrutinizer ignore-call */ esc_url_raw( $object[ $salesforce_field ] );
							break;
					}
				}

				// Make an array because we need to store the methods for each field as well.
				if ( isset( $object[ $salesforce_field ] ) ) {
					$params[ $wordpress_field ]          = array();
					$params[ $wordpress_field ]['value'] = $object[ $salesforce_field ];
				} elseif ( is_null( $object[ $salesforce_field ] ) ) {
					// Salesforce returns blank fields as null fields; set them to blank.
					$params[ $wordpress_field ]          = array();
					$params[ $wordpress_field ]['value'] = '';
				} else {
					// prevent fields that don't exist from being passed.
					continue;
				}

				// If the field is a key in Salesforce, disregard since this is caused by a Salesforce event. We're setting up data to be stored in WordPress here, and WordPress is not concerned with external key designations in Salesforce.

				// If the field is a prematch in Salesforce, put its name in the params array so we can check for it later.
				if ( '1' === $fieldmap['is_prematch'] ) {
					$params['prematch'] = array(
						'salesforce_field' => $salesforce_field,
						'wordpress_field'  => $wordpress_field,
						'value'            => $object[ $salesforce_field ],
						'method_match'     => isset( $fieldmap['wordpress_field']['methods']['match'] ) ? $fieldmap['wordpress_field']['methods']['match'] : $fieldmap['wordpress_field']['methods']['read'],
						'method_read'      => $fieldmap['wordpress_field']['methods']['read'],
						'method_create'    => $fieldmap['wordpress_field']['methods']['create'],
						'method_update'    => $fieldmap['wordpress_field']['methods']['update'],
					);
				}

				// Skip fields that aren't being pulled from Salesforce.
				if ( ! in_array( $fieldmap['direction'], array_values( $this->direction_salesforce ), true ) ) {
					// The trigger is a Salesforce trigger, but the fieldmap direction is not a Salesforce direction.
					unset( $params[ $wordpress_field ] );
					// we also need to continue here, so it doesn't create an empty array below for fields that are WordPress -> Salesforce only.
					continue;
				}

				// Skip fields that aren't editable by the plugin when mapping params.
				// By default this is only the WordPress object's ID field.
				// @see $wordpress->object_fields() method and object_sync_for_salesforce_wordpress_field_is_editable filter.
				if ( isset( $fieldmap['wordpress_field']['editable'] ) && true !== (bool) $fieldmap['wordpress_field']['editable'] ) {
					unset( $params[ $wordpress_field ] );
					continue;
				}

				switch ( $trigger ) {
					case $this->sync_sf_create:
						$params[ $wordpress_field ]['method_modify'] = $fieldmap['wordpress_field']['methods']['create'];
						break;
					case $this->sync_sf_update:
						$params[ $wordpress_field ]['method_modify'] = $fieldmap['wordpress_field']['methods']['update'];
						break;
					case $this->sync_sf_delete:
						$params[ $wordpress_field ]['method_modify'] = $fieldmap['wordpress_field']['methods']['delete'];
						break;
				}

				// always allow for the delete and read methods.
				$params[ $wordpress_field ]['method_delete'] = $fieldmap['wordpress_field']['methods']['delete'];
				$params[ $wordpress_field ]['method_read']   = $fieldmap['wordpress_field']['methods']['read'];

			} // End if() statement.
		} // End foreach() loop.

		if ( true === $has_missing_required_salesforce_field ) {
			update_option( $this->option_prefix . 'missing_required_data_id_' . $object[ $object_id_field ], true, false );
   update_option( $this->option_prefix . 'missing_required_data_id_' . $object[ $object_id_field ], true, false );
			return array();
		}

		return $params;

	}

	/**
	 * Prepare field map data for use
	 *
	 * @param array  $mappings Array of fieldmaps.
	 * @param string $record_type Optional Salesforce record type to see if it is allowed or not.
	 *
	 * @return array $mappings Associative array of field maps ready to use
	 */
	private function prepare_fieldmap_data( $mappings, $record_type = '' ) {
		foreach ( $mappings as $id => $mapping ) {
			$mappings[ $id ]['salesforce_record_types_allowed'] = isset( $mapping['salesforce_record_types_allowed'] ) ? maybe_unserialize( $mapping['salesforce_record_types_allowed'] ) : array();
			$mappings[ $id ]['salesforce_record_types_allowed'] = isset( $mapping['salesforce_record_types_allowed'] ) ? /** @scrutinizer ignore-call */ maybe_unserialize( $mapping['salesforce_record_types_allowed'] ) : array();
			$mappings[ $id ]['fields']                          = isset( $mapping['fields'] ) ? maybe_unserialize( $mapping['fields'] ) : array();
			$mappings[ $id ]['sync_triggers']                   = isset( $mapping['sync_triggers'] ) ? maybe_unserialize( $mapping['sync_triggers'] ) : array();
			// format the sync triggers.
			$sync_triggers                    = $this->maybe_upgrade_sync_triggers( $mappings[ $id ]['sync_triggers'], $mapping['version'], $mapping['id'] );
			$mappings[ $id ]['sync_triggers'] = $sync_triggers;
			if ( '' !== $record_type && ! in_array( $record_type, $mappings[ $id ]['salesforce_record_types_allowed'], true ) ) {
				unset( $mappings[ $id ] );
			}
		}
		return $mappings;
	}

	/**
	 * Format the sync trigger values for storage in the database.
	 *
	 * @param array  $sync_triggers Array of sync triggers.
	 * @param string $mapping_version the database version when the fieldmmap was saved.
	 * @param int    $mapping_id if the fieldmap already exists, this is the ID.
	 *
	 * @return array $sync_triggers possibly updated array of sync triggers.
	 */
	private function maybe_upgrade_sync_triggers( $sync_triggers, $mapping_version, $mapping_id = '' ) {
		// in v2 of this plugin, we replaced the bit flags with strings to make them more legible.
		if ( version_compare( $mapping_version, '2.0.0', '<' ) ) {
			// check if the triggers stored in the database are up to date. if not, update them.
			$intersect = array_intersect( $sync_triggers, array_merge( $this->wordpress_events, $this->salesforce_events ) );
			if ( empty( $intersect ) ) {
				$updated_sync_triggers = array();
				foreach ( $sync_triggers as $key => $value ) {
					if ( $value === (string) $this->sync_off_v1 ) {
						$updated_sync_triggers[] = $this->sync_off;
					}
					if ( $value === (string) $this->sync_wordpress_create_v1 ) {
						$updated_sync_triggers[] = $this->sync_wordpress_create;
					}
					if ( $value === (string) $this->sync_wordpress_update_v1 ) {
						$updated_sync_triggers[] = $this->sync_wordpress_update;
					}
					if ( $value === (string) $this->sync_wordpress_delete_v1 ) {
						$updated_sync_triggers[] = $this->sync_wordpress_delete;
					}
					if ( $value === (string) $this->sync_sf_create_v1 ) {
						$updated_sync_triggers[] = $this->sync_sf_create;
					}
					if ( $value === (string) $this->sync_sf_update_v1 ) {
						$updated_sync_triggers[] = $this->sync_sf_update;
					}
					if ( $value === (string) $this->sync_sf_delete_v1 ) {
						$updated_sync_triggers[] = $this->sync_sf_delete;
					}
				}

				if ( '' !== $mapping_id ) {
					// format the fieldmap update query for the database.
					$data = array();
					if ( ! empty( $updated_sync_triggers ) ) {
						$data['sync_triggers'] = array();
						foreach ( $updated_sync_triggers as $key => $value ) {
							$updated_sync_triggers[ $key ] = esc_html( $updated_sync_triggers[ $key ] );
							$updated_sync_triggers[ $key ] = /** @scrutinizer ignore-call */ esc_html( $updated_sync_triggers[ $key ] );
						}
						$data['sync_triggers'] = maybe_serialize( $updated_sync_triggers );
						$data['sync_triggers'] = /** @scrutinizer ignore-call */ maybe_serialize( $updated_sync_triggers );
						$data['version']       = get_option( $this->option_prefix . 'db_version', $this->version );
						$data['version']       = /** @scrutinizer ignore-call */ get_option( $this->option_prefix . 'db_version', $this->version );
						// update the sync triggers and version fieldmap in the database.
						$update = $this->wpdb->update(
							$this->fieldmap_table,
							$data,
							array(
								'id' => $mapping_id,
							)
						);
					}
				}
			}
		}
		// whether it was updated or not, this is the array of sync triggers.
		return $sync_triggers;
	}

	/**
	 * Check object map table to see if there have been any failed object map create attempts
	 *
	 * @return array $errors Associative array of rows that failed to finish from either system
	 */
	public function get_failed_object_maps() {
		$table                 = $this->object_map_table;
		$errors                = array();
		$items_per_page        = (int) get_option( $this->option_prefix . 'errors_per_page', 50 );
		$items_per_page        = (int) /** @scrutinizer ignore-call */ get_option( $this->option_prefix . 'errors_per_page', 50 );
		$current_error_page    = isset( $_GET['error_page'] ) ? (int) $_GET['error_page'] : 1;
		$offset                = ( $current_error_page * $items_per_page ) - $items_per_page;
		$all_errors            = $this->wpdb->get_results( "SELECT * FROM {$table} WHERE salesforce_id LIKE 'tmp_sf_%' OR wordpress_id LIKE 'tmp_wp_%' OR last_sync_status = 0 LIMIT {$offset}, {$items_per_page}", ARRAY_A );

		$errors_total          = $this->wpdb->get_var( "SELECT COUNT(`id`) FROM {$table} WHERE salesforce_id LIKE 'tmp_sf_%' OR wordpress_id LIKE 'tmp_wp_%' OR last_sync_status = 0" );
		$errors['total_pages'] = ceil( $errors_total / $items_per_page );
		$errors['pagination']  = paginate_links(
		$errors['pagination']  = /** @scrutinizer ignore-call */ paginate_links(
			array(
				'base'      => add_query_arg( 'error_page', '%#%' ),
				'base'      => /** @scrutinizer ignore-call */ add_query_arg( 'error_page', '%#%' ),
				'format'    => '',
				'total'     => $errors['total_pages'],
				'prev_text' => __( '&laquo;', 'object-sync-for-salesforce' ),
				'prev_text' => /** @scrutinizer ignore-call */ __( '&laquo;', 'object-sync-for-salesforce' ),
				'next_text' => __( '&raquo;', 'object-sync-for-salesforce' ),
				'current'   => $current_error_page,
			)
		);
		$errors['error_page']  = $current_error_page;
		$errors['all_errors']  = $all_errors;
		$errors['total']       = $errors_total;
		return $errors;
	}

	/**
	 * Check object map table to see if there have been any failed object map create attempts
	 *
	 * @param int $id The ID of a desired mapping.
	 * @return array $error Associative array of single row that failed to finish based on id
	 */
	public function get_failed_object_map( $id ) {
		$table     = $this->object_map_table;
		$error     = array();
		$error_row = $this->wpdb->get_row( 'SELECT * FROM ' . $table . ' WHERE id = "' . $id . '"', ARRAY_A );

		if ( ! empty( $error_row ) ) {
			$error = $error_row;
		}
		return $error;
	}

}

MinnPost / object-sync-for-salesforce

Object_Sync_Sf_Mapping::update_object_map() A last analyzed 2024-10-09 02:21 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Object_Sync_Sf_Mapping::update_object_map() A
last analyzed 2024-10-09 02:21 UTC
