Wordlift\Dataset\Sync_Service

Complexity

Total Complexity

8

Size/Duplication

Total Lines	135
Duplicated Lines	25.93 %

Coupling/Cohesion

Components	2
Dependencies	6

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
A	start()	0	6	1
A	request_cancel()	0	5	1
A	next()	20	20	1
A	count()	15	15	1
A	info()	0	3	1
A	sync_item()	0	28	2

<?php

namespace Wordlift\Dataset;

use Wordlift\Api\Api_Service;
use Wordlift\Jsonld\Jsonld_Service;

class Sync_Service {

	/**
	 * @var \Wordlift_Log_Service
	 */
	private $log;

	/**
	 * @var Api_Service
	 */
	private $api_service;

	/**
	 * @var Jsonld_Service
	 */
	private $jsonld_service;

	/**
	 * @var Sync_Background_Process
	 */
	private $sync_background_process;

	/**
	 * Constructor.
	 *
	 * @param $api_service Api_Service The {@link Api_Service} used to communicate with the remote APIs.
	 * @param $jsonld_service Jsonld_Service The {@link Jsonld_Service} used to generate the JSON-LD to post to the remote API.
	 */
	public function __construct( $api_service, $jsonld_service ) {

		$this->log = \Wordlift_Log_Service::get_logger( get_class() );

		$this->api_service    = $api_service;
		$this->jsonld_service = $jsonld_service;

		// You need to initialize this early, otherwise the Background Process isn't registered in AJAX calls.
		$this->sync_background_process = new Sync_Background_Process( $this );;

	}

	/**
	 * Starts a new synchronization.
	 */
	public function start() {

		// Create the Sync_Background_Process.
		$this->sync_background_process->start();

	}

	/**
	 * Request to cancel a background process.
	 */
	public function request_cancel() {

		$this->sync_background_process->request_cancel();

	}

	/**
	 * Get the next post ID to synchronize or NULL if there are no posts to synchronize.
	 *
	 * @return string|null The post ID or NULL if there are no posts to synchronize.
	 */
	public function next() {

This method seems to be duplicated in your project.

		global $wpdb;

		// Limit the query to the allowed post types.
		$post_type_in = implode( "','", array_map( 'esc_sql', \Wordlift_Entity_Service::valid_entity_post_types() ) );

		// Get the next post ID.
		return $wpdb->get_var( "
			SELECT p.ID
				FROM $wpdb->posts p
				LEFT JOIN $wpdb->postmeta pm
					ON pm.post_id = p.ID
						AND pm.meta_key = '_wl_synced_gmt'				
				WHERE p.post_status = 'publish'
					AND p.post_type IN ( '$post_type_in' )
					AND ( pm.meta_value IS NULL OR pm.meta_value < p.post_modified_gmt )
				ORDER BY p.post_modified_gmt DESC
				LIMIT 1
			" );
	}

	public function count() {

This method seems to be duplicated in your project.

		global $wpdb;
		$post_type_in = implode( "','", array_map( 'esc_sql', \Wordlift_Entity_Service::valid_entity_post_types() ) );

		return $wpdb->get_var( "
			SELECT COUNT( 1 )
				FROM $wpdb->posts p
				LEFT JOIN $wpdb->postmeta pm
					ON pm.post_id = p.ID
						AND pm.meta_key = '_wl_synced_gmt'				
				WHERE p.post_status = 'publish'
					AND p.post_type IN ( '$post_type_in' )
					AND ( pm.meta_value IS NULL OR pm.meta_value < p.post_modified_gmt )
			" );
	}

	public function info() {
		return Sync_Background_Process::get_state();
	}

	public function sync_item( $post_id ) {

		// Get the JSON-LD for the specified post and its entity URI.
		$jsonld_value = $this->jsonld_service->get( Jsonld_Service::TYPE_POST, $post_id );
		$uri          = get_post_meta( $post_id, 'entity_url', true );
		$jsonld       = wp_json_encode( $jsonld_value );

		// Make a request to the remote endpoint.
		$response = $this->api_service->request(
			'POST', '/middleware/dataset?uri=' . rawurlencode( $uri ),
			array( 'Content-Type' => 'application/ld+json' ),
			$jsonld );

		// Update the sync date in case of success, otherwise log an error.
		if ( $response->is_success() ) {
			update_post_meta( $post_id, '_wl_synced_gmt', current_time( 'mysql', 1 ) );

			return true;
		} else {
			// @@todo: should we put a limit retry here?
			$response_dump = var_export( $response, true );
			$this->log->error(
				sprintf( 'An error occurred while synchronizing the data for post ID %d: %s', $post_id, $response_dump ) );

			return false;
		}

	}

}