insideout10 / wordlift-plugin

src/wordlift/vocabulary/api/class-tag-rest-endpoint.php

Doc Comments +2 added lines, -2 removed lines

@@ -105,8 +105,8 @@
 	}
 
 	/**
-	 * @param $limit
-	 * @param $offset
+	 * @param integer $limit
+	 * @param integer $offset
 	 *
 	 * @return int|\WP_Error|\WP_Term[]
 	 */

Unused Use Statements -1 removed lines

@@ -4,7 +4,6 @@
 
 
 use Wordlift\Vocabulary\Analysis_Background_Service;
-use Wordlift\Vocabulary\Analysis_Service;
 use Wordlift\Vocabulary\Data\Term_Data\Term_Data_Factory;
 use WP_REST_Server;
 

Indentation +124 added lines, -124 removed lines

@@ -14,130 +14,130 @@
  */
 class Tag_Rest_Endpoint {
 
-	/**
-	 * @var Term_Data_Factory
-	 */
-	private $term_data_factory;
-
-	/**
-	 * Tag_Rest_Endpoint constructor.
-	 *
-	 * @param Term_Data_Factory $term_data_factory
-	 */
-	public function __construct( $term_data_factory ) {
-
-		$this->term_data_factory = $term_data_factory;
-
-	}
-
-
-	public function register_routes() {
-		$that = $this;
-		add_action( 'rest_api_init',
-			function () use ( $that ) {
-				register_rest_route(
-					Api_Config::REST_NAMESPACE,
-					'/tags',
-					array(
-						'methods'             => WP_REST_Server::CREATABLE,
-						'callback'            => array( $that, 'get_tags' ),
-						//@todo : review the permission level
-						'permission_callback' => function () {
-							return current_user_can( 'manage_options' );
-						},
-						'args'                => array(
-							'limit'  => array(
-								'validate_callback' => function ( $param, $request, $key ) {
-									return is_numeric( $param ) && $param;
-								},
-								'required'          => true,
-							),
-							'offset' => array(
-								'validate_callback' => function ( $param, $request, $key ) {
-									return is_numeric( $param );
-								},
-								'required'          => true,
-							),
-						),
-					)
-				);
-			} );
-
-
-	}
-
-
-	public function get_tags( $request ) {
-
-		$data   = $request->get_params();
-		$offset = (int) $data['offset'];
-		$limit  = (int) $data['limit'];
-		$tags = $this->get_tags_from_db( $limit, $offset );
-		$term_data_list = array();
-
-		foreach ( $tags as $tag ) {
-
-			if ( $this->is_tag_excluded_from_ui( $tag ) ) {
-				continue;
-			}
-
-			/**
-			 * @param $tag \WP_Term
-			 */
-			$term_data_instance = $this->term_data_factory->get_term_data($tag);
-			$term_data = $term_data_instance->get_data();
-			if ( $term_data['entities'] ) {
-				$term_data_list[] = $term_data;
-			}
-		}
-
-
-		return $term_data_list;
-	}
-
-	/**
-	 * @param \WP_Term $tag
-	 *
-	 * @return bool
-	 */
-	private function is_tag_excluded_from_ui( $tag ) {
-		return (int) get_term_meta( $tag->term_id, Entity_Rest_Endpoint::IGNORE_TAG_FROM_LISTING, true ) === 1;
-	}
-
-	/**
-	 * @param $limit
-	 * @param $offset
-	 *
-	 * @return int|\WP_Error|\WP_Term[]
-	 */
-	public function get_tags_from_db( $limit, $offset ) {
-
-
-		$args = array(
-			'taxonomy'   => 'post_tag',
-			'hide_empty' => false,
-			'number'     => $limit,
-			'offset'     => $offset,
-			'meta_query' => array(
-				array(
-					'key'     => Analysis_Background_Service::ENTITIES_PRESENT_FOR_TERM,
-					'compare' => 'EXISTS'
-				)
-			),
-			'orderby'    => 'count',
-			'order'      => 'DESC',
-		);
-
-		global $wp_version;
-
-		if ( version_compare( $wp_version, '4.5', '<' ) ) {
-			return get_terms( 'post_tag', $args );
-		} else {
-			return get_terms( $args );
-		}
-
-
-	}
+    /**
+     * @var Term_Data_Factory
+     */
+    private $term_data_factory;
+
+    /**
+     * Tag_Rest_Endpoint constructor.
+     *
+     * @param Term_Data_Factory $term_data_factory
+     */
+    public function __construct( $term_data_factory ) {
+
+        $this->term_data_factory = $term_data_factory;
+
+    }
+
+
+    public function register_routes() {
+        $that = $this;
+        add_action( 'rest_api_init',
+            function () use ( $that ) {
+                register_rest_route(
+                    Api_Config::REST_NAMESPACE,
+                    '/tags',
+                    array(
+                        'methods'             => WP_REST_Server::CREATABLE,
+                        'callback'            => array( $that, 'get_tags' ),
+                        //@todo : review the permission level
+                        'permission_callback' => function () {
+                            return current_user_can( 'manage_options' );
+                        },
+                        'args'                => array(
+                            'limit'  => array(
+                                'validate_callback' => function ( $param, $request, $key ) {
+                                    return is_numeric( $param ) && $param;
+                                },
+                                'required'          => true,
+                            ),
+                            'offset' => array(
+                                'validate_callback' => function ( $param, $request, $key ) {
+                                    return is_numeric( $param );
+                                },
+                                'required'          => true,
+                            ),
+                        ),
+                    )
+                );
+            } );
+
+
+    }
+
+
+    public function get_tags( $request ) {
+
+        $data   = $request->get_params();
+        $offset = (int) $data['offset'];
+        $limit  = (int) $data['limit'];
+        $tags = $this->get_tags_from_db( $limit, $offset );
+        $term_data_list = array();
+
+        foreach ( $tags as $tag ) {
+
+            if ( $this->is_tag_excluded_from_ui( $tag ) ) {
+                continue;
+            }
+
+            /**
+             * @param $tag \WP_Term
+             */
+            $term_data_instance = $this->term_data_factory->get_term_data($tag);
+            $term_data = $term_data_instance->get_data();
+            if ( $term_data['entities'] ) {
+                $term_data_list[] = $term_data;
+            }
+        }
+
+
+        return $term_data_list;
+    }
+
+    /**
+     * @param \WP_Term $tag
+     *
+     * @return bool
+     */
+    private function is_tag_excluded_from_ui( $tag ) {
+        return (int) get_term_meta( $tag->term_id, Entity_Rest_Endpoint::IGNORE_TAG_FROM_LISTING, true ) === 1;
+    }
+
+    /**
+     * @param $limit
+     * @param $offset
+     *
+     * @return int|\WP_Error|\WP_Term[]
+     */
+    public function get_tags_from_db( $limit, $offset ) {
+
+
+        $args = array(
+            'taxonomy'   => 'post_tag',
+            'hide_empty' => false,
+            'number'     => $limit,
+            'offset'     => $offset,
+            'meta_query' => array(
+                array(
+                    'key'     => Analysis_Background_Service::ENTITIES_PRESENT_FOR_TERM,
+                    'compare' => 'EXISTS'
+                )
+            ),
+            'orderby'    => 'count',
+            'order'      => 'DESC',
+        );
+
+        global $wp_version;
+
+        if ( version_compare( $wp_version, '4.5', '<' ) ) {
+            return get_terms( 'post_tag', $args );
+        } else {
+            return get_terms( $args );
+        }
+
+
+    }
 
 
 }

