insideout10 / wordlift-plugin

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

Indentation +110 added lines, -110 removed lines

@@ -6,136 +6,136 @@
 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();
-	}
+    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 cancel() {
+        $this->analysis_background_process->cancel();
+    }
 
-	public function stop() {
-		$this->analysis_background_process->cancel();
-		$this->analysis_background_process->request_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() {
+    /**
+     * A list of term ids.
+     * @return int|\WP_Error|\WP_Term[]
+     */
+    public function next() {
 
-		$state = $this->info();
+        $state = $this->info();
 
-		return Terms_Compat::get_terms( Terms_Compat::get_public_taxonomies(), array(
-			'fields'     => 'ids',
-			'hide_empty' => false,
-			'number'     => $this->get_batch_size(),
-			'offset'     => $state->index,
-			'meta_query' => array(
-				array(
-					'key'     => self::ANALYSIS_DONE_FLAG,
-					'compare' => 'NOT EXISTS'
-				)
-			),
-		) );
-	}
+        return Terms_Compat::get_terms( Terms_Compat::get_public_taxonomies(), array(
+            'fields'     => 'ids',
+            '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() {
+    public function count() {
 
-		$count = count( Terms_Compat::get_terms(
-			Terms_Compat::get_public_taxonomies(),
-			array(
-			'fields'     => 'ids',
-			'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'
-				)
-			),
-		) ) );
+        $count = count( Terms_Compat::get_terms(
+            Terms_Compat::get_public_taxonomies(),
+            array(
+            'fields'     => 'ids',
+            '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" );
+        $this->log->debug( "Count returned as $count" );
 
 
-		return $count;
-	}
+        return $count;
+    }
 
-	public function get_batch_size() {
-		return 10;
-	}
+    public function get_batch_size() {
+        return 10;
+    }
 
-	public function info() {
-		return Analysis_Background_Process::get_state();
-	}
+    public function info() {
+        return Analysis_Background_Process::get_state();
+    }
 
-	/**
-	 * @param $term_ids
-	 *
-	 * @return bool
-	 */
-	public function perform_analysis_for_terms( $term_ids ) {
+    /**
+     * @param $term_ids
+     *
+     * @return bool
+     */
+    public function perform_analysis_for_terms( $term_ids ) {
 
-		foreach ( $term_ids as $term_id ) {
+        foreach ( $term_ids as $term_id ) {
 
-			$tag = get_term( $term_id );
+            $tag = get_term( $term_id );
 
-			// This adds the entities to ttl cache
-			$result = $this->analysis_service->get_entities( $tag );
+            // 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}" );
+            $this->log->debug( "Received result " . var_export( $result ) . " for ${term_id}" );
 
-			// then set the analysis complete flag.
-			update_term_meta( $term_id, self::ANALYSIS_DONE_FLAG, 1 );
+            // then set the analysis complete flag.
+            update_term_meta( $term_id, self::ANALYSIS_DONE_FLAG, 1 );
 
-			if ( $result !== false ) {
-				if ( count( $result ) > 0 ) {
-					update_term_meta( $term_id, self::ENTITIES_PRESENT_FOR_TERM, 1 );
-				}
-			}
+            if ( $result !== false ) {
+                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;
-
-
-	}
+        /**
+         * 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;
+
+
+    }
 
 }
\ No newline at end of file

Spacing +18 added lines, -18 removed lines

@@ -25,13 +25,13 @@ 
 	private $log;
 
 
-	public function __construct( $analysis_service ) {
+	public function __construct($analysis_service) {
 
 		$this->analysis_service = $analysis_service;
 
-		$this->analysis_background_process = new Analysis_Background_Process( $this );
+		$this->analysis_background_process = new Analysis_Background_Process($this);
 
-		$this->log = \Wordlift_Log_Service::get_logger( get_class() );
+		$this->log = \Wordlift_Log_Service::get_logger(get_class());
 	}
 
 	public function start() {
@@ -55,7 +55,7 @@ 
 
 		$state = $this->info();
 
-		return Terms_Compat::get_terms( Terms_Compat::get_public_taxonomies(), array(
+		return Terms_Compat::get_terms(Terms_Compat::get_public_taxonomies(), array(
 			'fields'     => 'ids',
 			'hide_empty' => false,
 			'number'     => $this->get_batch_size(),
@@ -66,12 +66,12 @@ 
 					'compare' => 'NOT EXISTS'
 				)
 			),
-		) );
+		));
 	}
 
 	public function count() {
 
-		$count = count( Terms_Compat::get_terms(
+		$count = count(Terms_Compat::get_terms(
 			Terms_Compat::get_public_taxonomies(),
 			array(
 			'fields'     => 'ids',
@@ -84,9 +84,9 @@ 
 					'compare' => 'NOT EXISTS'
 				)
 			),
-		) ) );
+		) ));
 
-		$this->log->debug( "Count returned as $count" );
+		$this->log->debug("Count returned as $count");
 
 
 		return $count;
@@ -105,23 +105,23 @@ 
 	 *
 	 * @return bool
 	 */
-	public function perform_analysis_for_terms( $term_ids ) {
+	public function perform_analysis_for_terms($term_ids) {
 
-		foreach ( $term_ids as $term_id ) {
+		foreach ($term_ids as $term_id) {
 
-			$tag = get_term( $term_id );
+			$tag = get_term($term_id);
 
 			// This adds the entities to ttl cache
-			$result = $this->analysis_service->get_entities( $tag );
+			$result = $this->analysis_service->get_entities($tag);
 
-			$this->log->debug( "Received result " . var_export( $result ) . " for ${term_id}" );
+			$this->log->debug("Received result ".var_export($result)." for ${term_id}");
 
 			// then set the analysis complete flag.
-			update_term_meta( $term_id, self::ANALYSIS_DONE_FLAG, 1 );
+			update_term_meta($term_id, self::ANALYSIS_DONE_FLAG, 1);
 
-			if ( $result !== false ) {
-				if ( count( $result ) > 0 ) {
-					update_term_meta( $term_id, self::ENTITIES_PRESENT_FOR_TERM, 1 );
+			if ($result !== false) {
+				if (count($result) > 0) {
+					update_term_meta($term_id, self::ENTITIES_PRESENT_FOR_TERM, 1);
 				}
 			}
 
@@ -131,7 +131,7 @@ 
 		 * 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' );
+		do_action('wordlift_vocabulary_analysis_complete_for_terms_batch');
 
 		return true;