Module::get_next_chunk() - Code Metrics - Inspection of "remove usages of the deprecated constant" - Automattic/jetpack - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — add/deprecate_JETPACK_MASTER_U... ( 16e35b...747f29 )

unknown

created 2020-09-24 17:55 UTC

Module::get_next_chunk() A

↳ Parent: Module

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
nc	1
nop	3
dl	0
loc	15
rs	9.7666
c	0
b	0
f	0

<?php
/**
 * A base abstraction of a sync module.
 *
 * @package automattic/jetpack-sync
 */

namespace Automattic\Jetpack\Sync\Modules;

use Automattic\Jetpack\Sync\Listener;
use Automattic\Jetpack\Sync\Replicastore;
use Automattic\Jetpack\Sync\Sender;
use Automattic\Jetpack\Sync\Settings;

/**
 * Basic methods implemented by Jetpack Sync extensions.
 *
 * @abstract
 */
abstract class Module {
	/**
	 * Number of items per chunk when grouping objects for performance reasons.
	 *
	 * @access public
	 *
	 * @var int
	 */
	const ARRAY_CHUNK_SIZE = 10;

	/**
	 * Sync module name.
	 *
	 * @access public
	 *
	 * @return string
	 */
	abstract public function name();

	/**
	 * The id field in the database.
	 *
	 * @access public
	 *
	 * @return string
	 */
	public function id_field() {
		return 'ID';
	}

	/**
	 * The table in the database.
	 *
	 * @access public
	 *
	 * @return string|bool
	 */
	public function table_name() {
		return false;
	}

	// phpcs:disable VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable

	/**
	 * Retrieve a sync object by its ID.
	 *
	 * @access public
	 *
	 * @param string $object_type Type of the sync object.
	 * @param int    $id          ID of the sync object.
	 * @return mixed Object, or false if the object is invalid.
	 */
	public function get_object_by_id( $object_type, $id ) {
		return false;
	}

	/**
	 * Initialize callables action listeners.
	 * Override these to set up listeners and set/reset data/defaults.
	 *
	 * @access public
	 *
	 * @param callable $callable Action handler callable.
	 */
	public function init_listeners( $callable ) {
	}

	/**
	 * Initialize module action listeners for full sync.
	 *
	 * @access public
	 *
	 * @param callable $callable Action handler callable.
	 */
	public function init_full_sync_listeners( $callable ) {
	}

	/**
	 * Initialize the module in the sender.
	 *
	 * @access public
	 */
	public function init_before_send() {
	}

	/**
	 * Set module defaults.
	 *
	 * @access public
	 */
	public function set_defaults() {
	}

	/**
	 * Perform module cleanup.
	 * Usually triggered when uninstalling the plugin.
	 *
	 * @access public
	 */
	public function reset_data() {
	}

	/**
	 * Enqueue the module actions for full sync.
	 *
	 * @access public
	 *
	 * @param array   $config               Full sync configuration for this sync module.
	 * @param int     $max_items_to_enqueue Maximum number of items to enqueue.
	 * @param boolean $state                True if full sync has finished enqueueing this module, false otherwise.
	 * @return array  Number of actions enqueued, and next module state.
	 */
	public function enqueue_full_sync_actions( $config, $max_items_to_enqueue, $state ) {
		// In subclasses, return the number of actions enqueued, and next module state (true == done).
		return array( null, true );
	}

	/**
	 * Retrieve an estimated number of actions that will be enqueued.
	 *
	 * @access public
	 *
	 * @param array $config Full sync configuration for this sync module.
	 * @return array Number of items yet to be enqueued.
	 */
	public function estimate_full_sync_actions( $config ) {
		// In subclasses, return the number of items yet to be enqueued.
		return null;
	}

	// phpcs:enable VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable

	/**
	 * Retrieve the actions that will be sent for this module during a full sync.
	 *
	 * @access public
	 *
	 * @return array Full sync actions of this module.
	 */
	public function get_full_sync_actions() {
		return array();
	}

	/**
	 * Get the number of actions that we care about.
	 *
	 * @access protected
	 *
	 * @param array $action_names     Action names we're interested in.
	 * @param array $actions_to_count Unfiltered list of actions we want to count.
	 * @return array Number of actions that we're interested in.
	 */
	protected function count_actions( $action_names, $actions_to_count ) {
		return count( array_intersect( $action_names, $actions_to_count ) );
	}

	/**
	 * Calculate the checksum of one or more values.
	 *
	 * @access protected
	 *
	 * @param mixed $values Values to calculate checksum for.
	 * @param bool  $sort If $values should have ksort called on it.
	 * @return int The checksum.
	 */
	protected function get_check_sum( $values, $sort = true ) {
		// Associative array order changes the generated checksum value.
		if ( $sort && is_array( $values ) ) {
			$this->recursive_ksort( $values );
		}
		return crc32( wp_json_encode( jetpack_json_wrap( $values ) ) );
	}

