insideout10 / wordlift-plugin

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

Indentation +26 added lines, -26 removed lines

@@ -6,31 +6,31 @@
 
 class Sync_User_Adapter extends Abstract_Sync_Object_Adapter {
 
-	/**
-	 * Sync_User_Adapter constructor.
-	 *
-	 * @param int $user_id
-	 *
-	 * @throws \Exception
-	 */
-	function __construct( $user_id ) {
-		parent::__construct( Object_Type_Enum::USER, $user_id );
-	}
-
-	function is_published() {
-		return true;
-	}
-
-	function is_public() {
-		return true;
-	}
-
-	function set_values( $arr ) {
-		// @@todo
-	}
-
-	function get_value( $key ) {
-		// @@todo
-	}
+    /**
+     * Sync_User_Adapter constructor.
+     *
+     * @param int $user_id
+     *
+     * @throws \Exception
+     */
+    function __construct( $user_id ) {
+        parent::__construct( Object_Type_Enum::USER, $user_id );
+    }
+
+    function is_published() {
+        return true;
+    }
+
+    function is_public() {
+        return true;
+    }
+
+    function set_values( $arr ) {
+        // @@todo
+    }
+
+    function get_value( $key ) {
+        // @@todo
+    }
 
 }

Spacing +4 added lines, -4 removed lines

@@ -13,8 +13,8 @@ 
 	 *
 	 * @throws \Exception
 	 */
