insideout10 / wordlift-plugin

src/wordlift/vocabulary/api/class-reconcile-progress-endpoint.php

Indentation +60 added lines, -60 removed lines

@@ -14,70 +14,70 @@
  */
 class Reconcile_Progress_Endpoint {
 
-	public function register_routes() {
-		$that = $this;
-		add_action(
-			'rest_api_init',
-			function () use ( $that ) {
-				$that->register_progress_route();
-			}
-		);
-	}
+    public function register_routes() {
+        $that = $this;
+        add_action(
+            'rest_api_init',
+            function () use ( $that ) {
+                $that->register_progress_route();
+            }
+        );
+    }
 
-	public function progress() {
+    public function progress() {
 
-		$total_tags = count(
-			Terms_Compat::get_terms(
-				Terms_Compat::get_public_taxonomies(),
-				array(
-					'hide_empty' => false,
-					'fields'     => 'ids',
-					'meta_query' => array(
-						array(
-							'key'     => Analysis_Background_Service::ENTITIES_PRESENT_FOR_TERM,
-							'compare' => '=',
-							'value'   => '1',
-						),
-					),
-				)
-			)
-		);
+        $total_tags = count(
+            Terms_Compat::get_terms(
+                Terms_Compat::get_public_taxonomies(),
+                array(
+                    'hide_empty' => false,
+                    'fields'     => 'ids',
+                    'meta_query' => array(
+                        array(
+                            'key'     => Analysis_Background_Service::ENTITIES_PRESENT_FOR_TERM,
+                            'compare' => '=',
+                            'value'   => '1',
+                        ),
+                    ),
+                )
+            )
+        );
 
-		$completed = count(
-			Terms_Compat::get_terms(
-				Terms_Compat::get_public_taxonomies(),
-				array(
-					'hide_empty' => false,
-					'fields'     => 'ids',
-					'meta_query' => array(
-						array(
-							'key'     => Entity_Rest_Endpoint::IGNORE_TAG_FROM_LISTING,
-							'compare' => '=',
-							'value'   => '1',
-						),
-					),
-				)
-			)
-		);
+        $completed = count(
+            Terms_Compat::get_terms(
+                Terms_Compat::get_public_taxonomies(),
+                array(
+                    'hide_empty' => false,
+                    'fields'     => 'ids',
+                    'meta_query' => array(
+                        array(
+                            'key'     => Entity_Rest_Endpoint::IGNORE_TAG_FROM_LISTING,
+                            'compare' => '=',
+                            'value'   => '1',
+                        ),
+                    ),
+                )
+            )
+        );
 
-		return array(
-			'completed' => $completed,
-			'total'     => $total_tags,
-		);
-	}
+        return array(
+            'completed' => $completed,
+            'total'     => $total_tags,
+        );
+    }
 
-	private function register_progress_route() {
-		register_rest_route(
-			Api_Config::REST_NAMESPACE,
-			'/reconcile_progress/progress',
-			array(
-				'methods'             => \WP_REST_Server::CREATABLE,
-				'callback'            => array( $this, 'progress' ),
-				'permission_callback' => function () {
-					return current_user_can( 'manage_options' );
-				},
-			)
-		);
-	}
+    private function register_progress_route() {
+        register_rest_route(
+            Api_Config::REST_NAMESPACE,
+            '/reconcile_progress/progress',
+            array(
+                'methods'             => \WP_REST_Server::CREATABLE,
+                'callback'            => array( $this, 'progress' ),
+                'permission_callback' => function () {
+                    return current_user_can( 'manage_options' );
+                },
+            )
+        );
+    }
 
 }

Spacing +4 added lines, -4 removed lines

@@ -18,7 +18,7 @@ 
 		$that = $this;
 		add_action(
 			'rest_api_init',
-			function () use ( $that ) {
+			function() use ($that) {
 				$that->register_progress_route();
 			}
 		);
@@ -72,9 +72,9 @@ 
 			'/reconcile_progress/progress',
 			array(
 				'methods'             => \WP_REST_Server::CREATABLE,
-				'callback'            => array( $this, 'progress' ),
-				'permission_callback' => function () {
-					return current_user_can( 'manage_options' );
+				'callback'            => array($this, 'progress'),
+				'permission_callback' => function() {
+					return current_user_can('manage_options');
 				},
 			)
 		);

src/wordlift/vocabulary/api/class-api-config.php

Indentation +12 added lines, -12 removed lines

@@ -8,19 +8,19 @@
  */
 class Api_Config {
 
-	const REST_NAMESPACE = 'cafemediakg/v1';
+    const REST_NAMESPACE = 'cafemediakg/v1';
 
-	public static function get_api_config() {
-		// Create ui settings array to be used by js client.
-		$settings            = array();
-		$settings['restUrl'] = get_rest_url(
-			null,
-			self::REST_NAMESPACE . '/tags'
-		);
-		$settings['baseUrl'] = get_rest_url( null, self::REST_NAMESPACE );
-		$settings['nonce']   = wp_create_nonce( 'wp_rest' );
+    public static function get_api_config() {
+        // Create ui settings array to be used by js client.
+        $settings            = array();
+        $settings['restUrl'] = get_rest_url(
+            null,
+            self::REST_NAMESPACE . '/tags'
+        );
+        $settings['baseUrl'] = get_rest_url( null, self::REST_NAMESPACE );
+        $settings['nonce']   = wp_create_nonce( 'wp_rest' );
 
-		return $settings;
-	}
+        return $settings;
+    }
 
 }

Spacing +3 added lines, -3 removed lines

@@ -15,10 +15,10 @@
 		$settings            = array();
 		$settings['restUrl'] = get_rest_url(
 			null,
-			self::REST_NAMESPACE . '/tags'
+			self::REST_NAMESPACE.'/tags'
 		);
-		$settings['baseUrl'] = get_rest_url( null, self::REST_NAMESPACE );
-		$settings['nonce']   = wp_create_nonce( 'wp_rest' );
+		$settings['baseUrl'] = get_rest_url(null, self::REST_NAMESPACE);
+		$settings['nonce']   = wp_create_nonce('wp_rest');
 
 		return $settings;
 	}

