+global\Wordlift_Batch_Analysis_Service::complete()

Complexity

Conditions	7
Paths	5

Size

Total Lines	89
Code Lines	33

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
	public function complete() {

		$this->log->debug( 'Requesting results...' );

		// By default 5 posts of any post type are returned.
		$posts = get_posts( array(
			'fields'     => 'ids',
			'meta_key'   => self::STATE_META_KEY,
			'meta_value' => self::STATE_REQUEST,
			'orderby'    => 'ID',
			'post_type'  => 'any',
		) );

		// Bail out if there are no submitted posts.
		if ( empty( $posts ) ) {
			$this->log->debug( 'No posts in request state found.' );

			return;
		}

		// Send a request for each post.
		foreach ( $posts as $id ) {
			$this->log->debug( "Requesting results for post $id..." );

			// Send the actual request to the remote service.
			$response = $this->do_complete( $id );

			// Move to the next item if we don't have a reply for this one.
			if ( is_wp_error( $response ) || 200 !== (int) $response['response']['code'] || ! isset( $response['body'] ) ) {
				continue;
			}

			$this->log->debug( "Results received for post $id." );

			// Save the returned content as new revision.
			$json = json_decode( $response['body'] );

			// Continue if the content isn't set.
			if ( empty( $json->content ) ) {
				// The post content is empty, so is should be marked as completed.
				$this->log->error( "An error occurred while decoding the batch analysis response for post $id: {$response['body']}" );

				$this->set_state( $id, self::STATE_ERROR );
				continue;
			}

			// Set the warning flag if needed.
			$this->set_warning_based_on_content( $json->content, $id );

			// Get the content, cleaned up if there are interpolation errors.
			$pre_content = $this->fix_interpolation_errors( $json->content, $id );

			/**
			 * Filter: 'wl_batch_analysis_update_post_content' - Allow third
			 * parties to perform additional actions when the post content is
			 * updated.
			 *
			 * @since  3.17.0
			 * @api    string $data The {@link WP_Post}'s content.
			 * @api    int    $id   The {@link WP_Post}'s id.
			 */
			$content = apply_filters( 'wl_batch_analysis_update_post_content', $pre_content, $id );

			// Update the post content.
			wp_update_post( array(
				'ID'           => $id,
				'post_content' => wp_slash( $content ),
			) );

			// Update the status.
			$this->set_state( $id, self::STATE_SUCCESS );

			// Invalidating the cache for the current post.
			$this->cache_service->delete_cache( $id );

			$this->log->debug( "Post $id updated with batch analysis results." );

			// Set default entity type term for posts that didn't have any.
			$this->maybe_set_default_term( $id );

			// @todo: implement a kind of timeout that sets an error if the
			// results haven't been received after a long time.
		}

		// Call the `wl_batch_analysis_request` action again. This is going
		// to be handled by the async task.
		do_action( 'wl_batch_analysis_complete' );

	}