-	function __construct( $user_id ) {
-		parent::__construct( Object_Type_Enum::USER, $user_id );
+	function __construct($user_id) {
+		parent::__construct(Object_Type_Enum::USER, $user_id);
 	}
 
 	function is_published() {
@@ -25,11 +25,11 @@ 
 		return true;
 	}
 
-	function set_values( $arr ) {
+	function set_values($arr) {
 		// @@todo
 	}
 
-	function get_value( $key ) {
+	function get_value($key) {
 		// @@todo
 	}
 

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

Indentation +15 added lines, -15 removed lines

@@ -4,27 +4,27 @@
 
 abstract class Abstract_Sync_Hooks {
 
-	private $queue = array();
+    private $queue = array();
 
-	function __construct() {
+    function __construct() {
 
-		// To sync at the end of the usual WordPress lifecycle
-		add_action( 'shutdown', array( $this, 'shutdown' ) );
+        // To sync at the end of the usual WordPress lifecycle
+        add_action( 'shutdown', array( $this, 'shutdown' ) );
 
-	}
+    }
 
-	protected function enqueue( $item ) {
+    protected function enqueue( $item ) {
 
-		if ( empty( $this->queue ) || $item !== $this->queue[ count( $this->queue ) - 1 ] ) {
-			$this->queue[] = $item;
-		}
+        if ( empty( $this->queue ) || $item !== $this->queue[ count( $this->queue ) - 1 ] ) {
+            $this->queue[] = $item;
+        }
 
-	}
+    }
 
-	public function shutdown() {
-		foreach ( $this->queue as $callback ) {
-			call_user_func( array( $this, $callback[0] ), $callback[1] );
-		}
-	}
+    public function shutdown() {
+        foreach ( $this->queue as $callback ) {
+            call_user_func( array( $this, $callback[0] ), $callback[1] );
+        }
+    }
 
 }

Spacing +5 added lines, -5 removed lines

@@ -9,21 +9,21 @@
 	function __construct() {
 
 		// To sync at the end of the usual WordPress lifecycle
-		add_action( 'shutdown', array( $this, 'shutdown' ) );
+		add_action('shutdown', array($this, 'shutdown'));
 
 	}
 
-	protected function enqueue( $item ) {
+	protected function enqueue($item) {
 
-		if ( empty( $this->queue ) || $item !== $this->queue[ count( $this->queue ) - 1 ] ) {
+		if (empty($this->queue) || $item !== $this->queue[count($this->queue) - 1]) {
 			$this->queue[] = $item;
 		}
 
 	}
 
 	public function shutdown() {
-		foreach ( $this->queue as $callback ) {
-			call_user_func( array( $this, $callback[0] ), $callback[1] );
+		foreach ($this->queue as $callback) {
+			call_user_func(array($this, $callback[0]), $callback[1]);
 		}
 	}
 

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

Indentation +40 added lines, -40 removed lines

@@ -7,45 +7,45 @@
 
 abstract class Abstract_Sync_Object_Adapter implements Sync_Object_Adapter {
 
-	private $object_id;
-
-	private $type;
-
-	private static $meta_name = array(
-		Object_Type_Enum::POST => 'post',
-		Object_Type_Enum::TERM => 'term',
-		Object_Type_Enum::USER => 'user',
-	);
-
-	/**
-	 * 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 ) {
-
-		$this->type      = filter_var( $type, FILTER_VALIDATE_INT );
-		$this->object_id = filter_var( $object_id, FILTER_VALIDATE_INT );
-
-		if ( null === $this->type || ! isset( self::$meta_name[ $this->type ] ) ) {
-			throw new \Exception( 'Invalid $type.' );
-		}
-		if ( null === $this->object_id ) {
-			throw new \Exception( 'Invalid $object.' );
-		}
-
-	}
-
-	function get_type() {
-		return $this->type;
-	}
-
-	function get_object_id() {
-		return $this->object_id;
-	}
+    private $object_id;
+
+    private $type;
+
+    private static $meta_name = array(
+        Object_Type_Enum::POST => 'post',
+        Object_Type_Enum::TERM => 'term',
+        Object_Type_Enum::USER => 'user',
+    );
+
+    /**
+     * 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 ) {
+
+        $this->type      = filter_var( $type, FILTER_VALIDATE_INT );
+        $this->object_id = filter_var( $object_id, FILTER_VALIDATE_INT );
+
+        if ( null === $this->type || ! isset( self::$meta_name[ $this->type ] ) ) {
+            throw new \Exception( 'Invalid $type.' );
+        }
+        if ( null === $this->object_id ) {
+            throw new \Exception( 'Invalid $object.' );
+        }
+
+    }
+
+    function get_type() {
+        return $this->type;
+    }
+
+    function get_object_id() {
+        return $this->object_id;
+    }
 
 }

Spacing +7 added lines, -7 removed lines

@@ -26,16 +26,16 @@
 	 *
 	 * @throws \Exception
 	 */
-	function __construct( $type, $object_id ) {
+	function __construct($type, $object_id) {
 
-		$this->type      = filter_var( $type, FILTER_VALIDATE_INT );
-		$this->object_id = filter_var( $object_id, FILTER_VALIDATE_INT );
+		$this->type      = filter_var($type, FILTER_VALIDATE_INT);
+		$this->object_id = filter_var($object_id, FILTER_VALIDATE_INT);
 
-		if ( null === $this->type || ! isset( self::$meta_name[ $this->type ] ) ) {
-			throw new \Exception( 'Invalid $type.' );
+		if (null === $this->type || ! isset(self::$meta_name[$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.');
 		}
 
 	}

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

Indentation +95 added lines, -95 removed lines

@@ -7,100 +7,100 @@
 use Wordlift\Object_Type_Enum;
 
 class Sync_User_Hooks extends Abstract_Sync_Hooks {
-	/**
-	 * @var \Wordlift_Log_Service
-	 */
-	private $log;
-
-	/**
-	 * @var Sync_Service
-	 */
-	private $sync_service;
-
-	/**
-	 * Sync_User_Hooks constructor.
-	 *
-	 * @param Sync_Service $sync_service
-	 */
-	function __construct( Sync_Service $sync_service ) {
-		parent::__construct();
-
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
-
-		$this->sync_service = $sync_service;
-
-		$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' ) );
-
-	}
-
-	public function changed_user( $user_id ) {
-
-		$this->sync( $user_id );
-
-	}
-
-	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',
-				apply_filters( 'wl_dataset__sync_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 );
-
-	}
-
-	private function sync( $user_id ) {
-		$this->enqueue( array( 'do_sync', $user_id ) );
-	}
-
-	public function do_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 );
-		}
-
-	}
-
-	public function delete_user( $user_id ) {
-		$this->enqueue( array( 'do_delete', $user_id ) );
-	}
-
-	public function do_delete( $user_id ) {
-		try {
-			$this->sync_service->delete_one( Object_Type_Enum::USER, $user_id,
-				Wordpress_User_Content_Legacy_Service::get_instance()->get_entity_id( Wordpress_Content_Id::create_user( $user_id ) ) );
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to delete user $user_id: " . $e->getMessage(), $e );
-		}
-
-	}
+    /**
+     * @var \Wordlift_Log_Service
+     */
+    private $log;
+
+    /**
+     * @var Sync_Service
+     */
+    private $sync_service;
+
+    /**
+     * Sync_User_Hooks constructor.
+     *
+     * @param Sync_Service $sync_service
+     */
+    function __construct( Sync_Service $sync_service ) {
+        parent::__construct();
+
+        $this->log = \Wordlift_Log_Service::get_logger( get_class() );
+
+        $this->sync_service = $sync_service;
+
+        $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' ) );
+
+    }
+
+    public function changed_user( $user_id ) {
+
+        $this->sync( $user_id );
+
+    }
+
+    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',
+                apply_filters( 'wl_dataset__sync_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 );
+
+    }
+
+    private function sync( $user_id ) {
+        $this->enqueue( array( 'do_sync', $user_id ) );
+    }
+
+    public function do_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 );
+        }
+
+    }
+
+    public function delete_user( $user_id ) {
+        $this->enqueue( array( 'do_delete', $user_id ) );
+    }
+
+    public function do_delete( $user_id ) {
+        try {
+            $this->sync_service->delete_one( Object_Type_Enum::USER, $user_id,
+                Wordpress_User_Content_Legacy_Service::get_instance()->get_entity_id( Wordpress_Content_Id::create_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 +29 added lines, -29 removed lines

@@ -22,10 +22,10 @@ 
 	 *
 	 * @param Sync_Service $sync_service
 	 */
-	function __construct( Sync_Service $sync_service ) {
+	function __construct(Sync_Service $sync_service) {
 		parent::__construct();
 
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
+		$this->log = \Wordlift_Log_Service::get_logger(get_class());
 
 		$this->sync_service = $sync_service;
 
@@ -37,26 +37,26 @@ 
 		/**
 		 * 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',
-				apply_filters( 'wl_dataset__sync_hooks__ignored_meta_keys',
+		if (in_array($meta_key,
+			apply_filters('wl_dataset__sync_user_hooks__ignored_meta_keys',
+				apply_filters('wl_dataset__sync_hooks__ignored_meta_keys',
 					array(
 						'rich_editing',
 						'comment_shortcuts',
@@ -67,38 +67,38 @@ 
 						'wptests_user_level',
 						'dismissed_wp_pointers',
 						'entity_url',
-					) ) ) ) ) {
+					))))) {
 			return;
 		}
 
-		$this->sync( $user_id );
+		$this->sync($user_id);
 
 	}
 
-	private function sync( $user_id ) {
-		$this->enqueue( array( 'do_sync', $user_id ) );
+	private function sync($user_id) {
+		$this->enqueue(array('do_sync', $user_id));
 	}
 
-	public function do_sync( $user_id ) {
+	public function do_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 ) {
-		$this->enqueue( array( 'do_delete', $user_id ) );
+	public function delete_user($user_id) {
+		$this->enqueue(array('do_delete', $user_id));
 	}
 
-	public function do_delete( $user_id ) {
+	public function do_delete($user_id) {
 		try {
-			$this->sync_service->delete_one( Object_Type_Enum::USER, $user_id,
-				Wordpress_User_Content_Legacy_Service::get_instance()->get_entity_id( Wordpress_Content_Id::create_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,
+				Wordpress_User_Content_Legacy_Service::get_instance()->get_entity_id(Wordpress_Content_Id::create_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-service.php

Indentation +240 added lines, -240 removed lines

@@ -8,247 +8,247 @@
 use Wordlift\Object_Type_Enum;
 
 class Sync_Service {
-	const JSONLD_HASH = 'jsonld_hash';
-	const SYNCED_GMT = 'synced_gmt';
-
-	/**
-	 * @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;
-	private $entity_service;
-
-	/**
-	 * 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
-	 * @param Jsonld_Service $jsonld_service
-	 * @param \Wordlift_Entity_Service $entity_service
-	 */
-	public function __construct( $api_service, $sync_object_adapter_factory, $jsonld_service, $entity_service ) {
-
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
-
-		$this->api_service                 = $api_service;
-		$this->sync_object_adapter_factory = $sync_object_adapter_factory;
-		$this->jsonld_service              = $jsonld_service;
-		$this->entity_service              = $entity_service;
-		$this->batch_size                  = 10;
-
-		// You need to initialize this early, otherwise the Background Process isn't registered in AJAX calls.
+    const JSONLD_HASH = 'jsonld_hash';
+    const SYNCED_GMT = 'synced_gmt';
+
+    /**
+     * @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;
+    private $entity_service;
+
+    /**
+     * 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
+     * @param Jsonld_Service $jsonld_service
+     * @param \Wordlift_Entity_Service $entity_service
+     */
+    public function __construct( $api_service, $sync_object_adapter_factory, $jsonld_service, $entity_service ) {
+
+        $this->log = \Wordlift_Log_Service::get_logger( get_class() );
+
+        $this->api_service                 = $api_service;
+        $this->sync_object_adapter_factory = $sync_object_adapter_factory;
+        $this->jsonld_service              = $jsonld_service;
+        $this->entity_service              = $entity_service;
+        $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 );;
 
-		// Exclude the JSONLD_HASH meta key from those that require a resync.
-		add_filter( 'wl_dataset__sync_hooks__ignored_meta_keys', function ( $args ) {
-			$args[] = Sync_Service::JSONLD_HASH;
-			$args[] = Sync_Service::SYNCED_GMT;
-
-			return $args;
-		} );
-
-		self::$instance = $this;
-	}
-
-	public static function get_instance() {
-		return self::$instance;
-	}
-
-	/**
-	 * @param int $type
-	 * @param int $object_id
-	 *
-	 * @return array|false
-	 * @throws Exception
-	 */
-	public function sync_one( $type, $object_id ) {
-
-		$object = $this->sync_object_adapter_factory->create( $type, $object_id );
-
-		return $this->sync_many( array( $object ) );
-	}
-
-	/**
-	 * @param $type string Post or User.
-	 * @param $object_id  int Post or User id
-	 * @param $uri string Entity uri , This needs to be supplied before deletion, if we
-	 * get it from meta it might not be available.
-	 *
-	 * @return bool
-	 */
-	public function delete_one( $type, $object_id, $uri ) {
-		// Entity URL isn't set, bail out.
-		if ( empty( $uri ) ) {
-			return false;
-		}
-
-		$response = $this->api_service->request(
-			'DELETE', sprintf( '/middleware/dataset?uri=%s', rawurlencode( $uri ) ) );
-
-
-		// Update the sync date in case of success, otherwise log an error.
-		if ( ! $response->is_success() ) {
-			return false;
-		}
-
-		/**
-		 * Allow 3rd parties to run additional sync work.
-		 */
-		do_action( 'wl_sync__delete_one', $type, $object_id, $uri );
-
-		return true;
-	}
-
-	/**
-	 * @param Sync_Object_Adapter[] $objects
-	 * @param bool $force Force synchronization even if the json-ld hash hasn't changed.
-	 *
-	 * @return bool
-	 * @throws Exception
-	 */
-	public function sync_many( $objects, $force = false ) {
-
-		$hashes   = array();
-		$payloads = array();
-		/** @var Sync_Object_Adapter $object */
-		foreach ( $objects as $object ) {
-			// Bail out if no payload.
-			$payload_as_string = $this->get_payload_as_string( $object );
-			if ( empty( $payload_as_string ) ) {
-				continue;
-			}
-			$new_hash = sha1( $payload_as_string );
-			$old_hash = $object->get_value( self::JSONLD_HASH );
-
-			// JSON-LD hasn't changed, bail out.
-			$should_sync = $force || $new_hash !== $old_hash;
-			if ( ! apply_filters( 'wl_dataset__sync_service__sync_item', $should_sync, $object, $payload_as_string ) ) {
-				continue;
-			}
-
-			// Collect the hashes and the payloads.
-			$hashes[]   = array( $object, $new_hash, $payload_as_string );
-			$payloads[] = $payload_as_string;
-		}
-
-		// Bail out if payloads are empty.
-		if ( empty( $payloads ) ) {
-			return false;
-		}
-
-		$response = $this->api_service->request(
-			'POST', '/middleware/dataset/batch',
-			array( 'Content-Type' => 'application/json', ),
-			// Put the payload in a JSON array w/o decoding/encoding again.
-			'[ ' . implode( ', ', $payloads ) . ' ]' );
-
-		// Update the sync date in case of success, otherwise log an error.
-		if ( ! $response->is_success() ) {
-			return false;
-		}
-
-		// If successful update the hashes and sync'ed datetime.
-		foreach ( $hashes as $hash ) {
-			$object   = $hash[0];
-			$new_hash = $hash[1];
-
-			$object->set_values( array(
-				self::JSONLD_HASH => $new_hash,
-				self::SYNCED_GMT  => current_time( 'mysql', true ),
-			) );
-		}
-
-
-		/**
-		 * Allow 3rd parties to run additional sync work.
-		 */
-		do_action( 'wl_sync__sync_many', $hashes );
-
-		return true;
-	}
-
-	/**
-	 * @param Sync_Object_Adapter $object
-	 *
-	 * @return false|string
-	 * @throws Exception
-	 */
-	private function get_payload_as_string( $object ) {
-		$type             = $object->get_type();
-		$object_id        = $object->get_object_id();
-		$jsonld_as_string = wp_json_encode( apply_filters( 'wl_dataset__sync_service__sync_item__jsonld',
-			$this->jsonld_service->get( $type, $object_id ), $type, $object_id ) );
-		$uri              = $this->entity_service->get_uri( $object_id, $type );
-
-		// Entity URL isn't set, bail out.
-		if ( empty( $uri ) ) {
-			return false;
-		}
-
-		return wp_json_encode( array(
-			'uri'     => $uri,
-			'model'   => $jsonld_as_string,
-			'private' => ! $object->is_public(),
-		) );
-	}
-
-	/**
-	 * @param $post_id
-	 *
-	 * @todo Complete the delete item.
-	 */
-	public function delete_item( $post_id ) {
-		$uri = $this->entity_service->get_uri( $post_id, Object_Type_Enum::POST );
-
-		if ( ! isset( $uri ) ) {
-			return;
-		}
-
-		// Make a request to the remote endpoint.
-		$response = $this->api_service->request(
-			'DELETE', '/middleware/dataset?uri=' . rawurlencode( $uri ),
-			array( 'Content-Type' => 'application/ld+json', ) );
-
-	}
-
-	public function get_batch_size() {
-
-		return $this->batch_size;
-	}
-
-	public function delete_all() {
-		$this->api_service->request( 'DELETE', '/middleware/dataset/all' );
-	}
+        // Exclude the JSONLD_HASH meta key from those that require a resync.
+        add_filter( 'wl_dataset__sync_hooks__ignored_meta_keys', function ( $args ) {
+            $args[] = Sync_Service::JSONLD_HASH;
+            $args[] = Sync_Service::SYNCED_GMT;
+
+            return $args;
+        } );
+
+        self::$instance = $this;
+    }
+
+    public static function get_instance() {
+        return self::$instance;
+    }
+
+    /**
+     * @param int $type
+     * @param int $object_id
+     *
+     * @return array|false
+     * @throws Exception
+     */
+    public function sync_one( $type, $object_id ) {
+
+        $object = $this->sync_object_adapter_factory->create( $type, $object_id );
+
+        return $this->sync_many( array( $object ) );
+    }
+
+    /**
+     * @param $type string Post or User.
+     * @param $object_id  int Post or User id
+     * @param $uri string Entity uri , This needs to be supplied before deletion, if we
+     * get it from meta it might not be available.
+     *
+     * @return bool
+     */
+    public function delete_one( $type, $object_id, $uri ) {
+        // Entity URL isn't set, bail out.
+        if ( empty( $uri ) ) {
+            return false;
+        }
+
+        $response = $this->api_service->request(
+            'DELETE', sprintf( '/middleware/dataset?uri=%s', rawurlencode( $uri ) ) );
+
+
+        // Update the sync date in case of success, otherwise log an error.
+        if ( ! $response->is_success() ) {
+            return false;
+        }
+
+        /**
+         * Allow 3rd parties to run additional sync work.
+         */
+        do_action( 'wl_sync__delete_one', $type, $object_id, $uri );
+
+        return true;
+    }
+
+    /**
+     * @param Sync_Object_Adapter[] $objects
+     * @param bool $force Force synchronization even if the json-ld hash hasn't changed.
+     *
+     * @return bool
+     * @throws Exception
+     */
+    public function sync_many( $objects, $force = false ) {
+
+        $hashes   = array();
+        $payloads = array();
+        /** @var Sync_Object_Adapter $object */
+        foreach ( $objects as $object ) {
+            // Bail out if no payload.
+            $payload_as_string = $this->get_payload_as_string( $object );
+            if ( empty( $payload_as_string ) ) {
+                continue;
+            }
+            $new_hash = sha1( $payload_as_string );
+            $old_hash = $object->get_value( self::JSONLD_HASH );
+
+            // JSON-LD hasn't changed, bail out.
+            $should_sync = $force || $new_hash !== $old_hash;
+            if ( ! apply_filters( 'wl_dataset__sync_service__sync_item', $should_sync, $object, $payload_as_string ) ) {
+                continue;
+            }
+
+            // Collect the hashes and the payloads.
+            $hashes[]   = array( $object, $new_hash, $payload_as_string );
+            $payloads[] = $payload_as_string;
+        }
+
+        // Bail out if payloads are empty.
+        if ( empty( $payloads ) ) {
+            return false;
+        }
+
+        $response = $this->api_service->request(
+            'POST', '/middleware/dataset/batch',
+            array( 'Content-Type' => 'application/json', ),
+            // Put the payload in a JSON array w/o decoding/encoding again.
+            '[ ' . implode( ', ', $payloads ) . ' ]' );
+
+        // Update the sync date in case of success, otherwise log an error.
+        if ( ! $response->is_success() ) {
+            return false;
+        }
+
+        // If successful update the hashes and sync'ed datetime.
+        foreach ( $hashes as $hash ) {
+            $object   = $hash[0];
+            $new_hash = $hash[1];
+
+            $object->set_values( array(
+                self::JSONLD_HASH => $new_hash,
+                self::SYNCED_GMT  => current_time( 'mysql', true ),
+            ) );
+        }
+
+
+        /**
+         * Allow 3rd parties to run additional sync work.
+         */
+        do_action( 'wl_sync__sync_many', $hashes );
+
+        return true;
+    }
+
+    /**
+     * @param Sync_Object_Adapter $object
+     *
+     * @return false|string
+     * @throws Exception
+     */
+    private function get_payload_as_string( $object ) {
+        $type             = $object->get_type();
+        $object_id        = $object->get_object_id();
+        $jsonld_as_string = wp_json_encode( apply_filters( 'wl_dataset__sync_service__sync_item__jsonld',
+            $this->jsonld_service->get( $type, $object_id ), $type, $object_id ) );
+        $uri              = $this->entity_service->get_uri( $object_id, $type );
+
+        // Entity URL isn't set, bail out.
+        if ( empty( $uri ) ) {
+            return false;
+        }
+
+        return wp_json_encode( array(
+            'uri'     => $uri,
+            'model'   => $jsonld_as_string,
+            'private' => ! $object->is_public(),
+        ) );
+    }
+
+    /**
+     * @param $post_id
+     *
+     * @todo Complete the delete item.
+     */
+    public function delete_item( $post_id ) {
+        $uri = $this->entity_service->get_uri( $post_id, Object_Type_Enum::POST );
+
+        if ( ! isset( $uri ) ) {
+            return;
+        }
+
+        // Make a request to the remote endpoint.
+        $response = $this->api_service->request(
+            'DELETE', '/middleware/dataset?uri=' . rawurlencode( $uri ),
+            array( 'Content-Type' => 'application/ld+json', ) );
+
+    }
+
+    public function get_batch_size() {
+
+        return $this->batch_size;
+    }
+
+    public function delete_all() {
+        $this->api_service->request( 'DELETE', '/middleware/dataset/all' );
+    }
 
 }

Spacing +41 added lines, -41 removed lines

@@ -57,9 +57,9 @@ 
 	 * @param Jsonld_Service $jsonld_service
 	 * @param \Wordlift_Entity_Service $entity_service
 	 */
-	public function __construct( $api_service, $sync_object_adapter_factory, $jsonld_service, $entity_service ) {
+	public function __construct($api_service, $sync_object_adapter_factory, $jsonld_service, $entity_service) {
 
-		$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;
@@ -71,7 +71,7 @@ 
 //		$this->sync_background_process = new Sync_Background_Process( $this );;
 
 		// Exclude the JSONLD_HASH meta key from those that require a resync.
-		add_filter( 'wl_dataset__sync_hooks__ignored_meta_keys', function ( $args ) {
+		add_filter('wl_dataset__sync_hooks__ignored_meta_keys', function($args) {
 			$args[] = Sync_Service::JSONLD_HASH;
 			$args[] = Sync_Service::SYNCED_GMT;
 
@@ -92,11 +92,11 @@ 
 	 * @return array|false
 	 * @throws Exception
 	 */
-	public function sync_one( $type, $object_id ) {
+	public function sync_one($type, $object_id) {
 
-		$object = $this->sync_object_adapter_factory->create( $type, $object_id );
+		$object = $this->sync_object_adapter_factory->create($type, $object_id);
 
-		return $this->sync_many( array( $object ) );
+		return $this->sync_many(array($object));
 	}
 
 	/**
@@ -107,25 +107,25 @@ 
 	 *
 	 * @return bool
 	 */
-	public function delete_one( $type, $object_id, $uri ) {
+	public function delete_one($type, $object_id, $uri) {
 		// Entity URL isn't set, bail out.
-		if ( empty( $uri ) ) {
+		if (empty($uri)) {
 			return false;
 		}
 
 		$response = $this->api_service->request(
-			'DELETE', sprintf( '/middleware/dataset?uri=%s', rawurlencode( $uri ) ) );
+			'DELETE', sprintf('/middleware/dataset?uri=%s', rawurlencode($uri)) );
 
 
 		// Update the sync date in case of success, otherwise log an error.
-		if ( ! $response->is_success() ) {
+		if ( ! $response->is_success()) {
 			return false;
 		}
 
 		/**
 		 * Allow 3rd parties to run additional sync work.
 		 */
-		do_action( 'wl_sync__delete_one', $type, $object_id, $uri );
+		do_action('wl_sync__delete_one', $type, $object_id, $uri);
 
 		return true;
 	}
@@ -137,63 +137,63 @@ 
 	 * @return bool
 	 * @throws Exception
 	 */
-	public function sync_many( $objects, $force = false ) {
+	public function sync_many($objects, $force = false) {
 
 		$hashes   = array();
 		$payloads = array();
 		/** @var Sync_Object_Adapter $object */
-		foreach ( $objects as $object ) {
+		foreach ($objects as $object) {
 			// Bail out if no payload.
-			$payload_as_string = $this->get_payload_as_string( $object );
-			if ( empty( $payload_as_string ) ) {
+			$payload_as_string = $this->get_payload_as_string($object);
+			if (empty($payload_as_string)) {
 				continue;
 			}
-			$new_hash = sha1( $payload_as_string );
-			$old_hash = $object->get_value( self::JSONLD_HASH );
+			$new_hash = sha1($payload_as_string);
+			$old_hash = $object->get_value(self::JSONLD_HASH);
 
 			// JSON-LD hasn't changed, bail out.
 			$should_sync = $force || $new_hash !== $old_hash;
-			if ( ! apply_filters( 'wl_dataset__sync_service__sync_item', $should_sync, $object, $payload_as_string ) ) {
+			if ( ! apply_filters('wl_dataset__sync_service__sync_item', $should_sync, $object, $payload_as_string)) {
 				continue;
 			}
 
 			// Collect the hashes and the payloads.
-			$hashes[]   = array( $object, $new_hash, $payload_as_string );
+			$hashes[]   = array($object, $new_hash, $payload_as_string);
 			$payloads[] = $payload_as_string;
 		}
 
 		// Bail out if payloads are empty.
-		if ( empty( $payloads ) ) {
+		if (empty($payloads)) {
 			return false;
 		}
 
 		$response = $this->api_service->request(
 			'POST', '/middleware/dataset/batch',
-			array( 'Content-Type' => 'application/json', ),
+			array('Content-Type' => 'application/json',),
 			// Put the payload in a JSON array w/o decoding/encoding again.
-			'[ ' . implode( ', ', $payloads ) . ' ]' );
+			'[ '.implode(', ', $payloads).' ]' );
 
 		// Update the sync date in case of success, otherwise log an error.
-		if ( ! $response->is_success() ) {
+		if ( ! $response->is_success()) {
 			return false;
 		}
 
 		// If successful update the hashes and sync'ed datetime.
-		foreach ( $hashes as $hash ) {
+		foreach ($hashes as $hash) {
 			$object   = $hash[0];
 			$new_hash = $hash[1];
 
-			$object->set_values( array(
+			$object->set_values(array(
 				self::JSONLD_HASH => $new_hash,
-				self::SYNCED_GMT  => current_time( 'mysql', true ),
-			) );
+				self::SYNCED_GMT  => current_time('mysql', true),
+			));
 		}
 
 
 		/**
 		 * Allow 3rd parties to run additional sync work.
 		 */
-		do_action( 'wl_sync__sync_many', $hashes );
+		do_action('wl_sync__sync_many', $hashes);
 
 		return true;
 	}
@@ -204,23 +204,23 @@ 
 	 * @return false|string
 	 * @throws Exception
 	 */
-	private function get_payload_as_string( $object ) {
+	private function get_payload_as_string($object) {
 		$type             = $object->get_type();
 		$object_id        = $object->get_object_id();
-		$jsonld_as_string = wp_json_encode( apply_filters( 'wl_dataset__sync_service__sync_item__jsonld',
-			$this->jsonld_service->get( $type, $object_id ), $type, $object_id ) );
-		$uri              = $this->entity_service->get_uri( $object_id, $type );
+		$jsonld_as_string = wp_json_encode(apply_filters('wl_dataset__sync_service__sync_item__jsonld',
+			$this->jsonld_service->get($type, $object_id), $type, $object_id));
+		$uri              = $this->entity_service->get_uri($object_id, $type);
 
 		// Entity URL isn't set, bail out.
-		if ( empty( $uri ) ) {
+		if (empty($uri)) {
 			return false;
 		}
 
-		return wp_json_encode( array(
+		return wp_json_encode(array(
 			'uri'     => $uri,
 			'model'   => $jsonld_as_string,
 			'private' => ! $object->is_public(),
-		) );
+		));
 	}
 
 	/**
@@ -228,17 +228,17 @@ 
 	 *
 	 * @todo Complete the delete item.
 	 */
-	public function delete_item( $post_id ) {
-		$uri = $this->entity_service->get_uri( $post_id, Object_Type_Enum::POST );
+	public function delete_item($post_id) {
+		$uri = $this->entity_service->get_uri($post_id, Object_Type_Enum::POST);
 
-		if ( ! isset( $uri ) ) {
+		if ( ! isset($uri)) {
 			return;
 		}
 
 		// Make a request to the remote endpoint.
 		$response = $this->api_service->request(
-			'DELETE', '/middleware/dataset?uri=' . rawurlencode( $uri ),
-			array( 'Content-Type' => 'application/ld+json', ) );
+			'DELETE', '/middleware/dataset?uri='.rawurlencode($uri),
+			array('Content-Type' => 'application/ld+json',) );
 
 	}
 
@@ -248,7 +248,7 @@ 
 	}
 
 	public function delete_all() {
-		$this->api_service->request( 'DELETE', '/middleware/dataset/all' );
+		$this->api_service->request('DELETE', '/middleware/dataset/all');
 	}
 
 }

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

Indentation +115 added lines, -115 removed lines

@@ -7,119 +7,119 @@
 use Wordlift\Object_Type_Enum;
 
 class Sync_Term_Hooks extends Abstract_Sync_Hooks {
-	/**
-	 * @var \Wordlift_Log_Service
-	 */
-	private $log;
-
-	/**
-	 * @var Sync_Service
-	 */
-	private $sync_service;
-
-	/**
-	 * @var Sync_Object_Adapter_Factory
-	 */
-	private $sync_object_factory;
-
-	/**
-	 * Sync_Term_Hooks constructor.
-	 *
-	 * @param Sync_Service $sync_service
-	 * @param Sync_Object_Adapter_Factory $sync_object_factory
-	 */
-	function __construct( $sync_service, $sync_object_factory ) {
-		parent::__construct();
-
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
-
-		$this->sync_service        = $sync_service;
-		$this->sync_object_factory = $sync_object_factory;
-
-		$this->register_hooks();
-	}
-
-	private function register_hooks() {
-		/**
-		 * Register hooks for post and meta.
-		 */
-		add_action( 'create_term', array( $this, 'do_sync' ) );
-		add_action( 'edit_term', array( $this, 'do_sync' ) );
-		add_action( 'added_term_meta', array( $this, 'changed_term_meta' ), 10, 4 );
-		add_action( 'updated_term_meta', array( $this, 'changed_term_meta' ), 10, 4 );
-		add_action( 'deleted_term_meta', array( $this, 'changed_term_meta' ), 10, 4 );
-		add_action( 'pre_delete_term', array( $this, 'delete_term' ) );
-
-	}
-
-	public function saved_term( $term_id ) {
-
-		// Sync all the terms without filtering.
-		$this->sync( $term_id );
-	}
-
-	public function changed_term_meta( $meta_id, $term_id, $meta_key, $_meta_value ) {
-
-		if ( in_array( $meta_key,
-			apply_filters( 'wl_dataset__sync_post_hooks__ignored_meta_keys',
-				apply_filters( 'wl_dataset__sync_hooks__ignored_meta_keys',
-					array(
-						'_pingme',
-						'_encloseme',
-						'entity_url',
-					) ) ) )
-		) {
-			return;
-		}
-
-		$this->sync( $term_id );
-
-	}
-
-	private function sync( $term_id ) {
-
-		$this->enqueue( array( 'do_sync', $term_id ) );
-	}
-
-	public function do_sync( $term_id ) {
-
-		try {
-			$term = get_term( $term_id );
-			if ( ! isset( $term ) ) {
-				return;
-			}
-			$this->sync_service->sync_many( array(
-				$this->sync_object_factory->create( Object_Type_Enum::TERM, $term_id ),
-			) );
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to sync post $term_id: " . $e->getMessage(), $e );
-		}
-	}
-
-	/**
-	 * @param $term \WP_Term
-	 *
-	 * @throws \Exception
-	 */
-	public function delete_term( $term_id ) {
-		$args = array(
-			$term_id,
-			Wordpress_Term_Content_Legacy_Service
-				::get_instance()
-				->get_entity_id( Wordpress_Content_Id::create_term( $term_id ) )
-		);
-		// We can't postpone the execution for a `delete` because we would miss the actual data.
-		$this->do_delete( $args );
-	}
-
-	public function do_delete( $args ) {
-		$term_id         = $args[0];
-		$term_entity_uri = $args[1];
-
-		try {
-			$this->sync_service->delete_one( Object_Type_Enum::TERM, $term_id, $term_entity_uri );
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to delete term $term_id: " . $e->getMessage(), $e );
-		}
-	}
+    /**
+     * @var \Wordlift_Log_Service
+     */
+    private $log;
+
+    /**
+     * @var Sync_Service
+     */
+    private $sync_service;
+
+    /**
+     * @var Sync_Object_Adapter_Factory
+     */
+    private $sync_object_factory;
+
+    /**
+     * Sync_Term_Hooks constructor.
+     *
+     * @param Sync_Service $sync_service
+     * @param Sync_Object_Adapter_Factory $sync_object_factory
+     */
+    function __construct( $sync_service, $sync_object_factory ) {
+        parent::__construct();
+
+        $this->log = \Wordlift_Log_Service::get_logger( get_class() );
+
+        $this->sync_service        = $sync_service;
+        $this->sync_object_factory = $sync_object_factory;
+
+        $this->register_hooks();
+    }
+
+    private function register_hooks() {
+        /**
+         * Register hooks for post and meta.
+         */
+        add_action( 'create_term', array( $this, 'do_sync' ) );
+        add_action( 'edit_term', array( $this, 'do_sync' ) );
+        add_action( 'added_term_meta', array( $this, 'changed_term_meta' ), 10, 4 );
+        add_action( 'updated_term_meta', array( $this, 'changed_term_meta' ), 10, 4 );
+        add_action( 'deleted_term_meta', array( $this, 'changed_term_meta' ), 10, 4 );
+        add_action( 'pre_delete_term', array( $this, 'delete_term' ) );
+
+    }
+
+    public function saved_term( $term_id ) {
+
+        // Sync all the terms without filtering.
+        $this->sync( $term_id );
+    }
+
+    public function changed_term_meta( $meta_id, $term_id, $meta_key, $_meta_value ) {
+
+        if ( in_array( $meta_key,
+            apply_filters( 'wl_dataset__sync_post_hooks__ignored_meta_keys',
+                apply_filters( 'wl_dataset__sync_hooks__ignored_meta_keys',
+                    array(
+                        '_pingme',
+                        '_encloseme',
+                        'entity_url',
+                    ) ) ) )
+        ) {
+            return;
+        }
+
+        $this->sync( $term_id );
+
+    }
+
+    private function sync( $term_id ) {
+
+        $this->enqueue( array( 'do_sync', $term_id ) );
+    }
+
+    public function do_sync( $term_id ) {
+
+        try {
+            $term = get_term( $term_id );
+            if ( ! isset( $term ) ) {
+                return;
+            }
+            $this->sync_service->sync_many( array(
+                $this->sync_object_factory->create( Object_Type_Enum::TERM, $term_id ),
+            ) );
+        } catch ( \Exception $e ) {
+            $this->log->error( "An error occurred while trying to sync post $term_id: " . $e->getMessage(), $e );
+        }
+    }
+
+    /**
+     * @param $term \WP_Term
+     *
+     * @throws \Exception
+     */
+    public function delete_term( $term_id ) {
+        $args = array(
+            $term_id,
+            Wordpress_Term_Content_Legacy_Service
+                ::get_instance()
+                ->get_entity_id( Wordpress_Content_Id::create_term( $term_id ) )
+        );
+        // We can't postpone the execution for a `delete` because we would miss the actual data.
+        $this->do_delete( $args );
+    }
+
+    public function do_delete( $args ) {
+        $term_id         = $args[0];
+        $term_entity_uri = $args[1];
+
+        try {
+            $this->sync_service->delete_one( Object_Type_Enum::TERM, $term_id, $term_entity_uri );
+        } catch ( \Exception $e ) {
+            $this->log->error( "An error occurred while trying to delete term $term_id: " . $e->getMessage(), $e );
+        }
+    }
 }

Spacing +33 added lines, -33 removed lines

@@ -28,10 +28,10 @@ 
 	 * @param Sync_Service $sync_service
 	 * @param Sync_Object_Adapter_Factory $sync_object_factory
 	 */
-	function __construct( $sync_service, $sync_object_factory ) {
+	function __construct($sync_service, $sync_object_factory) {
 		parent::__construct();
 
-		$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_object_factory = $sync_object_factory;
@@ -43,56 +43,56 @@ 
 		/**
 		 * Register hooks for post and meta.
 		 */
-		add_action( 'create_term', array( $this, 'do_sync' ) );
-		add_action( 'edit_term', array( $this, 'do_sync' ) );
-		add_action( 'added_term_meta', array( $this, 'changed_term_meta' ), 10, 4 );
-		add_action( 'updated_term_meta', array( $this, 'changed_term_meta' ), 10, 4 );
-		add_action( 'deleted_term_meta', array( $this, 'changed_term_meta' ), 10, 4 );
-		add_action( 'pre_delete_term', array( $this, 'delete_term' ) );
+		add_action('create_term', array($this, 'do_sync'));
+		add_action('edit_term', array($this, 'do_sync'));
+		add_action('added_term_meta', array($this, 'changed_term_meta'), 10, 4);
+		add_action('updated_term_meta', array($this, 'changed_term_meta'), 10, 4);
+		add_action('deleted_term_meta', array($this, 'changed_term_meta'), 10, 4);
+		add_action('pre_delete_term', array($this, 'delete_term'));
 
 	}
 
-	public function saved_term( $term_id ) {
+	public function saved_term($term_id) {
 
 		// Sync all the terms without filtering.
-		$this->sync( $term_id );
+		$this->sync($term_id);
 	}
 
-	public function changed_term_meta( $meta_id, $term_id, $meta_key, $_meta_value ) {
+	public function changed_term_meta($meta_id, $term_id, $meta_key, $_meta_value) {
 
-		if ( in_array( $meta_key,
-			apply_filters( 'wl_dataset__sync_post_hooks__ignored_meta_keys',
-				apply_filters( 'wl_dataset__sync_hooks__ignored_meta_keys',
+		if (in_array($meta_key,
+			apply_filters('wl_dataset__sync_post_hooks__ignored_meta_keys',
+				apply_filters('wl_dataset__sync_hooks__ignored_meta_keys',
 					array(
 						'_pingme',
 						'_encloseme',
 						'entity_url',
-					) ) ) )
+					))))
 		) {
 			return;
 		}
 
-		$this->sync( $term_id );
+		$this->sync($term_id);
 
 	}
 
-	private function sync( $term_id ) {
+	private function sync($term_id) {
 
-		$this->enqueue( array( 'do_sync', $term_id ) );
+		$this->enqueue(array('do_sync', $term_id));
 	}
 
-	public function do_sync( $term_id ) {
+	public function do_sync($term_id) {
 
 		try {
-			$term = get_term( $term_id );
-			if ( ! isset( $term ) ) {
+			$term = get_term($term_id);
+			if ( ! isset($term)) {
 				return;
 			}
-			$this->sync_service->sync_many( array(
-				$this->sync_object_factory->create( Object_Type_Enum::TERM, $term_id ),
-			) );
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to sync post $term_id: " . $e->getMessage(), $e );
+			$this->sync_service->sync_many(array(
+				$this->sync_object_factory->create(Object_Type_Enum::TERM, $term_id),
+			));
+		} catch (\Exception $e) {
+			$this->log->error("An error occurred while trying to sync post $term_id: ".$e->getMessage(), $e);
 		}
 	}
 
@@ -101,25 +101,25 @@ 
 	 *
 	 * @throws \Exception
 	 */
-	public function delete_term( $term_id ) {
+	public function delete_term($term_id) {
 		$args = array(
 			$term_id,
 			Wordpress_Term_Content_Legacy_Service
 				::get_instance()
-				->get_entity_id( Wordpress_Content_Id::create_term( $term_id ) )
+				->get_entity_id(Wordpress_Content_Id::create_term($term_id))
 		);
 		// We can't postpone the execution for a `delete` because we would miss the actual data.
-		$this->do_delete( $args );
+		$this->do_delete($args);
 	}
 
-	public function do_delete( $args ) {
+	public function do_delete($args) {
 		$term_id         = $args[0];
 		$term_entity_uri = $args[1];
 
 		try {
-			$this->sync_service->delete_one( Object_Type_Enum::TERM, $term_id, $term_entity_uri );
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to delete term $term_id: " . $e->getMessage(), $e );
+			$this->sync_service->delete_one(Object_Type_Enum::TERM, $term_id, $term_entity_uri);
+		} catch (\Exception $e) {
+			$this->log->error("An error occurred while trying to delete term $term_id: ".$e->getMessage(), $e);
 		}
 	}
 }

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

Indentation +35 added lines, -35 removed lines

@@ -5,41 +5,41 @@
 use Wordlift\Object_Type_Enum;
 
 class Sync_Term_Adapter extends Abstract_Sync_Object_Adapter {
-	/**
-	 * @var int
-	 */
-	private $term_id;
-
-	/**
-	 * Sync_Term_Adapter constructor.
-	 *
-	 * @param int $term_id
-	 *
-	 * @throws \Exception
-	 */
-	function __construct( $term_id ) {
-		parent::__construct( Object_Type_Enum::TERM, $term_id );
-
-		$this->term_id = $term_id;
-	}
-
-	function is_published() {
-		return $this->is_public();
-	}
-
-	function is_public() {
-		$term = get_term( $this->term_id );
-
-		return get_taxonomy( $term->taxonomy )->public;
-	}
-
-	function set_values( $arr ) {
-		// @@todo
-	}
-
-	function get_value( $key ) {
-		// @@todo
-	}
+    /**
+     * @var int
+     */
+    private $term_id;
+
+    /**
+     * Sync_Term_Adapter constructor.
+     *
+     * @param int $term_id
+     *
+     * @throws \Exception
+     */
+    function __construct( $term_id ) {
+        parent::__construct( Object_Type_Enum::TERM, $term_id );
+
+        $this->term_id = $term_id;
+    }
+
+    function is_published() {
+        return $this->is_public();
+    }
+
+    function is_public() {
+        $term = get_term( $this->term_id );
+
+        return get_taxonomy( $term->taxonomy )->public;
+    }
+
+    function set_values( $arr ) {
+        // @@todo
+    }
+
+    function get_value( $key ) {
+        // @@todo
+    }
 
 
 }

Spacing +6 added lines, -6 removed lines

@@ -17,8 +17,8 @@ 
 	 *
 	 * @throws \Exception
 	 */
-	function __construct( $term_id ) {
-		parent::__construct( Object_Type_Enum::TERM, $term_id );
+	function __construct($term_id) {
+		parent::__construct(Object_Type_Enum::TERM, $term_id);
 
 		$this->term_id = $term_id;
 	}
@@ -28,16 +28,16 @@ 
 	}
 
 	function is_public() {
-		$term = get_term( $this->term_id );
+		$term = get_term($this->term_id);
 
-		return get_taxonomy( $term->taxonomy )->public;
+		return get_taxonomy($term->taxonomy)->public;
 	}
 
-	function set_values( $arr ) {
+	function set_values($arr) {
 		// @@todo
 	}
 
-	function get_value( $key ) {
+	function get_value($key) {
 		// @@todo
 	}
 

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

Indentation +9 added lines, -9 removed lines

@@ -6,19 +6,19 @@
 
 interface Sync_Object_Adapter {
 
-	/**
-	 * @return int see {@link Object_Type_Enum}
-	 */
-	function get_type();
+    /**
+     * @return int see {@link Object_Type_Enum}
+     */
+    function get_type();
 
-	function get_object_id();
+    function get_object_id();
 
-	function is_published();
+    function is_published();
 
-	function is_public();
+    function is_public();
 
-	function set_values( $arr );
+    function set_values( $arr );
 
-	function get_value( $key );
+    function get_value( $key );
 
 }
\ No newline at end of file

Spacing +2 added lines, -2 removed lines

@@ -17,8 +17,8 @@
 
 	function is_public();
 
-	function set_values( $arr );
+	function set_values($arr);
 
-	function get_value( $key );
+	function get_value($key);
 
 }
\ No newline at end of file

src/wordlift/dataset/index.php

Indentation +25 added lines, -25 removed lines

@@ -14,35 +14,35 @@
 use Wordlift\Jsonld\Jsonld_Service;
 
 if ( ! defined( 'ABSPATH' ) ) {
-	exit;
+    exit;
 }
 
 // Register the Dataset JSON Endpoint.
 if ( apply_filters( 'wl_feature__enable__dataset-ng', false ) ) {
 
-	$sync_object_adapter_factory = new Sync_Object_Adapter_Factory();
-	$sync_service                = new Sync_Service( Default_Api_Service::get_instance(), $sync_object_adapter_factory, Jsonld_Service::get_instance(), Wordlift_Entity_Service::get_instance() );
-	new Sync_Post_Hooks( $sync_service, $sync_object_adapter_factory );
-	new Sync_User_Hooks( $sync_service );
-
-	if ( apply_filters( 'wl_feature__enable__no-vocabulary-terms', false ) ) {
-		new Sync_Term_Hooks( $sync_service, $sync_object_adapter_factory );
-	}
-	/**
-	 * @since 3.28.0
-	 * @see https://github.com/insideout10/wordlift-plugin/issues/1186
-	 */
-	new Sync_Hooks_Entity_Relation( Wordlift_Entity_Service::get_instance() );
-
-	if ( apply_filters( 'wl_feature__enable__wordpress-ontology', false ) ) {
-		new Sync_Hooks_Wordpress_Ontology();
-	}
-
-	if ( apply_filters( 'wl_feature__enable__sync-background', false ) ) {
-		// Set up the sync background process.
-		$sync_background_process = new Sync_Background_Process( $sync_service, $sync_object_adapter_factory );
-		new Sync_Background_Process_Wpjson_Endpoint( $sync_background_process );
-		new Sync_Page();
-	}
+    $sync_object_adapter_factory = new Sync_Object_Adapter_Factory();
+    $sync_service                = new Sync_Service( Default_Api_Service::get_instance(), $sync_object_adapter_factory, Jsonld_Service::get_instance(), Wordlift_Entity_Service::get_instance() );
+    new Sync_Post_Hooks( $sync_service, $sync_object_adapter_factory );
+    new Sync_User_Hooks( $sync_service );
+
+    if ( apply_filters( 'wl_feature__enable__no-vocabulary-terms', false ) ) {
+        new Sync_Term_Hooks( $sync_service, $sync_object_adapter_factory );
+    }
+    /**
+     * @since 3.28.0
+     * @see https://github.com/insideout10/wordlift-plugin/issues/1186
+     */
+    new Sync_Hooks_Entity_Relation( Wordlift_Entity_Service::get_instance() );
+
+    if ( apply_filters( 'wl_feature__enable__wordpress-ontology', false ) ) {
+        new Sync_Hooks_Wordpress_Ontology();
+    }
+
+    if ( apply_filters( 'wl_feature__enable__sync-background', false ) ) {
+        // Set up the sync background process.
+        $sync_background_process = new Sync_Background_Process( $sync_service, $sync_object_adapter_factory );
+        new Sync_Background_Process_Wpjson_Endpoint( $sync_background_process );
+        new Sync_Page();
+    }
 
 }

Spacing +12 added lines, -12 removed lines

@@ -13,35 +13,35 @@
 use Wordlift\Dataset\Sync_User_Hooks;
 use Wordlift\Jsonld\Jsonld_Service;
 
-if ( ! defined( 'ABSPATH' ) ) {
+if ( ! defined('ABSPATH')) {
 	exit;
 }
 
 // Register the Dataset JSON Endpoint.
-if ( apply_filters( 'wl_feature__enable__dataset-ng', false ) ) {
+if (apply_filters('wl_feature__enable__dataset-ng', false)) {
 
 	$sync_object_adapter_factory = new Sync_Object_Adapter_Factory();
-	$sync_service                = new Sync_Service( Default_Api_Service::get_instance(), $sync_object_adapter_factory, Jsonld_Service::get_instance(), Wordlift_Entity_Service::get_instance() );
-	new Sync_Post_Hooks( $sync_service, $sync_object_adapter_factory );
-	new Sync_User_Hooks( $sync_service );
+	$sync_service                = new Sync_Service(Default_Api_Service::get_instance(), $sync_object_adapter_factory, Jsonld_Service::get_instance(), Wordlift_Entity_Service::get_instance());
+	new Sync_Post_Hooks($sync_service, $sync_object_adapter_factory);
+	new Sync_User_Hooks($sync_service);
 
-	if ( apply_filters( 'wl_feature__enable__no-vocabulary-terms', false ) ) {
-		new Sync_Term_Hooks( $sync_service, $sync_object_adapter_factory );
+	if (apply_filters('wl_feature__enable__no-vocabulary-terms', false)) {
+		new Sync_Term_Hooks($sync_service, $sync_object_adapter_factory);
 	}
 	/**
 	 * @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());
 
-	if ( apply_filters( 'wl_feature__enable__wordpress-ontology', false ) ) {
+	if (apply_filters('wl_feature__enable__wordpress-ontology', false)) {
 		new Sync_Hooks_Wordpress_Ontology();
 	}
 
-	if ( apply_filters( 'wl_feature__enable__sync-background', false ) ) {
+	if (apply_filters('wl_feature__enable__sync-background', false)) {
 		// Set up the sync background process.
-		$sync_background_process = new Sync_Background_Process( $sync_service, $sync_object_adapter_factory );
-		new Sync_Background_Process_Wpjson_Endpoint( $sync_background_process );
+		$sync_background_process = new Sync_Background_Process($sync_service, $sync_object_adapter_factory);
+		new Sync_Background_Process_Wpjson_Endpoint($sync_background_process);
 		new Sync_Page();
 	}