Jetpack_Sync_Full

Complexity

Total Complexity

6

Size/Duplication

Total Lines	45
Duplicated Lines	55.56 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	4
Bugs	1	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	start()	0	7	1
A	enqueue_all_constants()	0	4	1
A	enqueue_all_posts()	14	15	2
A	enqueue_all_comments()	11	11	2

<?php

/**
 * This class does a full resync of the database by 
 * enqueuing an outbound action for every single object
 * that we care about.
 * 
 * This class contains a few non-obvious optimisations that should be explained:
 * - we fire an action called jp_full_sync_start so that WPCOM can erase the contents of the cached database
 * - for each object type, we obtain a full list of object IDs to sync via a single API call (hoping that since they're ints, they can all fit in RAM)
 * - we load the full objects for those IDs in chunks of Jetpack_Sync_Full::$array_chunk_size (to reduce the number of MySQL calls)
 * - we fire a trigger for the entire array which the Jetpack_Sync_Client then serializes and queues.
 */

class Jetpack_Sync_Full {
	static $array_chunk_size = 5;

The visibility should be declared for property $array_chunk_size.

	function start() {
		// TODO

Comment refers to a TODO task

		do_action( 'jp_full_sync_start' );
		$this->enqueue_all_constants();
		$this->enqueue_all_posts();
		$this->enqueue_all_comments();
	}

	private function enqueue_all_constants() {
		$client = Jetpack_Sync_Client::getInstance();
		$client->force_sync_constants();
	}

	private function enqueue_all_posts() {
		global $wpdb;

		// I hope this is never bigger than RAM...
		$post_ids = $wpdb->get_col( "SELECT id FROM $wpdb->posts");

		// Request posts in groups of N for efficiency
		$chunked_post_ids = array_chunk( $post_ids, self::$array_chunk_size );

		// Send each chunk as an array of objects
		foreach ( $chunked_post_ids as $chunk ) {
			$posts = get_posts( array( 'post__in' => $chunk, 'post_status' => 'any' ) );
			do_action( 'jp_full_sync_posts', $posts );
		}
	}

	private function enqueue_all_comments() {
		global $wpdb;

		$comment_ids = $wpdb->get_col( "SELECT comment_id FROM $wpdb->comments");
		$chunked_comment_ids = array_chunk( $comment_ids, self::$array_chunk_size );

		foreach ( $chunked_comment_ids as $chunk ) {
			$comments = get_comments( array( 'comment__in' => $chunk ) );
			do_action( 'jp_full_sync_comments', $comments );
		}
	}
	
}