	/**
	 * Recursively call ksort on an Array
	 *
	 * @param array $values Array.
	 */
	private function recursive_ksort( &$values ) {
		ksort( $values );
		foreach ( $values as &$value ) {
			if ( is_array( $value ) ) {
				$this->recursive_ksort( $value );
			}
		}
	}

	/**
	 * Whether a particular checksum in a set of checksums is valid.
	 *
	 * @access protected
	 *
	 * @param array  $sums_to_check Array of checksums.
	 * @param string $name          Name of the checksum.
	 * @param int    $new_sum       Checksum to compare against.
	 * @return boolean Whether the checksum is valid.
	 */
	protected function still_valid_checksum( $sums_to_check, $name, $new_sum ) {
		if ( isset( $sums_to_check[ $name ] ) && $sums_to_check[ $name ] === $new_sum ) {
			return true;
		}

		return false;
	}

	/**
	 * Enqueue all items of a sync type as an action.
	 *
	 * @access protected
	 *
	 * @param string  $action_name          Name of the action.
	 * @param string  $table_name           Name of the database table.
	 * @param string  $id_field             Name of the ID field in the database.
	 * @param string  $where_sql            The SQL WHERE clause to filter to the desired items.
	 * @param int     $max_items_to_enqueue Maximum number of items to enqueue in the same time.
	 * @param boolean $state                Whether enqueueing has finished.
	 * @return array Array, containing the number of chunks and TRUE, indicating enqueueing has finished.
	 */
	protected function enqueue_all_ids_as_action( $action_name, $table_name, $id_field, $where_sql, $max_items_to_enqueue, $state ) {
		global $wpdb;

		if ( ! $where_sql ) {
			$where_sql = '1 = 1';
		}

		$items_per_page        = 1000;
		$page                  = 1;
		$chunk_count           = 0;
		$previous_interval_end = $state ? $state : '~0';
		$listener              = Listener::get_instance();

		// Count down from max_id to min_id so we get newest posts/comments/etc first.
		// phpcs:ignore WordPress.CodeAnalysis.AssignmentInCondition.FoundInWhileCondition, WordPress.DB.PreparedSQL.InterpolatedNotPrepared
		while ( $ids = $wpdb->get_col( "SELECT {$id_field} FROM {$table_name} WHERE {$where_sql} AND {$id_field} < {$previous_interval_end} ORDER BY {$id_field} DESC LIMIT {$items_per_page}" ) ) {
			// Request posts in groups of N for efficiency.
			$chunked_ids = array_chunk( $ids, self::ARRAY_CHUNK_SIZE );

			// If we hit our row limit, process and return.
			if ( $chunk_count + count( $chunked_ids ) >= $max_items_to_enqueue ) {
				$remaining_items_count                      = $max_items_to_enqueue - $chunk_count;
				$remaining_items                            = array_slice( $chunked_ids, 0, $remaining_items_count );
				$remaining_items_with_previous_interval_end = $this->get_chunks_with_preceding_end( $remaining_items, $previous_interval_end );
				$listener->bulk_enqueue_full_sync_actions( $action_name, $remaining_items_with_previous_interval_end );

				$last_chunk = end( $remaining_items );
				return array( $remaining_items_count + $chunk_count, end( $last_chunk ) );
			}
			$chunked_ids_with_previous_end = $this->get_chunks_with_preceding_end( $chunked_ids, $previous_interval_end );

			$listener->bulk_enqueue_full_sync_actions( $action_name, $chunked_ids_with_previous_end );

			$chunk_count += count( $chunked_ids );
			$page++;
			// The $ids are ordered in descending order.
			$previous_interval_end = end( $ids );
		}

		if ( $wpdb->last_error ) {
			// return the values that were passed in so all these chunks get retried.
			return array( $max_items_to_enqueue, $state );
		}

		return array( $chunk_count, true );
	}

	/**
	 * Given the Module Full Sync Configuration and Status return the next chunk of items to send.
	 *
	 * @param array $config This module Full Sync configuration.
	 * @param array $status This module Full Sync status.
	 * @param int   $chunk_size Chunk size.
	 *
	 * @return array|object|null
	 */
	public function get_next_chunk( $config, $status, $chunk_size ) {
		// phpcs:disable WordPress.DB.PreparedSQL.InterpolatedNotPrepared
		global $wpdb;
		return $wpdb->get_col(
			<<<SQL
SELECT {$this->id_field()}
FROM {$wpdb->{$this->table_name()}}
WHERE {$this->get_where_sql( $config )}
AND {$this->id_field()} < {$status['last_sent']}
ORDER BY {$this->id_field()}
DESC LIMIT {$chunk_size}
SQL
		);
		// phpcs:enable WordPress.DB.PreparedSQL.InterpolatedNotPrepared
	}

	/**
	 * Return the initial last sent object.
	 *
	 * @return string|array initial status.
	 */
	public function get_initial_last_sent() {
		return '~0';
	}

