insideout10 / wordlift-plugin

src/includes/class-wordlift-log-service.php

Doc Comments +6 added lines

@@ -73,6 +73,9 @@ 
 	}
 
 
+	/**
+	 * @param string $class_name
+	 */
 	public static function get_logger( $class_name ) {
 
 		return new Wordlift_Log_Service( $class_name );
@@ -119,6 +122,9 @@ 
 
 	}
 
+	/**
+	 * @param Exception $exception
+	 */
 	public function error( $message, $exception ) {
 
 		$this->log( self::ERROR, $message );

Indentation +109 added lines, -109 removed lines

@@ -7,146 +7,146 @@
  */
 class Wordlift_Log_Service {
 
-	const MESSAGE_TEMPLATE = '%-6s [%-40.40s] %s';
-
-	const ERROR = 4;
-	const WARN = 3;
-	const INFO = 2;
-	const DEBUG = 1;
-	const TRACE = 0;
-
-	/**
-	 * The class related to the logs.
-	 *
-	 * @since  1.0.0
-	 * @access private
-	 * @var string $class_name The class related to the logs.
-	 */
-	private $class_name;
-
-	/**
-	 * The log levels for printing in log lines.
-	 *
-	 * @var array $levels An array of log levels.
-	 */
-	private static $levels = array(
-		self::TRACE => 'TRACE',
-		self::DEBUG => 'DEBUG',
-		self::INFO  => 'INFO',
-		self::WARN  => 'WARN',
-		self::ERROR => 'ERROR',
-	);
-
-	/**
-	 * A singleton instance for legacy logging.
-	 *
-	 * @since  3.10.0
-	 * @access private
-	 * @var \Wordlift_Log_Service $instance A singleton instance for legacy logging.
-	 */
-	private static $instance = null;
+    const MESSAGE_TEMPLATE = '%-6s [%-40.40s] %s';
+
+    const ERROR = 4;
+    const WARN = 3;
+    const INFO = 2;
+    const DEBUG = 1;
+    const TRACE = 0;
+
+    /**
+     * The class related to the logs.
+     *
+     * @since  1.0.0
+     * @access private
+     * @var string $class_name The class related to the logs.
+     */
+    private $class_name;
+
+    /**
+     * The log levels for printing in log lines.
+     *
+     * @var array $levels An array of log levels.
+     */
+    private static $levels = array(
+        self::TRACE => 'TRACE',
+        self::DEBUG => 'DEBUG',
+        self::INFO  => 'INFO',
+        self::WARN  => 'WARN',
+        self::ERROR => 'ERROR',
+    );
+
+    /**
+     * A singleton instance for legacy logging.
+     *
+     * @since  3.10.0
+     * @access private
+     * @var \Wordlift_Log_Service $instance A singleton instance for legacy logging.
+     */
+    private static $instance = null;
 
-	/**
-	 * Create an instance of the Log service.
-	 *
-	 * @param string $class_name The class related to the logs.
-	 *
-	 * @since 1.0.0
-	 *
-	 */
-	public function __construct( $class_name ) {
+    /**
+     * Create an instance of the Log service.
+     *
+     * @param string $class_name The class related to the logs.
+     *
+     * @since 1.0.0
+     *
+     */
+    public function __construct( $class_name ) {
 
-		$this->class_name = $class_name;
+        $this->class_name = $class_name;
 
-	}
+    }
 
-	/**
-	 * Get the ROOT logger.
-	 *
-	 * @return \Wordlift_Log_Service A singleton instance for legacy logging.
-	 * @since 3.10.0
-	 *
-	 */
-	public static function get_instance() {
+    /**
+     * Get the ROOT logger.
+     *
+     * @return \Wordlift_Log_Service A singleton instance for legacy logging.
+     * @since 3.10.0
+     *
+     */
+    public static function get_instance() {
 
-		return self::$instance ?: self::$instance = new Wordlift_Log_Service( 'ROOT' );
-	}
+        return self::$instance ?: self::$instance = new Wordlift_Log_Service( 'ROOT' );
+    }
 
 
-	public static function get_logger( $class_name ) {
+    public static function get_logger( $class_name ) {
 
-		return new Wordlift_Log_Service( $class_name );
+        return new Wordlift_Log_Service( $class_name );
 
-	}
+    }
 
-	/**
-	 * Log a message.
-	 *
-	 * @param string $level The log level.
-	 * @param string $message The message to log.
-	 *
-	 * @since 1.0.0
-	 *
-	 */
-	public function log( $level, $message ) {
+    /**
+     * Log a message.
+     *
+     * @param string $level The log level.
+     * @param string $message The message to log.
+     *
+     * @since 1.0.0
+     *
+     */
+    public function log( $level, $message ) {
 
-		// echo( sprintf( self::MESSAGE_TEMPLATE . "\n", self::$levels[ $level ], $this->class_name, is_array( $message ) ? implode( ', ', $message ) : $message ) );
+        // echo( sprintf( self::MESSAGE_TEMPLATE . "\n", self::$levels[ $level ], $this->class_name, is_array( $message ) ? implode( ', ', $message ) : $message ) );
 
-		// Bail out if `WL_DEBUG` isn't defined or it's false.
-		if ( ! defined( 'WL_DEBUG' ) || false === WL_DEBUG ) {
-			return;
-		}
+        // Bail out if `WL_DEBUG` isn't defined or it's false.
+        if ( ! defined( 'WL_DEBUG' ) || false === WL_DEBUG ) {
+            return;
+        }
 
-		// Bail out if WordLift log level isn't defined, and WP debug is disabled.
-		if ( ! defined( 'WL_LOG_LEVEL' ) && $level < self::ERROR
-		     && ( ! defined( 'WP_DEBUG' ) || false === WP_DEBUG ) ) {
-			return;
-		}
+        // Bail out if WordLift log level isn't defined, and WP debug is disabled.
+        if ( ! defined( 'WL_LOG_LEVEL' ) && $level < self::ERROR
+             && ( ! defined( 'WP_DEBUG' ) || false === WP_DEBUG ) ) {
+            return;
+        }
 
-		// Bail out if the log message is below the minimum log level.
-		if ( defined( 'WL_LOG_LEVEL' ) && $level < intval( WL_LOG_LEVEL ) ) {
-			return;
-		}
+        // Bail out if the log message is below the minimum log level.
+        if ( defined( 'WL_LOG_LEVEL' ) && $level < intval( WL_LOG_LEVEL ) ) {
+            return;
+        }
 
-		// Bail out if there's a filter and we don't match it.
-		$class_name = wp_slash( $this->class_name );
-		if ( defined( 'WL_LOG_FILTER' ) && 1 !== preg_match( "/(^|,)$class_name($|,)/", WL_LOG_FILTER ) ) {
-			return;
-		}
+        // Bail out if there's a filter and we don't match it.
+        $class_name = wp_slash( $this->class_name );
+        if ( defined( 'WL_LOG_FILTER' ) && 1 !== preg_match( "/(^|,)$class_name($|,)/", WL_LOG_FILTER ) ) {
+            return;
+        }
 
-		// Finally log the message.
-		error_log( sprintf( self::MESSAGE_TEMPLATE, self::$levels[ $level ], $this->class_name, is_array( $message ) ? implode( ', ', $message ) : $message ) );
+        // Finally log the message.
+        error_log( sprintf( self::MESSAGE_TEMPLATE, self::$levels[ $level ], $this->class_name, is_array( $message ) ? implode( ', ', $message ) : $message ) );
 
-	}
+    }
 
-	public function error( $message, $exception ) {
+    public function error( $message, $exception ) {
 
-		$this->log( self::ERROR, $message );
+        $this->log( self::ERROR, $message );
 
-	}
+    }
 
-	public function warn( $message ) {
+    public function warn( $message ) {
 
-		$this->log( self::WARN, $message );
+        $this->log( self::WARN, $message );
 
-	}
+    }
 
-	public function info( $message ) {
+    public function info( $message ) {
 
-		$this->log( self::INFO, $message );
+        $this->log( self::INFO, $message );
 
-	}
+    }
 
-	public function debug( $message ) {
+    public function debug( $message ) {
 
-		$this->log( self::DEBUG, $message );
+        $this->log( self::DEBUG, $message );
 
-	}
+    }
 
-	public function trace( $message ) {
+    public function trace( $message ) {
 
-		$this->log( self::TRACE, $message );
+        $this->log( self::TRACE, $message );
 
-	}
+    }
 
 }

Spacing +22 added lines, -22 removed lines

@@ -54,7 +54,7 @@ 
 	 * @since 1.0.0
 	 *
 	 */
-	public function __construct( $class_name ) {
+	public function __construct($class_name) {
 
 		$this->class_name = $class_name;
 
@@ -69,13 +69,13 @@ 
 	 */
 	public static function get_instance() {
 
-		return self::$instance ?: self::$instance = new Wordlift_Log_Service( 'ROOT' );
+		return self::$instance ?: self::$instance = new Wordlift_Log_Service('ROOT');
 	}
 
 
-	public static function get_logger( $class_name ) {
+	public static function get_logger($class_name) {
 
-		return new Wordlift_Log_Service( $class_name );
+		return new Wordlift_Log_Service($class_name);
 
 	}
 
@@ -88,64 +88,64 @@ 
 	 * @since 1.0.0
 	 *
 	 */
-	public function log( $level, $message ) {
+	public function log($level, $message) {
 
 		// echo( sprintf( self::MESSAGE_TEMPLATE . "\n", self::$levels[ $level ], $this->class_name, is_array( $message ) ? implode( ', ', $message ) : $message ) );
 
 		// Bail out if `WL_DEBUG` isn't defined or it's false.
-		if ( ! defined( 'WL_DEBUG' ) || false === WL_DEBUG ) {
+		if ( ! defined('WL_DEBUG') || false === WL_DEBUG) {
 			return;
 		}
 
 		// Bail out if WordLift log level isn't defined, and WP debug is disabled.
-		if ( ! defined( 'WL_LOG_LEVEL' ) && $level < self::ERROR
-		     && ( ! defined( 'WP_DEBUG' ) || false === WP_DEBUG ) ) {
+		if ( ! defined('WL_LOG_LEVEL') && $level < self::ERROR
+		     && ( ! defined('WP_DEBUG') || false === WP_DEBUG)) {
 			return;
 		}
 
 		// Bail out if the log message is below the minimum log level.
-		if ( defined( 'WL_LOG_LEVEL' ) && $level < intval( WL_LOG_LEVEL ) ) {
+		if (defined('WL_LOG_LEVEL') && $level < intval(WL_LOG_LEVEL)) {
 			return;
 		}
 
 		// Bail out if there's a filter and we don't match it.
-		$class_name = wp_slash( $this->class_name );
-		if ( defined( 'WL_LOG_FILTER' ) && 1 !== preg_match( "/(^|,)$class_name($|,)/", WL_LOG_FILTER ) ) {
+		$class_name = wp_slash($this->class_name);
+		if (defined('WL_LOG_FILTER') && 1 !== preg_match("/(^|,)$class_name($|,)/", WL_LOG_FILTER)) {
 			return;
 		}
 
 		// Finally log the message.
-		error_log( sprintf( self::MESSAGE_TEMPLATE, self::$levels[ $level ], $this->class_name, is_array( $message ) ? implode( ', ', $message ) : $message ) );
+		error_log(sprintf(self::MESSAGE_TEMPLATE, self::$levels[$level], $this->class_name, is_array($message) ? implode(', ', $message) : $message));
 
 	}
 
-	public function error( $message, $exception ) {
+	public function error($message, $exception) {
 
-		$this->log( self::ERROR, $message );
+		$this->log(self::ERROR, $message);
 
 	}
 
-	public function warn( $message ) {
+	public function warn($message) {
 
-		$this->log( self::WARN, $message );
+		$this->log(self::WARN, $message);
 
 	}
 
-	public function info( $message ) {
+	public function info($message) {
 
-		$this->log( self::INFO, $message );
+		$this->log(self::INFO, $message);
 
 	}
 
-	public function debug( $message ) {
+	public function debug($message) {
 
-		$this->log( self::DEBUG, $message );
+		$this->log(self::DEBUG, $message);
 
 	}
 
-	public function trace( $message ) {
+	public function trace($message) {
 
-		$this->log( self::TRACE, $message );
+		$this->log(self::TRACE, $message);
 
 	}
 

src/wordlift/dataset/class-sync-object-adapter.php

Doc Comments +1 added lines

@@ -24,6 +24,7 @@
 	 * @param int $type One of Object_Type_Enum.
 	 * @param int $object_id A post or term id.
 	 * @param Jsonld_Service
+	 * @param Jsonld_Service $jsonld_service
 	 *
 	 * @throws \Exception
 	 */

Indentation +54 added lines, -54 removed lines

@@ -7,78 +7,78 @@
 
 class Sync_Object_Adapter {
 
-	const HASH = '_wl_jsonld_hash';
+    const HASH = '_wl_jsonld_hash';
 
-	private $object_id;
+    private $object_id;
 
-	private $type;
+    private $type;
 
-	private $jsonld_service;
+    private $jsonld_service;
 
-	private $get_meta;
-	private $update_meta;
+    private $get_meta;
+    private $update_meta;
 
-	/**
-	 * Sync_Object_Adapter constructor.
-	 *
-	 * @param int $type One of Object_Type_Enum.
-	 * @param int $object_id A post or term id.
-	 * @param Jsonld_Service
-	 *
-	 * @throws \Exception
-	 */
-	function __construct( $type, $object_id, $jsonld_service ) {
+    /**
+     * Sync_Object_Adapter constructor.
+     *
+     * @param int $type One of Object_Type_Enum.
+     * @param int $object_id A post or term id.
+     * @param Jsonld_Service
+     *
+     * @throws \Exception
+     */
+    function __construct( $type, $object_id, $jsonld_service ) {
 
-		$this->type = filter_var( $type, FILTER_VALIDATE_INT, array(
-			'options' => array(
-				'min_range' => 0,
-				'max_range' => 1,
-			),
-		) );
+        $this->type = filter_var( $type, FILTER_VALIDATE_INT, array(
+            'options' => array(
+                'min_range' => 0,
+                'max_range' => 1,
+            ),
+        ) );
 
-		$this->object_id = filter_var( $object_id, FILTER_VALIDATE_INT );
+        $this->object_id = filter_var( $object_id, FILTER_VALIDATE_INT );
 
-		if ( null === $this->type ) {
-			throw new \Exception( 'Invalid $type.' );
-		}
-		if ( null === $this->object_id ) {
-			throw new \Exception( 'Invalid $object.' );
-		}
+        if ( null === $this->type ) {
+            throw new \Exception( 'Invalid $type.' );
+        }
+        if ( null === $this->object_id ) {
+            throw new \Exception( 'Invalid $object.' );
+        }
 
-		$this->jsonld_service = $jsonld_service;
+        $this->jsonld_service = $jsonld_service;
 
-		if ( Object_Type_Enum::POST === $this->type ) {
-			$this->get_meta    = 'get_post_meta';
-			$this->update_meta = 'update_post_meta';
-		} else {
-			$this->get_meta    = 'get_term_meta';
-			$this->update_meta = 'update_term_meta';
-		}
-	}
+        if ( Object_Type_Enum::POST === $this->type ) {
+            $this->get_meta    = 'get_post_meta';
+            $this->update_meta = 'update_post_meta';
+        } else {
+            $this->get_meta    = 'get_term_meta';
+            $this->update_meta = 'update_term_meta';
+        }
+    }
 
-	function is_changed() {
+    function is_changed() {
 
-		$hash = call_user_func( $this->get_meta, $this->object_id, self::HASH, true );
+        $hash = call_user_func( $this->get_meta, $this->object_id, self::HASH, true );
 
-		return empty( $hash ) || $hash !== $this->hash( $this->get_jsonld() );
-	}
+        return empty( $hash ) || $hash !== $this->hash( $this->get_jsonld() );
+    }
 
-	function get_jsonld() {
+    function get_jsonld() {
 
-		return apply_filters( 'wl_dataset__sync_service__sync_item__jsonld',
-			$this->jsonld_service->get( $this->type, $this->object_id ), $this->type, $this->object_id );
-	}
+        return apply_filters( 'wl_dataset__sync_service__sync_item__jsonld',
+            $this->jsonld_service->get( $this->type, $this->object_id ), $this->type, $this->object_id );
+    }
 
-	function get_jsonld_and_update_hash() {
-		$jsonld = $this->get_jsonld();
+    function get_jsonld_and_update_hash() {
+        $jsonld = $this->get_jsonld();
 
-		call_user_func( $this->update_meta, $this->object_id, self::HASH, $this->hash( $jsonld ) );
+        call_user_func( $this->update_meta, $this->object_id, self::HASH, $this->hash( $jsonld ) );
 
-		return $jsonld;
-	}
+        return $jsonld;
+    }
 
-	private function hash( $jsonld ) {
-		return sha1( wp_json_encode( $jsonld ) );
-	}
+    private function hash( $jsonld ) {
+        return sha1( wp_json_encode( $jsonld ) );
+    }
 
 }

Spacing +16 added lines, -16 removed lines

@@ -27,27 +27,27 @@ 
 	 *
 	 * @throws \Exception
 	 */
-	function __construct( $type, $object_id, $jsonld_service ) {
+	function __construct($type, $object_id, $jsonld_service) {
 
-		$this->type = filter_var( $type, FILTER_VALIDATE_INT, array(
+		$this->type = filter_var($type, FILTER_VALIDATE_INT, array(
 			'options' => array(
 				'min_range' => 0,
 				'max_range' => 1,
 			),
-		) );
+		));
 
-		$this->object_id = filter_var( $object_id, FILTER_VALIDATE_INT );
+		$this->object_id = filter_var($object_id, FILTER_VALIDATE_INT);
 
-		if ( null === $this->type ) {
-			throw new \Exception( 'Invalid $type.' );
+		if (null === $this->type) {
+			throw new \Exception('Invalid $type.');
 		}
-		if ( null === $this->object_id ) {
-			throw new \Exception( 'Invalid $object.' );
+		if (null === $this->object_id) {
+			throw new \Exception('Invalid $object.');
 		}
 
 		$this->jsonld_service = $jsonld_service;
 
-		if ( Object_Type_Enum::POST === $this->type ) {
+		if (Object_Type_Enum::POST === $this->type) {
 			$this->get_meta    = 'get_post_meta';
 			$this->update_meta = 'update_post_meta';
 		} else {
@@ -58,27 +58,27 @@ 
 
 	function is_changed() {
 
-		$hash = call_user_func( $this->get_meta, $this->object_id, self::HASH, true );
+		$hash = call_user_func($this->get_meta, $this->object_id, self::HASH, true);
 
-		return empty( $hash ) || $hash !== $this->hash( $this->get_jsonld() );
+		return empty($hash) || $hash !== $this->hash($this->get_jsonld());
 	}
 
 	function get_jsonld() {
 
-		return apply_filters( 'wl_dataset__sync_service__sync_item__jsonld',
-			$this->jsonld_service->get( $this->type, $this->object_id ), $this->type, $this->object_id );
+		return apply_filters('wl_dataset__sync_service__sync_item__jsonld',
+			$this->jsonld_service->get($this->type, $this->object_id), $this->type, $this->object_id);
 	}
 
 	function get_jsonld_and_update_hash() {
 		$jsonld = $this->get_jsonld();
 
-		call_user_func( $this->update_meta, $this->object_id, self::HASH, $this->hash( $jsonld ) );
+		call_user_func($this->update_meta, $this->object_id, self::HASH, $this->hash($jsonld));
 
 		return $jsonld;
 	}
 
-	private function hash( $jsonld ) {
-		return sha1( wp_json_encode( $jsonld ) );
+	private function hash($jsonld) {
+		return sha1(wp_json_encode($jsonld));
 	}
 
 }

src/wordlift/class-object-type-enum.php

Indentation +4 added lines, -4 removed lines

@@ -4,9 +4,9 @@
 
 class Object_Type_Enum {
 
-	const POST = 0;
-	const TERM = 1;
-	const HOMEPAGE = 2;
-	const USER = 3;
+    const POST = 0;
+    const TERM = 1;
+    const HOMEPAGE = 2;
+    const USER = 3;
 
 }

src/wordlift/dataset/class-sync-object-adapter-factory.php

Indentation +35 added lines, -35 removed lines

@@ -5,40 +5,40 @@
 use Wordlift\Jsonld\Jsonld_Service;
 
 class Sync_Object_Adapter_Factory {
-	/**
-	 * @var Sync_Object_Adapter_Factory
-	 */
-	private static $instance;
-
-	/**
-	 * @var Jsonld_Service
-	 */
-	private $jsonld_service;
-
-	/**
-	 * Sync_Object_Adapter_Factory constructor.
-	 *
-	 * @param $jsonld_service
-	 */
-	function __construct( $jsonld_service ) {
-		$this->jsonld_service = $jsonld_service;
-
-		self::$instance = $this;
-	}
-
-	static function get_instance() {
-		return self::$instance;
-	}
-
-	/**
-	 * @param $type
-	 * @param $object_id
-	 *
-	 * @return Sync_Object_Adapter
-	 * @throws \Exception
-	 */
-	function create( $type, $object_id ) {
-		return new Sync_Object_Adapter( $type, $object_id, $this->jsonld_service );
-	}
+    /**
+     * @var Sync_Object_Adapter_Factory
+     */
+    private static $instance;
+
+    /**
+     * @var Jsonld_Service
+     */
+    private $jsonld_service;
+
+    /**
+     * Sync_Object_Adapter_Factory constructor.
+     *
+     * @param $jsonld_service
+     */
+    function __construct( $jsonld_service ) {
+        $this->jsonld_service = $jsonld_service;
+
+        self::$instance = $this;
+    }
+
+    static function get_instance() {
+        return self::$instance;
+    }
+
+    /**
+     * @param $type
+     * @param $object_id
+     *
+     * @return Sync_Object_Adapter
+     * @throws \Exception
+     */
+    function create( $type, $object_id ) {
+        return new Sync_Object_Adapter( $type, $object_id, $this->jsonld_service );
+    }
 
 }

Spacing +3 added lines, -3 removed lines

@@ -20,7 +20,7 @@ 
 	 *
 	 * @param $jsonld_service
 	 */
-	function __construct( $jsonld_service ) {
+	function __construct($jsonld_service) {
 		$this->jsonld_service = $jsonld_service;
 
 		self::$instance = $this;
@@ -37,8 +37,8 @@ 
 	 * @return Sync_Object_Adapter
 	 * @throws \Exception
 	 */
-	function create( $type, $object_id ) {
-		return new Sync_Object_Adapter( $type, $object_id, $this->jsonld_service );
+	function create($type, $object_id) {
+		return new Sync_Object_Adapter($type, $object_id, $this->jsonld_service);
 	}
 
 }

src/wordlift/dataset/class-sync-service.php

Indentation +223 added lines, -223 removed lines

@@ -8,102 +8,102 @@ 
 
 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;
-
-	/**
-	 * The number of posts processed in one call.
-	 *
-	 * @var int The batch size.
-	 */
-	private $batch_size;
-
-	/**
-	 * @var Sync_Object_Adapter_Factory
-	 */
-	private $sync_object_adapter_factory;
-
-	/**
-	 * @var Sync_Service
-	 */
-	private static $instance;
-
-	/**
-	 * Constructor.
-	 *
-	 * @param Api_Service $api_service The {@link Api_Service} used to communicate with the remote APIs.
-	 * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
-	 */
-	public function __construct( $api_service, $sync_object_adapter_factory ) {
-
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
-
-		$this->api_service                 = $api_service;
-		$this->sync_object_adapter_factory = $sync_object_adapter_factory;
-		$this->batch_size                  = 10;
-
-		// 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 );;
-
-		self::$instance = $this;
-
-	}
-
-	public static function get_instance() {
-		return self::$instance;
-	}
-
-	/**
-	 * 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 IDs to synchronize.
-	 *
-	 * @return array An array of post IDs.
-	 */
-	public function next() {
-		global $wpdb;
-
-		$state = $this->info();
-
-		// 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_col( "
+    /**
+     * @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;
+
+    /**
+     * The number of posts processed in one call.
+     *
+     * @var int The batch size.
+     */
+    private $batch_size;
+
+    /**
+     * @var Sync_Object_Adapter_Factory
+     */
+    private $sync_object_adapter_factory;
+
+    /**
+     * @var Sync_Service
+     */
+    private static $instance;
+
+    /**
+     * Constructor.
+     *
+     * @param Api_Service $api_service The {@link Api_Service} used to communicate with the remote APIs.
+     * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
+     */
+    public function __construct( $api_service, $sync_object_adapter_factory ) {
+
+        $this->log = \Wordlift_Log_Service::get_logger( get_class() );
+
+        $this->api_service                 = $api_service;
+        $this->sync_object_adapter_factory = $sync_object_adapter_factory;
+        $this->batch_size                  = 10;
+
+        // 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 );;
+
+        self::$instance = $this;
+
+    }
+
+    public static function get_instance() {
+        return self::$instance;
+    }
+
+    /**
+     * 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 IDs to synchronize.
+     *
+     * @return array An array of post IDs.
+     */
+    public function next() {
+        global $wpdb;
+
+        $state = $this->info();
+
+        // 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_col( "
 			SELECT p.ID
 			FROM $wpdb->posts p
 			WHERE p.post_status = 'publish'
@@ -111,139 +111,139 @@ 
 			ORDER BY p.ID
 			LIMIT {$state->index},{$this->batch_size}
 			" );
-	}
+    }
 
-	public function count() {
-		global $wpdb;
-		$post_type_in = implode( "','", array_map( 'esc_sql', \Wordlift_Entity_Service::valid_entity_post_types() ) );
+    public function count() {
+        global $wpdb;
+        $post_type_in = implode( "','", array_map( 'esc_sql', \Wordlift_Entity_Service::valid_entity_post_types() ) );
 
-		return $wpdb->get_var( "
+        return $wpdb->get_var( "
 			SELECT COUNT(1)
 			FROM $wpdb->posts p
 			WHERE p.post_status = 'publish'
 			  AND p.post_type IN ('$post_type_in')
 			" );
-	}
-
-	public function info() {
-		return Sync_Background_Process::get_state();
-	}
-
-	/**
-	 * @param $type
-	 * @param $post_id
-	 *
-	 * @throws \Exception
-	 */
-	public function sync_one( $type, $post_id ) {
-
-		if ( Object_Type_Enum::POST !== $type ) {
-			throw new \Exception( "Type $type is unsupported." );
-		}
-
-		$this->sync_items( array( $post_id ), false );
-	}
-
-	public function sync_items( $post_ids, $clear = true ) {
-
-		$this->log->debug( sprintf( 'Synchronizing post(s) %s...', implode( ', ', $post_ids ) ) );
-
-		debug_print_backtrace( DEBUG_BACKTRACE_IGNORE_ARGS, 10 );
-
-		// If we're starting the sync, try to clear the dataset.
-		if ( $clear && 0 === $this->info()->index ) {
-			$this->api_service->request( 'DELETE', '/middleware/dataset/delete' );
-		}
-
-		$that         = $this;
-		$request_body = array_filter( array_map( function ( $post_id ) use ( $that ) {
-			// Check if the post type is public.
-			$post_type     = get_post_type( $post_id );
-			$post_type_obj = get_post_type_object( $post_type );
-			if ( ! $post_type_obj->public ) {
-				return false;
-			}
-
-			$is_private       = ( 'publish' !== get_post_status( $post_id ) );
-			$uri              = get_post_meta( $post_id, 'entity_url', true );
-			$object_adapter   = $that->sync_object_adapter_factory->create( Object_Type_Enum::POST, $post_id );
-			$jsonld           = $object_adapter->get_jsonld_and_update_hash();
-			$jsonld_as_string = wp_json_encode( $jsonld );
-
-			$that->log->trace( "Posting JSON-LD:\n$jsonld_as_string" );
-
-			return array(
-				'uri'     => $uri,
-				'model'   => $jsonld_as_string,
-				'private' => $is_private
-			);
-		}, $post_ids ) );
-
-		// There's no point in making a request if the request is empty.
-		if ( empty( $request_body ) ) {
-			return true;
-		}
-
-		// Make a request to the remote endpoint.
-		$state              = $this->info();
-		$state_header_value = str_replace( "\n", '', wp_json_encode( $state ) );
-		$response           = $this->api_service->request(
-			'POST', '/middleware/dataset/batch',
-			array(
-				'Content-Type'                     => 'application/json',
-				'X-Wordlift-Dataset-Sync-State-V1' => $state_header_value
-			),
-			wp_json_encode( $request_body ) );
-
-		$this->log->debug( "Response received: " . ( $response->is_success() ? 'yes' : 'no' ) );
-
-		// Update the sync date in case of success, otherwise log an error.
-		if ( $response->is_success() ) {
-
-			foreach ( $post_ids as $post_id ) {
-				update_post_meta( $post_id, '_wl_synced_gmt', current_time( 'mysql', true ) );
-			}
-
-			$this->log->debug( sprintf( 'Posts %s synchronized.', implode( ', ', $post_ids ) ) );
-
-			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 IDs %s: %s', implode( ', ', $post_ids ), $response_dump ) );
-
-			return false;
-		}
-
-	}
-
-	/**
-	 * @param $post_id
-	 *
-	 * @todo Complete the delete item.
-	 */
-	public function delete_item( $post_id ) {
-		$uri = get_post_meta( $post_id, 'entity_url', true );
-		// Make a request to the remote endpoint.
-		$state_header_value = str_replace( wp_json_encode( $this->info() ), "\n", '' );
-		$response           = $this->api_service->request(
-			'DELETE', '/middleware/dataset?uri=' . rawurlencode( $uri ),
-			array(
-				'Content-Type'                     => 'application/ld+json',
-				'X-Wordlift-Dataset-Sync-State-V1' => $state_header_value
-			) );
-	}
-
-	public function get_batch_size() {
-
-		return $this->batch_size;
-	}
-
-	public function delete_one($type, $object_id) {
-
-		// @@todo implement.
-
-	}
+    }
+
+    public function info() {
+        return Sync_Background_Process::get_state();
+    }
+
+    /**
+     * @param $type
+     * @param $post_id
+     *
+     * @throws \Exception
+     */
+    public function sync_one( $type, $post_id ) {
+
+        if ( Object_Type_Enum::POST !== $type ) {
+            throw new \Exception( "Type $type is unsupported." );
+        }
+
+        $this->sync_items( array( $post_id ), false );
+    }
+
+    public function sync_items( $post_ids, $clear = true ) {
+
+        $this->log->debug( sprintf( 'Synchronizing post(s) %s...', implode( ', ', $post_ids ) ) );
+
+        debug_print_backtrace( DEBUG_BACKTRACE_IGNORE_ARGS, 10 );
+
+        // If we're starting the sync, try to clear the dataset.
+        if ( $clear && 0 === $this->info()->index ) {
+            $this->api_service->request( 'DELETE', '/middleware/dataset/delete' );
+        }
+
+        $that         = $this;
+        $request_body = array_filter( array_map( function ( $post_id ) use ( $that ) {
+            // Check if the post type is public.
+            $post_type     = get_post_type( $post_id );
+            $post_type_obj = get_post_type_object( $post_type );
+            if ( ! $post_type_obj->public ) {
+                return false;
+            }
+
+            $is_private       = ( 'publish' !== get_post_status( $post_id ) );
+            $uri              = get_post_meta( $post_id, 'entity_url', true );
+            $object_adapter   = $that->sync_object_adapter_factory->create( Object_Type_Enum::POST, $post_id );
+            $jsonld           = $object_adapter->get_jsonld_and_update_hash();
+            $jsonld_as_string = wp_json_encode( $jsonld );
+
+            $that->log->trace( "Posting JSON-LD:\n$jsonld_as_string" );
+
+            return array(
+                'uri'     => $uri,
+                'model'   => $jsonld_as_string,
+                'private' => $is_private
+            );
+        }, $post_ids ) );
+
+        // There's no point in making a request if the request is empty.
+        if ( empty( $request_body ) ) {
+            return true;
+        }
+
+        // Make a request to the remote endpoint.
+        $state              = $this->info();
+        $state_header_value = str_replace( "\n", '', wp_json_encode( $state ) );
+        $response           = $this->api_service->request(
+            'POST', '/middleware/dataset/batch',
+            array(
+                'Content-Type'                     => 'application/json',
+                'X-Wordlift-Dataset-Sync-State-V1' => $state_header_value
+            ),
+            wp_json_encode( $request_body ) );
+
+        $this->log->debug( "Response received: " . ( $response->is_success() ? 'yes' : 'no' ) );
+
+        // Update the sync date in case of success, otherwise log an error.
+        if ( $response->is_success() ) {
+
+            foreach ( $post_ids as $post_id ) {
+                update_post_meta( $post_id, '_wl_synced_gmt', current_time( 'mysql', true ) );
+            }
+
+            $this->log->debug( sprintf( 'Posts %s synchronized.', implode( ', ', $post_ids ) ) );
+
+            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 IDs %s: %s', implode( ', ', $post_ids ), $response_dump ) );
+
+            return false;
+        }
+
+    }
+
+    /**
+     * @param $post_id
+     *
+     * @todo Complete the delete item.
+     */
+    public function delete_item( $post_id ) {
+        $uri = get_post_meta( $post_id, 'entity_url', true );
+        // Make a request to the remote endpoint.
+        $state_header_value = str_replace( wp_json_encode( $this->info() ), "\n", '' );
+        $response           = $this->api_service->request(
+            'DELETE', '/middleware/dataset?uri=' . rawurlencode( $uri ),
+            array(
+                'Content-Type'                     => 'application/ld+json',
+                'X-Wordlift-Dataset-Sync-State-V1' => $state_header_value
+            ) );
+    }
+
+    public function get_batch_size() {
+
+        return $this->batch_size;
+    }
+
+    public function delete_one($type, $object_id) {
+
+        // @@todo implement.
+
+    }
 
 }

Spacing +42 added lines, -42 removed lines

@@ -51,16 +51,16 @@ 
 	 * @param Api_Service $api_service The {@link Api_Service} used to communicate with the remote APIs.
 	 * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
 	 */
-	public function __construct( $api_service, $sync_object_adapter_factory ) {
+	public function __construct($api_service, $sync_object_adapter_factory) {
 
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
+		$this->log = \Wordlift_Log_Service::get_logger(get_class());
 
 		$this->api_service                 = $api_service;
 		$this->sync_object_adapter_factory = $sync_object_adapter_factory;
 		$this->batch_size                  = 10;
 
 		// 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 );;
+		$this->sync_background_process = new Sync_Background_Process($this); ;
 
 		self::$instance = $this;
 
@@ -100,29 +100,29 @@ 
 		$state = $this->info();
 
 		// Limit the query to the allowed post types.
-		$post_type_in = implode( "','", array_map( 'esc_sql', \Wordlift_Entity_Service::valid_entity_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_col( "
+		return $wpdb->get_col("
 			SELECT p.ID
 			FROM $wpdb->posts p
 			WHERE p.post_status = 'publish'
 			  AND p.post_type IN ('$post_type_in')
 			ORDER BY p.ID
 			LIMIT {$state->index},{$this->batch_size}
-			" );
+			");
 	}
 
 	public function count() {
 		global $wpdb;
-		$post_type_in = implode( "','", array_map( 'esc_sql', \Wordlift_Entity_Service::valid_entity_post_types() ) );
+		$post_type_in = implode("','", array_map('esc_sql', \Wordlift_Entity_Service::valid_entity_post_types()));
 
-		return $wpdb->get_var( "
+		return $wpdb->get_var("
 			SELECT COUNT(1)
 			FROM $wpdb->posts p
 			WHERE p.post_status = 'publish'
 			  AND p.post_type IN ('$post_type_in')
-			" );
+			");
 	}
 
 	public function info() {
@@ -135,83 +135,83 @@ 
 	 *
 	 * @throws \Exception
 	 */
-	public function sync_one( $type, $post_id ) {
+	public function sync_one($type, $post_id) {
 
-		if ( Object_Type_Enum::POST !== $type ) {
-			throw new \Exception( "Type $type is unsupported." );
+		if (Object_Type_Enum::POST !== $type) {
+			throw new \Exception("Type $type is unsupported.");
 		}
 
-		$this->sync_items( array( $post_id ), false );
+		$this->sync_items(array($post_id), false);
 	}
 
-	public function sync_items( $post_ids, $clear = true ) {
+	public function sync_items($post_ids, $clear = true) {
 
-		$this->log->debug( sprintf( 'Synchronizing post(s) %s...', implode( ', ', $post_ids ) ) );
+		$this->log->debug(sprintf('Synchronizing post(s) %s...', implode(', ', $post_ids)));
 
-		debug_print_backtrace( DEBUG_BACKTRACE_IGNORE_ARGS, 10 );
+		debug_print_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS, 10);
 
 		// If we're starting the sync, try to clear the dataset.
-		if ( $clear && 0 === $this->info()->index ) {
-			$this->api_service->request( 'DELETE', '/middleware/dataset/delete' );
+		if ($clear && 0 === $this->info()->index) {
+			$this->api_service->request('DELETE', '/middleware/dataset/delete');
 		}
 
 		$that         = $this;
-		$request_body = array_filter( array_map( function ( $post_id ) use ( $that ) {
+		$request_body = array_filter(array_map(function($post_id) use ($that) {
 			// Check if the post type is public.
-			$post_type     = get_post_type( $post_id );
-			$post_type_obj = get_post_type_object( $post_type );
-			if ( ! $post_type_obj->public ) {
+			$post_type     = get_post_type($post_id);
+			$post_type_obj = get_post_type_object($post_type);
+			if ( ! $post_type_obj->public) {
 				return false;
 			}
 
-			$is_private       = ( 'publish' !== get_post_status( $post_id ) );
-			$uri              = get_post_meta( $post_id, 'entity_url', true );
-			$object_adapter   = $that->sync_object_adapter_factory->create( Object_Type_Enum::POST, $post_id );
+			$is_private       = ('publish' !== get_post_status($post_id));
+			$uri              = get_post_meta($post_id, 'entity_url', true);
+			$object_adapter   = $that->sync_object_adapter_factory->create(Object_Type_Enum::POST, $post_id);
 			$jsonld           = $object_adapter->get_jsonld_and_update_hash();
-			$jsonld_as_string = wp_json_encode( $jsonld );
+			$jsonld_as_string = wp_json_encode($jsonld);
 
-			$that->log->trace( "Posting JSON-LD:\n$jsonld_as_string" );
+			$that->log->trace("Posting JSON-LD:\n$jsonld_as_string");
 
 			return array(
 				'uri'     => $uri,
 				'model'   => $jsonld_as_string,
 				'private' => $is_private
 			);
-		}, $post_ids ) );
+		}, $post_ids));
 
 		// There's no point in making a request if the request is empty.
-		if ( empty( $request_body ) ) {
+		if (empty($request_body)) {
 			return true;
 		}
 
 		// Make a request to the remote endpoint.
 		$state              = $this->info();
-		$state_header_value = str_replace( "\n", '', wp_json_encode( $state ) );
+		$state_header_value = str_replace("\n", '', wp_json_encode($state));
 		$response           = $this->api_service->request(
 			'POST', '/middleware/dataset/batch',
 			array(
 				'Content-Type'                     => 'application/json',
 				'X-Wordlift-Dataset-Sync-State-V1' => $state_header_value
 			),
-			wp_json_encode( $request_body ) );
+			wp_json_encode($request_body) );
 
-		$this->log->debug( "Response received: " . ( $response->is_success() ? 'yes' : 'no' ) );
+		$this->log->debug("Response received: ".($response->is_success() ? 'yes' : 'no'));
 
 		// Update the sync date in case of success, otherwise log an error.
-		if ( $response->is_success() ) {
+		if ($response->is_success()) {
 
-			foreach ( $post_ids as $post_id ) {
-				update_post_meta( $post_id, '_wl_synced_gmt', current_time( 'mysql', true ) );
+			foreach ($post_ids as $post_id) {
+				update_post_meta($post_id, '_wl_synced_gmt', current_time('mysql', true));
 			}
 
-			$this->log->debug( sprintf( 'Posts %s synchronized.', implode( ', ', $post_ids ) ) );
+			$this->log->debug(sprintf('Posts %s synchronized.', implode(', ', $post_ids)));
 
 			return true;
 		} else {
 			// @@todo: should we put a limit retry here?
-			$response_dump = var_export( $response, true );
+			$response_dump = var_export($response, true);
 			$this->log->error(
-				sprintf( 'An error occurred while synchronizing the data for post IDs %s: %s', implode( ', ', $post_ids ), $response_dump ) );
+				sprintf('An error occurred while synchronizing the data for post IDs %s: %s', implode(', ', $post_ids), $response_dump) );
 
 			return false;
 		}
@@ -223,12 +223,12 @@ 
 	 *
 	 * @todo Complete the delete item.
 	 */
-	public function delete_item( $post_id ) {
-		$uri = get_post_meta( $post_id, 'entity_url', true );
+	public function delete_item($post_id) {
+		$uri = get_post_meta($post_id, 'entity_url', true);
 		// Make a request to the remote endpoint.
-		$state_header_value = str_replace( wp_json_encode( $this->info() ), "\n", '' );
+		$state_header_value = str_replace(wp_json_encode($this->info()), "\n", '');
 		$response           = $this->api_service->request(
-			'DELETE', '/middleware/dataset?uri=' . rawurlencode( $uri ),
+			'DELETE', '/middleware/dataset?uri='.rawurlencode($uri),
 			array(
 				'Content-Type'                     => 'application/ld+json',
 				'X-Wordlift-Dataset-Sync-State-V1' => $state_header_value

src/wordlift/dataset/class-sync-hooks-entity-relation.php

Indentation +52 added lines, -52 removed lines

@@ -15,57 +15,57 @@
  */
 class Sync_Hooks_Entity_Relation {
 
-	/**
-	 * @var \Wordlift_Entity_Service
-	 */
-	private $entity_service;
-
-	/**
-	 * Entity_Dct_Relation constructor.
-	 *
-	 * @param $entity_service \Wordlift_Entity_Service
-	 */
-	public function __construct( $entity_service ) {
-		$this->entity_service = $entity_service;
-
-		add_filter( 'wl_dataset__sync_service__sync_item__jsonld', array( $this, 'jsonld' ), 10, 3 );
-	}
-
-	public function jsonld( $jsonld, $type, $post_id ) {
-
-		// @@todo add support for terms.
-		if ( Object_Type_Enum::TERM === $type ) {
-			return $jsonld;
-		}
-
-		// Choose the dcterm property according to the post type.
-		$property = $this->entity_service->is_entity( $post_id )
-			? 'http://purl.org/dc/terms/relation'
-			: 'http://purl.org/dc/terms/references';
-
-		$references = array_unique( $this->entity_service->get_related_entities( $post_id ) );
-
-		// Bail out if there are no references.
-		if ( empty( $references ) ) {
-			return $jsonld;
-		}
-
-		if ( ! isset( $jsonld[0][ $property ] ) ) {
-			$jsonld[0][ $property ] = array();
-		}
-
-		if ( ! is_array( $jsonld[0][ $property ] ) ) {
-			$jsonld[0][ $property ] = array( $jsonld[0][ $property ] );
-		}
-
-		$that             = $this;
-		$references_array = array_values( array_map( function ( $item ) use ( $that ) {
-			return array( '@id' => $that->entity_service->get_uri( $item ) );
-		}, $references ) );
-
-		$jsonld[0][ $property ] = array_merge( $jsonld[0][ $property ], $references_array );
-
-		return $jsonld;
-	}
+    /**
+     * @var \Wordlift_Entity_Service
+     */
+    private $entity_service;
+
+    /**
+     * Entity_Dct_Relation constructor.
+     *
+     * @param $entity_service \Wordlift_Entity_Service
+     */
+    public function __construct( $entity_service ) {
+        $this->entity_service = $entity_service;
+
+        add_filter( 'wl_dataset__sync_service__sync_item__jsonld', array( $this, 'jsonld' ), 10, 3 );
+    }
+
+    public function jsonld( $jsonld, $type, $post_id ) {
+
+        // @@todo add support for terms.
+        if ( Object_Type_Enum::TERM === $type ) {
+            return $jsonld;
+        }
+
+        // Choose the dcterm property according to the post type.
+        $property = $this->entity_service->is_entity( $post_id )
+            ? 'http://purl.org/dc/terms/relation'
+            : 'http://purl.org/dc/terms/references';
+
+        $references = array_unique( $this->entity_service->get_related_entities( $post_id ) );
+
+        // Bail out if there are no references.
+        if ( empty( $references ) ) {
+            return $jsonld;
+        }
+
+        if ( ! isset( $jsonld[0][ $property ] ) ) {
+            $jsonld[0][ $property ] = array();
+        }
+
+        if ( ! is_array( $jsonld[0][ $property ] ) ) {
+            $jsonld[0][ $property ] = array( $jsonld[0][ $property ] );
+        }
+
+        $that             = $this;
+        $references_array = array_values( array_map( function ( $item ) use ( $that ) {
+            return array( '@id' => $that->entity_service->get_uri( $item ) );
+        }, $references ) );
+
+        $jsonld[0][ $property ] = array_merge( $jsonld[0][ $property ], $references_array );
+
+        return $jsonld;
+    }
 
 }

Spacing +15 added lines, -15 removed lines

@@ -25,45 +25,45 @@
 	 *
 	 * @param $entity_service \Wordlift_Entity_Service
 	 */
-	public function __construct( $entity_service ) {
+	public function __construct($entity_service) {
 		$this->entity_service = $entity_service;
 
-		add_filter( 'wl_dataset__sync_service__sync_item__jsonld', array( $this, 'jsonld' ), 10, 3 );
+		add_filter('wl_dataset__sync_service__sync_item__jsonld', array($this, 'jsonld'), 10, 3);
 	}
 
-	public function jsonld( $jsonld, $type, $post_id ) {
+	public function jsonld($jsonld, $type, $post_id) {
 
 		// @@todo add support for terms.
-		if ( Object_Type_Enum::TERM === $type ) {
+		if (Object_Type_Enum::TERM === $type) {
 			return $jsonld;
 		}
 
 		// Choose the dcterm property according to the post type.
-		$property = $this->entity_service->is_entity( $post_id )
+		$property = $this->entity_service->is_entity($post_id)
 			? 'http://purl.org/dc/terms/relation'
 			: 'http://purl.org/dc/terms/references';
 
-		$references = array_unique( $this->entity_service->get_related_entities( $post_id ) );
+		$references = array_unique($this->entity_service->get_related_entities($post_id));
 
 		// Bail out if there are no references.
-		if ( empty( $references ) ) {
+		if (empty($references)) {
 			return $jsonld;
 		}
 
-		if ( ! isset( $jsonld[0][ $property ] ) ) {
-			$jsonld[0][ $property ] = array();
+		if ( ! isset($jsonld[0][$property])) {
+			$jsonld[0][$property] = array();
 		}
 
-		if ( ! is_array( $jsonld[0][ $property ] ) ) {
-			$jsonld[0][ $property ] = array( $jsonld[0][ $property ] );
+		if ( ! is_array($jsonld[0][$property])) {
+			$jsonld[0][$property] = array($jsonld[0][$property]);
 		}
 
 		$that             = $this;
-		$references_array = array_values( array_map( function ( $item ) use ( $that ) {
-			return array( '@id' => $that->entity_service->get_uri( $item ) );
-		}, $references ) );
+		$references_array = array_values(array_map(function($item) use ($that) {
+			return array('@id' => $that->entity_service->get_uri($item));
+		}, $references));
 
-		$jsonld[0][ $property ] = array_merge( $jsonld[0][ $property ], $references_array );
+		$jsonld[0][$property] = array_merge($jsonld[0][$property], $references_array);
 
 		return $jsonld;
 	}

src/wordlift/dataset/index.php

Indentation +13 added lines, -13 removed lines

@@ -9,28 +9,28 @@
 use Wordlift\Jsonld\Jsonld_Service;
 
 if ( ! defined( 'ABSPATH' ) ) {
-	exit;
+    exit;
 }
 // Register the Dataset JSON Endpoint. The `$api_service` variable must be defined in the calling file (wordlift.php).
 if ( apply_filters( 'wl_feature__enable__dataset-ng', false ) ) {
-	/*
+    /*
 	 * Add Composer Autoload with Mozart support.
 	 *
 	 * @since 3.27.6
 	 */
 //	require dirname( dirname( dirname( __FILE__ ) ) ) . '/vendor/autoload.php';
 
-	$sync_object_adapter_factory = new Sync_Object_Adapter_Factory( Jsonld_Service::get_instance() );
-	$sync_service                = new Sync_Service( $api_service, $sync_object_adapter_factory );
-	new Sync_Post_Hooks( $sync_service );
-	new Sync_User_Hooks( $sync_service );
-	new Sync_Wpjson_Endpoint( $sync_service );
-	new Sync_Page();
+    $sync_object_adapter_factory = new Sync_Object_Adapter_Factory( Jsonld_Service::get_instance() );
+    $sync_service                = new Sync_Service( $api_service, $sync_object_adapter_factory );
+    new Sync_Post_Hooks( $sync_service );
+    new Sync_User_Hooks( $sync_service );
+    new Sync_Wpjson_Endpoint( $sync_service );
+    new Sync_Page();
 
-	/**
-	 * @since 3.28.0
-	 * @see https://github.com/insideout10/wordlift-plugin/issues/1186
-	 */
-	new Sync_Hooks_Entity_Relation( Wordlift_Entity_Service::get_instance() );
+    /**
+     * @since 3.28.0
+     * @see https://github.com/insideout10/wordlift-plugin/issues/1186
+     */
+    new Sync_Hooks_Entity_Relation( Wordlift_Entity_Service::get_instance() );
 
 }

Spacing +8 added lines, -8 removed lines

@@ -8,11 +8,11 @@ 
 use Wordlift\Dataset\Sync_Wpjson_Endpoint;
 use Wordlift\Jsonld\Jsonld_Service;
 
-if ( ! defined( 'ABSPATH' ) ) {
+if ( ! defined('ABSPATH')) {
 	exit;
 }
 // Register the Dataset JSON Endpoint. The `$api_service` variable must be defined in the calling file (wordlift.php).
-if ( apply_filters( 'wl_feature__enable__dataset-ng', false ) ) {
+if (apply_filters('wl_feature__enable__dataset-ng', false)) {
 	/*
 	 * Add Composer Autoload with Mozart support.
 	 *
@@ -20,17 +20,17 @@ 
 	 */
 //	require dirname( dirname( dirname( __FILE__ ) ) ) . '/vendor/autoload.php';
 
-	$sync_object_adapter_factory = new Sync_Object_Adapter_Factory( Jsonld_Service::get_instance() );
-	$sync_service                = new Sync_Service( $api_service, $sync_object_adapter_factory );
-	new Sync_Post_Hooks( $sync_service );
-	new Sync_User_Hooks( $sync_service );
-	new Sync_Wpjson_Endpoint( $sync_service );
+	$sync_object_adapter_factory = new Sync_Object_Adapter_Factory(Jsonld_Service::get_instance());
+	$sync_service                = new Sync_Service($api_service, $sync_object_adapter_factory);
+	new Sync_Post_Hooks($sync_service);
+	new Sync_User_Hooks($sync_service);
+	new Sync_Wpjson_Endpoint($sync_service);
 	new Sync_Page();
 
 	/**
 	 * @since 3.28.0
 	 * @see https://github.com/insideout10/wordlift-plugin/issues/1186
 	 */
-	new Sync_Hooks_Entity_Relation( Wordlift_Entity_Service::get_instance() );
+	new Sync_Hooks_Entity_Relation(Wordlift_Entity_Service::get_instance());
 
 }

src/wordlift/dataset/class-sync-user-hooks.php

Indentation +62 added lines, -62 removed lines

@@ -5,88 +5,88 @@
 use Wordlift\Object_Type_Enum;
 
 class Sync_User_Hooks {
-	/**
-	 * @var \Wordlift_Log_Service
-	 */
-	private $log;
+    /**
+     * @var \Wordlift_Log_Service
+     */
+    private $log;
 
-	/**
-	 * @var Sync_Service
-	 */
-	private $sync_service;
+    /**
+     * @var Sync_Service
+     */
+    private $sync_service;
 
-	/**
-	 * Sync_User_Hooks constructor.
-	 *
-	 * @param Sync_Service $sync_service
-	 */
-	function __construct( Sync_Service $sync_service ) {
+    /**
+     * Sync_User_Hooks constructor.
+     *
+     * @param Sync_Service $sync_service
+     */
+    function __construct( Sync_Service $sync_service ) {
 
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
+        $this->log = \Wordlift_Log_Service::get_logger( get_class() );
 
-		$this->sync_service = $sync_service;
+        $this->sync_service = $sync_service;
 
-		$this->register_hooks();
+        $this->register_hooks();
 
-	}
+    }
 
-	private function register_hooks() {
-		/**
-		 * Register hooks for user and meta.
-		 */
-		add_action( 'user_register', array( $this, 'changed_user' ) );
-		add_action( 'profile_update', array( $this, 'changed_user' ) );
-		add_action( 'added_user_meta', array( $this, 'changed_user_meta' ), 10, 3 );
-		add_action( 'updated_user_meta', array( $this, 'changed_user_meta' ), 10, 3 );
-		add_action( 'deleted_user_meta', array( $this, 'changed_user_meta' ), 10, 3 );
-		add_action( 'delete_user', array( $this, 'delete_user' ) );
+    private function register_hooks() {
+        /**
+         * Register hooks for user and meta.
+         */
+        add_action( 'user_register', array( $this, 'changed_user' ) );
+        add_action( 'profile_update', array( $this, 'changed_user' ) );
+        add_action( 'added_user_meta', array( $this, 'changed_user_meta' ), 10, 3 );
+        add_action( 'updated_user_meta', array( $this, 'changed_user_meta' ), 10, 3 );
+        add_action( 'deleted_user_meta', array( $this, 'changed_user_meta' ), 10, 3 );
+        add_action( 'delete_user', array( $this, 'delete_user' ) );
 
-	}
+    }
 
-	public function changed_user( $user_id ) {
+    public function changed_user( $user_id ) {
 
-		$this->sync( $user_id );
+        $this->sync( $user_id );
 
-	}
+    }
 
-	public function changed_user_meta( $meta_id, $user_id, $meta_key ) {
+    public function changed_user_meta( $meta_id, $user_id, $meta_key ) {
 
-		if ( in_array( $meta_key, apply_filters( 'wl_dataset__sync_user_hooks__ignored_meta_keys', array(
-			'rich_editing',
-			'comment_shortcuts',
-			'admin_color',
-			'use_ssl',
-			'show_admin_bar_front',
-			'wptests_capabilities',
-			'wptests_user_level',
-			'dismissed_wp_pointers',
-			'entity_url',
-		) ) ) ) {
-			return;
-		}
+        if ( in_array( $meta_key, apply_filters( 'wl_dataset__sync_user_hooks__ignored_meta_keys', array(
+            'rich_editing',
+            'comment_shortcuts',
+            'admin_color',
+            'use_ssl',
+            'show_admin_bar_front',
+            'wptests_capabilities',
+            'wptests_user_level',
+            'dismissed_wp_pointers',
+            'entity_url',
+        ) ) ) ) {
+            return;
+        }
 
-		$this->sync( $user_id );
+        $this->sync( $user_id );
 
-	}
+    }
 
-	private function sync( $user_id ) {
+    private function sync( $user_id ) {
 
-		try {
-			$this->sync_service->sync_one( Object_Type_Enum::USER, (int) $user_id );
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to sync user $user_id: " . $e->getMessage(), $e );
-		}
+        try {
+            $this->sync_service->sync_one( Object_Type_Enum::USER, (int) $user_id );
+        } catch ( \Exception $e ) {
+            $this->log->error( "An error occurred while trying to sync user $user_id: " . $e->getMessage(), $e );
+        }
 
-	}
+    }
 
-	public function delete_user( $user_id ) {
+    public function delete_user( $user_id ) {
 
-		try {
-			$this->sync_service->delete_one( Object_Type_Enum::USER, $user_id );
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to delete user $user_id: " . $e->getMessage(), $e );
-		}
+        try {
+            $this->sync_service->delete_one( Object_Type_Enum::USER, $user_id );
+        } catch ( \Exception $e ) {
+            $this->log->error( "An error occurred while trying to delete user $user_id: " . $e->getMessage(), $e );
+        }
 
-	}
+    }
 
 }
\ No newline at end of file

Spacing +22 added lines, -22 removed lines

@@ -20,9 +20,9 @@ 
 	 *
 	 * @param Sync_Service $sync_service
 	 */
-	function __construct( Sync_Service $sync_service ) {
+	function __construct(Sync_Service $sync_service) {
 
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
+		$this->log = \Wordlift_Log_Service::get_logger(get_class());
 
 		$this->sync_service = $sync_service;
 
@@ -34,24 +34,24 @@ 
 		/**
 		 * Register hooks for user and meta.
 		 */
-		add_action( 'user_register', array( $this, 'changed_user' ) );
-		add_action( 'profile_update', array( $this, 'changed_user' ) );
-		add_action( 'added_user_meta', array( $this, 'changed_user_meta' ), 10, 3 );
-		add_action( 'updated_user_meta', array( $this, 'changed_user_meta' ), 10, 3 );
-		add_action( 'deleted_user_meta', array( $this, 'changed_user_meta' ), 10, 3 );
-		add_action( 'delete_user', array( $this, 'delete_user' ) );
+		add_action('user_register', array($this, 'changed_user'));
+		add_action('profile_update', array($this, 'changed_user'));
+		add_action('added_user_meta', array($this, 'changed_user_meta'), 10, 3);
+		add_action('updated_user_meta', array($this, 'changed_user_meta'), 10, 3);
+		add_action('deleted_user_meta', array($this, 'changed_user_meta'), 10, 3);
+		add_action('delete_user', array($this, 'delete_user'));
 
 	}
 
-	public function changed_user( $user_id ) {
+	public function changed_user($user_id) {
 
-		$this->sync( $user_id );
+		$this->sync($user_id);
 
 	}
 
-	public function changed_user_meta( $meta_id, $user_id, $meta_key ) {
+	public function changed_user_meta($meta_id, $user_id, $meta_key) {
 
-		if ( in_array( $meta_key, apply_filters( 'wl_dataset__sync_user_hooks__ignored_meta_keys', array(
+		if (in_array($meta_key, apply_filters('wl_dataset__sync_user_hooks__ignored_meta_keys', array(
 			'rich_editing',
 			'comment_shortcuts',
 			'admin_color',
@@ -61,30 +61,30 @@ 
 			'wptests_user_level',
 			'dismissed_wp_pointers',
 			'entity_url',
-		) ) ) ) {
+		)))) {
 			return;
 		}
 
-		$this->sync( $user_id );
+		$this->sync($user_id);
 
 	}
 
-	private function sync( $user_id ) {
+	private function sync($user_id) {
 
 		try {
-			$this->sync_service->sync_one( Object_Type_Enum::USER, (int) $user_id );
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to sync user $user_id: " . $e->getMessage(), $e );
+			$this->sync_service->sync_one(Object_Type_Enum::USER, (int) $user_id);
+		} catch (\Exception $e) {
+			$this->log->error("An error occurred while trying to sync user $user_id: ".$e->getMessage(), $e);
 		}
 
 	}
 
-	public function delete_user( $user_id ) {
+	public function delete_user($user_id) {
 
 		try {
-			$this->sync_service->delete_one( Object_Type_Enum::USER, $user_id );
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to delete user $user_id: " . $e->getMessage(), $e );
+			$this->sync_service->delete_one(Object_Type_Enum::USER, $user_id);
+		} catch (\Exception $e) {
+			$this->log->error("An error occurred while trying to delete user $user_id: ".$e->getMessage(), $e);
 		}
 
 	}

src/wordlift/dataset/class-sync-post-hooks.php

Indentation +55 added lines, -55 removed lines

@@ -5,81 +5,81 @@
 use Wordlift\Object_Type_Enum;
 
 class Sync_Post_Hooks {
-	/**
-	 * @var \Wordlift_Log_Service
-	 */
-	private $log;
+    /**
+     * @var \Wordlift_Log_Service
+     */
+    private $log;
 
-	/**
-	 * @var Sync_Service
-	 */
-	private $sync_service;
+    /**
+     * @var Sync_Service
+     */
+    private $sync_service;
 
-	/**
-	 * Sync_Post_Hooks constructor.
-	 *
-	 * @param Sync_Service $sync_service
-	 */
-	function __construct( $sync_service ) {
+    /**
+     * Sync_Post_Hooks constructor.
+     *
+     * @param Sync_Service $sync_service
+     */
+    function __construct( $sync_service ) {
 
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
+        $this->log = \Wordlift_Log_Service::get_logger( get_class() );
 
-		$this->sync_service = $sync_service;
+        $this->sync_service = $sync_service;
 
-		$this->register_hooks();
+        $this->register_hooks();
 
-	}
+    }
 
-	private function register_hooks() {
-		/**
-		 * Register hooks for post and meta.
-		 */
-		add_action( 'save_post', array( $this, 'save_post' ) );
-		add_action( 'added_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
-		add_action( 'updated_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
-		add_action( 'deleted_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
-		add_action( 'delete_post', array( $this, 'delete_post' ) );
+    private function register_hooks() {
+        /**
+         * Register hooks for post and meta.
+         */
+        add_action( 'save_post', array( $this, 'save_post' ) );
+        add_action( 'added_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
+        add_action( 'updated_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
+        add_action( 'deleted_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
+        add_action( 'delete_post', array( $this, 'delete_post' ) );
 
-	}
+    }
 
-	public function save_post( $post_id ) {
+    public function save_post( $post_id ) {
 
-		$this->sync( $post_id );
+        $this->sync( $post_id );
 
-	}
+    }
 
-	public function changed_post_meta( $meta_id, $post_id, $meta_key, $_meta_value ) {
+    public function changed_post_meta( $meta_id, $post_id, $meta_key, $_meta_value ) {
 
-		if ( in_array( $meta_key, apply_filters( 'wl_dataset__sync_post_hooks__ignored_meta_keys', array(
-			'_pingme',
-			'_encloseme',
-			'entity_url',
-		) ) ) ) {
-			return;
-		}
+        if ( in_array( $meta_key, apply_filters( 'wl_dataset__sync_post_hooks__ignored_meta_keys', array(
+            '_pingme',
+            '_encloseme',
+            'entity_url',
+        ) ) ) ) {
+            return;
+        }
 
-		$this->sync( $post_id );
+        $this->sync( $post_id );
 
-	}
+    }
 
-	private function sync( $post_id ) {
+    private function sync( $post_id ) {
 
-		try {
-			$this->sync_service->sync_one( Object_Type_Enum::POST, $post_id );
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to sync post $post_id: " . $e->getMessage(), $e );
-		}
+        try {
+            $this->sync_service->sync_one( Object_Type_Enum::POST, $post_id );
+        } catch ( \Exception $e ) {
+            $this->log->error( "An error occurred while trying to sync post $post_id: " . $e->getMessage(), $e );
+        }
 
-	}
+    }
 
-	public function delete_post( $post_id ) {
+    public function delete_post( $post_id ) {
 
-		try {
-			$this->sync_service->delete_one( Object_Type_Enum::POST, $post_id );
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to delete post $post_id: " . $e->getMessage(), $e );
-		}
+        try {
+            $this->sync_service->delete_one( Object_Type_Enum::POST, $post_id );
+        } catch ( \Exception $e ) {
+            $this->log->error( "An error occurred while trying to delete post $post_id: " . $e->getMessage(), $e );
+        }
 
-	}
+    }
 
 }
\ No newline at end of file

Spacing +21 added lines, -21 removed lines

@@ -20,9 +20,9 @@ 
 	 *
 	 * @param Sync_Service $sync_service
 	 */
-	function __construct( $sync_service ) {
+	function __construct($sync_service) {
 
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
+		$this->log = \Wordlift_Log_Service::get_logger(get_class());
 
 		$this->sync_service = $sync_service;
 
@@ -34,50 +34,50 @@ 
 		/**
 		 * Register hooks for post and meta.
 		 */
-		add_action( 'save_post', array( $this, 'save_post' ) );
-		add_action( 'added_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
-		add_action( 'updated_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
-		add_action( 'deleted_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
-		add_action( 'delete_post', array( $this, 'delete_post' ) );
+		add_action('save_post', array($this, 'save_post'));
+		add_action('added_post_meta', array($this, 'changed_post_meta'), 10, 4);
+		add_action('updated_post_meta', array($this, 'changed_post_meta'), 10, 4);
+		add_action('deleted_post_meta', array($this, 'changed_post_meta'), 10, 4);
+		add_action('delete_post', array($this, 'delete_post'));
 
 	}
 
-	public function save_post( $post_id ) {
+	public function save_post($post_id) {
 
-		$this->sync( $post_id );
+		$this->sync($post_id);
 
 	}
 
-	public function changed_post_meta( $meta_id, $post_id, $meta_key, $_meta_value ) {
+	public function changed_post_meta($meta_id, $post_id, $meta_key, $_meta_value) {
 
-		if ( in_array( $meta_key, apply_filters( 'wl_dataset__sync_post_hooks__ignored_meta_keys', array(
+		if (in_array($meta_key, apply_filters('wl_dataset__sync_post_hooks__ignored_meta_keys', array(
 			'_pingme',
 			'_encloseme',
 			'entity_url',
-		) ) ) ) {
+		)))) {
 			return;
 		}
 
-		$this->sync( $post_id );
+		$this->sync($post_id);
 
 	}
 
-	private function sync( $post_id ) {
+	private function sync($post_id) {
 
 		try {
-			$this->sync_service->sync_one( Object_Type_Enum::POST, $post_id );
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to sync post $post_id: " . $e->getMessage(), $e );
+			$this->sync_service->sync_one(Object_Type_Enum::POST, $post_id);
+		} catch (\Exception $e) {
+			$this->log->error("An error occurred while trying to sync post $post_id: ".$e->getMessage(), $e);
 		}
 
 	}
 
-	public function delete_post( $post_id ) {
+	public function delete_post($post_id) {
 
 		try {
-			$this->sync_service->delete_one( Object_Type_Enum::POST, $post_id );
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to delete post $post_id: " . $e->getMessage(), $e );
+			$this->sync_service->delete_one(Object_Type_Enum::POST, $post_id);
+		} catch (\Exception $e) {
+			$this->log->error("An error occurred while trying to delete post $post_id: ".$e->getMessage(), $e);
 		}
 
 	}