insideout10 / wordlift-plugin

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

Indentation +104 added lines, -104 removed lines

@@ -5,109 +5,109 @@
 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
-	 */
-	public function delete_term( $term ) {
-		$this->enqueue( array( 'do_delete', $term->term_id ) );
-	}
-
-	public function do_delete( $term_id ) {
-		try {
-			$this->sync_service->delete_one( Object_Type_Enum::TERM, $term_id,  get_term_meta( $term_id, 'entity_url', true ) );
-		} 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
+     */
+    public function delete_term( $term ) {
+        $this->enqueue( array( 'do_delete', $term->term_id ) );
+    }
+
+    public function do_delete( $term_id ) {
+        try {
+            $this->sync_service->delete_one( Object_Type_Enum::TERM, $term_id,  get_term_meta( $term_id, 'entity_url', true ) );
+        } catch ( \Exception $e ) {
+            $this->log->error( "An error occurred while trying to delete term $term_id: " . $e->getMessage(), $e );
+        }
+    }
 
 }
\ No newline at end of file

Spacing +32 added lines, -32 removed lines

@@ -26,10 +26,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;
@@ -41,72 +41,72 @@ 
 		/**
 		 * 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);
 		}
 	}
 
 	/**
 	 * @param $term \WP_Term
 	 */
-	public function delete_term( $term ) {
-		$this->enqueue( array( 'do_delete', $term->term_id ) );
+	public function delete_term($term) {
+		$this->enqueue(array('do_delete', $term->term_id));
 	}
 
-	public function do_delete( $term_id ) {
+	public function do_delete($term_id) {
 		try {
-			$this->sync_service->delete_one( Object_Type_Enum::TERM, $term_id,  get_term_meta( $term_id, 'entity_url', true ) );
-		} 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, get_term_meta($term_id, 'entity_url', true));
+		} catch (\Exception $e) {
+			$this->log->error("An error occurred while trying to delete term $term_id: ".$e->getMessage(), $e);
 		}
 	}
 

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

Indentation +227 added lines, -227 removed lines

@@ -7,234 +7,234 @@
 use Wordlift\Jsonld\Jsonld_Service;
 
 class Sync_Service {
-	const JSONLD_HASH = '_wl_jsonld_hash';
-	const SYNCED_GMT = '_wl_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 = '_wl_jsonld_hash';
+    const SYNCED_GMT = '_wl_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.
-		 */
-		add_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();
-		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_meta( self::JSONLD_HASH, true );
-
-			// JSON-LD hasn't changed, bail out.
-			if ( ! $force && $new_hash === $old_hash ) {
-				continue;
-			}
-
-			// Collect the hashes and the payloads.
-			$hashes[]   = array( $object, $new_hash );
-			$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->update_meta( self::JSONLD_HASH, $new_hash );
-			$object->update_meta( self::SYNCED_GMT, current_time( 'mysql', true ) );
-		}
-
-		/**
-		 * Allow 3rd parties to run additional sync work.
-		 */
-		add_action( 'wl_sync__sync_many', $payloads, array_column( $hashes, 0 ) );
-
-		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 = get_post_meta( $post_id, 'entity_url', true );
-		// 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.
+         */
+        add_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();
+        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_meta( self::JSONLD_HASH, true );
+
+            // JSON-LD hasn't changed, bail out.
+            if ( ! $force && $new_hash === $old_hash ) {
+                continue;
+            }
+
+            // Collect the hashes and the payloads.
+            $hashes[]   = array( $object, $new_hash );
+            $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->update_meta( self::JSONLD_HASH, $new_hash );
+            $object->update_meta( self::SYNCED_GMT, current_time( 'mysql', true ) );
+        }
+
+        /**
+         * Allow 3rd parties to run additional sync work.
+         */
+        add_action( 'wl_sync__sync_many', $payloads, array_column( $hashes, 0 ) );
+
+        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 = get_post_meta( $post_id, 'entity_url', true );
+        // 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 +39 added lines, -39 removed lines

@@ -56,9 +56,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;
@@ -70,7 +70,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;
 
@@ -91,11 +91,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));
 	}
 
 	/**
@@ -106,24 +106,24 @@ 
 	 *
 	 * @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.
 		 */
-		add_action( 'wl_sync__delete_one', $type, $object_id, $uri );
+		add_action('wl_sync__delete_one', $type, $object_id, $uri);
 
 		return true;
 	}
@@ -135,57 +135,57 @@ 
 	 * @return bool
 	 * @throws Exception
 	 */
-	public function sync_many( $objects, $force = false ) {
+	public function sync_many($objects, $force = false) {
 
 		$hashes   = array();
 		$payloads = array();
-		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_meta( self::JSONLD_HASH, true );
+			$new_hash = sha1($payload_as_string);
+			$old_hash = $object->get_meta(self::JSONLD_HASH, true);
 
 			// JSON-LD hasn't changed, bail out.
-			if ( ! $force && $new_hash === $old_hash ) {
+			if ( ! $force && $new_hash === $old_hash) {
 				continue;
 			}
 
 			// Collect the hashes and the payloads.
-			$hashes[]   = array( $object, $new_hash );
+			$hashes[]   = array($object, $new_hash);
 			$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->update_meta( self::JSONLD_HASH, $new_hash );
-			$object->update_meta( self::SYNCED_GMT, current_time( 'mysql', true ) );
+			$object->update_meta(self::JSONLD_HASH, $new_hash);
+			$object->update_meta(self::SYNCED_GMT, current_time('mysql', true));
 		}
 
 		/**
 		 * Allow 3rd parties to run additional sync work.
 		 */
-		add_action( 'wl_sync__sync_many', $payloads, array_column( $hashes, 0 ) );
+		add_action('wl_sync__sync_many', $payloads, array_column($hashes, 0));
 
 		return true;
 	}
@@ -196,23 +196,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(),
-		) );
+		));
 	}
 
 	/**
@@ -220,12 +220,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.
 		$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',) );
 	}
 
 	public function get_batch_size() {
@@ -234,7 +234,7 @@ 
 	}
 
 	public function delete_all() {
-		$this->api_service->request( 'DELETE', '/middleware/dataset/all' );
+		$this->api_service->request('DELETE', '/middleware/dataset/all');
 	}
 
 }