	/**
	 * Immediately send all items of a sync type as an action.
	 *
	 * @access protected
	 *
	 * @param string $config Full sync configuration for this module.
	 * @param array  $status the current module full sync status.
	 * @param float  $send_until timestamp until we want this request to send full sync events.
	 *
	 * @return array Status, the module full sync status updated.
	 */
	public function send_full_sync_actions( $config, $status, $send_until ) {
		global $wpdb;

		if ( empty( $status['last_sent'] ) ) {
			$status['last_sent'] = $this->get_initial_last_sent();
		}

		$limits = Settings::get_setting( 'full_sync_limits' )[ $this->name() ];

		$chunks_sent = 0;
		// phpcs:ignore WordPress.CodeAnalysis.AssignmentInCondition.FoundInWhileCondition
		while ( $objects = $this->get_next_chunk( $config, $status, $limits['chunk_size'] ) ) {
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
			if ( $chunks_sent++ === $limits['max_chunks'] || microtime( true ) >= $send_until ) {
				return $status;
			}

			$result = $this->send_action( 'jetpack_full_sync_' . $this->name(), array( $objects, $status['last_sent'] ) );

			if ( is_wp_error( $result ) || $wpdb->last_error ) {
				return $status;
			}
			// The $ids are ordered in descending order.
			$status['last_sent'] = end( $objects );
			$status['sent']     += count( $objects );
		}

		if ( ! $wpdb->last_error ) {
			$status['finished'] = true;
		}

		return $status;
	}


	/**
	 * Immediately sends a single item without firing or enqueuing it
	 *
	 * @param string $action_name The action.
	 * @param array  $data The data associated with the action.

	 */
	public function send_action( $action_name, $data = null ) {
		$sender = Sender::get_instance();
		return $sender->send_action( $action_name, $data );
	}

	/**
	 * Retrieve chunk IDs with previous interval end.
	 *
	 * @access protected
	 *
	 * @param array $chunks                All remaining items.
	 * @param int   $previous_interval_end The last item from the previous interval.
	 * @return array Chunk IDs with the previous interval end.
	 */
	protected function get_chunks_with_preceding_end( $chunks, $previous_interval_end ) {
		$chunks_with_ends = array();
		foreach ( $chunks as $chunk ) {
			$chunks_with_ends[] = array(
				'ids'          => $chunk,
				'previous_end' => $previous_interval_end,
			);
			// Chunks are ordered in descending order.
			$previous_interval_end = end( $chunk );
		}
		return $chunks_with_ends;
	}

	/**
	 * Get metadata of a particular object type within the designated meta key whitelist.
	 *
	 * @access protected
	 *
	 * @todo Refactor to use $wpdb->prepare() on the SQL query.
	 *
	 * @param array  $ids                Object IDs.
	 * @param string $meta_type          Meta type.
	 * @param array  $meta_key_whitelist Meta key whitelist.
	 * @return array Unserialized meta values.
	 */
	protected function get_metadata( $ids, $meta_type, $meta_key_whitelist ) {
		global $wpdb;
		$table = _get_meta_table( $meta_type );
		$id    = $meta_type . '_id';
		if ( ! $table ) {
			return array();
		}

		$private_meta_whitelist_sql = "'" . implode( "','", array_map( 'esc_sql', $meta_key_whitelist ) ) . "'";

		return array_map(
			array( $this, 'unserialize_meta' ),
			$wpdb->get_results(
				// phpcs:disable WordPress.DB.PreparedSQL.InterpolatedNotPrepared, WordPress.DB.PreparedSQL.NotPrepared
				"SELECT $id, meta_key, meta_value, meta_id FROM $table WHERE $id IN ( " . implode( ',', wp_parse_id_list( $ids ) ) . ' )' .
				" AND meta_key IN ( $private_meta_whitelist_sql ) ",
				// phpcs:enable WordPress.DB.PreparedSQL.InterpolatedNotPrepared, WordPress.DB.PreparedSQL.NotPrepared
				OBJECT
			)
		);
	}

	/**
	 * Initialize listeners for the particular meta type.
	 *
	 * @access public
	 *
	 * @param string   $meta_type Meta type.
	 * @param callable $callable  Action handler callable.
	 */
	public function init_listeners_for_meta_type( $meta_type, $callable ) {
		add_action( "added_{$meta_type}_meta", $callable, 10, 4 );
		add_action( "updated_{$meta_type}_meta", $callable, 10, 4 );
		add_action( "deleted_{$meta_type}_meta", $callable, 10, 4 );
	}

	/**
	 * Initialize meta whitelist handler for the particular meta type.
	 *
	 * @access public
	 *
	 * @param string   $meta_type         Meta type.
	 * @param callable $whitelist_handler Action handler callable.
	 */
	public function init_meta_whitelist_handler( $meta_type, $whitelist_handler ) {
		add_filter( "jetpack_sync_before_enqueue_added_{$meta_type}_meta", $whitelist_handler );
		add_filter( "jetpack_sync_before_enqueue_updated_{$meta_type}_meta", $whitelist_handler );
		add_filter( "jetpack_sync_before_enqueue_deleted_{$meta_type}_meta", $whitelist_handler );
	}

