insideout10 / wordlift-plugin

src/wordlift/mappings/transforms/class-url-to-entity-transform-function.php

Indentation +67 added lines, -67 removed lines

@@ -19,72 +19,72 @@
  */
 class Url_To_Entity_Transform_Function implements Mappings_Transform_Function {
 
-	/**
-	 * The {@link Wordlift_Entity_Uri_Service} instance.
-	 *
-	 * @var Wordlift_Entity_Uri_Service $entity_uri_service The {@link Wordlift_Entity_Uri_Service} instance.
-	 */
-	private $entity_uri_service;
-
-	/**
-	 * Url_To_Entity_Transform_Function constructor.
-	 *
-	 * @param Wordlift_Entity_Uri_Service $entity_uri_service The {@link Wordlift_Entity_Uri_Service} instance.
-	 */
-	public function __construct( $entity_uri_service ) {
-
-		$this->entity_uri_service = $entity_uri_service;
-
-		add_filter( 'wl_mappings_transformation_functions', array( $this, 'wl_mappings_transformation_functions' ) );
-
-	}
-
-	/**
-	 * Hook to add ourselves to the list of available transform functions.
-	 *
-	 * @param Mappings_Transform_Function[] $value An array of {@link Mappings_Transform_Function}s.
-	 *
-	 * @return Mappings_Transform_Function[] An updated array with ourselves too.
-	 */
-	public function wl_mappings_transformation_functions( $value ) {
-
-		$value[] = $this;
-
-		return $value;
-	}
-
-	/**
-	 * @inheritDoc
-	 */
-	public function get_name() {
-
-		return 'url_to_entity';
-	}
-
-	/**
-	 * @inheritDoc
-	 */
-	public function get_label() {
-
-		return __( 'URL to Entity', 'wordlift' );
-	}
-
-	/**
-	 * @inheritDoc
-	 */
-	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function transform_data( $data, $jsonld, &$references, $post_id ) {
-
-		// Get the entity by URI.
-		$post = $this->entity_uri_service->get_entity( $data );
-
-		// If found, add the reference.
-		if ( is_a( $post, 'WP_Post' ) ) {
-			// Add the entity among the references using the post ID.
-			$references[] = $post->ID;
-		}
-
-		return array( '@id' => $data );
-	}
+    /**
+     * The {@link Wordlift_Entity_Uri_Service} instance.
+     *
+     * @var Wordlift_Entity_Uri_Service $entity_uri_service The {@link Wordlift_Entity_Uri_Service} instance.
+     */
+    private $entity_uri_service;
+
+    /**
+     * Url_To_Entity_Transform_Function constructor.
+     *
+     * @param Wordlift_Entity_Uri_Service $entity_uri_service The {@link Wordlift_Entity_Uri_Service} instance.
+     */
+    public function __construct( $entity_uri_service ) {
+
+        $this->entity_uri_service = $entity_uri_service;
+
+        add_filter( 'wl_mappings_transformation_functions', array( $this, 'wl_mappings_transformation_functions' ) );
+
+    }
+
+    /**
+     * Hook to add ourselves to the list of available transform functions.
+     *
+     * @param Mappings_Transform_Function[] $value An array of {@link Mappings_Transform_Function}s.
+     *
+     * @return Mappings_Transform_Function[] An updated array with ourselves too.
+     */
+    public function wl_mappings_transformation_functions( $value ) {
+
+        $value[] = $this;
+
+        return $value;
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function get_name() {
+
+        return 'url_to_entity';
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function get_label() {
+
+        return __( 'URL to Entity', 'wordlift' );
+    }
+
+    /**
+     * @inheritDoc
+     */
+    // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
+    public function transform_data( $data, $jsonld, &$references, $post_id ) {
+
+        // Get the entity by URI.
+        $post = $this->entity_uri_service->get_entity( $data );
+
+        // If found, add the reference.
+        if ( is_a( $post, 'WP_Post' ) ) {
+            // Add the entity among the references using the post ID.
+            $references[] = $post->ID;
+        }
+
+        return array( '@id' => $data );
+    }
 
 }

Spacing +8 added lines, -8 removed lines

@@ -31,11 +31,11 @@ 
 	 *
 	 * @param Wordlift_Entity_Uri_Service $entity_uri_service The {@link Wordlift_Entity_Uri_Service} instance.
 	 */
-	public function __construct( $entity_uri_service ) {
+	public function __construct($entity_uri_service) {
 
 		$this->entity_uri_service = $entity_uri_service;
 
-		add_filter( 'wl_mappings_transformation_functions', array( $this, 'wl_mappings_transformation_functions' ) );
+		add_filter('wl_mappings_transformation_functions', array($this, 'wl_mappings_transformation_functions'));
 
 	}
 
@@ -46,7 +46,7 @@ 
 	 *
 	 * @return Mappings_Transform_Function[] An updated array with ourselves too.
 	 */
-	public function wl_mappings_transformation_functions( $value ) {
+	public function wl_mappings_transformation_functions($value) {
 
 		$value[] = $this;
 
@@ -66,25 +66,25 @@ 
 	 */
 	public function get_label() {
 
-		return __( 'URL to Entity', 'wordlift' );
+		return __('URL to Entity', 'wordlift');
 	}
 
 	/**
 	 * @inheritDoc
 	 */
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function transform_data( $data, $jsonld, &$references, $post_id ) {
+	public function transform_data($data, $jsonld, &$references, $post_id) {
 
 		// Get the entity by URI.
-		$post = $this->entity_uri_service->get_entity( $data );
+		$post = $this->entity_uri_service->get_entity($data);
 
 		// If found, add the reference.
-		if ( is_a( $post, 'WP_Post' ) ) {
+		if (is_a($post, 'WP_Post')) {
 			// Add the entity among the references using the post ID.
 			$references[] = $post->ID;
 		}
 
-		return array( '@id' => $data );
+		return array('@id' => $data);
 	}
 
 }

src/wordlift/mappings/transforms/class-taxonomy-to-terms-transform-function.php

Indentation +39 added lines, -39 removed lines

@@ -18,57 +18,57 @@
  */
 class Taxonomy_To_Terms_Transform_Function implements Mappings_Transform_Function {
 
-	/**
-	 * Taxonomy_To_Terms_Transform_Function constructor.
-	 */
-	public function __construct() {
+    /**
+     * Taxonomy_To_Terms_Transform_Function constructor.
+     */
+    public function __construct() {
 
-		add_filter( 'wl_mappings_transformation_functions', array( $this, 'wl_mappings_transformation_functions' ) );
+        add_filter( 'wl_mappings_transformation_functions', array( $this, 'wl_mappings_transformation_functions' ) );
 
-	}
+    }
 
-	/**
-	 * Hook to add ourselves to the list of available transform functions.
-	 *
-	 * @param Mappings_Transform_Function[] $value An array of {@link Mappings_Transform_Function}s.
-	 *
-	 * @return Mappings_Transform_Function[] An updated array with ourselves too.
-	 */
-	public function wl_mappings_transformation_functions( $value ) {
+    /**
+     * Hook to add ourselves to the list of available transform functions.
+     *
+     * @param Mappings_Transform_Function[] $value An array of {@link Mappings_Transform_Function}s.
+     *
+     * @return Mappings_Transform_Function[] An updated array with ourselves too.
+     */
+    public function wl_mappings_transformation_functions( $value ) {
 
-		$value[] = $this;
+        $value[] = $this;
 
-		return $value;
-	}
+        return $value;
+    }
 
-	/**
-	 * @inheritDoc
-	 */
-	public function get_name() {
+    /**
+     * @inheritDoc
+     */
+    public function get_name() {
 
-		return 'taxonomy_to_terms';
-	}
+        return 'taxonomy_to_terms';
+    }
 
-	/**
-	 * @inheritDoc
-	 */
-	public function get_label() {
+    /**
+     * @inheritDoc
+     */
+    public function get_label() {
 
-		return __( 'Taxonomy to Terms', 'wordlift' );
-	}
+        return __( 'Taxonomy to Terms', 'wordlift' );
+    }
 
-	/**
-	 * @inheritDoc
-	 */
-	public function transform_data( $data, $jsonld, &$references, $post_id ) {
+    /**
+     * @inheritDoc
+     */
+    public function transform_data( $data, $jsonld, &$references, $post_id ) {
 
-		$terms = wp_get_object_terms( $post_id, $data, array( 'fields' => 'names' ) );
+        $terms = wp_get_object_terms( $post_id, $data, array( 'fields' => 'names' ) );
 
-		if ( ! is_array( $terms ) || empty( $terms ) ) {
-			return null;
-		}
+        if ( ! is_array( $terms ) || empty( $terms ) ) {
+            return null;
+        }
 
-		return $terms;
-	}
+        return $terms;
+    }
 
 }

Spacing +6 added lines, -6 removed lines

@@ -23,7 +23,7 @@ 
 	 */
 	public function __construct() {
 
-		add_filter( 'wl_mappings_transformation_functions', array( $this, 'wl_mappings_transformation_functions' ) );
+		add_filter('wl_mappings_transformation_functions', array($this, 'wl_mappings_transformation_functions'));
 
 	}
 
@@ -34,7 +34,7 @@ 
 	 *
 	 * @return Mappings_Transform_Function[] An updated array with ourselves too.
 	 */
-	public function wl_mappings_transformation_functions( $value ) {
+	public function wl_mappings_transformation_functions($value) {
 
 		$value[] = $this;
 
@@ -54,17 +54,17 @@ 
 	 */
 	public function get_label() {
 
-		return __( 'Taxonomy to Terms', 'wordlift' );
+		return __('Taxonomy to Terms', 'wordlift');
 	}
 
 	/**
 	 * @inheritDoc
 	 */
-	public function transform_data( $data, $jsonld, &$references, $post_id ) {
+	public function transform_data($data, $jsonld, &$references, $post_id) {
 
-		$terms = wp_get_object_terms( $post_id, $data, array( 'fields' => 'names' ) );
+		$terms = wp_get_object_terms($post_id, $data, array('fields' => 'names'));
 
-		if ( ! is_array( $terms ) || empty( $terms ) ) {
+		if ( ! is_array($terms) || empty($terms)) {
 			return null;
 		}
 

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

Indentation +55 added lines, -55 removed lines

@@ -5,71 +5,71 @@
 use Wordlift\Object_Type_Enum;
 
 class Sync_Post_Adapter extends Abstract_Sync_Object_Adapter {
-	/**
-	 * @var int
-	 */
-	private $post_id;
+    /**
+     * @var int
+     */
+    private $post_id;
 
-	/**
-	 * Sync_Term_Adapter constructor.
-	 *
-	 * @param int $post_id
-	 *
-	 * @throws \Exception when an error occurs.
-	 */
-	public function __construct( $post_id ) {
-		parent::__construct( Object_Type_Enum::POST, $post_id );
+    /**
+     * Sync_Term_Adapter constructor.
+     *
+     * @param int $post_id
+     *
+     * @throws \Exception when an error occurs.
+     */
+    public function __construct( $post_id ) {
+        parent::__construct( Object_Type_Enum::POST, $post_id );
 
-		$this->post_id = $post_id;
-	}
+        $this->post_id = $post_id;
+    }
 
-	public function is_published() {
-		return ( 'publish' === get_post_status( $this->post_id ) );
-	}
+    public function is_published() {
+        return ( 'publish' === get_post_status( $this->post_id ) );
+    }
 
-	public function is_public() {
-		// Check if the post type is public.
-		$post_type     = get_post_type( $this->post_id );
-		$post_type_obj = get_post_type_object( $post_type );
+    public function is_public() {
+        // Check if the post type is public.
+        $post_type     = get_post_type( $this->post_id );
+        $post_type_obj = get_post_type_object( $post_type );
 
-		return $post_type_obj->public;
-	}
+        return $post_type_obj->public;
+    }
 
-	public function set_values( $arr ) {
-		global $wpdb;
+    public function set_values( $arr ) {
+        global $wpdb;
 
-		$field_names  = implode( ', ', array_map( 'esc_sql', array_keys( $arr ) ) );
-		$field_values = "'" . implode( "', '", array_map( 'esc_sql', array_values( $arr ) ) ) . "'";
+        $field_names  = implode( ', ', array_map( 'esc_sql', array_keys( $arr ) ) );
+        $field_values = "'" . implode( "', '", array_map( 'esc_sql', array_values( $arr ) ) ) . "'";
 
-		$update_stmt = implode(
-			', ',
-			array_map(
-				function ( $key ) use ( $arr ) {
-					return "$key = '" . esc_sql( $arr[ $key ] ) . "'";
-				},
-				array_keys( $arr )
-			)
-		);
+        $update_stmt = implode(
+            ', ',
+            array_map(
+                function ( $key ) use ( $arr ) {
+                    return "$key = '" . esc_sql( $arr[ $key ] ) . "'";
+                },
+                array_keys( $arr )
+            )
+        );
 
-		$wpdb->query(
-			$wpdb->prepare(
-				"INSERT INTO {$wpdb->prefix}wl_entities( content_id, content_type, $field_names ) VALUES ( %d, %d, $field_values ) ON DUPLICATE KEY UPDATE $update_stmt;", // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-				$this->post_id,
-				Object_Type_Enum::POST
-			)
-		);
-	}
+        $wpdb->query(
+            $wpdb->prepare(
+                "INSERT INTO {$wpdb->prefix}wl_entities( content_id, content_type, $field_names ) VALUES ( %d, %d, $field_values ) ON DUPLICATE KEY UPDATE $update_stmt;", // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
+                $this->post_id,
+                Object_Type_Enum::POST
+            )
+        );
+    }
 
-	public function get_value( $key ) {
-		global $wpdb;
+    public function get_value( $key ) {
+        global $wpdb;
 
-		return $wpdb->get_var(
-			$wpdb->prepare(
-				"SELECT $key FROM {$wpdb->prefix}wl_entities WHERE content_id = %d AND content_type = %d",  // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-				$this->post_id,
-				Object_Type_Enum::POST
-			)
-		);
-	}
+        return $wpdb->get_var(
+            $wpdb->prepare(
+                "SELECT $key FROM {$wpdb->prefix}wl_entities WHERE content_id = %d AND content_type = %d",  // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
+                $this->post_id,
+                Object_Type_Enum::POST
+            )
+        );
+    }
 
 }

Spacing +13 added lines, -13 removed lines

@@ -17,37 +17,37 @@ 
 	 *
 	 * @throws \Exception when an error occurs.
 	 */
-	public function __construct( $post_id ) {
-		parent::__construct( Object_Type_Enum::POST, $post_id );
+	public function __construct($post_id) {
+		parent::__construct(Object_Type_Enum::POST, $post_id);
 
 		$this->post_id = $post_id;
 	}
 
 	public function is_published() {
-		return ( 'publish' === get_post_status( $this->post_id ) );
+		return ('publish' === get_post_status($this->post_id));
 	}
 
 	public function is_public() {
 		// Check if the post type is public.
-		$post_type     = get_post_type( $this->post_id );
-		$post_type_obj = get_post_type_object( $post_type );
+		$post_type     = get_post_type($this->post_id);
+		$post_type_obj = get_post_type_object($post_type);
 
 		return $post_type_obj->public;
 	}
 
-	public function set_values( $arr ) {
+	public function set_values($arr) {
 		global $wpdb;
 
-		$field_names  = implode( ', ', array_map( 'esc_sql', array_keys( $arr ) ) );
-		$field_values = "'" . implode( "', '", array_map( 'esc_sql', array_values( $arr ) ) ) . "'";
+		$field_names  = implode(', ', array_map('esc_sql', array_keys($arr)));
+		$field_values = "'".implode("', '", array_map('esc_sql', array_values($arr)))."'";
 
 		$update_stmt = implode(
 			', ',
 			array_map(
-				function ( $key ) use ( $arr ) {
-					return "$key = '" . esc_sql( $arr[ $key ] ) . "'";
+				function($key) use ($arr) {
+					return "$key = '".esc_sql($arr[$key])."'";
 				},
-				array_keys( $arr )
+				array_keys($arr)
 			)
 		);
 
@@ -60,12 +60,12 @@ 
 		);
 	}
 
-	public function get_value( $key ) {
+	public function get_value($key) {
 		global $wpdb;
 
 		return $wpdb->get_var(
 			$wpdb->prepare(
-				"SELECT $key FROM {$wpdb->prefix}wl_entities WHERE content_id = %d AND content_type = %d",  // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
+				"SELECT $key FROM {$wpdb->prefix}wl_entities WHERE content_id = %d AND content_type = %d", // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
 				$this->post_id,
 				Object_Type_Enum::POST
 			)

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

Indentation +57 added lines, -57 removed lines

@@ -15,62 +15,62 @@
  */
 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 anything that isn't a POST.
-		if ( Object_Type_Enum::POST !== $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 anything that isn't a POST.
+        if ( Object_Type_Enum::POST !== $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 +14 added lines, -14 removed lines

@@ -25,50 +25,50 @@
 	 *
 	 * @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 anything that isn't a POST.
-		if ( Object_Type_Enum::POST !== $type ) {
+		if (Object_Type_Enum::POST !== $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 ) );
+				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/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();
 
-	public function __construct() {
+    public 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 @@
 	public 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/background/class-abstract-sync-background-process-state.php

Indentation +28 added lines, -28 removed lines

@@ -4,33 +4,33 @@
 
 abstract class Abstract_Sync_Background_Process_State implements Sync_Background_Process_State {
 
-	private $state;
-
-	public function __construct( $state ) {
-		$this->state = $state;
-	}
-
-	public function get_info() {
-		$started     = get_option( '_wl_sync_background_process_started' );
-		$offset      = get_option( '_wl_sync_background_process_offset' );
-		$stage       = get_option( '_wl_sync_background_process_stage' );
-		$counts      = get_option( '_wl_sync_background_process_count', array( 0 ) );
-		$last_update = get_option( '_wl_sync_background_process_updated' );
-
-		// Calculate the overall index by adding the count of completed stages.
-		$index = $offset + 1;
-		for ( $i = 0; $i < $stage; $i ++ ) {
-			$index += $counts[ $i ];
-		}
-
-		// Get the total count.
-		$total_count = array_sum( $counts );
-
-		return new Sync_Background_Process_Info( $this->state, $started, $index, $total_count, $last_update );
-	}
-
-	public function resume() {
-		// do nothing.
-	}
+    private $state;
+
+    public function __construct( $state ) {
+        $this->state = $state;
+    }
+
+    public function get_info() {
+        $started     = get_option( '_wl_sync_background_process_started' );
+        $offset      = get_option( '_wl_sync_background_process_offset' );
+        $stage       = get_option( '_wl_sync_background_process_stage' );
+        $counts      = get_option( '_wl_sync_background_process_count', array( 0 ) );
+        $last_update = get_option( '_wl_sync_background_process_updated' );
+
+        // Calculate the overall index by adding the count of completed stages.
+        $index = $offset + 1;
+        for ( $i = 0; $i < $stage; $i ++ ) {
+            $index += $counts[ $i ];
+        }
+
+        // Get the total count.
+        $total_count = array_sum( $counts );
+
+        return new Sync_Background_Process_Info( $this->state, $started, $index, $total_count, $last_update );
+    }
+
+    public function resume() {
+        // do nothing.
+    }
 
 }

Spacing +10 added lines, -10 removed lines

@@ -6,27 +6,27 @@
 
 	private $state;
 
-	public function __construct( $state ) {
+	public function __construct($state) {
 		$this->state = $state;
 	}
 
 	public function get_info() {
-		$started     = get_option( '_wl_sync_background_process_started' );
-		$offset      = get_option( '_wl_sync_background_process_offset' );
-		$stage       = get_option( '_wl_sync_background_process_stage' );
-		$counts      = get_option( '_wl_sync_background_process_count', array( 0 ) );
-		$last_update = get_option( '_wl_sync_background_process_updated' );
+		$started     = get_option('_wl_sync_background_process_started');
+		$offset      = get_option('_wl_sync_background_process_offset');
+		$stage       = get_option('_wl_sync_background_process_stage');
+		$counts      = get_option('_wl_sync_background_process_count', array(0));
+		$last_update = get_option('_wl_sync_background_process_updated');
 
 		// Calculate the overall index by adding the count of completed stages.
 		$index = $offset + 1;
-		for ( $i = 0; $i < $stage; $i ++ ) {
-			$index += $counts[ $i ];
+		for ($i = 0; $i < $stage; $i++) {
+			$index += $counts[$i];
 		}
 
 		// Get the total count.
-		$total_count = array_sum( $counts );
+		$total_count = array_sum($counts);
 
-		return new Sync_Background_Process_Info( $this->state, $started, $index, $total_count, $last_update );
+		return new Sync_Background_Process_Info($this->state, $started, $index, $total_count, $last_update);
 	}
 
 	public function resume() {

src/wordlift/dataset/background/class-sync-background-process-state.php

Indentation +24 added lines, -24 removed lines

@@ -4,29 +4,29 @@
 
 interface Sync_Background_Process_State {
 
-	public function enter();
-
-	public function leave();
-
-	/**
-	 * Task
-	 *
-	 * Override this method to perform any actions required on each
-	 * queue item. Return the modified item for further processing
-	 * in the next pass through. Or, return false to remove the
-	 * item from the queue.
-	 *
-	 * @param mixed $item Queue item to iterate over.
-	 *
-	 * @return mixed
-	 */
-	public function task( $item );
-
-	public function get_info();
-
-	/**
-	 * Try to resume an interrupted task.
-	 */
-	public function resume();
+    public function enter();
+
+    public function leave();
+
+    /**
+     * Task
+     *
+     * Override this method to perform any actions required on each
+     * queue item. Return the modified item for further processing
+     * in the next pass through. Or, return false to remove the
+     * item from the queue.
+     *
+     * @param mixed $item Queue item to iterate over.
+     *
+     * @return mixed
+     */
+    public function task( $item );
+
+    public function get_info();
+
+    /**
+     * Try to resume an interrupted task.
+     */
+    public function resume();
 
 }

Spacing +1 added lines, -1 removed lines

@@ -20,7 +20,7 @@
 	 *
 	 * @return mixed
 	 */
-	public function task( $item );
+	public function task($item);
 
 	public function get_info();
 

src/wordlift/dataset/background/class-sync-background-process-wpjson-endpoint.php

Indentation +77 added lines, -77 removed lines

@@ -6,82 +6,82 @@
 
 class Sync_Background_Process_Wpjson_Endpoint {
 
-	/**
-	 * @var Sync_Background_Process
-	 */
-	private $sync_background_process;
-
-	/**
-	 * Sync_Background_Process_Wpjson_Endpoint constructor.
-	 *
-	 * @param Sync_Background_Process $sync_background_process
-	 */
-	public function __construct( $sync_background_process ) {
-
-		add_action( 'rest_api_init', array( $this, 'rest_api_init' ) );
-
-		$this->sync_background_process = $sync_background_process;
-
-	}
-
-	public function rest_api_init() {
-
-		register_rest_route(
-			'wordlift/v1',
-			'/dataset/background/sync',
-			array(
-				'methods'             => WP_REST_Server::CREATABLE,
-				'callback'            => array( $this->sync_background_process, 'start' ),
-				'permission_callback' => function () {
-					$user = wp_get_current_user();
-
-					return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true );
-				},
-			)
-		);
-
-		register_rest_route(
-			'wordlift/v1',
-			'/dataset/background/sync',
-			array(
-				'methods'             => WP_REST_Server::READABLE,
-				'callback'            => array( $this->sync_background_process, 'get_info' ),
-				'permission_callback' => function () {
-					$user = wp_get_current_user();
-
-					return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true );
-				},
-			)
-		);
-
-		register_rest_route(
-			'wordlift/v1',
-			'/dataset/background/sync',
-			array(
-				'methods'             => WP_REST_Server::DELETABLE,
-				'callback'            => array( $this->sync_background_process, 'stop' ),
-				'permission_callback' => function () {
-					$user = wp_get_current_user();
-
-					return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true );
-				},
-			)
-		);
-
-		register_rest_route(
-			'wordlift/v1',
-			'/dataset/background/sync',
-			array(
-				'methods'             => 'PUT',
-				'callback'            => array( $this->sync_background_process, 'resume' ),
-				'permission_callback' => function () {
-					$user = wp_get_current_user();
-
-					return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true );
-				},
-			)
-		);
-
-	}
+    /**
+     * @var Sync_Background_Process
+     */
+    private $sync_background_process;
+
+    /**
+     * Sync_Background_Process_Wpjson_Endpoint constructor.
+     *
+     * @param Sync_Background_Process $sync_background_process
+     */
+    public function __construct( $sync_background_process ) {
+
+        add_action( 'rest_api_init', array( $this, 'rest_api_init' ) );
+
+        $this->sync_background_process = $sync_background_process;
+
+    }
+
+    public function rest_api_init() {
+
+        register_rest_route(
+            'wordlift/v1',
+            '/dataset/background/sync',
+            array(
+                'methods'             => WP_REST_Server::CREATABLE,
+                'callback'            => array( $this->sync_background_process, 'start' ),
+                'permission_callback' => function () {
+                    $user = wp_get_current_user();
+
+                    return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true );
+                },
+            )
+        );
+
+        register_rest_route(
+            'wordlift/v1',
+            '/dataset/background/sync',
+            array(
+                'methods'             => WP_REST_Server::READABLE,
+                'callback'            => array( $this->sync_background_process, 'get_info' ),
+                'permission_callback' => function () {
+                    $user = wp_get_current_user();
+
+                    return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true );
+                },
+            )
+        );
+
+        register_rest_route(
+            'wordlift/v1',
+            '/dataset/background/sync',
+            array(
+                'methods'             => WP_REST_Server::DELETABLE,
+                'callback'            => array( $this->sync_background_process, 'stop' ),
+                'permission_callback' => function () {
+                    $user = wp_get_current_user();
+
+                    return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true );
+                },
+            )
+        );
+
+        register_rest_route(
+            'wordlift/v1',
+            '/dataset/background/sync',
+            array(
+                'methods'             => 'PUT',
+                'callback'            => array( $this->sync_background_process, 'resume' ),
+                'permission_callback' => function () {
+                    $user = wp_get_current_user();
+
+                    return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true );
+                },
+            )
+        );
+
+    }
 
 }

Spacing +14 added lines, -14 removed lines

@@ -16,9 +16,9 @@ 
 	 *
 	 * @param Sync_Background_Process $sync_background_process
 	 */
-	public function __construct( $sync_background_process ) {
+	public function __construct($sync_background_process) {
 
-		add_action( 'rest_api_init', array( $this, 'rest_api_init' ) );
+		add_action('rest_api_init', array($this, 'rest_api_init'));
 
 		$this->sync_background_process = $sync_background_process;
 
@@ -31,11 +31,11 @@ 
 			'/dataset/background/sync',
 			array(
 				'methods'             => WP_REST_Server::CREATABLE,
-				'callback'            => array( $this->sync_background_process, 'start' ),
-				'permission_callback' => function () {
+				'callback'            => array($this->sync_background_process, 'start'),
+				'permission_callback' => function() {
 					$user = wp_get_current_user();
 
-					return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true );
+					return is_super_admin($user->ID) || in_array('administrator', (array) $user->roles, true);
 				},
 			)
 		);
@@ -45,11 +45,11 @@ 
 			'/dataset/background/sync',
 			array(
 				'methods'             => WP_REST_Server::READABLE,
-				'callback'            => array( $this->sync_background_process, 'get_info' ),
-				'permission_callback' => function () {
+				'callback'            => array($this->sync_background_process, 'get_info'),
+				'permission_callback' => function() {
 					$user = wp_get_current_user();
 
-					return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true );
+					return is_super_admin($user->ID) || in_array('administrator', (array) $user->roles, true);
 				},
 			)
 		);
@@ -59,11 +59,11 @@ 
 			'/dataset/background/sync',
 			array(
 				'methods'             => WP_REST_Server::DELETABLE,
-				'callback'            => array( $this->sync_background_process, 'stop' ),
-				'permission_callback' => function () {
+				'callback'            => array($this->sync_background_process, 'stop'),
+				'permission_callback' => function() {
 					$user = wp_get_current_user();
 
-					return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true );
+					return is_super_admin($user->ID) || in_array('administrator', (array) $user->roles, true);
 				},
 			)
 		);
@@ -73,11 +73,11 @@ 
 			'/dataset/background/sync',
 			array(
 				'methods'             => 'PUT',
-				'callback'            => array( $this->sync_background_process, 'resume' ),
-				'permission_callback' => function () {
+				'callback'            => array($this->sync_background_process, 'resume'),
+				'permission_callback' => function() {
 					$user = wp_get_current_user();
 
-					return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true );
+					return is_super_admin($user->ID) || in_array('administrator', (array) $user->roles, true);
 				},
 			)
 		);

src/wordlift/dataset/background/class-sync-background-process.php

Indentation +111 added lines, -111 removed lines

@@ -18,116 +18,116 @@
  */
 class Sync_Background_Process extends \Wordlift_Plugin_WP_Background_Process {
 
-	const STATE_STARTED = 'started';
-	const STATE_STOPPED = 'stopped';
-
-	protected $action = 'wl_dataset__sync';
-
-	/**
-	 * @var Sync_Service
-	 */
-	private $sync_service;
-
-	/**
-	 * @var Sync_Object_Adapter_Factory
-	 */
-	private $sync_object_adapter_factory;
-
-	/**
-	 * @var \Wordlift_Log_Service
-	 */
-	private $log;
-
-	/**
-	 * @var Sync_Background_Process_State
-	 */
-	private $state;
-
-	/**
-	 * Sync_Background_Process constructor.
-	 *
-	 * @param Sync_Service                $sync_service A {@link Sync_Service} instance providing the supporting functions to this background process.
-	 * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
-	 */
-	public function __construct( $sync_service, $sync_object_adapter_factory ) {
-		parent::__construct();
-
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
-
-		$this->sync_service                = $sync_service;
-		$this->sync_object_adapter_factory = $sync_object_adapter_factory;
-
-		// Set the current state.
-		if ( self::STATE_STARTED === $this->get_state() ) {
-			$this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
-		} else {
-			$this->state = new Sync_Background_Process_Stopped_State( $this );
-		}
-
-	}
-
-	/**
-	 * This function is called:
-	 *  - To start a new Synchronization, by passing a {@link Sync_Start_Message} instance.
-	 *  - To synchronize a post, by passing a numeric ID.
-	 *
-	 * This function returns the parameter for the next call or NULL if there are no more posts to process.
-	 *
-	 * @param mixed $item Queue item to iterate over.
-	 *
-	 * @return int[]|false The next post IDs or false if there are no more.
-	 */
-	protected function task( $item ) {
-
-		return $this->state->task( $item );
-	}
-
-	/**
-	 * Transition to the started state.
-	 */
-	public function start() {
-		$this->state->leave();
-		$this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
-		$this->state->enter();
-	}
-
-	/**
-	 * Transition to the stopped state.
-	 */
-	public function stop() {
-		$this->state->leave();
-		$this->state = new Sync_Background_Process_Stopped_State( $this );
-		$this->state->enter();
-	}
-
-	public function resume() {
-		$this->state->resume();
-	}
-
-	/**
-	 * Get the current state.
-	 *
-	 * @return string Either self::STARTED_STATE or self::STOPPED_STATE (default).
-	 */
-	public function get_state() {
-		return get_option( '_wl_sync_background_process_state', self::STATE_STOPPED );
-	}
-
-	/**
-	 * Persist the current state.
-	 *
-	 * @param string $value
-	 *
-	 * @return bool
-	 */
-	public function set_state( $value ) {
-		return null === $value
-			? delete_option( '_wl_sync_background_process_state' )
-			: update_option( '_wl_sync_background_process_state', $value, true );
-	}
-
-	public function get_info() {
-		return $this->state->get_info();
-	}
+    const STATE_STARTED = 'started';
+    const STATE_STOPPED = 'stopped';
+
+    protected $action = 'wl_dataset__sync';
+
+    /**
+     * @var Sync_Service
+     */
+    private $sync_service;
+
+    /**
+     * @var Sync_Object_Adapter_Factory
+     */
+    private $sync_object_adapter_factory;
+
+    /**
+     * @var \Wordlift_Log_Service
+     */
+    private $log;
+
+    /**
+     * @var Sync_Background_Process_State
+     */
+    private $state;
+
+    /**
+     * Sync_Background_Process constructor.
+     *
+     * @param Sync_Service                $sync_service A {@link Sync_Service} instance providing the supporting functions to this background process.
+     * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
+     */
+    public function __construct( $sync_service, $sync_object_adapter_factory ) {
+        parent::__construct();
+
+        $this->log = \Wordlift_Log_Service::get_logger( get_class() );
+
+        $this->sync_service                = $sync_service;
+        $this->sync_object_adapter_factory = $sync_object_adapter_factory;
+
+        // Set the current state.
+        if ( self::STATE_STARTED === $this->get_state() ) {
+            $this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
+        } else {
+            $this->state = new Sync_Background_Process_Stopped_State( $this );
+        }
+
+    }
+
+    /**
+     * This function is called:
+     *  - To start a new Synchronization, by passing a {@link Sync_Start_Message} instance.
+     *  - To synchronize a post, by passing a numeric ID.
+     *
+     * This function returns the parameter for the next call or NULL if there are no more posts to process.
+     *
+     * @param mixed $item Queue item to iterate over.
+     *
+     * @return int[]|false The next post IDs or false if there are no more.
+     */
+    protected function task( $item ) {
+
+        return $this->state->task( $item );
+    }
+
+    /**
+     * Transition to the started state.
+     */
+    public function start() {
+        $this->state->leave();
+        $this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
+        $this->state->enter();
+    }
+
+    /**
+     * Transition to the stopped state.
+     */
+    public function stop() {
+        $this->state->leave();
+        $this->state = new Sync_Background_Process_Stopped_State( $this );
+        $this->state->enter();
+    }
+
+    public function resume() {
+        $this->state->resume();
+    }
+
+    /**
+     * Get the current state.
+     *
+     * @return string Either self::STARTED_STATE or self::STOPPED_STATE (default).
+     */
+    public function get_state() {
+        return get_option( '_wl_sync_background_process_state', self::STATE_STOPPED );
+    }
+
+    /**
+     * Persist the current state.
+     *
+     * @param string $value
+     *
+     * @return bool
+     */
+    public function set_state( $value ) {
+        return null === $value
+            ? delete_option( '_wl_sync_background_process_state' )
+            : update_option( '_wl_sync_background_process_state', $value, true );
+    }
+
+    public function get_info() {
+        return $this->state->get_info();
+    }
 
 }

Spacing +13 added lines, -13 removed lines

@@ -49,19 +49,19 @@ 
 	 * @param Sync_Service                $sync_service A {@link Sync_Service} instance providing the supporting functions to this background process.
 	 * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
 	 */
-	public function __construct( $sync_service, $sync_object_adapter_factory ) {
+	public function __construct($sync_service, $sync_object_adapter_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_adapter_factory = $sync_object_adapter_factory;
 
 		// Set the current state.
-		if ( self::STATE_STARTED === $this->get_state() ) {
-			$this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
+		if (self::STATE_STARTED === $this->get_state()) {
+			$this->state = new Sync_Background_Process_Started_State($this, $this->sync_service, $this->sync_object_adapter_factory);
 		} else {
-			$this->state = new Sync_Background_Process_Stopped_State( $this );
+			$this->state = new Sync_Background_Process_Stopped_State($this);
 		}
 
 	}
@@ -77,9 +77,9 @@ 
 	 *
 	 * @return int[]|false The next post IDs or false if there are no more.
 	 */
-	protected function task( $item ) {
+	protected function task($item) {
 
-		return $this->state->task( $item );
+		return $this->state->task($item);
 	}
 
 	/**
@@ -87,7 +87,7 @@ 
 	 */
 	public function start() {
 		$this->state->leave();
-		$this->state = new Sync_Background_Process_Started_State( $this, $this->sync_service, $this->sync_object_adapter_factory );
+		$this->state = new Sync_Background_Process_Started_State($this, $this->sync_service, $this->sync_object_adapter_factory);
 		$this->state->enter();
 	}
 
@@ -96,7 +96,7 @@ 
 	 */
 	public function stop() {
 		$this->state->leave();
-		$this->state = new Sync_Background_Process_Stopped_State( $this );
+		$this->state = new Sync_Background_Process_Stopped_State($this);
 		$this->state->enter();
 	}
 
@@ -110,7 +110,7 @@ 
 	 * @return string Either self::STARTED_STATE or self::STOPPED_STATE (default).
 	 */
 	public function get_state() {
-		return get_option( '_wl_sync_background_process_state', self::STATE_STOPPED );
+		return get_option('_wl_sync_background_process_state', self::STATE_STOPPED);
 	}
 
 	/**
@@ -120,10 +120,10 @@ 
 	 *
 	 * @return bool
 	 */
-	public function set_state( $value ) {
+	public function set_state($value) {
 		return null === $value
-			? delete_option( '_wl_sync_background_process_state' )
-			: update_option( '_wl_sync_background_process_state', $value, true );
+			? delete_option('_wl_sync_background_process_state')
+			: update_option('_wl_sync_background_process_state', $value, true);
 	}
 
 	public function get_info() {