Spacing +21 added lines, -21 removed lines

@@ -24,7 +24,7 @@ 
 	 *
 	 * @param Term_Data_Factory $term_data_factory
 	 */
-	public function __construct( $term_data_factory ) {
+	public function __construct($term_data_factory) {
 
 		$this->term_data_factory = $term_data_factory;
 
@@ -33,28 +33,28 @@ 
 
 	public function register_routes() {
 		$that = $this;
-		add_action( 'rest_api_init',
-			function () use ( $that ) {
+		add_action('rest_api_init',
+			function() use ($that) {
 				register_rest_route(
 					Api_Config::REST_NAMESPACE,
 					'/tags',
 					array(
 						'methods'             => WP_REST_Server::CREATABLE,
-						'callback'            => array( $that, 'get_tags' ),
+						'callback'            => array($that, 'get_tags'),
 						//@todo : review the permission level
-						'permission_callback' => function () {
-							return current_user_can( 'manage_options' );
+						'permission_callback' => function() {
+							return current_user_can('manage_options');
 						},
 						'args'                => array(
 							'limit'  => array(
-								'validate_callback' => function ( $param, $request, $key ) {
-									return is_numeric( $param ) && $param;
+								'validate_callback' => function($param, $request, $key) {
+									return is_numeric($param) && $param;
 								},
 								'required'          => true,
 							),
 							'offset' => array(
-								'validate_callback' => function ( $param, $request, $key ) {
-									return is_numeric( $param );
+								'validate_callback' => function($param, $request, $key) {
+									return is_numeric($param);
 								},
 								'required'          => true,
 							),
@@ -67,17 +67,17 @@ 
 	}
 
 
-	public function get_tags( $request ) {
+	public function get_tags($request) {
 
 		$data   = $request->get_params();
 		$offset = (int) $data['offset'];
 		$limit  = (int) $data['limit'];
-		$tags = $this->get_tags_from_db( $limit, $offset );
+		$tags = $this->get_tags_from_db($limit, $offset);
 		$term_data_list = array();
 
-		foreach ( $tags as $tag ) {
+		foreach ($tags as $tag) {
 
-			if ( $this->is_tag_excluded_from_ui( $tag ) ) {
+			if ($this->is_tag_excluded_from_ui($tag)) {
 				continue;
 			}
 
@@ -86,7 +86,7 @@ 
 			 */
 			$term_data_instance = $this->term_data_factory->get_term_data($tag);
 			$term_data = $term_data_instance->get_data();
-			if ( $term_data['entities'] ) {
+			if ($term_data['entities']) {
 				$term_data_list[] = $term_data;
 			}
 		}
@@ -100,8 +100,8 @@ 
 	 *
 	 * @return bool
 	 */
-	private function is_tag_excluded_from_ui( $tag ) {
-		return (int) get_term_meta( $tag->term_id, Entity_Rest_Endpoint::IGNORE_TAG_FROM_LISTING, true ) === 1;
+	private function is_tag_excluded_from_ui($tag) {
+		return (int) get_term_meta($tag->term_id, Entity_Rest_Endpoint::IGNORE_TAG_FROM_LISTING, true) === 1;
 	}
 
 	/**
@@ -110,7 +110,7 @@ 
 	 *
 	 * @return int|\WP_Error|\WP_Term[]
 	 */
-	public function get_tags_from_db( $limit, $offset ) {
+	public function get_tags_from_db($limit, $offset) {
 
 
 		$args = array(
@@ -130,10 +130,10 @@ 
 
 		global $wp_version;
 
-		if ( version_compare( $wp_version, '4.5', '<' ) ) {
-			return get_terms( 'post_tag', $args );
+		if (version_compare($wp_version, '4.5', '<')) {
+			return get_terms('post_tag', $args);
 		} else {
-			return get_terms( $args );
+			return get_terms($args);
 		}
 
 

src/wordlift/vocabulary/class-analysis-background-process.php

Doc Comments +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
 	/**
 	 * Analysis_Background_Process constructor.
 	 *
-	 * @param $analysis_background_service Analysis_Background_Service A {@link Analysis_Background_Service} instance providing the supporting functions to this background process.
+	 * @param Analysis_Background_Service $analysis_background_service Analysis_Background_Service A {@link Analysis_Background_Service} instance providing the supporting functions to this background process.
 	 */
 	public function __construct( $analysis_background_service ) {
 		parent::__construct();

Indentation +198 added lines, -198 removed lines

@@ -4,208 +4,208 @@
 
 class Analysis_Background_Process extends \Wordlift_Plugin_WP_Background_Process {
 
-	const WL_CMKG_ANALYSIS_BACKGROUND_PROCESS = '_wl_cmkg_analysis_background_process';
-
-
-	protected $action = 'wl_cmkg_analysis_background__analysis';
-
-	/**
-	 * @var Analysis_Background_Service
-	 */
-	private $analysis_background_service;
-
-	/**
-	 * @var \Wordlift_Log_Service
-	 */
-	private $log;
-
-	/**
-	 * Analysis_Background_Process constructor.
-	 *
-	 * @param $analysis_background_service Analysis_Background_Service A {@link Analysis_Background_Service} instance providing the supporting functions to this background process.
-	 */
-	public function __construct( $analysis_background_service ) {
-		parent::__construct();
-
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
-
-		$this->analysis_background_service = $analysis_background_service;
-
-
-	}
-
-	/**
-	 * 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 int[] $term_ids An array of term IDs.
-	 *
-	 * @return int[]|false The next term IDs or false if there are no more.
-	 */
-	protected function task( $term_ids ) {
-
-		// Check if we must cancel.
-		if ( $this->must_cancel() ) {
-			$this->cancel();
-
-			return false;
-		}
-
-		if ( $term_ids && is_array($term_ids) ) {
-			$this->log->debug( sprintf( "Synchronizing terms %s...", implode( ', ', $term_ids ) ) );
-		}
-		// Sync the item.
-		return $this->sync_items( $term_ids );
-	}
-
-	/**
-	 * Start the background processing.
-	 *
-	 * @return bool True if the process has been started, otherwise false.
-	 */
-	public function start() {
-		$this->log->debug( "Trying to start analysis bg service..." );
-		// Create a new Sync_Model state of `started`.
-		if ( ! $this->is_started( self::get_state() ) ) {
-			$this->log->debug( "Starting..." );
-
-			$sync_state = new Sync_State( time(), 0, $this->analysis_background_service->count(), time(), 'started' );
-			update_option( self::WL_CMKG_ANALYSIS_BACKGROUND_PROCESS, $sync_state, false );
-
-			$next = $this->analysis_background_service->next();
-
-			$this->push_to_queue( $next );
-			$this->save()->dispatch();
-
-			if ( $next && is_array($next) ) {
-				$this->log->debug( sprintf( 'Started with term IDs %s.', implode( ', ', $next ) ) );
-			}
-			return true;
-		}
-
-		return false;
-	}
-
-	/**
-	 * Set the transient to cancel the process. The next time the process runs, it'll check whether this transient is
-	 * set and will stop processing.
-	 */
-	public function request_cancel() {
-
-		set_transient( "{$this->action}__cancel", true );
-
-	}
-
-	/**
-	 * Get the sync state.
-	 *
-	 * @return Sync_State The {@link Sync_State}.
-	 */
-	public static function get_state() {
-
-		try {
-			return get_option( self::WL_CMKG_ANALYSIS_BACKGROUND_PROCESS, Sync_State::unknown() );
-		} catch ( \Exception $e ) {
-			return Sync_State::unknown();
-		}
-
-	}
-
-	/**
-	 * Check whether the provided state is `started` or not.
-	 *
-	 * @param Sync_State $state The {@link Sync_State}.
-	 *
-	 * @return bool True if the state is started.
-	 */
-	private function is_started( $state ) {
-		return $state instanceof Sync_State && 'started' === $state->state && 30 > ( time() - $state->last_update );
-	}
-
-	/**
-	 * Check whether the process must cancel or not.
-	 *
-	 * @return bool Whether to cancel or not the process.
-	 */
-	private function must_cancel() {
-
-		return get_transient( "{$this->action}__cancel" );
-	}
-
-	/**
-	 * Cancels the current process.
-	 */
-	public function cancel() {
-
-		$this->log->debug( "Cancelling synchronization..." );
-
-		// Cleanup the process data.
-		$this->cancel_process();
-
-		// Set the state to cancelled.
-		$state = self::get_state();
-		$state->set_state( 'cancelled' );
-		update_option( self::WL_CMKG_ANALYSIS_BACKGROUND_PROCESS, $state, false );
-
-		// Finally delete the transient.
-		delete_transient( "{$this->action}__cancel" );
-
-	}
-
-	/**
-	 * Push the post with the provided ID to the remote platform.
-	 *
-	 * @param int[] $term_ids The term IDs.
-	 *
-	 * @return int[]|false The next term ID to process or false if processing is complete.
-	 */
-	private function sync_items( $term_ids ) {
-
-
-		$this->log->debug( "sync_items called with term ids : " . join( ",", $term_ids ) );
-
-		if (! $term_ids ) {
-			$this->cancel_process();
-			return false;
-		}
+    const WL_CMKG_ANALYSIS_BACKGROUND_PROCESS = '_wl_cmkg_analysis_background_process';
+
+
+    protected $action = 'wl_cmkg_analysis_background__analysis';
+
+    /**
+     * @var Analysis_Background_Service
+     */
+    private $analysis_background_service;
+
+    /**
+     * @var \Wordlift_Log_Service
+     */
+    private $log;
+
+    /**
+     * Analysis_Background_Process constructor.
+     *
+     * @param $analysis_background_service Analysis_Background_Service A {@link Analysis_Background_Service} instance providing the supporting functions to this background process.
+     */
+    public function __construct( $analysis_background_service ) {
+        parent::__construct();
+
+        $this->log = \Wordlift_Log_Service::get_logger( get_class() );
+
+        $this->analysis_background_service = $analysis_background_service;
+
+
+    }
+
+    /**
+     * 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 int[] $term_ids An array of term IDs.
+     *
+     * @return int[]|false The next term IDs or false if there are no more.
+     */
+    protected function task( $term_ids ) {
+
+        // Check if we must cancel.
+        if ( $this->must_cancel() ) {
+            $this->cancel();
+
+            return false;
+        }
+
+        if ( $term_ids && is_array($term_ids) ) {
+            $this->log->debug( sprintf( "Synchronizing terms %s...", implode( ', ', $term_ids ) ) );
+        }
+        // Sync the item.
+        return $this->sync_items( $term_ids );
+    }
+
+    /**
+     * Start the background processing.
+     *
+     * @return bool True if the process has been started, otherwise false.
+     */
+    public function start() {
+        $this->log->debug( "Trying to start analysis bg service..." );
+        // Create a new Sync_Model state of `started`.
+        if ( ! $this->is_started( self::get_state() ) ) {
+            $this->log->debug( "Starting..." );
+
+            $sync_state = new Sync_State( time(), 0, $this->analysis_background_service->count(), time(), 'started' );
+            update_option( self::WL_CMKG_ANALYSIS_BACKGROUND_PROCESS, $sync_state, false );
+
+            $next = $this->analysis_background_service->next();
+
+            $this->push_to_queue( $next );
+            $this->save()->dispatch();
+
+            if ( $next && is_array($next) ) {
+                $this->log->debug( sprintf( 'Started with term IDs %s.', implode( ', ', $next ) ) );
+            }
+            return true;
+        }
+
+        return false;
+    }
+
+    /**
+     * Set the transient to cancel the process. The next time the process runs, it'll check whether this transient is
+     * set and will stop processing.
+     */
+    public function request_cancel() {
+
+        set_transient( "{$this->action}__cancel", true );
+
+    }
+
+    /**
+     * Get the sync state.
+     *
+     * @return Sync_State The {@link Sync_State}.
+     */
+    public static function get_state() {
+
+        try {
+            return get_option( self::WL_CMKG_ANALYSIS_BACKGROUND_PROCESS, Sync_State::unknown() );
+        } catch ( \Exception $e ) {
+            return Sync_State::unknown();
+        }
+
+    }
+
+    /**
+     * Check whether the provided state is `started` or not.
+     *
+     * @param Sync_State $state The {@link Sync_State}.
+     *
+     * @return bool True if the state is started.
+     */
+    private function is_started( $state ) {
+        return $state instanceof Sync_State && 'started' === $state->state && 30 > ( time() - $state->last_update );
+    }
+
+    /**
+     * Check whether the process must cancel or not.
+     *
+     * @return bool Whether to cancel or not the process.
+     */
+    private function must_cancel() {
+
+        return get_transient( "{$this->action}__cancel" );
+    }
+
+    /**
+     * Cancels the current process.
+     */
+    public function cancel() {
+
+        $this->log->debug( "Cancelling synchronization..." );
+
+        // Cleanup the process data.
+        $this->cancel_process();
+
+        // Set the state to cancelled.
+        $state = self::get_state();
+        $state->set_state( 'cancelled' );
+        update_option( self::WL_CMKG_ANALYSIS_BACKGROUND_PROCESS, $state, false );
+
+        // Finally delete the transient.
+        delete_transient( "{$this->action}__cancel" );
+
+    }
+
+    /**
+     * Push the post with the provided ID to the remote platform.
+     *
+     * @param int[] $term_ids The term IDs.
+     *
+     * @return int[]|false The next term ID to process or false if processing is complete.
+     */
+    private function sync_items( $term_ids ) {
+
+
+        $this->log->debug( "sync_items called with term ids : " . join( ",", $term_ids ) );
+
+        if (! $term_ids ) {
+            $this->cancel_process();
+            return false;
+        }
 
-		if ( ! is_array( $term_ids ) ) {
-			$this->log->error( '$term_ids must be an array, received: ' . var_export( $term_ids, true ) );
+        if ( ! is_array( $term_ids ) ) {
+            $this->log->error( '$term_ids must be an array, received: ' . var_export( $term_ids, true ) );
 
-			return false;
-		}
-
-		// Sync this item.
-		if ( $this->analysis_background_service->perform_analysis_for_terms( $term_ids ) ) {
-
-			$next       = $this->analysis_background_service->next();
-			$next_state = isset( $next ) ? 'started' : 'ended';
-
-			/**
-			 * Update the synchronization meta data, by increasing the current index.
-			 *
-			 * @var Sync_State $sync The {@link Sync_State}.
-			 */
-			$state = self::get_state()
-			             ->increment_index( $this->analysis_background_service->get_batch_size() )
-			             ->set_state( $next_state );
-			update_option( self::WL_CMKG_ANALYSIS_BACKGROUND_PROCESS . '', $state, false );
+            return false;
+        }
+
+        // Sync this item.
+        if ( $this->analysis_background_service->perform_analysis_for_terms( $term_ids ) ) {
+
+            $next       = $this->analysis_background_service->next();
+            $next_state = isset( $next ) ? 'started' : 'ended';
+
+            /**
+             * Update the synchronization meta data, by increasing the current index.
+             *
+             * @var Sync_State $sync The {@link Sync_State}.
+             */
+            $state = self::get_state()
+                            ->increment_index( $this->analysis_background_service->get_batch_size() )
+                            ->set_state( $next_state );
+            update_option( self::WL_CMKG_ANALYSIS_BACKGROUND_PROCESS . '', $state, false );
 
 
-			// Return the next IDs or false if there aren't.
-			return isset( $next ) ? $next : false;
-		} else {
-			// Retry.
-			// @@todo: put a limit to the number of retries.
-
-			$this->log->error( sprintf( "Sync failed for terms %s.", implode( ', ', $term_ids ) ) );
-
-			return $term_ids;
-		}
+            // Return the next IDs or false if there aren't.
+            return isset( $next ) ? $next : false;
+        } else {
+            // Retry.
+            // @@todo: put a limit to the number of retries.
+
+            $this->log->error( sprintf( "Sync failed for terms %s.", implode( ', ', $term_ids ) ) );
+
+            return $term_ids;
+        }
 
-	}
+    }
 
 }

Spacing +37 added lines, -37 removed lines

@@ -24,10 +24,10 @@ 
 	 *
 	 * @param $analysis_background_service Analysis_Background_Service A {@link Analysis_Background_Service} instance providing the supporting functions to this background process.
 	 */
-	public function __construct( $analysis_background_service ) {
+	public function __construct($analysis_background_service) {
 		parent::__construct();
 
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
+		$this->log = \Wordlift_Log_Service::get_logger(get_class());
 
 		$this->analysis_background_service = $analysis_background_service;
 
@@ -45,20 +45,20 @@ 
 	 *
 	 * @return int[]|false The next term IDs or false if there are no more.
 	 */
-	protected function task( $term_ids ) {
+	protected function task($term_ids) {
 
 		// Check if we must cancel.
-		if ( $this->must_cancel() ) {
+		if ($this->must_cancel()) {
 			$this->cancel();
 
 			return false;
 		}
 
-		if ( $term_ids && is_array($term_ids) ) {
-			$this->log->debug( sprintf( "Synchronizing terms %s...", implode( ', ', $term_ids ) ) );
+		if ($term_ids && is_array($term_ids)) {
+			$this->log->debug(sprintf("Synchronizing terms %s...", implode(', ', $term_ids)));
 		}
 		// Sync the item.
-		return $this->sync_items( $term_ids );
+		return $this->sync_items($term_ids);
 	}
 
 	/**
@@ -67,21 +67,21 @@ 
 	 * @return bool True if the process has been started, otherwise false.
 	 */
 	public function start() {
-		$this->log->debug( "Trying to start analysis bg service..." );
+		$this->log->debug("Trying to start analysis bg service...");
 		// Create a new Sync_Model state of `started`.
-		if ( ! $this->is_started( self::get_state() ) ) {
-			$this->log->debug( "Starting..." );
+		if ( ! $this->is_started(self::get_state())) {
+			$this->log->debug("Starting...");
 
-			$sync_state = new Sync_State( time(), 0, $this->analysis_background_service->count(), time(), 'started' );
-			update_option( self::WL_CMKG_ANALYSIS_BACKGROUND_PROCESS, $sync_state, false );
+			$sync_state = new Sync_State(time(), 0, $this->analysis_background_service->count(), time(), 'started');
+			update_option(self::WL_CMKG_ANALYSIS_BACKGROUND_PROCESS, $sync_state, false);
 
 			$next = $this->analysis_background_service->next();
 
-			$this->push_to_queue( $next );
+			$this->push_to_queue($next);
 			$this->save()->dispatch();
 
-			if ( $next && is_array($next) ) {
-				$this->log->debug( sprintf( 'Started with term IDs %s.', implode( ', ', $next ) ) );
+			if ($next && is_array($next)) {
+				$this->log->debug(sprintf('Started with term IDs %s.', implode(', ', $next)));
 			}
 			return true;
 		}
@@ -95,7 +95,7 @@ 
 	 */
 	public function request_cancel() {
 
-		set_transient( "{$this->action}__cancel", true );
+		set_transient("{$this->action}__cancel", true);
 
 	}
 
@@ -107,8 +107,8 @@ 
 	public static function get_state() {
 
 		try {
-			return get_option( self::WL_CMKG_ANALYSIS_BACKGROUND_PROCESS, Sync_State::unknown() );
-		} catch ( \Exception $e ) {
+			return get_option(self::WL_CMKG_ANALYSIS_BACKGROUND_PROCESS, Sync_State::unknown());
+		} catch (\Exception $e) {
 			return Sync_State::unknown();
 		}
 
@@ -121,8 +121,8 @@ 
 	 *
 	 * @return bool True if the state is started.
 	 */
-	private function is_started( $state ) {
-		return $state instanceof Sync_State && 'started' === $state->state && 30 > ( time() - $state->last_update );
+	private function is_started($state) {
+		return $state instanceof Sync_State && 'started' === $state->state && 30 > (time() - $state->last_update);
 	}
 
 	/**
@@ -132,7 +132,7 @@ 
 	 */
 	private function must_cancel() {
 
-		return get_transient( "{$this->action}__cancel" );
+		return get_transient("{$this->action}__cancel");
 	}
 
 	/**
@@ -140,18 +140,18 @@ 
 	 */
 	public function cancel() {
 
-		$this->log->debug( "Cancelling synchronization..." );
+		$this->log->debug("Cancelling synchronization...");
 
 		// Cleanup the process data.
 		$this->cancel_process();
 
 		// Set the state to cancelled.
 		$state = self::get_state();
-		$state->set_state( 'cancelled' );
-		update_option( self::WL_CMKG_ANALYSIS_BACKGROUND_PROCESS, $state, false );
+		$state->set_state('cancelled');
+		update_option(self::WL_CMKG_ANALYSIS_BACKGROUND_PROCESS, $state, false);
 
 		// Finally delete the transient.
-		delete_transient( "{$this->action}__cancel" );
+		delete_transient("{$this->action}__cancel");
 
 	}
 
@@ -162,27 +162,27 @@ 
 	 *
 	 * @return int[]|false The next term ID to process or false if processing is complete.
 	 */
-	private function sync_items( $term_ids ) {
+	private function sync_items($term_ids) {
 
 
-		$this->log->debug( "sync_items called with term ids : " . join( ",", $term_ids ) );
+		$this->log->debug("sync_items called with term ids : ".join(",", $term_ids));
 
-		if (! $term_ids ) {
+		if ( ! $term_ids) {
 			$this->cancel_process();
 			return false;
 		}
 
-		if ( ! is_array( $term_ids ) ) {
-			$this->log->error( '$term_ids must be an array, received: ' . var_export( $term_ids, true ) );
+		if ( ! is_array($term_ids)) {
+			$this->log->error('$term_ids must be an array, received: '.var_export($term_ids, true));
 
 			return false;
 		}
 
 		// Sync this item.
-		if ( $this->analysis_background_service->perform_analysis_for_terms( $term_ids ) ) {
+		if ($this->analysis_background_service->perform_analysis_for_terms($term_ids)) {
 
 			$next       = $this->analysis_background_service->next();
-			$next_state = isset( $next ) ? 'started' : 'ended';
+			$next_state = isset($next) ? 'started' : 'ended';
 
 			/**
 			 * Update the synchronization meta data, by increasing the current index.
@@ -190,18 +190,18 @@ 
 			 * @var Sync_State $sync The {@link Sync_State}.
 			 */
 			$state = self::get_state()
-			             ->increment_index( $this->analysis_background_service->get_batch_size() )
-			             ->set_state( $next_state );
-			update_option( self::WL_CMKG_ANALYSIS_BACKGROUND_PROCESS . '', $state, false );
+			             ->increment_index($this->analysis_background_service->get_batch_size())
+			             ->set_state($next_state);
+			update_option(self::WL_CMKG_ANALYSIS_BACKGROUND_PROCESS.'', $state, false);
 
 
 			// Return the next IDs or false if there aren't.
-			return isset( $next ) ? $next : false;
+			return isset($next) ? $next : false;
 		} else {
 			// Retry.
 			// @@todo: put a limit to the number of retries.
 
-			$this->log->error( sprintf( "Sync failed for terms %s.", implode( ', ', $term_ids ) ) );
+			$this->log->error(sprintf("Sync failed for terms %s.", implode(', ', $term_ids)));
 
 			return $term_ids;
 		}

src/wordlift/vocabulary/data/term-count/class-term-count-factory.php

Indentation +7 added lines, -7 removed lines

@@ -7,14 +7,14 @@
  */
 class Term_Count_Factory {
 
-	const CACHED_TERM_COUNT = 'cached_term_count';
+    const CACHED_TERM_COUNT = 'cached_term_count';
 
-	public static function get_instance( $type ) {
-		if  ($type === self::CACHED_TERM_COUNT) {
-			return new Cached_Term_Count( new Default_Term_Count() );
-		}
-		return null;
-	}
+    public static function get_instance( $type ) {
+        if  ($type === self::CACHED_TERM_COUNT) {
+            return new Cached_Term_Count( new Default_Term_Count() );
+        }
+        return null;
+    }
 
 
 

Spacing +3 added lines, -3 removed lines

@@ -9,9 +9,9 @@
 
 	const CACHED_TERM_COUNT = 'cached_term_count';
 
-	public static function get_instance( $type ) {
-		if  ($type === self::CACHED_TERM_COUNT) {
-			return new Cached_Term_Count( new Default_Term_Count() );
+	public static function get_instance($type) {
+		if ($type === self::CACHED_TERM_COUNT) {
+			return new Cached_Term_Count(new Default_Term_Count());
 		}
 		return null;
 	}

src/wordlift/vocabulary/data/term-count/class-term-count.php

Indentation +5 added lines, -5 removed lines

@@ -9,11 +9,11 @@
 
 interface Term_Count {
 
-	/**
-	 * Return the term count which needs to be processed by the editor.
-	 * @return int
-	 */
-	public function get_term_count();
+    /**
+     * Return the term count which needs to be processed by the editor.
+     * @return int
+     */
+    public function get_term_count();
 
 }
 

src/wordlift/vocabulary/data/term-count/class-cached-term-count-manager.php

Indentation +8 added lines, -8 removed lines

@@ -7,16 +7,16 @@
  */
 class Cached_Term_count_Manager {
 
-	public function connect_hook() {
+    public function connect_hook() {
 
-		add_action( 'wordlift_vocabulary_analysis_complete_for_terms_batch', function () {
-			delete_transient( Cached_Term_Count::TRANSIENT_KEY );
-		} );
+        add_action( 'wordlift_vocabulary_analysis_complete_for_terms_batch', function () {
+            delete_transient( Cached_Term_Count::TRANSIENT_KEY );
+        } );
 
-		add_action('created_post_tag', function () {
-			delete_transient( Cached_Term_Count::TRANSIENT_KEY );
-		});
+        add_action('created_post_tag', function () {
+            delete_transient( Cached_Term_Count::TRANSIENT_KEY );
+        });
 
-	}
+    }
 
 }
\ No newline at end of file

Spacing +4 added lines, -4 removed lines

@@ -9,12 +9,12 @@
 
 	public function connect_hook() {
 
-		add_action( 'wordlift_vocabulary_analysis_complete_for_terms_batch', function () {
-			delete_transient( Cached_Term_Count::TRANSIENT_KEY );
+		add_action('wordlift_vocabulary_analysis_complete_for_terms_batch', function() {
+			delete_transient(Cached_Term_Count::TRANSIENT_KEY);
 		} );
 
-		add_action('created_post_tag', function () {
-			delete_transient( Cached_Term_Count::TRANSIENT_KEY );
+		add_action('created_post_tag', function() {
+			delete_transient(Cached_Term_Count::TRANSIENT_KEY);
 		});
 
 	}

src/wordlift/vocabulary/data/term-count/class-cached-term-count.php

Indentation +28 added lines, -28 removed lines

@@ -9,32 +9,32 @@
  */
 class Cached_Term_Count implements Term_Count {
 
-	const TRANSIENT_KEY = '_wl_vocabulary_term_count_transient';
-	/**
-	 * @var Term_Count
-	 */
-	private $term_count;
-
-
-	/**
-	 * Cached_Term_Count constructor.
-	 *
-	 * @param $term_count Term_Count
-	 */
-	public function __construct( $term_count ) {
-		$this->term_count = $term_count;
-	}
-
-	public function get_term_count() {
-		$data = get_transient( self::TRANSIENT_KEY );
-
-		if ( ! $data ) {
-			$data = $this->term_count->get_term_count();
-			set_transient( self::TRANSIENT_KEY, $data, 8 * 60 * 60 );
-
-			return $data;
-		}
-
-		return $data;
-	}
+    const TRANSIENT_KEY = '_wl_vocabulary_term_count_transient';
+    /**
+     * @var Term_Count
+     */
+    private $term_count;
+
+
+    /**
+     * Cached_Term_Count constructor.
+     *
+     * @param $term_count Term_Count
+     */
+    public function __construct( $term_count ) {
+        $this->term_count = $term_count;
+    }
+
+    public function get_term_count() {
+        $data = get_transient( self::TRANSIENT_KEY );
+
+        if ( ! $data ) {
+            $data = $this->term_count->get_term_count();
+            set_transient( self::TRANSIENT_KEY, $data, 8 * 60 * 60 );
+
+            return $data;
+        }
+
+        return $data;
+    }
 }

Spacing +4 added lines, -4 removed lines

@@ -21,16 +21,16 @@
 	 *
 	 * @param $term_count Term_Count
 	 */
-	public function __construct( $term_count ) {
+	public function __construct($term_count) {
 		$this->term_count = $term_count;
 	}
 
 	public function get_term_count() {
-		$data = get_transient( self::TRANSIENT_KEY );
+		$data = get_transient(self::TRANSIENT_KEY);
 
-		if ( ! $data ) {
+		if ( ! $data) {
 			$data = $this->term_count->get_term_count();
-			set_transient( self::TRANSIENT_KEY, $data, 8 * 60 * 60 );
+			set_transient(self::TRANSIENT_KEY, $data, 8 * 60 * 60);
 
 			return $data;
 		}

src/wordlift/vocabulary/data/term-count/class-default-term-count.php

Indentation +37 added lines, -37 removed lines

@@ -12,42 +12,42 @@
  */
 class Default_Term_Count implements Term_Count {
 
-	/**
-	 * Return count of terms which have entities and also not matched by editor, currently
-	 * it is used for the menu icon badge.
-	 * @return int
-	 */
-	public function get_term_count() {
-		/**
-		 * @todo: add support for all terms, currently we add only
-		 * post_tag.
-		 */
-		return count( $this->get_terms_compat( 'post_tag', array(
-			'taxonomy'   => 'post_tag',
-			'hide_empty' => false,
-			'fields'     => 'ids',
-			'meta_query' => array(
-				array(
-					'key'     => Entity_Rest_Endpoint::IGNORE_TAG_FROM_LISTING,
-					'compare' => 'NOT EXISTS',
-				),
-				array(
-					'key'     => Analysis_Background_Service::ENTITIES_PRESENT_FOR_TERM,
-					'compare' => 'EXISTS'
-				)
-			),
-		) ) );
-
-	}
-
-	private function get_terms_compat( $taxonomy, $args_with_taxonomy_key ) {
-		global $wp_version;
-
-		if ( version_compare( $wp_version, '4.5', '<' ) ) {
-			return get_terms( $taxonomy, $args_with_taxonomy_key );
-		} else {
-			return get_terms( $args_with_taxonomy_key );
-		}
-	}
+    /**
+     * Return count of terms which have entities and also not matched by editor, currently
+     * it is used for the menu icon badge.
+     * @return int
+     */
+    public function get_term_count() {
+        /**
+         * @todo: add support for all terms, currently we add only
+         * post_tag.
+         */
+        return count( $this->get_terms_compat( 'post_tag', array(
+            'taxonomy'   => 'post_tag',
+            'hide_empty' => false,
+            'fields'     => 'ids',
+            'meta_query' => array(
+                array(
+                    'key'     => Entity_Rest_Endpoint::IGNORE_TAG_FROM_LISTING,
+                    'compare' => 'NOT EXISTS',
+                ),
+                array(
+                    'key'     => Analysis_Background_Service::ENTITIES_PRESENT_FOR_TERM,
+                    'compare' => 'EXISTS'
+                )
+            ),
+        ) ) );
+
+    }
+
+    private function get_terms_compat( $taxonomy, $args_with_taxonomy_key ) {
+        global $wp_version;
+
+        if ( version_compare( $wp_version, '4.5', '<' ) ) {
+            return get_terms( $taxonomy, $args_with_taxonomy_key );
+        } else {
+            return get_terms( $args_with_taxonomy_key );
+        }
+    }
 
 }

Spacing +6 added lines, -6 removed lines

@@ -22,7 +22,7 @@ 
 		 * @todo: add support for all terms, currently we add only
 		 * post_tag.
 		 */
-		return count( $this->get_terms_compat( 'post_tag', array(
+		return count($this->get_terms_compat('post_tag', array(
 			'taxonomy'   => 'post_tag',
 			'hide_empty' => false,
 			'fields'     => 'ids',
@@ -36,17 +36,17 @@ 
 					'compare' => 'EXISTS'
 				)
 			),
-		) ) );
+		)));
 
 	}
 
-	private function get_terms_compat( $taxonomy, $args_with_taxonomy_key ) {
+	private function get_terms_compat($taxonomy, $args_with_taxonomy_key) {
 		global $wp_version;
 
-		if ( version_compare( $wp_version, '4.5', '<' ) ) {
-			return get_terms( $taxonomy, $args_with_taxonomy_key );
+		if (version_compare($wp_version, '4.5', '<')) {
+			return get_terms($taxonomy, $args_with_taxonomy_key);
 		} else {
-			return get_terms( $args_with_taxonomy_key );
+			return get_terms($args_with_taxonomy_key);
 		}
 	}
 

src/wordlift/vocabulary/data/term-data/class-term-data-factory.php

Indentation +19 added lines, -19 removed lines

@@ -4,27 +4,27 @@
 use Wordlift\Vocabulary\Analysis_Service;
 
 class Term_Data_Factory {
-	/**
-	 * @var Analysis_Service
-	 */
-	private $analysis_service;
+    /**
+     * @var Analysis_Service
+     */
+    private $analysis_service;
 
-	/**
-	 * @var Analysis_Service
-	 */
-	public function __construct( $analysis_service ) {
-		$this->analysis_service = $analysis_service;
-	}
+    /**
+     * @var Analysis_Service
+     */
+    public function __construct( $analysis_service ) {
+        $this->analysis_service = $analysis_service;
+    }
 
-	/**
-	 * @param $term \WP_Term
-	 *
-	 * @return Term_Data
-	 */
-	public function get_term_data( $term ) {
-		$entities = $this->analysis_service->get_entities( $term );
-		return new Default_Term_Data( $term, $entities );
-	}
+    /**
+     * @param $term \WP_Term
+     *
+     * @return Term_Data
+     */
+    public function get_term_data( $term ) {
+        $entities = $this->analysis_service->get_entities( $term );
+        return new Default_Term_Data( $term, $entities );
+    }
 
 
 }
\ No newline at end of file

Spacing +4 added lines, -4 removed lines

@@ -12,7 +12,7 @@ 
 	/**
 	 * @var Analysis_Service
 	 */
-	public function __construct( $analysis_service ) {
+	public function __construct($analysis_service) {
 		$this->analysis_service = $analysis_service;
 	}
 
@@ -21,9 +21,9 @@ 
 	 *
 	 * @return Term_Data
 	 */
-	public function get_term_data( $term ) {
-		$entities = $this->analysis_service->get_entities( $term );
-		return new Default_Term_Data( $term, $entities );
+	public function get_term_data($term) {
+		$entities = $this->analysis_service->get_entities($term);
+		return new Default_Term_Data($term, $entities);
 	}
 
 

src/wordlift/vocabulary/data/term-data/class-term-data.php

Indentation +5 added lines, -5 removed lines

@@ -8,10 +8,10 @@
 
 interface Term_Data {
 
-	/**
-	 * Should return an array which can be used by ui components.
-	 * @return array
-	 */
-	public function get_data();
+    /**
+     * Should return an array which can be used by ui components.
+     * @return array
+     */
+    public function get_data();
 
 }
\ No newline at end of file