src/wordlift/vocabulary/jsonld/class-post-jsonld.php

Indentation +76 added lines, -76 removed lines

@@ -11,109 +11,109 @@
 
 class Post_Jsonld {
 
-	public function enhance_post_jsonld() {
-		add_filter( 'wl_post_jsonld_array', array( $this, 'wl_post_jsonld_array' ), 11, 2 );
-		add_filter( 'wl_after_get_jsonld', array( $this, 'wl_after_get_jsonld' ), 11 );
-	}
+    public function enhance_post_jsonld() {
+        add_filter( 'wl_post_jsonld_array', array( $this, 'wl_post_jsonld_array' ), 11, 2 );
+        add_filter( 'wl_after_get_jsonld', array( $this, 'wl_after_get_jsonld' ), 11 );
+    }
 
-	public function wl_post_jsonld_array( $arr, $post_id ) {
+    public function wl_post_jsonld_array( $arr, $post_id ) {
 
-		$jsonld     = $arr['jsonld'];
-		$references = $arr['references'];
+        $jsonld     = $arr['jsonld'];
+        $references = $arr['references'];
 
-		$this->add_mentions( $post_id, $jsonld );
+        $this->add_mentions( $post_id, $jsonld );
 
-		return array(
-			'jsonld'     => $jsonld,
-			'references' => $references,
-		);
+        return array(
+            'jsonld'     => $jsonld,
+            'references' => $references,
+        );
 
-	}
+    }
 
-	public function add_mentions( $post_id, &$jsonld ) {
+    public function add_mentions( $post_id, &$jsonld ) {
 
-		$taxonomies = Terms_Compat::get_public_taxonomies();
-		$terms      = array();
+        $taxonomies = Terms_Compat::get_public_taxonomies();
+        $terms      = array();
 
-		foreach ( $taxonomies as $taxonomy ) {
-			$taxonomy_terms = get_the_terms( $post_id, $taxonomy );
-			if ( ! $taxonomy_terms ) {
-				continue;
-			}
-			$terms = array_merge( $taxonomy_terms, $terms );
-		}
+        foreach ( $taxonomies as $taxonomy ) {
+            $taxonomy_terms = get_the_terms( $post_id, $taxonomy );
+            if ( ! $taxonomy_terms ) {
+                continue;
+            }
+            $terms = array_merge( $taxonomy_terms, $terms );
+        }
 
-		if ( ! $terms ) {
-			return;
-		}
+        if ( ! $terms ) {
+            return;
+        }
 
-		if ( ! array_key_exists( 'mentions', $jsonld ) ) {
-			$jsonld['mentions'] = array();
-		}
+        if ( ! array_key_exists( 'mentions', $jsonld ) ) {
+            $jsonld['mentions'] = array();
+        }
 
-		foreach ( $terms as $term ) {
+        foreach ( $terms as $term ) {
 
-			$is_matched = intval( get_term_meta( $term->term_id, Entity_Rest_Endpoint::IGNORE_TAG_FROM_LISTING, true ) ) === 1;
+            $is_matched = intval( get_term_meta( $term->term_id, Entity_Rest_Endpoint::IGNORE_TAG_FROM_LISTING, true ) ) === 1;
 
-			if ( ! $is_matched ) {
-				continue;
-			}
+            if ( ! $is_matched ) {
+                continue;
+            }
 
-			$entities = Jsonld_Utils::get_matched_entities_for_term( $term->term_id );
+            $entities = Jsonld_Utils::get_matched_entities_for_term( $term->term_id );
 
-			if ( count( $entities ) === 0 ) {
-				continue;
-			}
+            if ( count( $entities ) === 0 ) {
+                continue;
+            }
 
-			$jsonld['mentions'] = array_merge( $jsonld['mentions'], self::add_additional_attrs( $term, $entities ) );
-		}
+            $jsonld['mentions'] = array_merge( $jsonld['mentions'], self::add_additional_attrs( $term, $entities ) );
+        }
 
-	}
+    }
 
-	/**
-	 * @param $term \WP_Term
-	 * @param $entities
-	 *
-	 * @return array
-	 */
-	public static function add_additional_attrs( $term, $entities ) {
+    /**
+     * @param $term \WP_Term
+     * @param $entities
+     *
+     * @return array
+     */
+    public static function add_additional_attrs( $term, $entities ) {
 
-		return array_map(
-			function ( $entity ) use ( $term ) {
-				$entity['@id'] = get_term_link( $term->term_id ) . '#id';
-				if ( ! empty( $term->description ) ) {
-					  $entity['description'] = $term->description;
-				}
+        return array_map(
+            function ( $entity ) use ( $term ) {
+                $entity['@id'] = get_term_link( $term->term_id ) . '#id';
+                if ( ! empty( $term->description ) ) {
+                        $entity['description'] = $term->description;
+                }
 
-				return $entity;
+                return $entity;
 
-			},
-			$entities
-		);
+            },
+            $entities
+        );
 
-	}
+    }
 
-	public function wl_after_get_jsonld( $jsonld ) {
+    public function wl_after_get_jsonld( $jsonld ) {
 
-		if ( ! is_array( $jsonld ) || count( $jsonld ) === 0 ) {
-			return $jsonld;
-		}
+        if ( ! is_array( $jsonld ) || count( $jsonld ) === 0 ) {
+            return $jsonld;
+        }
 
-		foreach ( $jsonld as $key => $value ) {
-			if ( 'Article' === $value['@type'] && isset( $value['image'] ) ) {
-				$image = $value['image'];
-			}
-			if ( 'Recipe' === $value['@type'] && ! isset( $value['image'] ) ) {
-				$index = $key;
-			}
-		}
+        foreach ( $jsonld as $key => $value ) {
+            if ( 'Article' === $value['@type'] && isset( $value['image'] ) ) {
+                $image = $value['image'];
+            }
+            if ( 'Recipe' === $value['@type'] && ! isset( $value['image'] ) ) {
+                $index = $key;
+            }
+        }
 
-		if ( isset( $index ) && ! empty( $image ) ) {
-			$jsonld[ $index ]['image'] = $image;
-		}
+        if ( isset( $index ) && ! empty( $image ) ) {
+            $jsonld[ $index ]['image'] = $image;
+        }
 
-		return $jsonld;
+        return $jsonld;
 
-	}
+    }
 
 }