	/**
	 * Retrieve the term relationships for the specified object IDs.
	 *
	 * @access protected
	 *
	 * @todo This feels too specific to be in the abstract sync Module class. Move it?
	 *
	 * @param array $ids Object IDs.
	 * @return array Term relationships - object ID and term taxonomy ID pairs.
	 */
	protected function get_term_relationships( $ids ) {
		global $wpdb;

		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
		return $wpdb->get_results( "SELECT object_id, term_taxonomy_id FROM $wpdb->term_relationships WHERE object_id IN ( " . implode( ',', wp_parse_id_list( $ids ) ) . ' )', OBJECT );
	}

	/**
	 * Unserialize the value of a meta object, if necessary.
	 *
	 * @access public
	 *
	 * @param object $meta Meta object.
	 * @return object Meta object with possibly unserialized value.
	 */
	public function unserialize_meta( $meta ) {
		$meta->meta_value = maybe_unserialize( $meta->meta_value );
		return $meta;
	}

	/**
	 * Retrieve a set of objects by their IDs.
	 *
	 * @access public
	 *
	 * @param string $object_type Object type.
	 * @param array  $ids         Object IDs.
	 * @return array Array of objects.
	 */
	public function get_objects_by_id( $object_type, $ids ) {
		if ( empty( $ids ) || empty( $object_type ) ) {
			return array();
		}

		$objects = array();
		foreach ( (array) $ids as $id ) {
			$object = $this->get_object_by_id( $object_type, $id );

			// Only add object if we have the object.
			if ( $object ) {
				$objects[ $id ] = $object;
			}
		}

		return $objects;
	}

	/**
	 * Gets a list of minimum and maximum object ids for each batch based on the given batch size.
	 *
	 * @access public
	 *
	 * @param int         $batch_size The batch size for objects.
	 * @param string|bool $where_sql  The sql where clause minus 'WHERE', or false if no where clause is needed.
	 *
	 * @return array|bool An array of min and max ids for each batch. FALSE if no table can be found.
	 */
	public function get_min_max_object_ids_for_batches( $batch_size, $where_sql = false ) {
		global $wpdb;

		if ( ! $this->table_name() ) {
			return false;
		}

		$results      = array();
		$table        = $wpdb->{$this->table_name()};
		$current_max  = 0;
		$current_min  = 1;
		$id_field     = $this->id_field();
		$replicastore = new Replicastore();

		$total = $replicastore->get_min_max_object_id(
			$id_field,
			$table,
			$where_sql,

			false
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
		);

		while ( $total->max > $current_max ) {
			$where  = $where_sql ?
				$where_sql . " AND $id_field > $current_max" :
				"$id_field > $current_max";
			$result = $replicastore->get_min_max_object_id(
				$id_field,
				$table,
				$where,
				$batch_size
			);
			if ( empty( $result->min ) && empty( $result->max ) ) {
				// Our query produced no min and max. We can assume the min from the previous query,
				// and the total max we found in the initial query.
				$current_max = (int) $total->max;
				$result      = (object) array(
					'min' => $current_min,
					'max' => $current_max,
				);
			} else {
				$current_min = (int) $result->min;
				$current_max = (int) $result->max;
			}
			$results[] = $result;
		}

		return $results;
	}

	/**
	 * Return Total number of objects.
	 *
	 * @param array $config Full Sync config.
	 *
	 * @return int total
	 */
	public function total( $config ) {
		global $wpdb;
		$table = $wpdb->{$this->table_name()};
		$where = $this->get_where_sql( $config );

		// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
		return $wpdb->get_var( "SELECT COUNT(*) FROM $table WHERE $where" );
	}

	/**
	 * Retrieve the WHERE SQL clause based on the module config.
	 *
	 * @access public
	 *
	 * @param array $config Full sync configuration for this sync module.
	 * @return string WHERE SQL clause, or `null` if no comments are specified in the module config.
	 */
	public function get_where_sql( $config ) { // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
		return '1=1';
	}

}


