Wordlift\Vocabulary\Analysis_Background_Service

Complexity

Total Complexity

12

Size/Duplication

Total Lines	135
Duplicated Lines	28.89 %

Coupling/Cohesion

Components	2
Dependencies	4

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	start()	0	3	1
A	cancel()	0	3	1
A	stop()	0	4	1
A	next()	18	18	1
A	count()	21	21	1
A	get_batch_size()	0	3	1
A	info()	0	3	1
A	perform_analysis_for_terms()	0	31	4

<?php

namespace Wordlift\Vocabulary;


class Analysis_Background_Service {


	const ANALYSIS_DONE_FLAG = '_wl_cmkg_analysis_complete_for_term_options_cache';
	const TERMS_COUNT_TRANSIENT = '_wl_cmkg_analysis_background_service_terms_count';
	const ENTITIES_PRESENT_FOR_TERM = '_wl_cmkg_analysis_entities_present_for_term_options_cache';

	/**
	 * @var Analysis_Service
	 */
	private $analysis_service;
	/**
	 * @var Analysis_Background_Process
	 */
	private $analysis_background_process;

	/**
	 * @var \Wordlift_Log_Service
	 */
	private $log;


	public function __construct( $analysis_service ) {

		$this->analysis_service = $analysis_service;

		$this->analysis_background_process = new Analysis_Background_Process( $this );

		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
	}

	public function start() {
		$this->analysis_background_process->start();
	}

	public function cancel() {
		$this->analysis_background_process->cancel();
	}

	public function stop() {
		$this->analysis_background_process->cancel();
		$this->analysis_background_process->request_cancel();
	}

	/**
	 * A list of term ids.
	 * @return int|\WP_Error|\WP_Term[]
	 */
	public function next() {

This method seems to be duplicated in your project.

		$state = $this->info();

		return get_terms( array(
			'fields'     => 'ids',
			'taxonomy'   => 'post_tag',
			'hide_empty' => false,
			'number'     => $this->get_batch_size(),
			'offset'     => $state->index,
			'meta_query' => array(
				array(
					'key'     => self::ANALYSIS_DONE_FLAG,
					'compare' => 'NOT EXISTS'
				)
			),
		) );
	}

	public function count() {

This method seems to be duplicated in your project.

		$count = count( get_terms( array(
			'fields'     => 'ids',
			'taxonomy'   => 'post_tag',
			'hide_empty' => false,
			// return all terms, we cant pass -1 here.
			'number'     => 0,
			'meta_query' => array(
				array(
					'key'     => self::ANALYSIS_DONE_FLAG,
					'compare' => 'NOT EXISTS'
				)
			),
		) ) );

		$this->log->debug( "Count returned as $count" );


		return $count;
	}

	public function get_batch_size() {
		return 10;
	}

	public function info() {
		return Analysis_Background_Process::get_state();
	}

	/**
	 * @param $term_ids
	 *
	 * @return bool
	 */
	public function perform_analysis_for_terms( $term_ids ) {

		foreach ( $term_ids as $term_id ) {

			$tag = get_term( $term_id );

			// This adds the entities to ttl cache
			$result = $this->analysis_service->get_entities( $tag );

			$this->log->debug( "Received result " . var_export( $result ) . " for ${term_id}" );

			if ( $result !== false ) {
				// then set the analysis complete flag.
				update_term_meta( $term_id, self::ANALYSIS_DONE_FLAG, 1 );
				if ( count( $result ) > 0 ) {
					update_term_meta( $term_id, self::ENTITIES_PRESENT_FOR_TERM, 1 );
				}
			}

		}

		/**
		 * This action fires when the analysis is complete for the current batch
		 * @since 3.30.0
		 */
		do_action( 'wordlift_vocabulary_analysis_complete_for_terms_batch' );

		return true;


	}

}