insideout10 / wordlift-plugin

src/wordlift/dataset/background/stages/class-sync-background-process-posts-stage.php

Indentation +34 added lines, -34 removed lines

@@ -8,49 +8,49 @@ 
 
 class Sync_Background_Process_Posts_Stage {
 
-	/**
-	 * @var Sync_Object_Adapter_Factory
-	 */
-	private $sync_object_adapter_factory;
+    /**
+     * @var Sync_Object_Adapter_Factory
+     */
+    private $sync_object_adapter_factory;
 
-	/**
-	 * Sync_Background_Process_Posts_Stage constructor.
-	 *
-	 * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
-	 */
-	public function __construct( $sync_object_adapter_factory ) {
-		$this->sync_object_adapter_factory = $sync_object_adapter_factory;
-	}
+    /**
+     * Sync_Background_Process_Posts_Stage constructor.
+     *
+     * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
+     */
+    public function __construct( $sync_object_adapter_factory ) {
+        $this->sync_object_adapter_factory = $sync_object_adapter_factory;
+    }
 
-	public function count() {
+    public function count() {
 
-		$post_types = get_post_types( array( 'public' => true ) );
+        $post_types = get_post_types( array( 'public' => true ) );
 
-		global $wpdb;
-		$in_post_type = implode( "','", array_map( 'esc_sql', $post_types ) );
-		$sql          = "
+        global $wpdb;
+        $in_post_type = implode( "','", array_map( 'esc_sql', $post_types ) );
+        $sql          = "
 			SELECT COUNT( 1 )
 			FROM $wpdb->posts
 			WHERE post_type IN ('$in_post_type')
 				AND post_status IN ( 'publish',  'future', 'draft', 'pending', 'private' )
 			";
 
-		return $wpdb->get_var( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-	}
+        return $wpdb->get_var( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+    }
 
-	/**
-	 * @param int $offset
-	 * @param int $limit
-	 *
-	 * @return Sync_Object_Adapter[]
-	 */
-	public function get_sync_object_adapters( $offset, $limit ) {
+    /**
+     * @param int $offset
+     * @param int $limit
+     *
+     * @return Sync_Object_Adapter[]
+     */
+    public function get_sync_object_adapters( $offset, $limit ) {
 
-		$post_types = get_post_types( array( 'public' => true ) );
+        $post_types = get_post_types( array( 'public' => true ) );
 
-		global $wpdb;
-		$in_post_type = implode( "','", array_map( 'esc_sql', $post_types ) );
-		$sql          = "
+        global $wpdb;
+        $in_post_type = implode( "','", array_map( 'esc_sql', $post_types ) );
+        $sql          = "
 			SELECT ID
 			FROM $wpdb->posts
 			WHERE post_type IN ('$in_post_type')
@@ -59,10 +59,10 @@ 
 			LIMIT %d, %d
 			";
 
-		$ids = $wpdb->get_col( $wpdb->prepare( $sql, $offset, $limit ) ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+        $ids = $wpdb->get_col( $wpdb->prepare( $sql, $offset, $limit ) ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
 
-		return $this->sync_object_adapter_factory
-			->create_many( Object_Type_Enum::POST, array_map( 'intval', $ids ) );
-	}
+        return $this->sync_object_adapter_factory
+            ->create_many( Object_Type_Enum::POST, array_map( 'intval', $ids ) );
+    }
 
 }

Spacing +9 added lines, -9 removed lines

@@ -18,16 +18,16 @@ 
 	 *
 	 * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
 	 */
-	public function __construct( $sync_object_adapter_factory ) {
+	public function __construct($sync_object_adapter_factory) {
 		$this->sync_object_adapter_factory = $sync_object_adapter_factory;
 	}
 
 	public function count() {
 
-		$post_types = get_post_types( array( 'public' => true ) );
+		$post_types = get_post_types(array('public' => true));
 
 		global $wpdb;
-		$in_post_type = implode( "','", array_map( 'esc_sql', $post_types ) );
+		$in_post_type = implode("','", array_map('esc_sql', $post_types));
 		$sql          = "
 			SELECT COUNT( 1 )
 			FROM $wpdb->posts
@@ -35,7 +35,7 @@ 
 				AND post_status IN ( 'publish',  'future', 'draft', 'pending', 'private' )
 			";
 
-		return $wpdb->get_var( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+		return $wpdb->get_var($sql); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
 	}
 
 	/**
@@ -44,12 +44,12 @@ 
 	 *
 	 * @return Sync_Object_Adapter[]
 	 */
-	public function get_sync_object_adapters( $offset, $limit ) {
+	public function get_sync_object_adapters($offset, $limit) {
 
-		$post_types = get_post_types( array( 'public' => true ) );
+		$post_types = get_post_types(array('public' => true));
 
 		global $wpdb;
-		$in_post_type = implode( "','", array_map( 'esc_sql', $post_types ) );
+		$in_post_type = implode("','", array_map('esc_sql', $post_types));
 		$sql          = "
 			SELECT ID
 			FROM $wpdb->posts
@@ -59,10 +59,10 @@ 
 			LIMIT %d, %d
 			";
 
-		$ids = $wpdb->get_col( $wpdb->prepare( $sql, $offset, $limit ) ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+		$ids = $wpdb->get_col($wpdb->prepare($sql, $offset, $limit)); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
 
 		return $this->sync_object_adapter_factory
-			->create_many( Object_Type_Enum::POST, array_map( 'intval', $ids ) );
+			->create_many(Object_Type_Enum::POST, array_map('intval', $ids));
 	}
 
 }

src/wordlift/dataset/background/stages/class-sync-background-process-users-stage.php

Indentation +32 added lines, -32 removed lines

@@ -7,39 +7,39 @@ 
 
 class Sync_Background_Process_Users_Stage {
 
-	/**
-	 * @var Sync_Object_Adapter_Factory
-	 */
-	private $sync_object_adapter_factory;
+    /**
+     * @var Sync_Object_Adapter_Factory
+     */
+    private $sync_object_adapter_factory;
 
-	/**
-	 * Sync_Background_Process_Posts_Stage constructor.
-	 *
-	 * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
-	 */
-	public function __construct( $sync_object_adapter_factory ) {
-		$this->sync_object_adapter_factory = $sync_object_adapter_factory;
-	}
+    /**
+     * Sync_Background_Process_Posts_Stage constructor.
+     *
+     * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
+     */
+    public function __construct( $sync_object_adapter_factory ) {
+        $this->sync_object_adapter_factory = $sync_object_adapter_factory;
+    }
 
-	public function count() {
+    public function count() {
 
-		global $wpdb;
-		$in_post_type = $this->get_post_types_string();
-		$sql          = "
+        global $wpdb;
+        $in_post_type = $this->get_post_types_string();
+        $sql          = "
 			SELECT COUNT( DISTINCT post_author )
 			FROM $wpdb->posts
 			WHERE post_type IN ('$in_post_type')
 			AND post_status IN ( 'publish',  'future', 'draft', 'pending', 'private' )
 			";
 
-		return $wpdb->get_var( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-	}
+        return $wpdb->get_var( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+    }
 
-	public function get_sync_object_adapters( $offset, $limit ) {
+    public function get_sync_object_adapters( $offset, $limit ) {
 
-		global $wpdb;
-		$in_post_type = $this->get_post_types_string();
-		$sql          = "
+        global $wpdb;
+        $in_post_type = $this->get_post_types_string();
+        $sql          = "
 			SELECT DISTINCT post_author
 			FROM $wpdb->posts
 			WHERE post_type IN ('$in_post_type')
@@ -47,18 +47,18 @@ 
 			LIMIT %d, %d
 			";
 
-		$ids = $wpdb->get_col( $wpdb->prepare( $sql, $offset, $limit ) ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+        $ids = $wpdb->get_col( $wpdb->prepare( $sql, $offset, $limit ) ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
 
-		return $this->sync_object_adapter_factory->create_many( Object_Type_Enum::USER, $ids );
-	}
+        return $this->sync_object_adapter_factory->create_many( Object_Type_Enum::USER, $ids );
+    }
 
-	/**
-	 * @return string
-	 */
-	protected function get_post_types_string() {
-		$post_types = get_post_types( array( 'public' => true ) );
+    /**
+     * @return string
+     */
+    protected function get_post_types_string() {
+        $post_types = get_post_types( array( 'public' => true ) );
 
-		return implode( "','", array_map( 'esc_sql', $post_types ) );
-	}
+        return implode( "','", array_map( 'esc_sql', $post_types ) );
+    }
 
 }

Spacing +7 added lines, -7 removed lines

@@ -17,7 +17,7 @@ 
 	 *
 	 * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
 	 */
-	public function __construct( $sync_object_adapter_factory ) {
+	public function __construct($sync_object_adapter_factory) {
 		$this->sync_object_adapter_factory = $sync_object_adapter_factory;
 	}
 
@@ -32,10 +32,10 @@ 
 			AND post_status IN ( 'publish',  'future', 'draft', 'pending', 'private' )
 			";
 
-		return $wpdb->get_var( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+		return $wpdb->get_var($sql); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
 	}
 
-	public function get_sync_object_adapters( $offset, $limit ) {
+	public function get_sync_object_adapters($offset, $limit) {
 
 		global $wpdb;
 		$in_post_type = $this->get_post_types_string();
@@ -47,18 +47,18 @@ 
 			LIMIT %d, %d
 			";
 
-		$ids = $wpdb->get_col( $wpdb->prepare( $sql, $offset, $limit ) ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+		$ids = $wpdb->get_col($wpdb->prepare($sql, $offset, $limit)); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
 
-		return $this->sync_object_adapter_factory->create_many( Object_Type_Enum::USER, $ids );
+		return $this->sync_object_adapter_factory->create_many(Object_Type_Enum::USER, $ids);
 	}
 
 	/**
 	 * @return string
 	 */
 	protected function get_post_types_string() {
-		$post_types = get_post_types( array( 'public' => true ) );
+		$post_types = get_post_types(array('public' => true));
 
-		return implode( "','", array_map( 'esc_sql', $post_types ) );
+		return implode("','", array_map('esc_sql', $post_types));
 	}
 
 }

src/wordlift/dataset/background/stages/class-sync-background-stage.php

Indentation +2 added lines, -2 removed lines

@@ -4,8 +4,8 @@
 
 interface Sync_Background_Process_Stage {
 
-	public function count();
+    public function count();
 
-	public function get_sync_object_adapters( $offset, $batch_size );
+    public function get_sync_object_adapters( $offset, $batch_size );
 
 }

Spacing +1 added lines, -1 removed lines

@@ -6,6 +6,6 @@
 
 	public function count();
 
-	public function get_sync_object_adapters( $offset, $batch_size );
+	public function get_sync_object_adapters($offset, $batch_size);
 
 }

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

Indentation +19 added lines, -19 removed lines

@@ -4,31 +4,31 @@
 
 class Sync_Background_Process_Stopped_State extends Abstract_Sync_Background_Process_State {
 
-	/**
-	 * @var Sync_Background_Process
-	 */
-	private $context;
+    /**
+     * @var Sync_Background_Process
+     */
+    private $context;
 
-	public function __construct( $context ) {
-		parent::__construct( Sync_Background_Process::STATE_STOPPED );
+    public function __construct( $context ) {
+        parent::__construct( Sync_Background_Process::STATE_STOPPED );
 
-		$this->context = $context;
-	}
+        $this->context = $context;
+    }
 
-	public function enter() {
-		$this->context->set_state( Sync_Background_Process::STATE_STOPPED );
-	}
+    public function enter() {
+        $this->context->set_state( Sync_Background_Process::STATE_STOPPED );
+    }
 
-	public function leave() {
-		$this->context->set_state( null );
-	}
+    public function leave() {
+        $this->context->set_state( null );
+    }
 
-	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function task( $item ) {
+    // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
+    public function task( $item ) {
 
-		$this->context->cancel_process();
+        $this->context->cancel_process();
 
-		return false;
-	}
+        return false;
+    }
 
 }

Spacing +5 added lines, -5 removed lines

@@ -9,22 +9,22 @@
 	 */
 	private $context;
 
-	public function __construct( $context ) {
-		parent::__construct( Sync_Background_Process::STATE_STOPPED );
+	public function __construct($context) {
+		parent::__construct(Sync_Background_Process::STATE_STOPPED);
 
 		$this->context = $context;
 	}
 
 	public function enter() {
-		$this->context->set_state( Sync_Background_Process::STATE_STOPPED );
+		$this->context->set_state(Sync_Background_Process::STATE_STOPPED);
 	}
 
 	public function leave() {
-		$this->context->set_state( null );
+		$this->context->set_state(null);
 	}
 
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function task( $item ) {
+	public function task($item) {
 
 		$this->context->cancel_process();
 

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

Indentation +133 added lines, -133 removed lines

@@ -11,138 +11,138 @@
 
 class Sync_Background_Process_Started_State extends Abstract_Sync_Background_Process_State {
 
-	/**
-	 * @var Sync_Background_Process
-	 */
-	private $context;
-
-	/**
-	 * @var Sync_Service
-	 */
-	private $sync_service;
-
-	/**
-	 * @var Sync_Background_Process_Stage[]
-	 */
-	private $stages;
-
-	private $batch_size = 5;
-	/**
-	 * @var bool
-	 */
-	private $reset;
-
-	/**
-	 * Sync_Background_Process_Started_State constructor.
-	 *
-	 * @param Sync_Background_Process     $context
-	 * @param Sync_Service                $sync_service
-	 * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
-	 * @param bool                        $reset Whether to reset the counters
-	 */
-	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function __construct( $context, $sync_service, $sync_object_adapter_factory, $reset = true ) {
-		parent::__construct( Sync_Background_Process::STATE_STARTED );
-
-		$this->context      = $context;
-		$this->sync_service = $sync_service;
-
-		$this->stages = array(
-			new Sync_Background_Process_Posts_Stage( $sync_object_adapter_factory ),
-			new Sync_Background_Process_Terms_Stage( $sync_object_adapter_factory ),
-			new Sync_Background_Process_Users_Stage( $sync_object_adapter_factory ),
-		);
-	}
-
-	public function enter() {
-		// Delete the KG contents.
-		$this->sync_service->delete_all();
-
-		// Clear caches.
-		do_action( 'wl_ttl_cache_cleaner__flush' );
-
-		$counts = array_map(
-			function ( $item ) {
-				return $item->count();
-			},
-			$this->stages
-		);
-
-		update_option( '_wl_sync_background_process_count', $counts, true );
-		update_option( '_wl_sync_background_process_stage', 0, true );
-		update_option( '_wl_sync_background_process_offset', 0, true );
-		update_option( '_wl_sync_background_process_started', time(), true );
-		update_option( '_wl_sync_background_process_updated', time(), true );
-
-		$this->context->set_state( Sync_Background_Process::STATE_STARTED );
-
-		$this->resume();
-	}
-
-	public function resume() {
-		$this->context->push_to_queue( true );
-		$this->context->save()->dispatch();
-	}
-
-	public function leave() {
-		$this->context->set_state( null );
-	}
-
-	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function task( $args ) {
-
-		$offset     = get_option( '_wl_sync_background_process_offset' );
-		$stage      = get_option( '_wl_sync_background_process_stage' );
-		$counts     = get_option( '_wl_sync_background_process_count' );
-		$batch_size = min( $counts[ $stage ] - $offset, $this->batch_size );
-
-		add_filter( 'wl_api_service__request', array( $this, 'api_service__request' ) );
-		try {
-			$object_adapters = $this->stages[ $stage ]->get_sync_object_adapters( $offset, $batch_size );
-			$this->sync_service->sync_many( $object_adapters, true );
-		// phpcs:ignore Generic.CodeAnalysis.EmptyStatement.DetectedCatch
-		} catch ( \Exception $e ) {
-			// ignored.
-		}
-		remove_filter( 'wl_api_service__request', array( $this, 'api_service__request' ) );
-
-		update_option( '_wl_sync_background_process_updated', time(), true );
-
-		// Increase the offset.
-		if ( ( $offset + $batch_size ) < $counts[ $stage ] ) {
-			update_option( '_wl_sync_background_process_offset', $offset + $batch_size, true );
-
-			return true;
-		}
-
-		// Increase the stage.
-		if ( ( $stage + 1 ) < count( $this->stages ) ) {
-			update_option( '_wl_sync_background_process_stage', $stage + 1, true );
-			update_option( '_wl_sync_background_process_offset', 0, true );
-
-			return true;
-		}
-
-		// Stop processing.
-		$this->context->stop();
-
-		return false;
-	}
-
-	/**
-	 * Hook to provide a request to update the status on the server.
-	 *
-	 * @param array $args
-	 *
-	 * @return mixed
-	 */
-	public function api_service__request( $args ) {
-
-		$state_header_value = str_replace( "\n", '', wp_json_encode( $this->context->get_info() ) );
-
-		$args['headers']['X-Wordlift-Dataset-Sync-State-V1'] = $state_header_value;
-
-		return $args;
-	}
+    /**
+     * @var Sync_Background_Process
+     */
+    private $context;
+
+    /**
+     * @var Sync_Service
+     */
+    private $sync_service;
+
+    /**
+     * @var Sync_Background_Process_Stage[]
+     */
+    private $stages;
+
+    private $batch_size = 5;
+    /**
+     * @var bool
+     */
+    private $reset;
+
+    /**
+     * Sync_Background_Process_Started_State constructor.
+     *
+     * @param Sync_Background_Process     $context
+     * @param Sync_Service                $sync_service
+     * @param Sync_Object_Adapter_Factory $sync_object_adapter_factory
+     * @param bool                        $reset Whether to reset the counters
+     */
+    // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
+    public function __construct( $context, $sync_service, $sync_object_adapter_factory, $reset = true ) {
+        parent::__construct( Sync_Background_Process::STATE_STARTED );
+
+        $this->context      = $context;
+        $this->sync_service = $sync_service;
+
+        $this->stages = array(
+            new Sync_Background_Process_Posts_Stage( $sync_object_adapter_factory ),
+            new Sync_Background_Process_Terms_Stage( $sync_object_adapter_factory ),
+            new Sync_Background_Process_Users_Stage( $sync_object_adapter_factory ),
+        );
+    }
+
+    public function enter() {
+        // Delete the KG contents.
+        $this->sync_service->delete_all();
+
+        // Clear caches.
+        do_action( 'wl_ttl_cache_cleaner__flush' );
+
+        $counts = array_map(
+            function ( $item ) {
+                return $item->count();
+            },
+            $this->stages
+        );
+
+        update_option( '_wl_sync_background_process_count', $counts, true );
+        update_option( '_wl_sync_background_process_stage', 0, true );
+        update_option( '_wl_sync_background_process_offset', 0, true );
+        update_option( '_wl_sync_background_process_started', time(), true );
+        update_option( '_wl_sync_background_process_updated', time(), true );
+
+        $this->context->set_state( Sync_Background_Process::STATE_STARTED );
+
+        $this->resume();
+    }
+
+    public function resume() {
+        $this->context->push_to_queue( true );
+        $this->context->save()->dispatch();
+    }
+
+    public function leave() {
+        $this->context->set_state( null );
+    }
+
+    // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
+    public function task( $args ) {
+
+        $offset     = get_option( '_wl_sync_background_process_offset' );
+        $stage      = get_option( '_wl_sync_background_process_stage' );
+        $counts     = get_option( '_wl_sync_background_process_count' );
+        $batch_size = min( $counts[ $stage ] - $offset, $this->batch_size );
+
+        add_filter( 'wl_api_service__request', array( $this, 'api_service__request' ) );
+        try {
+            $object_adapters = $this->stages[ $stage ]->get_sync_object_adapters( $offset, $batch_size );
+            $this->sync_service->sync_many( $object_adapters, true );
+        // phpcs:ignore Generic.CodeAnalysis.EmptyStatement.DetectedCatch
+        } catch ( \Exception $e ) {
+            // ignored.
+        }
+        remove_filter( 'wl_api_service__request', array( $this, 'api_service__request' ) );
+
+        update_option( '_wl_sync_background_process_updated', time(), true );
+
+        // Increase the offset.
+        if ( ( $offset + $batch_size ) < $counts[ $stage ] ) {
+            update_option( '_wl_sync_background_process_offset', $offset + $batch_size, true );
+
+            return true;
+        }
+
+        // Increase the stage.
+        if ( ( $stage + 1 ) < count( $this->stages ) ) {
+            update_option( '_wl_sync_background_process_stage', $stage + 1, true );
+            update_option( '_wl_sync_background_process_offset', 0, true );
+
+            return true;
+        }
+
+        // Stop processing.
+        $this->context->stop();
+
+        return false;
+    }
+
+    /**
+     * Hook to provide a request to update the status on the server.
+     *
+     * @param array $args
+     *
+     * @return mixed
+     */
+    public function api_service__request( $args ) {
+
+        $state_header_value = str_replace( "\n", '', wp_json_encode( $this->context->get_info() ) );
+
+        $args['headers']['X-Wordlift-Dataset-Sync-State-V1'] = $state_header_value;
+
+        return $args;
+    }
 
 }

Spacing +33 added lines, -33 removed lines

@@ -41,16 +41,16 @@ 
 	 * @param bool                        $reset Whether to reset the counters
 	 */
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function __construct( $context, $sync_service, $sync_object_adapter_factory, $reset = true ) {
-		parent::__construct( Sync_Background_Process::STATE_STARTED );
+	public function __construct($context, $sync_service, $sync_object_adapter_factory, $reset = true) {
+		parent::__construct(Sync_Background_Process::STATE_STARTED);
 
 		$this->context      = $context;
 		$this->sync_service = $sync_service;
 
 		$this->stages = array(
-			new Sync_Background_Process_Posts_Stage( $sync_object_adapter_factory ),
-			new Sync_Background_Process_Terms_Stage( $sync_object_adapter_factory ),
-			new Sync_Background_Process_Users_Stage( $sync_object_adapter_factory ),
+			new Sync_Background_Process_Posts_Stage($sync_object_adapter_factory),
+			new Sync_Background_Process_Terms_Stage($sync_object_adapter_factory),
+			new Sync_Background_Process_Users_Stage($sync_object_adapter_factory),
 		);
 	}
 
@@ -59,66 +59,66 @@ 
 		$this->sync_service->delete_all();
 
 		// Clear caches.
-		do_action( 'wl_ttl_cache_cleaner__flush' );
+		do_action('wl_ttl_cache_cleaner__flush');
 
 		$counts = array_map(
-			function ( $item ) {
+			function($item) {
 				return $item->count();
 			},
 			$this->stages
 		);
 
-		update_option( '_wl_sync_background_process_count', $counts, true );
-		update_option( '_wl_sync_background_process_stage', 0, true );
-		update_option( '_wl_sync_background_process_offset', 0, true );
-		update_option( '_wl_sync_background_process_started', time(), true );
-		update_option( '_wl_sync_background_process_updated', time(), true );
+		update_option('_wl_sync_background_process_count', $counts, true);
+		update_option('_wl_sync_background_process_stage', 0, true);
+		update_option('_wl_sync_background_process_offset', 0, true);
+		update_option('_wl_sync_background_process_started', time(), true);
+		update_option('_wl_sync_background_process_updated', time(), true);
 
-		$this->context->set_state( Sync_Background_Process::STATE_STARTED );
+		$this->context->set_state(Sync_Background_Process::STATE_STARTED);
 
 		$this->resume();
 	}
 
 	public function resume() {
-		$this->context->push_to_queue( true );
+		$this->context->push_to_queue(true);
 		$this->context->save()->dispatch();
 	}
 
 	public function leave() {
-		$this->context->set_state( null );
+		$this->context->set_state(null);
 	}
 
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function task( $args ) {
+	public function task($args) {
 
-		$offset     = get_option( '_wl_sync_background_process_offset' );
-		$stage      = get_option( '_wl_sync_background_process_stage' );
-		$counts     = get_option( '_wl_sync_background_process_count' );
-		$batch_size = min( $counts[ $stage ] - $offset, $this->batch_size );
+		$offset     = get_option('_wl_sync_background_process_offset');
+		$stage      = get_option('_wl_sync_background_process_stage');
+		$counts     = get_option('_wl_sync_background_process_count');
+		$batch_size = min($counts[$stage] - $offset, $this->batch_size);
 
-		add_filter( 'wl_api_service__request', array( $this, 'api_service__request' ) );
+		add_filter('wl_api_service__request', array($this, 'api_service__request'));
 		try {
-			$object_adapters = $this->stages[ $stage ]->get_sync_object_adapters( $offset, $batch_size );
-			$this->sync_service->sync_many( $object_adapters, true );
+			$object_adapters = $this->stages[$stage]->get_sync_object_adapters($offset, $batch_size);
+			$this->sync_service->sync_many($object_adapters, true);
 		// phpcs:ignore Generic.CodeAnalysis.EmptyStatement.DetectedCatch
-		} catch ( \Exception $e ) {
+		} catch (\Exception $e) {
 			// ignored.
 		}
-		remove_filter( 'wl_api_service__request', array( $this, 'api_service__request' ) );
+		remove_filter('wl_api_service__request', array($this, 'api_service__request'));
 
-		update_option( '_wl_sync_background_process_updated', time(), true );
+		update_option('_wl_sync_background_process_updated', time(), true);
 
 		// Increase the offset.
-		if ( ( $offset + $batch_size ) < $counts[ $stage ] ) {
-			update_option( '_wl_sync_background_process_offset', $offset + $batch_size, true );
+		if (($offset + $batch_size) < $counts[$stage]) {
+			update_option('_wl_sync_background_process_offset', $offset + $batch_size, true);
 
 			return true;
 		}
 
 		// Increase the stage.
-		if ( ( $stage + 1 ) < count( $this->stages ) ) {
-			update_option( '_wl_sync_background_process_stage', $stage + 1, true );
-			update_option( '_wl_sync_background_process_offset', 0, true );
+		if (($stage + 1) < count($this->stages)) {
+			update_option('_wl_sync_background_process_stage', $stage + 1, true);
+			update_option('_wl_sync_background_process_offset', 0, true);
 
 			return true;
 		}
@@ -136,9 +136,9 @@ 
 	 *
 	 * @return mixed
 	 */
-	public function api_service__request( $args ) {
+	public function api_service__request($args) {
 
-		$state_header_value = str_replace( "\n", '', wp_json_encode( $this->context->get_info() ) );
+		$state_header_value = str_replace("\n", '', wp_json_encode($this->context->get_info()));
 
 		$args['headers']['X-Wordlift-Dataset-Sync-State-V1'] = $state_header_value;
 

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

Indentation +37 added lines, -37 removed lines

@@ -5,42 +5,42 @@
 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 when an error occurs.
-	 */
-	public function __construct( $term_id ) {
-		parent::__construct( Object_Type_Enum::TERM, $term_id );
-
-		$this->term_id = $term_id;
-	}
-
-	public function is_published() {
-		return $this->is_public();
-	}
-
-	public function is_public() {
-		$term = get_term( $this->term_id );
-
-		return get_taxonomy( $term->taxonomy )->public;
-	}
-
-	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function set_values( $arr ) {
-		// @@todo
-	}
-
-	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function get_value( $key ) {
-		// @@todo
-	}
+    /**
+     * @var int
+     */
+    private $term_id;
+
+    /**
+     * Sync_Term_Adapter constructor.
+     *
+     * @param int $term_id
+     *
+     * @throws \Exception when an error occurs.
+     */
+    public function __construct( $term_id ) {
+        parent::__construct( Object_Type_Enum::TERM, $term_id );
+
+        $this->term_id = $term_id;
+    }
+
+    public function is_published() {
+        return $this->is_public();
+    }
+
+    public function is_public() {
+        $term = get_term( $this->term_id );
+
+        return get_taxonomy( $term->taxonomy )->public;
+    }
+
+    // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
+    public function set_values( $arr ) {
+        // @@todo
+    }
+
+    // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
+    public function get_value( $key ) {
+        // @@todo
+    }
 
 }

Spacing +6 added lines, -6 removed lines

@@ -17,8 +17,8 @@ 
 	 *
 	 * @throws \Exception when an error occurs.
 	 */
-	public function __construct( $term_id ) {
-		parent::__construct( Object_Type_Enum::TERM, $term_id );
+	public function __construct($term_id) {
+		parent::__construct(Object_Type_Enum::TERM, $term_id);
 
 		$this->term_id = $term_id;
 	}
@@ -28,18 +28,18 @@ 
 	}
 
 	public 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;
 	}
 
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function set_values( $arr ) {
+	public function set_values($arr) {
 		// @@todo
 	}
 
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function get_value( $key ) {
+	public function get_value($key) {
 		// @@todo
 	}
 

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

Indentation +138 added lines, -138 removed lines

@@ -7,143 +7,143 @@
 use Wordlift\Object_Type_Enum;
 
 class Sync_Post_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_Post_Hooks constructor.
-	 *
-	 * @param Sync_Service                $sync_service
-	 * @param Sync_Object_Adapter_Factory $sync_object_factory
-	 */
-	public 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( 'save_post', array( $this, 'save_post' ) );
-		add_action( 'added_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
-		add_action( 'updated_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
-		add_action( 'deleted_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
-
-		// running this on delete_post wouldnt work because at that time
-		// entity_url would be deleted, so we cant delete this item from KG.
-		add_action( 'before_delete_post', array( $this, 'delete_post' ) );
-
-		// Remove post when its trashed.
-		add_action( 'trashed_post', array( $this, 'delete_post' ) );
-		// Save the post when its untrashed.
-		add_action( 'untrashed_post', array( $this, 'save_post' ) );
-		// Get sticky posts changes.
-		add_action( 'update_option_sticky_posts', array( $this, 'sticky_posts' ), 10, 2 );
-
-	}
-
-	public function save_post( $post_id ) {
-
-		if ( ! in_array( get_post_type( $post_id ), \Wordlift_Entity_Service::valid_entity_post_types(), true ) ) {
-			return;
-		}
-
-		$this->sync( $post_id );
-
-	}
-
-	public function sticky_posts( $old_value, $value ) {
-		foreach ( $old_value as $post_id ) {
-			$this->sync( $post_id );
-		}
-
-		foreach ( $value as $post_id ) {
-			$this->sync( $post_id );
-		}
-	}
-
-	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function changed_post_meta( $meta_id, $post_id, $meta_key, $_meta_value ) {
-
-		if ( in_array(
-			$meta_key,
-			apply_filters(
-				'wl_dataset__sync_post_hooks__ignored_meta_keys',
-				apply_filters(
-					'wl_dataset__sync_hooks__ignored_meta_keys',
-					array(
-						'_pingme',
-						'_encloseme',
-						'entity_url',
-					)
-				)
-			),
-			true
-		)
-			 || ! in_array( get_post_type( $post_id ), \Wordlift_Entity_Service::valid_entity_post_types(), true )
-		) {
-			return;
-		}
-
-		$this->sync( $post_id );
-
-	}
-
-	private function sync( $post_id ) {
-		$this->enqueue( array( 'do_sync', $post_id ) );
-	}
-
-	public function do_sync( $post_id ) {
-		try {
-			$post = get_post( $post_id );
-			if ( ! isset( $post ) ) {
-				return;
-			}
-			$this->sync_service->sync_many(
-				array(
-					$this->sync_object_factory->create( Object_Type_Enum::POST, $post_id ),
-					$this->sync_object_factory->create( Object_Type_Enum::USER, $post->post_author ),
-				)
-			);
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to sync post $post_id: " . $e->getMessage(), $e );
-		}
-
-	}
-
-	public function delete_post( $post_id ) {
-		$this->enqueue( array( 'do_delete', $post_id ) );
-	}
-
-	public function do_delete( $post_id ) {
-		try {
-			$this->sync_service->delete_one(
-				Object_Type_Enum::POST,
-				$post_id,
-				Wordpress_Content_Service::get_instance()->get_entity_id( Wordpress_Content_Id::create_post( $post_id ) )
-			);
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to delete post $post_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_Post_Hooks constructor.
+     *
+     * @param Sync_Service                $sync_service
+     * @param Sync_Object_Adapter_Factory $sync_object_factory
+     */
+    public 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( 'save_post', array( $this, 'save_post' ) );
+        add_action( 'added_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
+        add_action( 'updated_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
+        add_action( 'deleted_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
+
+        // running this on delete_post wouldnt work because at that time
+        // entity_url would be deleted, so we cant delete this item from KG.
+        add_action( 'before_delete_post', array( $this, 'delete_post' ) );
+
+        // Remove post when its trashed.
+        add_action( 'trashed_post', array( $this, 'delete_post' ) );
+        // Save the post when its untrashed.
+        add_action( 'untrashed_post', array( $this, 'save_post' ) );
+        // Get sticky posts changes.
+        add_action( 'update_option_sticky_posts', array( $this, 'sticky_posts' ), 10, 2 );
+
+    }
+
+    public function save_post( $post_id ) {
+
+        if ( ! in_array( get_post_type( $post_id ), \Wordlift_Entity_Service::valid_entity_post_types(), true ) ) {
+            return;
+        }
+
+        $this->sync( $post_id );
+
+    }
+
+    public function sticky_posts( $old_value, $value ) {
+        foreach ( $old_value as $post_id ) {
+            $this->sync( $post_id );
+        }
+
+        foreach ( $value as $post_id ) {
+            $this->sync( $post_id );
+        }
+    }
+
+    // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
+    public function changed_post_meta( $meta_id, $post_id, $meta_key, $_meta_value ) {
+
+        if ( in_array(
+            $meta_key,
+            apply_filters(
+                'wl_dataset__sync_post_hooks__ignored_meta_keys',
+                apply_filters(
+                    'wl_dataset__sync_hooks__ignored_meta_keys',
+                    array(
+                        '_pingme',
+                        '_encloseme',
+                        'entity_url',
+                    )
+                )
+            ),
+            true
+        )
+             || ! in_array( get_post_type( $post_id ), \Wordlift_Entity_Service::valid_entity_post_types(), true )
+        ) {
+            return;
+        }
+
+        $this->sync( $post_id );
+
+    }
+
+    private function sync( $post_id ) {
+        $this->enqueue( array( 'do_sync', $post_id ) );
+    }
+
+    public function do_sync( $post_id ) {
+        try {
+            $post = get_post( $post_id );
+            if ( ! isset( $post ) ) {
+                return;
+            }
+            $this->sync_service->sync_many(
+                array(
+                    $this->sync_object_factory->create( Object_Type_Enum::POST, $post_id ),
+                    $this->sync_object_factory->create( Object_Type_Enum::USER, $post->post_author ),
+                )
+            );
+        } catch ( \Exception $e ) {
+            $this->log->error( "An error occurred while trying to sync post $post_id: " . $e->getMessage(), $e );
+        }
+
+    }
+
+    public function delete_post( $post_id ) {
+        $this->enqueue( array( 'do_delete', $post_id ) );
+    }
+
+    public function do_delete( $post_id ) {
+        try {
+            $this->sync_service->delete_one(
+                Object_Type_Enum::POST,
+                $post_id,
+                Wordpress_Content_Service::get_instance()->get_entity_id( Wordpress_Content_Id::create_post( $post_id ) )
+            );
+        } catch ( \Exception $e ) {
+            $this->log->error( "An error occurred while trying to delete post $post_id: " . $e->getMessage(), $e );
+        }
+    }
 
 }

Spacing +37 added lines, -37 removed lines

@@ -28,10 +28,10 @@ 
 	 * @param Sync_Service                $sync_service
 	 * @param Sync_Object_Adapter_Factory $sync_object_factory
 	 */
-	public function __construct( $sync_service, $sync_object_factory ) {
+	public 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,48 +43,48 @@ 
 		/**
 		 * Register hooks for post and meta.
 		 */
-		add_action( 'save_post', array( $this, 'save_post' ) );
-		add_action( 'added_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
-		add_action( 'updated_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
-		add_action( 'deleted_post_meta', array( $this, 'changed_post_meta' ), 10, 4 );
+		add_action('save_post', array($this, 'save_post'));
+		add_action('added_post_meta', array($this, 'changed_post_meta'), 10, 4);
+		add_action('updated_post_meta', array($this, 'changed_post_meta'), 10, 4);
+		add_action('deleted_post_meta', array($this, 'changed_post_meta'), 10, 4);
 
 		// running this on delete_post wouldnt work because at that time
 		// entity_url would be deleted, so we cant delete this item from KG.
-		add_action( 'before_delete_post', array( $this, 'delete_post' ) );
+		add_action('before_delete_post', array($this, 'delete_post'));
 
 		// Remove post when its trashed.
-		add_action( 'trashed_post', array( $this, 'delete_post' ) );
+		add_action('trashed_post', array($this, 'delete_post'));
 		// Save the post when its untrashed.
-		add_action( 'untrashed_post', array( $this, 'save_post' ) );
+		add_action('untrashed_post', array($this, 'save_post'));
 		// Get sticky posts changes.
-		add_action( 'update_option_sticky_posts', array( $this, 'sticky_posts' ), 10, 2 );
+		add_action('update_option_sticky_posts', array($this, 'sticky_posts'), 10, 2);
 
 	}
 
-	public function save_post( $post_id ) {
+	public function save_post($post_id) {
 
-		if ( ! in_array( get_post_type( $post_id ), \Wordlift_Entity_Service::valid_entity_post_types(), true ) ) {
+		if ( ! in_array(get_post_type($post_id), \Wordlift_Entity_Service::valid_entity_post_types(), true)) {
 			return;
 		}
 
-		$this->sync( $post_id );
+		$this->sync($post_id);
 
 	}
 
-	public function sticky_posts( $old_value, $value ) {
-		foreach ( $old_value as $post_id ) {
-			$this->sync( $post_id );
+	public function sticky_posts($old_value, $value) {
+		foreach ($old_value as $post_id) {
+			$this->sync($post_id);
 		}
 
-		foreach ( $value as $post_id ) {
-			$this->sync( $post_id );
+		foreach ($value as $post_id) {
+			$this->sync($post_id);
 		}
 	}
 
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	public function changed_post_meta( $meta_id, $post_id, $meta_key, $_meta_value ) {
+	public function changed_post_meta($meta_id, $post_id, $meta_key, $_meta_value) {
 
-		if ( in_array(
+		if (in_array(
 			$meta_key,
 			apply_filters(
 				'wl_dataset__sync_post_hooks__ignored_meta_keys',
@@ -99,50 +99,50 @@ 
 			),
 			true
 		)
-			 || ! in_array( get_post_type( $post_id ), \Wordlift_Entity_Service::valid_entity_post_types(), true )
+			 || ! in_array(get_post_type($post_id), \Wordlift_Entity_Service::valid_entity_post_types(), true)
 		) {
 			return;
 		}
 
-		$this->sync( $post_id );
+		$this->sync($post_id);
 
 	}
 
-	private function sync( $post_id ) {
-		$this->enqueue( array( 'do_sync', $post_id ) );
+	private function sync($post_id) {
+		$this->enqueue(array('do_sync', $post_id));
 	}
 
-	public function do_sync( $post_id ) {
+	public function do_sync($post_id) {
 		try {
-			$post = get_post( $post_id );
-			if ( ! isset( $post ) ) {
+			$post = get_post($post_id);
+			if ( ! isset($post)) {
 				return;
 			}
 			$this->sync_service->sync_many(
 				array(
-					$this->sync_object_factory->create( Object_Type_Enum::POST, $post_id ),
-					$this->sync_object_factory->create( Object_Type_Enum::USER, $post->post_author ),
+					$this->sync_object_factory->create(Object_Type_Enum::POST, $post_id),
+					$this->sync_object_factory->create(Object_Type_Enum::USER, $post->post_author),
 				)
 			);
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to sync post $post_id: " . $e->getMessage(), $e );
+		} catch (\Exception $e) {
+			$this->log->error("An error occurred while trying to sync post $post_id: ".$e->getMessage(), $e);
 		}
 
 	}
 
-	public function delete_post( $post_id ) {
-		$this->enqueue( array( 'do_delete', $post_id ) );
+	public function delete_post($post_id) {
+		$this->enqueue(array('do_delete', $post_id));
 	}
 
-	public function do_delete( $post_id ) {
+	public function do_delete($post_id) {
 		try {
 			$this->sync_service->delete_one(
 				Object_Type_Enum::POST,
 				$post_id,
-				Wordpress_Content_Service::get_instance()->get_entity_id( Wordpress_Content_Id::create_post( $post_id ) )
+				Wordpress_Content_Service::get_instance()->get_entity_id(Wordpress_Content_Id::create_post($post_id))
 			);
-		} catch ( \Exception $e ) {
-			$this->log->error( "An error occurred while trying to delete post $post_id: " . $e->getMessage(), $e );
+		} catch (\Exception $e) {
+			$this->log->error("An error occurred while trying to delete post $post_id: ".$e->getMessage(), $e);
 		}
 	}
 

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

Indentation +124 added lines, -124 removed lines

@@ -7,128 +7,128 @@
 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
-	 */
-	public 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 );
-	}
-
-	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	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',
-					)
-				)
-			),
-			true
-		)
-		) {
-			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 when an error occurs.
-	 */
-	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
+     */
+    public 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 );
+    }
+
+    // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
+    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',
+                    )
+                )
+            ),
+            true
+        )
+        ) {
+            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 when an error occurs.
+     */
+    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 +28 added lines, -28 removed lines

@@ -28,10 +28,10 @@ 
 	 * @param Sync_Service                $sync_service
 	 * @param Sync_Object_Adapter_Factory $sync_object_factory
 	 */
-	public function __construct( $sync_service, $sync_object_factory ) {
+	public 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,25 +43,25 @@ 
 		/**
 		 * 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);
 	}
 
 	// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable
-	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(
+		if (in_array(
 			$meta_key,
 			apply_filters(
 				'wl_dataset__sync_post_hooks__ignored_meta_keys',
@@ -80,29 +80,29 @@ 
 			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 ),
+					$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 );
+		} catch (\Exception $e) {
+			$this->log->error("An error occurred while trying to sync post $term_id: ".$e->getMessage(), $e);
 		}
 	}
 
@@ -111,24 +111,24 @@ 
 	 *
 	 * @throws \Exception when an error occurs.
 	 */
-	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-object-adapter.php

Indentation +9 added lines, -9 removed lines

@@ -4,19 +4,19 @@
 
 interface Sync_Object_Adapter {
 
-	/**
-	 * @return int see {@link Object_Type_Enum}
-	 */
-	public function get_type();
+    /**
+     * @return int see {@link Object_Type_Enum}
+     */
+    public function get_type();
 
-	public function get_object_id();
+    public function get_object_id();
 
-	public function is_published();
+    public function is_published();
 
-	public function is_public();
+    public function is_public();
 
-	public function set_values( $arr );
+    public function set_values( $arr );
 
-	public function get_value( $key );
+    public function get_value( $key );
 
 }

Spacing +2 added lines, -2 removed lines

@@ -15,8 +15,8 @@
 
 	public function is_public();
 
-	public function set_values( $arr );
+	public function set_values($arr);
 
-	public function get_value( $key );
+	public function get_value($key);
 
 }