1			<?php
2			/**
3			* A base abstraction of a sync module.
4			*
5			* @package automattic/jetpack-sync
6			*/
7
8			namespace Automattic\Jetpack\Sync\Modules;
9
10			use Automattic\Jetpack\Sync\Listener;
11			use Automattic\Jetpack\Sync\Replicastore;
12			use Automattic\Jetpack\Sync\Sender;
13			use Automattic\Jetpack\Sync\Settings;
14
15			/**
16			* Basic methods implemented by Jetpack Sync extensions.
17			*
18			* @abstract
19			*/
20			abstract class Module {
21			/**
22			* Number of items per chunk when grouping objects for performance reasons.
23			*
24			* @access public
25			*
26			* @var int
27			*/
28			const ARRAY_CHUNK_SIZE = 10;
29
30			/**
31			* Sync module name.
32			*
33			* @access public
34			*
35			* @return string
36			*/
37			abstract public function name();
38
39			/**
40			* The id field in the database.
41			*
42			* @access public
43			*
44			* @return string
45			*/
46			public function id_field() {
47			return 'ID';
48			}
49
50			/**
51			* The table in the database.
52			*
53			* @access public
54			*
55			* @return string\|bool
56			*/
57			public function table_name() {
58			return false;
59			}
60
61			// phpcs:disable VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
62
63			/**
64			* Retrieve a sync object by its ID.
65			*
66			* @access public
67			*
68			* @param string $object_type Type of the sync object.
69			* @param int $id ID of the sync object.
70			* @return mixed Object, or false if the object is invalid.
71			*/
72			public function get_object_by_id( $object_type, $id ) {
73			return false;
74			}
75
76			/**
77			* Initialize callables action listeners.
78			* Override these to set up listeners and set/reset data/defaults.
79			*
80			* @access public
81			*
82			* @param callable $callable Action handler callable.
83			*/
84			public function init_listeners( $callable ) {
85			}
86
87			/**
88			* Initialize module action listeners for full sync.
89			*
90			* @access public
91			*
92			* @param callable $callable Action handler callable.
93			*/
94			public function init_full_sync_listeners( $callable ) {
95			}
96
97			/**
98			* Initialize the module in the sender.
99			*
100			* @access public
101			*/
102			public function init_before_send() {
103			}
104
105			/**
106			* Set module defaults.
107			*
108			* @access public
109			*/
110			public function set_defaults() {
111			}
112
113			/**
114			* Perform module cleanup.
115			* Usually triggered when uninstalling the plugin.
116			*
117			* @access public
118			*/
119			public function reset_data() {
120			}
121
122			/**
123			* Enqueue the module actions for full sync.
124			*
125			* @access public
126			*
127			* @param array $config Full sync configuration for this sync module.
128			* @param int $max_items_to_enqueue Maximum number of items to enqueue.
129			* @param boolean $state True if full sync has finished enqueueing this module, false otherwise.
130			* @return array Number of actions enqueued, and next module state.
131			*/
132			public function enqueue_full_sync_actions( $config, $max_items_to_enqueue, $state ) {
133			// In subclasses, return the number of actions enqueued, and next module state (true == done).
134			return array( null, true );
135			}
136
137			/**
138			* Retrieve an estimated number of actions that will be enqueued.
139			*
140			* @access public
141			*
142			* @param array $config Full sync configuration for this sync module.
143			* @return array Number of items yet to be enqueued.
144			*/
145			public function estimate_full_sync_actions( $config ) {
146			// In subclasses, return the number of items yet to be enqueued.
147			return null;
148			}
149
150			// phpcs:enable VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
151
152			/**
153			* Retrieve the actions that will be sent for this module during a full sync.
154			*
155			* @access public
156			*
157			* @return array Full sync actions of this module.
158			*/
159			public function get_full_sync_actions() {
160			return array();
161			}
162
163			/**
164			* Get the number of actions that we care about.
165			*
166			* @access protected
167			*
168			* @param array $action_names Action names we're interested in.
169			* @param array $actions_to_count Unfiltered list of actions we want to count.
170			* @return array Number of actions that we're interested in.
171			*/
172			protected function count_actions( $action_names, $actions_to_count ) {
173			return count( array_intersect( $action_names, $actions_to_count ) );
174			}
175
176			/**
177			* Calculate the checksum of one or more values.
178			*
179			* @access protected
180			*
181			* @param mixed $values Values to calculate checksum for.
182			* @param bool $sort If $values should have ksort called on it.
183			* @return int The checksum.
184			*/
185			protected function get_check_sum( $values, $sort = true ) {
186			// Associative array order changes the generated checksum value.
187			if ( $sort && is_array( $values ) ) {
188			$this->recursive_ksort( $values );
189			}
190			return crc32( wp_json_encode( jetpack_json_wrap( $values ) ) );
191			}
192
193			/**
194			* Recursively call ksort on an Array
195			*
196			* @param array $values Array.
197			*/
198			private function recursive_ksort( &$values ) {
199			ksort( $values );
200			foreach ( $values as &$value ) {
201			if ( is_array( $value ) ) {
202			$this->recursive_ksort( $value );
203			}
204			}
205			}
206
207			/**
208			* Whether a particular checksum in a set of checksums is valid.
209			*
210			* @access protected
211			*
212			* @param array $sums_to_check Array of checksums.
213			* @param string $name Name of the checksum.
214			* @param int $new_sum Checksum to compare against.
215			* @return boolean Whether the checksum is valid.
216			*/
217			protected function still_valid_checksum( $sums_to_check, $name, $new_sum ) {
218			if ( isset( $sums_to_check[ $name ] ) && $sums_to_check[ $name ] === $new_sum ) {
219			return true;
220			}
221
222			return false;
223			}
224
225			/**
226			* Enqueue all items of a sync type as an action.
227			*
228			* @access protected
229			*
230			* @param string $action_name Name of the action.
231			* @param string $table_name Name of the database table.
232			* @param string $id_field Name of the ID field in the database.
233			* @param string $where_sql The SQL WHERE clause to filter to the desired items.
234			* @param int $max_items_to_enqueue Maximum number of items to enqueue in the same time.
235			* @param boolean $state Whether enqueueing has finished.
236			* @return array Array, containing the number of chunks and TRUE, indicating enqueueing has finished.
237			*/
238			protected function enqueue_all_ids_as_action( $action_name, $table_name, $id_field, $where_sql, $max_items_to_enqueue, $state ) {
239			global $wpdb;
240
241			if ( ! $where_sql ) {
242			$where_sql = '1 = 1';
243			}
244
245			$items_per_page = 1000;
246			$page = 1;
247			$chunk_count = 0;
248			$previous_interval_end = $state ? $state : '~0';
249			$listener = Listener::get_instance();
250
251			// Count down from max_id to min_id so we get newest posts/comments/etc first.
252			// phpcs:ignore WordPress.CodeAnalysis.AssignmentInCondition.FoundInWhileCondition, WordPress.DB.PreparedSQL.InterpolatedNotPrepared
253			while ( $ids = $wpdb->get_col( "SELECT {$id_field} FROM {$table_name} WHERE {$where_sql} AND {$id_field} < {$previous_interval_end} ORDER BY {$id_field} DESC LIMIT {$items_per_page}" ) ) {
254			// Request posts in groups of N for efficiency.
255			$chunked_ids = array_chunk( $ids, self::ARRAY_CHUNK_SIZE );
256
257			// If we hit our row limit, process and return.
258			if ( $chunk_count + count( $chunked_ids ) >= $max_items_to_enqueue ) {
259			$remaining_items_count = $max_items_to_enqueue - $chunk_count;
260			$remaining_items = array_slice( $chunked_ids, 0, $remaining_items_count );
261			$remaining_items_with_previous_interval_end = $this->get_chunks_with_preceding_end( $remaining_items, $previous_interval_end );
262			$listener->bulk_enqueue_full_sync_actions( $action_name, $remaining_items_with_previous_interval_end );
263
264			$last_chunk = end( $remaining_items );
265			return array( $remaining_items_count + $chunk_count, end( $last_chunk ) );
266			}
267			$chunked_ids_with_previous_end = $this->get_chunks_with_preceding_end( $chunked_ids, $previous_interval_end );
268
269			$listener->bulk_enqueue_full_sync_actions( $action_name, $chunked_ids_with_previous_end );
270
271			$chunk_count += count( $chunked_ids );
272			$page++;
273			// The $ids are ordered in descending order.
274			$previous_interval_end = end( $ids );
275			}
276
277			if ( $wpdb->last_error ) {
278			// return the values that were passed in so all these chunks get retried.
279			return array( $max_items_to_enqueue, $state );
280			}
281
282			return array( $chunk_count, true );
283			}
284
285			/**
286			* Given the Module Full Sync Configuration and Status return the next chunk of items to send.
287			*
288			* @param array $config This module Full Sync configuration.
289			* @param array $status This module Full Sync status.
290			* @param int $chunk_size Chunk size.
291			*
292			* @return array\|object\|null
293			*/
294			public function get_next_chunk( $config, $status, $chunk_size ) {
295			// phpcs:disable WordPress.DB.PreparedSQL.InterpolatedNotPrepared
296			global $wpdb;
297			return $wpdb->get_col(
298			<<<SQL
299			SELECT {$this->id_field()}
300			FROM {$wpdb->{$this->table_name()}}
301			WHERE {$this->get_where_sql( $config )}
302			AND {$this->id_field()} < {$status['last_sent']}
303			ORDER BY {$this->id_field()}
304			DESC LIMIT {$chunk_size}
305			SQL
306			);
307			// phpcs:enable WordPress.DB.PreparedSQL.InterpolatedNotPrepared
308			}
309
310			/**
311			* Return the initial last sent object.
312			*
313			* @return string\|array initial status.
314			*/
315			public function get_initial_last_sent() {
316			return '~0';
317			}
318
319			/**
320			* Immediately send all items of a sync type as an action.
321			*
322			* @access protected
323			*
324			* @param string $config Full sync configuration for this module.
325			* @param array $status the current module full sync status.
326			* @param float $send_until timestamp until we want this request to send full sync events.
327			*
328			* @return array Status, the module full sync status updated.
329			*/
330			public function send_full_sync_actions( $config, $status, $send_until ) {
331			global $wpdb;
332
333			if ( empty( $status['last_sent'] ) ) {
334			$status['last_sent'] = $this->get_initial_last_sent();
335			}
336
337			$limits = Settings::get_setting( 'full_sync_limits' )[ $this->name() ];
338
339			$chunks_sent = 0;
340			// phpcs:ignore WordPress.CodeAnalysis.AssignmentInCondition.FoundInWhileCondition
341			while ( $objects = $this->get_next_chunk( $config, $status, $limits['chunk_size'] ) ) {
			0 ignored issues – show Documentation introduced 2019-11-27 12:13 UTC by Report Bug Copy Issue Report `$config` is of type `string`, but the function expects a `array`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
342			if ( $chunks_sent++ === $limits['max_chunks'] \|\| microtime( true ) >= $send_until ) {
343			return $status;
344			}
345
346			$result = $this->send_action( 'jetpack_full_sync_' . $this->name(), array( $objects, $status['last_sent'] ) );
347
348			if ( is_wp_error( $result ) \|\| $wpdb->last_error ) {
349			return $status;
350			}
351			// The $ids are ordered in descending order.
352			$status['last_sent'] = end( $objects );
353			$status['sent'] += count( $objects );
354			}
355
356			if ( ! $wpdb->last_error ) {
357			$status['finished'] = true;
358			}
359
360			return $status;
361			}
362
363
364			/**
365			* Immediately sends a single item without firing or enqueuing it
366			*
367			* @param string $action_name The action.
368			* @param array $data The data associated with the action.
			0 ignored issues – show Documentation introduced 2020-01-18 00:34 UTC by Report Bug Copy Issue Report Should the type for parameter `$data` not be `array\|null`? This check looks for `@param` annotations where the type inferred by our type inference engine differs from the declared type. It makes a suggestion as to what type it considers more descriptive. Most often this is a case of a parameter that can be null in addition to its declared types. Loading history...
369			*/
370			public function send_action( $action_name, $data = null ) {
371			$sender = Sender::get_instance();
372			return $sender->send_action( $action_name, $data );
373			}
374
375			/**
376			* Retrieve chunk IDs with previous interval end.
377			*
378			* @access protected
379			*
380			* @param array $chunks All remaining items.
381			* @param int $previous_interval_end The last item from the previous interval.
382			* @return array Chunk IDs with the previous interval end.
383			*/
384			protected function get_chunks_with_preceding_end( $chunks, $previous_interval_end ) {
385			$chunks_with_ends = array();
386			foreach ( $chunks as $chunk ) {
387			$chunks_with_ends[] = array(
388			'ids' => $chunk,
389			'previous_end' => $previous_interval_end,
390			);
391			// Chunks are ordered in descending order.
392			$previous_interval_end = end( $chunk );
393			}
394			return $chunks_with_ends;
395			}
396
397			/**
398			* Get metadata of a particular object type within the designated meta key whitelist.
399			*
400			* @access protected
401			*
402			* @todo Refactor to use $wpdb->prepare() on the SQL query.
403			*
404			* @param array $ids Object IDs.
405			* @param string $meta_type Meta type.
406			* @param array $meta_key_whitelist Meta key whitelist.
407			* @return array Unserialized meta values.
408			*/
409			protected function get_metadata( $ids, $meta_type, $meta_key_whitelist ) {
410			global $wpdb;
411			$table = _get_meta_table( $meta_type );
412			$id = $meta_type . '_id';
413			if ( ! $table ) {
414			return array();
415			}
416
417			$private_meta_whitelist_sql = "'" . implode( "','", array_map( 'esc_sql', $meta_key_whitelist ) ) . "'";
418
419			return array_map(
420			array( $this, 'unserialize_meta' ),
421			$wpdb->get_results(
422			// phpcs:disable WordPress.DB.PreparedSQL.InterpolatedNotPrepared, WordPress.DB.PreparedSQL.NotPrepared
423			"SELECT $id, meta_key, meta_value, meta_id FROM $table WHERE $id IN ( " . implode( ',', wp_parse_id_list( $ids ) ) . ' )' .
424			" AND meta_key IN ( $private_meta_whitelist_sql ) ",
425			// phpcs:enable WordPress.DB.PreparedSQL.InterpolatedNotPrepared, WordPress.DB.PreparedSQL.NotPrepared
426			OBJECT
427			)
428			);
429			}
430
431			/**
432			* Initialize listeners for the particular meta type.
433			*
434			* @access public
435			*
436			* @param string $meta_type Meta type.
437			* @param callable $callable Action handler callable.
438			*/
439			public function init_listeners_for_meta_type( $meta_type, $callable ) {
440			add_action( "added_{$meta_type}_meta", $callable, 10, 4 );
441			add_action( "updated_{$meta_type}_meta", $callable, 10, 4 );
442			add_action( "deleted_{$meta_type}_meta", $callable, 10, 4 );
443			}
444
445			/**
446			* Initialize meta whitelist handler for the particular meta type.
447			*
448			* @access public
449			*
450			* @param string $meta_type Meta type.
451			* @param callable $whitelist_handler Action handler callable.
452			*/
453			public function init_meta_whitelist_handler( $meta_type, $whitelist_handler ) {
454			add_filter( "jetpack_sync_before_enqueue_added_{$meta_type}_meta", $whitelist_handler );
455			add_filter( "jetpack_sync_before_enqueue_updated_{$meta_type}_meta", $whitelist_handler );
456			add_filter( "jetpack_sync_before_enqueue_deleted_{$meta_type}_meta", $whitelist_handler );
457			}
458
459			/**
460			* Retrieve the term relationships for the specified object IDs.
461			*
462			* @access protected
463			*
464			* @todo This feels too specific to be in the abstract sync Module class. Move it?
465			*
466			* @param array $ids Object IDs.
467			* @return array Term relationships - object ID and term taxonomy ID pairs.
468			*/
469			protected function get_term_relationships( $ids ) {
470			global $wpdb;
471
472			// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
473			return $wpdb->get_results( "SELECT object_id, term_taxonomy_id FROM $wpdb->term_relationships WHERE object_id IN ( " . implode( ',', wp_parse_id_list( $ids ) ) . ' )', OBJECT );
474			}
475
476			/**
477			* Unserialize the value of a meta object, if necessary.
478			*
479			* @access public
480			*
481			* @param object $meta Meta object.
482			* @return object Meta object with possibly unserialized value.
483			*/
484			public function unserialize_meta( $meta ) {
485			$meta->meta_value = maybe_unserialize( $meta->meta_value );
486			return $meta;
487			}
488
489			/**
490			* Retrieve a set of objects by their IDs.
491			*
492			* @access public
493			*
494			* @param string $object_type Object type.
495			* @param array $ids Object IDs.
496			* @return array Array of objects.
497			*/
498			public function get_objects_by_id( $object_type, $ids ) {
499			if ( empty( $ids ) \|\| empty( $object_type ) ) {
500			return array();
501			}
502
503			$objects = array();
504			foreach ( (array) $ids as $id ) {
505			$object = $this->get_object_by_id( $object_type, $id );
506
507			// Only add object if we have the object.
508			if ( $object ) {
509			$objects[ $id ] = $object;
510			}
511			}
512
513			return $objects;
514			}
515
516			/**
517			* Gets a list of minimum and maximum object ids for each batch based on the given batch size.
518			*
519			* @access public
520			*
521			* @param int $batch_size The batch size for objects.
522			* @param string\|bool $where_sql The sql where clause minus 'WHERE', or false if no where clause is needed.
523			*
524			* @return array\|bool An array of min and max ids for each batch. FALSE if no table can be found.
525			*/
526			public function get_min_max_object_ids_for_batches( $batch_size, $where_sql = false ) {
527			global $wpdb;
528
529			if ( ! $this->table_name() ) {
530			return false;
531			}
532
533			$results = array();
534			$table = $wpdb->{$this->table_name()};
535			$current_max = 0;
536			$current_min = 1;
537			$id_field = $this->id_field();
538			$replicastore = new Replicastore();
539
540			$total = $replicastore->get_min_max_object_id(
541			$id_field,
542			$table,
543			$where_sql,
			0 ignored issues – show Bug introduced 2020-01-18 00:34 UTC by Report Bug Copy Issue Report It seems like `$where_sql` defined by parameter `$where_sql` on line 526 can also be of type `boolean`; however, `Automattic\Jetpack\Sync\...get_min_max_object_id()` does only seem to accept `string`, maybe add an additional type check? This check looks at variables that have been passed in as parameters and are passed out again to other methods. If the outgoing method call has stricter type requirements than the method itself, an issue is raised. An additional type check may prevent trouble. Loading history...
544			false
			0 ignored issues – show Documentation introduced 2020-01-18 00:34 UTC by Report Bug Copy Issue Report `false` is of type `boolean`, but the function expects a `integer`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
545			);
546
547			while ( $total->max > $current_max ) {
548			$where = $where_sql ?
549			$where_sql . " AND $id_field > $current_max" :
550			"$id_field > $current_max";
551			$result = $replicastore->get_min_max_object_id(
552			$id_field,
553			$table,
554			$where,
555			$batch_size
556			);
557			if ( empty( $result->min ) && empty( $result->max ) ) {
558			// Our query produced no min and max. We can assume the min from the previous query,
559			// and the total max we found in the initial query.
560			$current_max = (int) $total->max;
561			$result = (object) array(
562			'min' => $current_min,
563			'max' => $current_max,
564			);
565			} else {
566			$current_min = (int) $result->min;
567			$current_max = (int) $result->max;
568			}
569			$results[] = $result;
570			}
571
572			return $results;
573			}
574
575			/**
576			* Return Total number of objects.
577			*
578			* @param array $config Full Sync config.
579			*
580			* @return int total
581			*/
582			public function total( $config ) {
583			global $wpdb;
584			$table = $wpdb->{$this->table_name()};
585			$where = $this->get_where_sql( $config );
586
587			// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
588			return $wpdb->get_var( "SELECT COUNT(*) FROM $table WHERE $where" );
589			}
590
591			/**
592			* Retrieve the WHERE SQL clause based on the module config.
593			*
594			* @access public
595			*
596			* @param array $config Full sync configuration for this sync module.
597			* @return string WHERE SQL clause, or `null` if no comments are specified in the module config.
598			*/
599			public function get_where_sql( $config ) { // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
600			return '1=1';
601			}
602
603			}
604

Automattic / jetpack

Push — add/deprecate_JETPACK_MASTER_U... ( 16e35b...747f29 )

Module::get_next_chunk() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like