Spacing +28 added lines, -28 removed lines

@@ -12,16 +12,16 @@ 
 class Post_Jsonld {
 
 	public function enhance_post_jsonld() {
-		add_filter( 'wl_post_jsonld_array', array( $this, 'wl_post_jsonld_array' ), 11, 2 );
-		add_filter( 'wl_after_get_jsonld', array( $this, 'wl_after_get_jsonld' ), 11 );
+		add_filter('wl_post_jsonld_array', array($this, 'wl_post_jsonld_array'), 11, 2);
+		add_filter('wl_after_get_jsonld', array($this, 'wl_after_get_jsonld'), 11);
 	}
 
-	public function wl_post_jsonld_array( $arr, $post_id ) {
+	public function wl_post_jsonld_array($arr, $post_id) {
 
 		$jsonld     = $arr['jsonld'];
 		$references = $arr['references'];
 
-		$this->add_mentions( $post_id, $jsonld );
+		$this->add_mentions($post_id, $jsonld);
 
 		return array(
 			'jsonld'     => $jsonld,
@@ -30,42 +30,42 @@ 
 
 	}
 
-	public function add_mentions( $post_id, &$jsonld ) {
+	public function add_mentions($post_id, &$jsonld) {
 
 		$taxonomies = Terms_Compat::get_public_taxonomies();
 		$terms      = array();
 
-		foreach ( $taxonomies as $taxonomy ) {
-			$taxonomy_terms = get_the_terms( $post_id, $taxonomy );
-			if ( ! $taxonomy_terms ) {
+		foreach ($taxonomies as $taxonomy) {
+			$taxonomy_terms = get_the_terms($post_id, $taxonomy);
+			if ( ! $taxonomy_terms) {
 				continue;
 			}
-			$terms = array_merge( $taxonomy_terms, $terms );
+			$terms = array_merge($taxonomy_terms, $terms);
 		}
 
-		if ( ! $terms ) {
+		if ( ! $terms) {
 			return;
 		}
 
-		if ( ! array_key_exists( 'mentions', $jsonld ) ) {
+		if ( ! array_key_exists('mentions', $jsonld)) {
 			$jsonld['mentions'] = array();
 		}
 
-		foreach ( $terms as $term ) {
+		foreach ($terms as $term) {
 
-			$is_matched = intval( get_term_meta( $term->term_id, Entity_Rest_Endpoint::IGNORE_TAG_FROM_LISTING, true ) ) === 1;
+			$is_matched = intval(get_term_meta($term->term_id, Entity_Rest_Endpoint::IGNORE_TAG_FROM_LISTING, true)) === 1;
 
-			if ( ! $is_matched ) {
+			if ( ! $is_matched) {
 				continue;
 			}
 
-			$entities = Jsonld_Utils::get_matched_entities_for_term( $term->term_id );
+			$entities = Jsonld_Utils::get_matched_entities_for_term($term->term_id);
 
-			if ( count( $entities ) === 0 ) {
+			if (count($entities) === 0) {
 				continue;
 			}
 
-			$jsonld['mentions'] = array_merge( $jsonld['mentions'], self::add_additional_attrs( $term, $entities ) );
+			$jsonld['mentions'] = array_merge($jsonld['mentions'], self::add_additional_attrs($term, $entities));
 		}
 
 	}
@@ -76,12 +76,12 @@ 
 	 *
 	 * @return array
 	 */
-	public static function add_additional_attrs( $term, $entities ) {
+	public static function add_additional_attrs($term, $entities) {
 
 		return array_map(
-			function ( $entity ) use ( $term ) {
-				$entity['@id'] = get_term_link( $term->term_id ) . '#id';
-				if ( ! empty( $term->description ) ) {
+			function($entity) use ($term) {
+				$entity['@id'] = get_term_link($term->term_id).'#id';
+				if ( ! empty($term->description)) {
 					  $entity['description'] = $term->description;
 				}
 
@@ -93,23 +93,23 @@ 
 
 	}
 
-	public function wl_after_get_jsonld( $jsonld ) {
+	public function wl_after_get_jsonld($jsonld) {
 
-		if ( ! is_array( $jsonld ) || count( $jsonld ) === 0 ) {
+		if ( ! is_array($jsonld) || count($jsonld) === 0) {
 			return $jsonld;
 		}
 
-		foreach ( $jsonld as $key => $value ) {
-			if ( 'Article' === $value['@type'] && isset( $value['image'] ) ) {
+		foreach ($jsonld as $key => $value) {
+			if ('Article' === $value['@type'] && isset($value['image'])) {
 				$image = $value['image'];
 			}
-			if ( 'Recipe' === $value['@type'] && ! isset( $value['image'] ) ) {
+			if ('Recipe' === $value['@type'] && ! isset($value['image'])) {
 				$index = $key;
 			}
 		}
 
-		if ( isset( $index ) && ! empty( $image ) ) {
-			$jsonld[ $index ]['image'] = $image;
+		if (isset($index) && ! empty($image)) {
+			$jsonld[$index]['image'] = $image;
 		}
 
 		return $jsonld;

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

Indentation +190 added lines, -190 removed lines

@@ -4,195 +4,195 @@
 
 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->cancel();
-			return false;
-		}
-
-		$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 ) {
-
-		// 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;
-		}
-
-	}
+    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->cancel();
+            return false;
+        }
+
+        $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 ) {
+
+        // 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;
+        }
+
+    }
 
 }

Spacing +33 added lines, -33 removed lines

@@ -23,10 +23,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;
 
@@ -43,23 +43,23 @@ 
 	 *
 	 * @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 ) ) {
+		if ( ! $term_ids || ! is_array($term_ids)) {
 			$this->cancel();
 			return false;
 		}
 
-		$this->log->debug( sprintf( 'Synchronizing terms %s...', implode( ', ', $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);
 	}
 
 	/**
@@ -68,21 +68,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;
@@ -97,7 +97,7 @@ 
 	 */
 	public function request_cancel() {
 
-		set_transient( "{$this->action}__cancel", true );
+		set_transient("{$this->action}__cancel", true);
 
 	}
 
@@ -109,8 +109,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();
 		}
 
@@ -123,8 +123,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);
 	}
 
 	/**
@@ -134,7 +134,7 @@ 
 	 */
 	private function must_cancel() {
 
-		return get_transient( "{$this->action}__cancel" );
+		return get_transient("{$this->action}__cancel");
 	}
 
 	/**
@@ -142,18 +142,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");
 
 	}
 
@@ -164,13 +164,13 @@ 
 	 *
 	 * @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) {
 
 		// 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.
@@ -178,17 +178,17 @@ 
 			 * @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/class-sync-state.php

Indentation +51 added lines, -51 removed lines

@@ -4,56 +4,56 @@
 
 class Sync_State {
 
-	public $started;
-	public $index;
-	public $count;
-	public $last_update;
-	public $state;
-
-	/**
-	 * Sync_Model constructor.
-	 *
-	 * @param $started
-	 * @param $index
-	 * @param $count
-	 * @param $last_update
-	 * @param $state
-	 */
-	public function __construct( $started, $index, $count, $last_update, $state ) {
-		$this->started     = $started;
-		$this->index       = $index;
-		$this->count       = (int) $count;
-		$this->last_update = $last_update;
-		$this->state       = $state;
-	}
-
-	public function increment_index( $count ) {
-		$this->index      += $count;
-		$this->last_update = time();
-
-		return $this;
-	}
-
-	public function set_state( $value ) {
-		$this->state       = $value;
-		$this->last_update = time();
-
-		return $this;
-	}
-
-	public function get_array() {
-		return array(
-			'started'     => $this->started,
-			'index'       => $this->index,
-			'count'       => $this->count,
-			'last_update' => $this->last_update,
-			'state'       => $this->state,
-		);
-	}
-
-	public static function unknown() {
-
-		return new self( time(), 0, 0, time(), 'unknown' );
-	}
+    public $started;
+    public $index;
+    public $count;
+    public $last_update;
+    public $state;
+
+    /**
+     * Sync_Model constructor.
+     *
+     * @param $started
+     * @param $index
+     * @param $count
+     * @param $last_update
+     * @param $state
+     */
+    public function __construct( $started, $index, $count, $last_update, $state ) {
+        $this->started     = $started;
+        $this->index       = $index;
+        $this->count       = (int) $count;
+        $this->last_update = $last_update;
+        $this->state       = $state;
+    }
+
+    public function increment_index( $count ) {
+        $this->index      += $count;
+        $this->last_update = time();
+
+        return $this;
+    }
+
+    public function set_state( $value ) {
+        $this->state       = $value;
+        $this->last_update = time();
+
+        return $this;
+    }
+
+    public function get_array() {
+        return array(
+            'started'     => $this->started,
+            'index'       => $this->index,
+            'count'       => $this->count,
+            'last_update' => $this->last_update,
+            'state'       => $this->state,
+        );
+    }
+
+    public static function unknown() {
+
+        return new self( time(), 0, 0, time(), 'unknown' );
+    }
 
 }

Spacing +4 added lines, -4 removed lines

@@ -19,7 +19,7 @@ 
 	 * @param $last_update
 	 * @param $state
 	 */
-	public function __construct( $started, $index, $count, $last_update, $state ) {
+	public function __construct($started, $index, $count, $last_update, $state) {
 		$this->started     = $started;
 		$this->index       = $index;
 		$this->count       = (int) $count;
@@ -27,14 +27,14 @@ 
 		$this->state       = $state;
 	}
 
-	public function increment_index( $count ) {
+	public function increment_index($count) {
 		$this->index      += $count;
 		$this->last_update = time();
 
 		return $this;
 	}
 
-	public function set_state( $value ) {
+	public function set_state($value) {
 		$this->state       = $value;
 		$this->last_update = time();
 
@@ -53,7 +53,7 @@ 
 
 	public static function unknown() {
 
-		return new self( time(), 0, 0, time(), 'unknown' );
+		return new self(time(), 0, 0, time(), 'unknown');
 	}
 
 }

src/wordlift/vocabulary/cache/class-cache-service-factory.php

Indentation +3 added lines, -3 removed lines

@@ -4,8 +4,8 @@
 
 class Cache_Service_Factory {
 
-	public static function get_cache_service() {
-		return new Options_Cache( 'wordlift-cmkg' );
-	}
+    public static function get_cache_service() {
+        return new Options_Cache( 'wordlift-cmkg' );
+    }
 
 }

Spacing +1 added lines, -1 removed lines

@@ -5,7 +5,7 @@
 class Cache_Service_Factory {
 
 	public static function get_cache_service() {
-		return new Options_Cache( 'wordlift-cmkg' );
+		return new Options_Cache('wordlift-cmkg');
 	}
 
 }

src/wordlift/vocabulary/cache/class-options-cache.php

Indentation +22 added lines, -22 removed lines

@@ -4,35 +4,35 @@
 
 class Options_Cache implements Cache {
 
-	private $namespace;
+    private $namespace;
 
-	/**
-	 * Options_Cache constructor.
-	 *
-	 * @param $namespace
-	 */
-	public function __construct( $namespace ) {
-		$this->namespace = $namespace;
-	}
+    /**
+     * Options_Cache constructor.
+     *
+     * @param $namespace
+     */
+    public function __construct( $namespace ) {
+        $this->namespace = $namespace;
+    }
 
-	public function get( $cache_key ) {
+    public function get( $cache_key ) {
 
-		return get_option( $this->namespace . '__' . $cache_key, false );
+        return get_option( $this->namespace . '__' . $cache_key, false );
 
-	}
+    }
 
-	public function put( $cache_key, $value ) {
+    public function put( $cache_key, $value ) {
 
-		return update_option( $this->namespace . '__' . $cache_key, $value );
+        return update_option( $this->namespace . '__' . $cache_key, $value );
 
-	}
+    }
 
-	public function flush_all() {
-		if ( '' !== $this->namespace ) {
-			global $wpdb;
-			$namespace_esc = $wpdb->esc_like( $this->namespace ) . '__%';
-			$wpdb->query( $wpdb->prepare( "DELETE FROM $wpdb->options WHERE option_name LIKE %s", $namespace_esc ) );
-		}
-	}
+    public function flush_all() {
+        if ( '' !== $this->namespace ) {
+            global $wpdb;
+            $namespace_esc = $wpdb->esc_like( $this->namespace ) . '__%';
+            $wpdb->query( $wpdb->prepare( "DELETE FROM $wpdb->options WHERE option_name LIKE %s", $namespace_esc ) );
+        }
+    }
 
 }

Spacing +8 added lines, -8 removed lines

@@ -11,27 +11,27 @@
 	 *
 	 * @param $namespace
 	 */
-	public function __construct( $namespace ) {
+	public function __construct($namespace) {
 		$this->namespace = $namespace;
 	}
 
-	public function get( $cache_key ) {
+	public function get($cache_key) {
 
-		return get_option( $this->namespace . '__' . $cache_key, false );
+		return get_option($this->namespace.'__'.$cache_key, false);
 
 	}
 
-	public function put( $cache_key, $value ) {
+	public function put($cache_key, $value) {
 
-		return update_option( $this->namespace . '__' . $cache_key, $value );
+		return update_option($this->namespace.'__'.$cache_key, $value);
 
 	}
 
 	public function flush_all() {
-		if ( '' !== $this->namespace ) {
+		if ('' !== $this->namespace) {
 			global $wpdb;
-			$namespace_esc = $wpdb->esc_like( $this->namespace ) . '__%';
-			$wpdb->query( $wpdb->prepare( "DELETE FROM $wpdb->options WHERE option_name LIKE %s", $namespace_esc ) );
+			$namespace_esc = $wpdb->esc_like($this->namespace).'__%';
+			$wpdb->query($wpdb->prepare("DELETE FROM $wpdb->options WHERE option_name LIKE %s", $namespace_esc));
 		}
 	}
 

src/wordlift/link/class-term-link.php

Indentation +43 added lines, -43 removed lines

@@ -16,47 +16,47 @@
 
 class Term_Link extends Default_Link {
 
-	/**
-	 * @var Synonyms_Service
-	 */
-	private $synonyms_service;
-
-	public function __construct() {
-		parent::__construct();
-		$this->synonyms_service = Synonyms_Service::get_instance();
-	}
-
-	/**
-	 * @throws Exception when the {@link Wordpress_Term_Content_Legacy_Service} throws one, i.e. when passing a non term content id.
-	 */
-	public function get_same_as_uris( $id ) {
-		return array_merge(
-			(array) Wordpress_Term_Content_Legacy_Service::get_instance()
-														 ->get_entity_id( Wordpress_Content_Id::create_term( $id ) ),
-			get_term_meta( $id, Wordlift_Schema_Service::FIELD_SAME_AS )
-		);
-	}
-
-	public function get_id( $uri ) {
-		$content = Wordpress_Term_Content_Legacy_Service::get_instance()
-														->get_by_entity_id_or_same_as( $uri );
-
-		if ( ! isset( $content ) ) {
-			return false;
-		}
-
-		return $content->get_bag()->term_id;
-	}
-
-	public function get_synonyms( $id ) {
-		return $this->synonyms_service->get_synonyms( $id );
-	}
-
-	public function get_permalink( $id ) {
-		return get_term_link( $id );
-	}
-
-	public function get_edit_page_link( $id ) {
-		return get_edit_term_link( $id );
-	}
+    /**
+     * @var Synonyms_Service
+     */
+    private $synonyms_service;
+
+    public function __construct() {
+        parent::__construct();
+        $this->synonyms_service = Synonyms_Service::get_instance();
+    }
+
+    /**
+     * @throws Exception when the {@link Wordpress_Term_Content_Legacy_Service} throws one, i.e. when passing a non term content id.
+     */
+    public function get_same_as_uris( $id ) {
+        return array_merge(
+            (array) Wordpress_Term_Content_Legacy_Service::get_instance()
+                                                            ->get_entity_id( Wordpress_Content_Id::create_term( $id ) ),
+            get_term_meta( $id, Wordlift_Schema_Service::FIELD_SAME_AS )
+        );
+    }
+
+    public function get_id( $uri ) {
+        $content = Wordpress_Term_Content_Legacy_Service::get_instance()
+                                                        ->get_by_entity_id_or_same_as( $uri );
+
+        if ( ! isset( $content ) ) {
+            return false;
+        }
+
+        return $content->get_bag()->term_id;
+    }
+
+    public function get_synonyms( $id ) {
+        return $this->synonyms_service->get_synonyms( $id );
+    }
+
+    public function get_permalink( $id ) {
+        return get_term_link( $id );
+    }
+
+    public function get_edit_page_link( $id ) {
+        return get_edit_term_link( $id );
+    }
 }

Spacing +12 added lines, -12 removed lines

@@ -29,34 +29,34 @@
 	/**
 	 * @throws Exception when the {@link Wordpress_Term_Content_Legacy_Service} throws one, i.e. when passing a non term content id.
 	 */
-	public function get_same_as_uris( $id ) {
+	public function get_same_as_uris($id) {
 		return array_merge(
 			(array) Wordpress_Term_Content_Legacy_Service::get_instance()
-														 ->get_entity_id( Wordpress_Content_Id::create_term( $id ) ),
-			get_term_meta( $id, Wordlift_Schema_Service::FIELD_SAME_AS )
+														 ->get_entity_id(Wordpress_Content_Id::create_term($id)),
+			get_term_meta($id, Wordlift_Schema_Service::FIELD_SAME_AS)
 		);
 	}
 
-	public function get_id( $uri ) {
+	public function get_id($uri) {
 		$content = Wordpress_Term_Content_Legacy_Service::get_instance()
-														->get_by_entity_id_or_same_as( $uri );
+														->get_by_entity_id_or_same_as($uri);
 
-		if ( ! isset( $content ) ) {
+		if ( ! isset($content)) {
 			return false;
 		}
 
 		return $content->get_bag()->term_id;
 	}
 
-	public function get_synonyms( $id ) {
-		return $this->synonyms_service->get_synonyms( $id );
+	public function get_synonyms($id) {
+		return $this->synonyms_service->get_synonyms($id);
 	}
 
-	public function get_permalink( $id ) {
-		return get_term_link( $id );
+	public function get_permalink($id) {
+		return get_term_link($id);
 	}
 
-	public function get_edit_page_link( $id ) {
-		return get_edit_term_link( $id );
+	public function get_edit_page_link($id) {
+		return get_edit_term_link($id);
 	}
 }

src/wordlift/link/class-link-builder.php

Indentation +88 added lines, -88 removed lines

@@ -9,93 +9,93 @@
 
 class Link_Builder {
 
-	private $id;
-	private $type;
-	private $label;
-	private $href;
-	private $entity_url;
-	/**
-	 * @var Object_Link_Provider
-	 */
-	private $object_link_provider;
-
-	public function __construct( $entity_url, $id ) {
-		$this->entity_url           = $entity_url;
-		$this->id                   = $id;
-		$this->object_link_provider = Object_Link_Provider::get_instance();
-		$this->type                 = $this->object_link_provider->get_object_type( $entity_url );
-	}
-
-	public static function create( $entity_url, $id ) {
-		return new Link_Builder( $entity_url, $id );
-	}
-
-	public function label( $label ) {
-		$this->label = $label;
-
-		return $this;
-	}
-
-	public function href( $href ) {
-		$this->href = $href;
-
-		return $this;
-	}
-
-	private function get_attributes_for_link() {
-		/**
-		 * Allow 3rd parties to add additional attributes to the anchor link.
-		 *
-		 * @since 3.26.0
-		 */
-		$default_attributes = array(
-			'id' => implode( ';', $this->object_link_provider->get_same_as_uris( $this->id, $this->type ) ),
-		);
-
-		/**
-		 * @since 3.32.0
-		 * Additional parameter {@link $this->type} is added to the filter denoting the type of
-		 * the entity url by the enum values {@link Object_Type_Enum}
-		 */
-		$attributes      = apply_filters( 'wl_anchor_data_attributes', $default_attributes, $this->id, $this->type );
-		$attributes_html = '';
-		foreach ( $attributes as $key => $value ) {
-			$attributes_html .= ' data-' . esc_html( $key ) . '="' . esc_attr( $value ) . '" ';
-		}
-
-		return $attributes_html;
-	}
-
-	/**
-	 * Get a `title` attribute with an alternative label for the link.
-	 *
-	 * If an alternative title isn't available an empty string is returned.
-	 *
-	 * @return string A `title` attribute with an alternative label or an empty
-	 *                string if none available.
-	 * @since 3.32.0
-	 */
-	private function get_title_attribute() {
-
-		// Get an alternative title.
-		$title = $this->object_link_provider->get_link_title( $this->id, $this->label, $this->type );
-		if ( ! empty( $title ) ) {
-			return 'title="' . esc_attr( $title ) . '"';
-		}
-
-		return '';
-	}
-
-	/**
-	 * @return string
-	 */
-	public function generate_link() {
-		// Get an alternative title attribute.
-		$title_attribute = $this->get_title_attribute();
-		$attributes_html = $this->get_attributes_for_link();
-
-		// Return the link.
-		return "<a class=\"wl-entity-page-link\" $title_attribute href=\"{$this->href}\"$attributes_html>{$this->label}</a>";
-	}
+    private $id;
+    private $type;
+    private $label;
+    private $href;
+    private $entity_url;
+    /**
+     * @var Object_Link_Provider
+     */
+    private $object_link_provider;
+
+    public function __construct( $entity_url, $id ) {
+        $this->entity_url           = $entity_url;
+        $this->id                   = $id;
+        $this->object_link_provider = Object_Link_Provider::get_instance();
+        $this->type                 = $this->object_link_provider->get_object_type( $entity_url );
+    }
+
+    public static function create( $entity_url, $id ) {
+        return new Link_Builder( $entity_url, $id );
+    }
+
+    public function label( $label ) {
+        $this->label = $label;
+
+        return $this;
+    }
+
+    public function href( $href ) {
+        $this->href = $href;
+
+        return $this;
+    }
+
+    private function get_attributes_for_link() {
+        /**
+         * Allow 3rd parties to add additional attributes to the anchor link.
+         *
+         * @since 3.26.0
+         */
+        $default_attributes = array(
+            'id' => implode( ';', $this->object_link_provider->get_same_as_uris( $this->id, $this->type ) ),
+        );
+
+        /**
+         * @since 3.32.0
+         * Additional parameter {@link $this->type} is added to the filter denoting the type of
+         * the entity url by the enum values {@link Object_Type_Enum}
+         */
+        $attributes      = apply_filters( 'wl_anchor_data_attributes', $default_attributes, $this->id, $this->type );
+        $attributes_html = '';
+        foreach ( $attributes as $key => $value ) {
+            $attributes_html .= ' data-' . esc_html( $key ) . '="' . esc_attr( $value ) . '" ';
+        }
+
+        return $attributes_html;
+    }
+
+    /**
+     * Get a `title` attribute with an alternative label for the link.
+     *
+     * If an alternative title isn't available an empty string is returned.
+     *
+     * @return string A `title` attribute with an alternative label or an empty
+     *                string if none available.
+     * @since 3.32.0
+     */
+    private function get_title_attribute() {
+
+        // Get an alternative title.
+        $title = $this->object_link_provider->get_link_title( $this->id, $this->label, $this->type );
+        if ( ! empty( $title ) ) {
+            return 'title="' . esc_attr( $title ) . '"';
+        }
+
+        return '';
+    }
+
+    /**
+     * @return string
+     */
+    public function generate_link() {
+        // Get an alternative title attribute.
+        $title_attribute = $this->get_title_attribute();
+        $attributes_html = $this->get_attributes_for_link();
+
+        // Return the link.
+        return "<a class=\"wl-entity-page-link\" $title_attribute href=\"{$this->href}\"$attributes_html>{$this->label}</a>";
+    }
 
 }

Spacing +13 added lines, -13 removed lines

@@ -19,24 +19,24 @@ 
 	 */
 	private $object_link_provider;
 
-	public function __construct( $entity_url, $id ) {
+	public function __construct($entity_url, $id) {
 		$this->entity_url           = $entity_url;
 		$this->id                   = $id;
 		$this->object_link_provider = Object_Link_Provider::get_instance();
-		$this->type                 = $this->object_link_provider->get_object_type( $entity_url );
+		$this->type                 = $this->object_link_provider->get_object_type($entity_url);
 	}
 
-	public static function create( $entity_url, $id ) {
-		return new Link_Builder( $entity_url, $id );
+	public static function create($entity_url, $id) {
+		return new Link_Builder($entity_url, $id);
 	}
 
-	public function label( $label ) {
+	public function label($label) {
 		$this->label = $label;
 
 		return $this;
 	}
 
-	public function href( $href ) {
+	public function href($href) {
 		$this->href = $href;
 
 		return $this;
@@ -49,7 +49,7 @@ 
 		 * @since 3.26.0
 		 */
 		$default_attributes = array(
-			'id' => implode( ';', $this->object_link_provider->get_same_as_uris( $this->id, $this->type ) ),
+			'id' => implode(';', $this->object_link_provider->get_same_as_uris($this->id, $this->type)),
 		);
 
 		/**
@@ -57,10 +57,10 @@ 
 		 * Additional parameter {@link $this->type} is added to the filter denoting the type of
 		 * the entity url by the enum values {@link Object_Type_Enum}
 		 */
-		$attributes      = apply_filters( 'wl_anchor_data_attributes', $default_attributes, $this->id, $this->type );
+		$attributes      = apply_filters('wl_anchor_data_attributes', $default_attributes, $this->id, $this->type);
 		$attributes_html = '';
-		foreach ( $attributes as $key => $value ) {
-			$attributes_html .= ' data-' . esc_html( $key ) . '="' . esc_attr( $value ) . '" ';
+		foreach ($attributes as $key => $value) {
+			$attributes_html .= ' data-'.esc_html($key).'="'.esc_attr($value).'" ';
 		}
 
 		return $attributes_html;
@@ -78,9 +78,9 @@ 
 	private function get_title_attribute() {
 
 		// Get an alternative title.
-		$title = $this->object_link_provider->get_link_title( $this->id, $this->label, $this->type );
-		if ( ! empty( $title ) ) {
-			return 'title="' . esc_attr( $title ) . '"';
+		$title = $this->object_link_provider->get_link_title($this->id, $this->label, $this->type);
+		if ( ! empty($title)) {
+			return 'title="'.esc_attr($title).'"';
 		}
 
 		return '';