insideout10 / wordlift-plugin

src/wordlift.php

Indentation +161 added lines, -161 removed lines

@@ -26,7 +26,7 @@ 
 
 // If this file is called directly, abort.
 if ( ! defined( 'WPINC' ) ) {
-	die;
+    die;
 }
 
 // Include WordLift constants.
@@ -48,7 +48,7 @@ 
  */
 function wl_write_log( $log ) {
 
-	Wordlift_Log_Service::get_instance()->debug( $log );
+    Wordlift_Log_Service::get_instance()->debug( $log );
 
 }
 
@@ -64,20 +64,20 @@ 
  */
 function wl_write_log_handler( $log, $caller = null ) {
 
-	global $wl_logger;
+    global $wl_logger;
 
-	if ( true === WP_DEBUG ) {
+    if ( true === WP_DEBUG ) {
 
-		$message = ( isset( $caller ) ? sprintf( '[%-40.40s] ', $caller ) : '' ) .
-		           ( is_array( $log ) || is_object( $log ) ? print_r( $log, true ) : wl_write_log_hide_key( $log ) );
+        $message = ( isset( $caller ) ? sprintf( '[%-40.40s] ', $caller ) : '' ) .
+                    ( is_array( $log ) || is_object( $log ) ? print_r( $log, true ) : wl_write_log_hide_key( $log ) );
 
-		if ( isset( $wl_logger ) ) {
-			$wl_logger->info( $message );
-		} else {
-			error_log( $message );
-		}
+        if ( isset( $wl_logger ) ) {
+            $wl_logger->info( $message );
+        } else {
+            error_log( $message );
+        }
 
-	}
+    }
 
 }
 
@@ -94,7 +94,7 @@ 
  */
 function wl_write_log_hide_key( $text ) {
 
-	return str_ireplace( wl_configuration_get_key(), '<hidden>', $text );
+    return str_ireplace( wl_configuration_get_key(), '<hidden>', $text );
 }
 
 /**
@@ -102,21 +102,21 @@ 
  * see http://vip.wordpress.com/documentation/register-additional-html-attributes-for-tinymce-and-wp-kses/
  */
 function wordlift_allowed_post_tags() {
-	global $allowedposttags;
-
-	$tags           = array( 'span' );
-	$new_attributes = array(
-		'itemscope' => array(),
-		'itemtype'  => array(),
-		'itemprop'  => array(),
-		'itemid'    => array(),
-	);
-
-	foreach ( $tags as $tag ) {
-		if ( isset( $allowedposttags[ $tag ] ) && is_array( $allowedposttags[ $tag ] ) ) {
-			$allowedposttags[ $tag ] = array_merge( $allowedposttags[ $tag ], $new_attributes );
-		}
-	}
+    global $allowedposttags;
+
+    $tags           = array( 'span' );
+    $new_attributes = array(
+        'itemscope' => array(),
+        'itemtype'  => array(),
+        'itemprop'  => array(),
+        'itemid'    => array(),
+    );
+
+    foreach ( $tags as $tag ) {
+        if ( isset( $allowedposttags[ $tag ] ) && is_array( $allowedposttags[ $tag ] ) ) {
+            $allowedposttags[ $tag ] = array_merge( $allowedposttags[ $tag ], $new_attributes );
+        }
+    }
 }
 
 // add allowed post tags.
@@ -127,28 +127,28 @@ 
  */
 function wordlift_admin_enqueue_scripts() {
 
-	// Added for compatibility with WordPress 3.9 (see http://make.wordpress.org/core/2014/04/16/jquery-ui-and-wpdialogs-in-wordpress-3-9/)
-	wp_enqueue_script( 'wpdialogs' );
-	wp_enqueue_style( 'wp-jquery-ui-dialog' );
+    // Added for compatibility with WordPress 3.9 (see http://make.wordpress.org/core/2014/04/16/jquery-ui-and-wpdialogs-in-wordpress-3-9/)
+    wp_enqueue_script( 'wpdialogs' );
+    wp_enqueue_style( 'wp-jquery-ui-dialog' );
 
-	wp_enqueue_style( 'wordlift-reloaded', plugin_dir_url( __FILE__ ) . 'css/wordlift-reloaded.min.css' );
+    wp_enqueue_style( 'wordlift-reloaded', plugin_dir_url( __FILE__ ) . 'css/wordlift-reloaded.min.css' );
 
-	wp_enqueue_script( 'jquery-ui-autocomplete' );
-	wp_enqueue_script( 'angularjs', 'https://cdnjs.cloudflare.com/ajax/libs/angular.js/1.3.11/angular.min.js' );
-	wp_enqueue_script( 'angularjs-geolocation', plugin_dir_url( __FILE__ ) . 'bower_components/angularjs-geolocation/dist/angularjs-geolocation.min.js' );
-	wp_enqueue_script( 'angularjs-touch', 'https://cdnjs.cloudflare.com/ajax/libs/angular.js/1.3.11/angular-touch.min.js' );
-	wp_enqueue_script( 'angularjs-animate', 'https://cdnjs.cloudflare.com/ajax/libs/angular.js/1.3.11/angular-animate.min.js' );
+    wp_enqueue_script( 'jquery-ui-autocomplete' );
+    wp_enqueue_script( 'angularjs', 'https://cdnjs.cloudflare.com/ajax/libs/angular.js/1.3.11/angular.min.js' );
+    wp_enqueue_script( 'angularjs-geolocation', plugin_dir_url( __FILE__ ) . 'bower_components/angularjs-geolocation/dist/angularjs-geolocation.min.js' );
+    wp_enqueue_script( 'angularjs-touch', 'https://cdnjs.cloudflare.com/ajax/libs/angular.js/1.3.11/angular-touch.min.js' );
+    wp_enqueue_script( 'angularjs-animate', 'https://cdnjs.cloudflare.com/ajax/libs/angular.js/1.3.11/angular-animate.min.js' );
 
-	// Disable auto-save for custom entity posts only
-	if ( Wordlift_Entity_Service::TYPE_NAME === get_post_type() ) {
-		wp_dequeue_script( 'autosave' );
-	}
+    // Disable auto-save for custom entity posts only
+    if ( Wordlift_Entity_Service::TYPE_NAME === get_post_type() ) {
+        wp_dequeue_script( 'autosave' );
+    }
 }
 
 add_action( 'admin_enqueue_scripts', 'wordlift_admin_enqueue_scripts' );
 
 function wl_enqueue_scripts() {
-	wp_enqueue_style( 'wordlift-ui', plugin_dir_url( __FILE__ ) . 'css/wordlift-ui.min.css' );
+    wp_enqueue_style( 'wordlift-ui', plugin_dir_url( __FILE__ ) . 'css/wordlift-ui.min.css' );
 }
 
 add_action( 'wp_enqueue_scripts', 'wl_enqueue_scripts' );
@@ -163,18 +163,18 @@ 
  */
 function wordlift_allowed_html( $allowedtags, $context ) {
 
-	if ( 'post' !== $context ) {
-		return $allowedtags;
-	}
-
-	return array_merge_recursive( $allowedtags, array(
-		'span' => array(
-			'itemscope' => true,
-			'itemtype'  => true,
-			'itemid'    => true,
-			'itemprop'  => true,
-		),
-	) );
+    if ( 'post' !== $context ) {
+        return $allowedtags;
+    }
+
+    return array_merge_recursive( $allowedtags, array(
+        'span' => array(
+            'itemscope' => true,
+            'itemtype'  => true,
+            'itemid'    => true,
+            'itemprop'  => true,
+        ),
+    ) );
 }
 
 add_filter( 'wp_kses_allowed_html', 'wordlift_allowed_html', 10, 2 );
@@ -188,16 +188,16 @@ 
  */
 function wl_get_coordinates( $post_id ) {
 
-	$latitude  = wl_schema_get_value( $post_id, 'latitude' );
-	$longitude = wl_schema_get_value( $post_id, 'longitude' );
+    $latitude  = wl_schema_get_value( $post_id, 'latitude' );
+    $longitude = wl_schema_get_value( $post_id, 'longitude' );
 
-	// DO NOT set latitude/longitude to 0/0 as default values. It's a specific
-	// place on the globe:"The zero/zero point of this system is located in the
-	// Gulf of Guinea about 625 km (390 mi) south of Tema, Ghana."
-	return array(
-		'latitude'  => isset( $latitude[0] ) && is_numeric( $latitude[0] ) ? $latitude[0] : '',
-		'longitude' => isset( $longitude[0] ) && is_numeric( $longitude[0] ) ? $longitude[0] : '',
-	);
+    // DO NOT set latitude/longitude to 0/0 as default values. It's a specific
+    // place on the globe:"The zero/zero point of this system is located in the
+    // Gulf of Guinea about 625 km (390 mi) south of Tema, Ghana."
+    return array(
+        'latitude'  => isset( $latitude[0] ) && is_numeric( $latitude[0] ) ? $latitude[0] : '',
+        'longitude' => isset( $longitude[0] ) && is_numeric( $longitude[0] ) ? $longitude[0] : '',
+    );
 }
 
 /**
@@ -211,9 +211,9 @@ 
  */
 function wl_get_image_urls( $post_id ) {
 
-	return Wordlift_Storage_Factory::get_instance()
-	                               ->post_images()
-	                               ->get( $post_id );
+    return Wordlift_Storage_Factory::get_instance()
+                                    ->post_images()
+                                    ->get( $post_id );
 
 //	// If there is a featured image it has the priority.
 //	$featured_image_id = get_post_thumbnail_id( $post_id );
@@ -261,24 +261,24 @@ 
  */
 function wl_get_attachment_for_source_url( $parent_post_id, $source_url ) {
 
-	// wl_write_log( "wl_get_attachment_for_source_url [ parent post id :: $parent_post_id ][ source url :: $source_url ]" );
+    // wl_write_log( "wl_get_attachment_for_source_url [ parent post id :: $parent_post_id ][ source url :: $source_url ]" );
 
-	$posts = get_posts( array(
-		'post_type'      => 'attachment',
-		'posts_per_page' => 1,
-		'post_status'    => 'any',
-		'post_parent'    => $parent_post_id,
-		'meta_key'       => 'wl_source_url',
-		'meta_value'     => $source_url,
-	) );
+    $posts = get_posts( array(
+        'post_type'      => 'attachment',
+        'posts_per_page' => 1,
+        'post_status'    => 'any',
+        'post_parent'    => $parent_post_id,
+        'meta_key'       => 'wl_source_url',
+        'meta_value'     => $source_url,
+    ) );
 
-	// Return the found post.
-	if ( 1 === count( $posts ) ) {
-		return $posts[0];
-	}
+    // Return the found post.
+    if ( 1 === count( $posts ) ) {
+        return $posts[0];
+    }
 
-	// Return null.
-	return null;
+    // Return null.
+    return null;
 }
 
 /**
@@ -289,8 +289,8 @@ 
  */
 function wl_set_source_url( $post_id, $source_url ) {
 
-	delete_post_meta( $post_id, 'wl_source_url' );
-	add_post_meta( $post_id, 'wl_source_url', $source_url );
+    delete_post_meta( $post_id, 'wl_source_url' );
+    add_post_meta( $post_id, 'wl_source_url', $source_url );
 }
 
 
@@ -307,61 +307,61 @@ 
  */
 function wl_flush_rewrite_rules_hard( $hard ) {
 
-	// If WL is not yet configured, we cannot perform any update, so we exit.
-	if ( '' === wl_configuration_get_key() ) {
-		return;
-	}
+    // If WL is not yet configured, we cannot perform any update, so we exit.
+    if ( '' === wl_configuration_get_key() ) {
+        return;
+    }
 
-	// Set the initial offset and limit each call to 100 posts to avoid memory errors.
-	$offset = 0;
-	$limit  = 100;
+    // Set the initial offset and limit each call to 100 posts to avoid memory errors.
+    $offset = 0;
+    $limit  = 100;
 
-	// Get more posts if the number of returned posts matches the limit.
-	while ( $limit === ( $posts = get_posts( array(
-			'offset'      => $offset,
-			'numberposts' => $limit,
-			'orderby'     => 'ID',
-			'post_type'   => 'any',
-			'post_status' => 'publish',
-		) ) ) ) {
+    // Get more posts if the number of returned posts matches the limit.
+    while ( $limit === ( $posts = get_posts( array(
+            'offset'      => $offset,
+            'numberposts' => $limit,
+            'orderby'     => 'ID',
+            'post_type'   => 'any',
+            'post_status' => 'publish',
+        ) ) ) ) {
 
-		// Holds the delete part of the query.
-		$delete_query = rl_sparql_prefixes();
+        // Holds the delete part of the query.
+        $delete_query = rl_sparql_prefixes();
 
-		// Holds the insert part of the query.
-		$insert_query = '';
+        // Holds the insert part of the query.
+        $insert_query = '';
 
-		// Cycle in each post to build the query.
-		foreach ( $posts as $post ) {
+        // Cycle in each post to build the query.
+        foreach ( $posts as $post ) {
 
-			// Ignore revisions.
-			if ( wp_is_post_revision( $post->ID ) ) {
-				continue;
-			}
+            // Ignore revisions.
+            if ( wp_is_post_revision( $post->ID ) ) {
+                continue;
+            }
 
-			// Get the entity URI.
-			$s = Wordlift_Sparql_Service::escape_uri( Wordlift_Entity_Service::get_instance()
-			                                                                 ->get_uri( $post->ID ) );
+            // Get the entity URI.
+            $s = Wordlift_Sparql_Service::escape_uri( Wordlift_Entity_Service::get_instance()
+                                                                                ->get_uri( $post->ID ) );
 
-			// Get the post URL.
-			// $url = wl_sparql_escape_uri( get_permalink( $post->ID ) );
+            // Get the post URL.
+            // $url = wl_sparql_escape_uri( get_permalink( $post->ID ) );
 
-			// Prepare the DELETE and INSERT commands.
-			$delete_query .= "DELETE { <$s> schema:url ?u . } WHERE  { <$s> schema:url ?u . };\n";
+            // Prepare the DELETE and INSERT commands.
+            $delete_query .= "DELETE { <$s> schema:url ?u . } WHERE  { <$s> schema:url ?u . };\n";
 
-			$insert_query .= Wordlift_Schema_Url_Property_Service::get_instance()
-			                                                     ->get_insert_query( $s, $post->ID );
+            $insert_query .= Wordlift_Schema_Url_Property_Service::get_instance()
+                                                                    ->get_insert_query( $s, $post->ID );
 
-		}
+        }
 
 
-		// Execute the query.
-		rl_execute_sparql_update_query( $delete_query . $insert_query );
+        // Execute the query.
+        rl_execute_sparql_update_query( $delete_query . $insert_query );
 
-		// Advance to the next posts.
-		$offset += $limit;
+        // Advance to the next posts.
+        $offset += $limit;
 
-	}
+    }
 
 }
 
@@ -380,7 +380,7 @@ 
  */
 function wl_sanitize_uri_path( $path, $char = '_' ) {
 
-	return Wordlift_Uri_Service::get_instance()->sanitize_path( $path, $char );
+    return Wordlift_Uri_Service::get_instance()->sanitize_path( $path, $char );
 }
 
 ///**
@@ -421,46 +421,46 @@ 
  */
 function wl_replace_item_id_with_uri( $content ) {
 
-	// wl_write_log( "wl_replace_item_id_with_uri" );
+    // wl_write_log( "wl_replace_item_id_with_uri" );
 
-	// Strip slashes, see https://core.trac.wordpress.org/ticket/21767
-	$content = stripslashes( $content );
+    // Strip slashes, see https://core.trac.wordpress.org/ticket/21767
+    $content = stripslashes( $content );
 
-	// If any match are found.
-	$matches = array();
-	if ( 0 < preg_match_all( '/ itemid="([^"]+)"/i', $content, $matches, PREG_SET_ORDER ) ) {
+    // If any match are found.
+    $matches = array();
+    if ( 0 < preg_match_all( '/ itemid="([^"]+)"/i', $content, $matches, PREG_SET_ORDER ) ) {
 
-		foreach ( $matches as $match ) {
+        foreach ( $matches as $match ) {
 
-			// Get the item ID.
-			$item_id = $match[1];
+            // Get the item ID.
+            $item_id = $match[1];
 
-			// Get the post bound to that item ID (looking both in the 'official' URI and in the 'same-as' .
-			$post = Wordlift_Entity_Service::get_instance()
-			                               ->get_entity_post_by_uri( $item_id );
+            // Get the post bound to that item ID (looking both in the 'official' URI and in the 'same-as' .
+            $post = Wordlift_Entity_Service::get_instance()
+                                            ->get_entity_post_by_uri( $item_id );
 
-			// If no entity is found, continue to the next one.
-			if ( null === $post ) {
-				continue;
-			}
+            // If no entity is found, continue to the next one.
+            if ( null === $post ) {
+                continue;
+            }
 
-			// Get the URI for that post.
-			$uri = wl_get_entity_uri( $post->ID );
+            // Get the URI for that post.
+            $uri = wl_get_entity_uri( $post->ID );
 
-			// wl_write_log( "wl_replace_item_id_with_uri [ item id :: $item_id ][ uri :: $uri ]" );
+            // wl_write_log( "wl_replace_item_id_with_uri [ item id :: $item_id ][ uri :: $uri ]" );
 
-			// If the item ID and the URI differ, replace the item ID with the URI saved in WordPress.
-			if ( $item_id !== $uri ) {
-				$uri_e   = esc_html( $uri );
-				$content = str_replace( " itemid=\"$item_id\"", " itemid=\"$uri_e\"", $content );
-			}
-		}
-	}
+            // If the item ID and the URI differ, replace the item ID with the URI saved in WordPress.
+            if ( $item_id !== $uri ) {
+                $uri_e   = esc_html( $uri );
+                $content = str_replace( " itemid=\"$item_id\"", " itemid=\"$uri_e\"", $content );
+            }
+        }
+    }
 
-	// Reapply slashes.
-	$content = addslashes( $content );
+    // Reapply slashes.
+    $content = addslashes( $content );
 
-	return $content;
+    return $content;
 }
 
 add_filter( 'content_save_pre', 'wl_replace_item_id_with_uri', 1, 1 );
@@ -528,9 +528,9 @@ 
  */
 function activate_wordlift() {
 
-	require_once plugin_dir_path( __FILE__ ) . 'includes/class-wordlift-activator.php';
-	Wordlift_Activator::activate();
-	flush_rewrite_rules();
+    require_once plugin_dir_path( __FILE__ ) . 'includes/class-wordlift-activator.php';
+    Wordlift_Activator::activate();
+    flush_rewrite_rules();
 
 }
 
@@ -540,9 +540,9 @@ 
  */
 function deactivate_wordlift() {
 
-	require_once plugin_dir_path( __FILE__ ) . 'includes/class-wordlift-deactivator.php';
-	Wordlift_Deactivator::deactivate();
-	flush_rewrite_rules();
+    require_once plugin_dir_path( __FILE__ ) . 'includes/class-wordlift-deactivator.php';
+    Wordlift_Deactivator::deactivate();
+    flush_rewrite_rules();
 
 }
 
@@ -566,8 +566,8 @@ 
  */
 function run_wordlift() {
 
-	$plugin = new Wordlift();
-	$plugin->run();
+    $plugin = new Wordlift();
+    $plugin->run();
 
 }
 

Spacing +107 added lines, -107 removed lines

@@ -25,15 +25,15 @@ 
  */
 
 // If this file is called directly, abort.
-if ( ! defined( 'WPINC' ) ) {
+if ( ! defined('WPINC')) {
 	die;
 }
 
 // Include WordLift constants.
-require_once( 'wordlift_constants.php' );
+require_once('wordlift_constants.php');
 
 // Load modules.
-require_once( 'modules/core/wordlift_core.php' );
+require_once('modules/core/wordlift_core.php');
 
 /**
  * Log to the debug.log file.
@@ -46,9 +46,9 @@ 
  *
  * @param string|mixed $log The log data.
  */
-function wl_write_log( $log ) {
+function wl_write_log($log) {
 
-	Wordlift_Log_Service::get_instance()->debug( $log );
+	Wordlift_Log_Service::get_instance()->debug($log);
 
 }
 
@@ -62,19 +62,19 @@ 
  * @param string|array $log    The log data.
  * @param string       $caller The calling function.
  */
-function wl_write_log_handler( $log, $caller = null ) {
+function wl_write_log_handler($log, $caller = null) {
 
 	global $wl_logger;
 
-	if ( true === WP_DEBUG ) {
+	if (true === WP_DEBUG) {
 
-		$message = ( isset( $caller ) ? sprintf( '[%-40.40s] ', $caller ) : '' ) .
-		           ( is_array( $log ) || is_object( $log ) ? print_r( $log, true ) : wl_write_log_hide_key( $log ) );
+		$message = (isset($caller) ? sprintf('[%-40.40s] ', $caller) : '').
+		           (is_array($log) || is_object($log) ? print_r($log, true) : wl_write_log_hide_key($log));
 
-		if ( isset( $wl_logger ) ) {
-			$wl_logger->info( $message );
+		if (isset($wl_logger)) {
+			$wl_logger->info($message);
 		} else {
-			error_log( $message );
+			error_log($message);
 		}
 
 	}
@@ -92,9 +92,9 @@ 
  *
  * @return string A text with the key hidden.
  */
-function wl_write_log_hide_key( $text ) {
+function wl_write_log_hide_key($text) {
 
-	return str_ireplace( wl_configuration_get_key(), '<hidden>', $text );
+	return str_ireplace(wl_configuration_get_key(), '<hidden>', $text);
 }
 
 /**
@@ -104,7 +104,7 @@ 
 function wordlift_allowed_post_tags() {
 	global $allowedposttags;
 
-	$tags           = array( 'span' );
+	$tags           = array('span');
 	$new_attributes = array(
 		'itemscope' => array(),
 		'itemtype'  => array(),
@@ -112,15 +112,15 @@ 
 		'itemid'    => array(),
 	);
 
-	foreach ( $tags as $tag ) {
-		if ( isset( $allowedposttags[ $tag ] ) && is_array( $allowedposttags[ $tag ] ) ) {
-			$allowedposttags[ $tag ] = array_merge( $allowedposttags[ $tag ], $new_attributes );
+	foreach ($tags as $tag) {
+		if (isset($allowedposttags[$tag]) && is_array($allowedposttags[$tag])) {
+			$allowedposttags[$tag] = array_merge($allowedposttags[$tag], $new_attributes);
 		}
 	}
 }
 
 // add allowed post tags.
-add_action( 'init', 'wordlift_allowed_post_tags' );
+add_action('init', 'wordlift_allowed_post_tags');
 
 /**
  * Register additional scripts for the admin UI.
@@ -128,30 +128,30 @@ 
 function wordlift_admin_enqueue_scripts() {
 
 	// Added for compatibility with WordPress 3.9 (see http://make.wordpress.org/core/2014/04/16/jquery-ui-and-wpdialogs-in-wordpress-3-9/)
-	wp_enqueue_script( 'wpdialogs' );
-	wp_enqueue_style( 'wp-jquery-ui-dialog' );
+	wp_enqueue_script('wpdialogs');
+	wp_enqueue_style('wp-jquery-ui-dialog');
 
-	wp_enqueue_style( 'wordlift-reloaded', plugin_dir_url( __FILE__ ) . 'css/wordlift-reloaded.min.css' );
+	wp_enqueue_style('wordlift-reloaded', plugin_dir_url(__FILE__).'css/wordlift-reloaded.min.css');
 
-	wp_enqueue_script( 'jquery-ui-autocomplete' );
-	wp_enqueue_script( 'angularjs', 'https://cdnjs.cloudflare.com/ajax/libs/angular.js/1.3.11/angular.min.js' );
-	wp_enqueue_script( 'angularjs-geolocation', plugin_dir_url( __FILE__ ) . 'bower_components/angularjs-geolocation/dist/angularjs-geolocation.min.js' );
-	wp_enqueue_script( 'angularjs-touch', 'https://cdnjs.cloudflare.com/ajax/libs/angular.js/1.3.11/angular-touch.min.js' );
-	wp_enqueue_script( 'angularjs-animate', 'https://cdnjs.cloudflare.com/ajax/libs/angular.js/1.3.11/angular-animate.min.js' );
+	wp_enqueue_script('jquery-ui-autocomplete');
+	wp_enqueue_script('angularjs', 'https://cdnjs.cloudflare.com/ajax/libs/angular.js/1.3.11/angular.min.js');
+	wp_enqueue_script('angularjs-geolocation', plugin_dir_url(__FILE__).'bower_components/angularjs-geolocation/dist/angularjs-geolocation.min.js');
+	wp_enqueue_script('angularjs-touch', 'https://cdnjs.cloudflare.com/ajax/libs/angular.js/1.3.11/angular-touch.min.js');
+	wp_enqueue_script('angularjs-animate', 'https://cdnjs.cloudflare.com/ajax/libs/angular.js/1.3.11/angular-animate.min.js');
 
 	// Disable auto-save for custom entity posts only
-	if ( Wordlift_Entity_Service::TYPE_NAME === get_post_type() ) {
-		wp_dequeue_script( 'autosave' );
+	if (Wordlift_Entity_Service::TYPE_NAME === get_post_type()) {
+		wp_dequeue_script('autosave');
 	}
 }
 
-add_action( 'admin_enqueue_scripts', 'wordlift_admin_enqueue_scripts' );
+add_action('admin_enqueue_scripts', 'wordlift_admin_enqueue_scripts');
 
 function wl_enqueue_scripts() {
-	wp_enqueue_style( 'wordlift-ui', plugin_dir_url( __FILE__ ) . 'css/wordlift-ui.min.css' );
+	wp_enqueue_style('wordlift-ui', plugin_dir_url(__FILE__).'css/wordlift-ui.min.css');
 }
 
-add_action( 'wp_enqueue_scripts', 'wl_enqueue_scripts' );
+add_action('wp_enqueue_scripts', 'wl_enqueue_scripts');
 
 /**
  * Hooked to *wp_kses_allowed_html* filter, adds microdata attributes.
@@ -161,23 +161,23 @@ 
  *
  * @return array An array which contains allowed microdata attributes.
  */
-function wordlift_allowed_html( $allowedtags, $context ) {
+function wordlift_allowed_html($allowedtags, $context) {
 
-	if ( 'post' !== $context ) {
+	if ('post' !== $context) {
 		return $allowedtags;
 	}
 
-	return array_merge_recursive( $allowedtags, array(
+	return array_merge_recursive($allowedtags, array(
 		'span' => array(
 			'itemscope' => true,
 			'itemtype'  => true,
 			'itemid'    => true,
 			'itemprop'  => true,
 		),
-	) );
+	));
 }
 
-add_filter( 'wp_kses_allowed_html', 'wordlift_allowed_html', 10, 2 );
+add_filter('wp_kses_allowed_html', 'wordlift_allowed_html', 10, 2);
 
 /**
  * Get the coordinates for the specified post ID.
@@ -186,17 +186,17 @@ 
  *
  * @return array|null An array of coordinates or null.
  */
-function wl_get_coordinates( $post_id ) {
+function wl_get_coordinates($post_id) {
 
-	$latitude  = wl_schema_get_value( $post_id, 'latitude' );
-	$longitude = wl_schema_get_value( $post_id, 'longitude' );
+	$latitude  = wl_schema_get_value($post_id, 'latitude');
+	$longitude = wl_schema_get_value($post_id, 'longitude');
 
 	// DO NOT set latitude/longitude to 0/0 as default values. It's a specific
 	// place on the globe:"The zero/zero point of this system is located in the
 	// Gulf of Guinea about 625 km (390 mi) south of Tema, Ghana."
 	return array(
-		'latitude'  => isset( $latitude[0] ) && is_numeric( $latitude[0] ) ? $latitude[0] : '',
-		'longitude' => isset( $longitude[0] ) && is_numeric( $longitude[0] ) ? $longitude[0] : '',
+		'latitude'  => isset($latitude[0]) && is_numeric($latitude[0]) ? $latitude[0] : '',
+		'longitude' => isset($longitude[0]) && is_numeric($longitude[0]) ? $longitude[0] : '',
 	);
 }
 
@@ -209,11 +209,11 @@ 
  *
  * @return array An array of image URLs.
  */
-function wl_get_image_urls( $post_id ) {
+function wl_get_image_urls($post_id) {
 
 	return Wordlift_Storage_Factory::get_instance()
 	                               ->post_images()
-	                               ->get( $post_id );
+	                               ->get($post_id);
 
 //	// If there is a featured image it has the priority.
 //	$featured_image_id = get_post_thumbnail_id( $post_id );
@@ -259,21 +259,21 @@ 
  *
  * @return WP_Post|null A post instance or null if not found.
  */
-function wl_get_attachment_for_source_url( $parent_post_id, $source_url ) {
+function wl_get_attachment_for_source_url($parent_post_id, $source_url) {
 
 	// wl_write_log( "wl_get_attachment_for_source_url [ parent post id :: $parent_post_id ][ source url :: $source_url ]" );
 
-	$posts = get_posts( array(
+	$posts = get_posts(array(
 		'post_type'      => 'attachment',
 		'posts_per_page' => 1,
 		'post_status'    => 'any',
 		'post_parent'    => $parent_post_id,
 		'meta_key'       => 'wl_source_url',
 		'meta_value'     => $source_url,
-	) );
+	));
 
 	// Return the found post.
-	if ( 1 === count( $posts ) ) {
+	if (1 === count($posts)) {
 		return $posts[0];
 	}
 
@@ -287,10 +287,10 @@ 
  * @param int    $post_id    The post ID.
  * @param string $source_url The source URL.
  */
-function wl_set_source_url( $post_id, $source_url ) {
+function wl_set_source_url($post_id, $source_url) {
 
-	delete_post_meta( $post_id, 'wl_source_url' );
-	add_post_meta( $post_id, 'wl_source_url', $source_url );
+	delete_post_meta($post_id, 'wl_source_url');
+	add_post_meta($post_id, 'wl_source_url', $source_url);
 }
 
 
@@ -305,10 +305,10 @@ 
  *
  * @param bool $hard True if the rewrite involves configuration updates in Apache/IIS.
  */
-function wl_flush_rewrite_rules_hard( $hard ) {
+function wl_flush_rewrite_rules_hard($hard) {
 
 	// If WL is not yet configured, we cannot perform any update, so we exit.
-	if ( '' === wl_configuration_get_key() ) {
+	if ('' === wl_configuration_get_key()) {
 		return;
 	}
 
@@ -317,13 +317,13 @@ 
 	$limit  = 100;
 
 	// Get more posts if the number of returned posts matches the limit.
-	while ( $limit === ( $posts = get_posts( array(
+	while ($limit === ($posts = get_posts(array(
 			'offset'      => $offset,
 			'numberposts' => $limit,
 			'orderby'     => 'ID',
 			'post_type'   => 'any',
 			'post_status' => 'publish',
-		) ) ) ) {
+		)))) {
 
 		// Holds the delete part of the query.
 		$delete_query = rl_sparql_prefixes();
@@ -332,16 +332,16 @@ 
 		$insert_query = '';
 
 		// Cycle in each post to build the query.
-		foreach ( $posts as $post ) {
+		foreach ($posts as $post) {
 
 			// Ignore revisions.
-			if ( wp_is_post_revision( $post->ID ) ) {
+			if (wp_is_post_revision($post->ID)) {
 				continue;
 			}
 
 			// Get the entity URI.
-			$s = Wordlift_Sparql_Service::escape_uri( Wordlift_Entity_Service::get_instance()
-			                                                                 ->get_uri( $post->ID ) );
+			$s = Wordlift_Sparql_Service::escape_uri(Wordlift_Entity_Service::get_instance()
+			                                                                 ->get_uri($post->ID));
 
 			// Get the post URL.
 			// $url = wl_sparql_escape_uri( get_permalink( $post->ID ) );
@@ -350,13 +350,13 @@ 
 			$delete_query .= "DELETE { <$s> schema:url ?u . } WHERE  { <$s> schema:url ?u . };\n";
 
 			$insert_query .= Wordlift_Schema_Url_Property_Service::get_instance()
-			                                                     ->get_insert_query( $s, $post->ID );
+			                                                     ->get_insert_query($s, $post->ID);
 
 		}
 
 
 		// Execute the query.
-		rl_execute_sparql_update_query( $delete_query . $insert_query );
+		rl_execute_sparql_update_query($delete_query.$insert_query);
 
 		// Advance to the next posts.
 		$offset += $limit;
@@ -365,7 +365,7 @@ 
 
 }
 
-add_filter( 'flush_rewrite_rules_hard', 'wl_flush_rewrite_rules_hard', 10, 1 );
+add_filter('flush_rewrite_rules_hard', 'wl_flush_rewrite_rules_hard', 10, 1);
 
 /**
  * Sanitizes an URI path by replacing the non allowed characters with an underscore.
@@ -378,9 +378,9 @@ 
  *
  * @return string The sanitized path.
  */
-function wl_sanitize_uri_path( $path, $char = '_' ) {
+function wl_sanitize_uri_path($path, $char = '_') {
 
-	return Wordlift_Uri_Service::get_instance()->sanitize_path( $path, $char );
+	return Wordlift_Uri_Service::get_instance()->sanitize_path($path, $char);
 }
 
 ///**
@@ -419,107 +419,107 @@ 
  *
  * @return string The updated post content.
  */
-function wl_replace_item_id_with_uri( $content ) {
+function wl_replace_item_id_with_uri($content) {
 
 	// wl_write_log( "wl_replace_item_id_with_uri" );
 
 	// Strip slashes, see https://core.trac.wordpress.org/ticket/21767
-	$content = stripslashes( $content );
+	$content = stripslashes($content);
 
 	// If any match are found.
 	$matches = array();
-	if ( 0 < preg_match_all( '/ itemid="([^"]+)"/i', $content, $matches, PREG_SET_ORDER ) ) {
+	if (0 < preg_match_all('/ itemid="([^"]+)"/i', $content, $matches, PREG_SET_ORDER)) {
 
-		foreach ( $matches as $match ) {
+		foreach ($matches as $match) {
 
 			// Get the item ID.
 			$item_id = $match[1];
 
 			// Get the post bound to that item ID (looking both in the 'official' URI and in the 'same-as' .
 			$post = Wordlift_Entity_Service::get_instance()
-			                               ->get_entity_post_by_uri( $item_id );
+			                               ->get_entity_post_by_uri($item_id);
 
 			// If no entity is found, continue to the next one.
-			if ( null === $post ) {
+			if (null === $post) {
 				continue;
 			}
 
 			// Get the URI for that post.
-			$uri = wl_get_entity_uri( $post->ID );
+			$uri = wl_get_entity_uri($post->ID);
 
 			// wl_write_log( "wl_replace_item_id_with_uri [ item id :: $item_id ][ uri :: $uri ]" );
 
 			// If the item ID and the URI differ, replace the item ID with the URI saved in WordPress.
-			if ( $item_id !== $uri ) {
-				$uri_e   = esc_html( $uri );
-				$content = str_replace( " itemid=\"$item_id\"", " itemid=\"$uri_e\"", $content );
+			if ($item_id !== $uri) {
+				$uri_e   = esc_html($uri);
+				$content = str_replace(" itemid=\"$item_id\"", " itemid=\"$uri_e\"", $content);
 			}
 		}
 	}
 
 	// Reapply slashes.
-	$content = addslashes( $content );
+	$content = addslashes($content);
 
 	return $content;
 }
 
-add_filter( 'content_save_pre', 'wl_replace_item_id_with_uri', 1, 1 );
+add_filter('content_save_pre', 'wl_replace_item_id_with_uri', 1, 1);
 
-require_once( 'wordlift_entity_functions.php' );
+require_once('wordlift_entity_functions.php');
 
 // add editor related methods.
-require_once( 'wordlift_editor.php' );
+require_once('wordlift_editor.php');
 
 // add the WordLift entity custom type.
-require_once( 'wordlift_entity_type.php' );
-require_once( 'wordlift_entity_type_taxonomy.php' );
+require_once('wordlift_entity_type.php');
+require_once('wordlift_entity_type_taxonomy.php');
 
 // add callbacks on post save to notify data changes from wp to redlink triple store
-require_once( 'wordlift_to_redlink_data_push_callbacks.php' );
+require_once('wordlift_to_redlink_data_push_callbacks.php');
 
-require_once( 'modules/configuration/wordlift_configuration_settings.php' );
+require_once('modules/configuration/wordlift_configuration_settings.php');
 
 // Load modules
-require_once( 'modules/analyzer/wordlift_analyzer.php' );
-require_once( 'modules/linked_data/wordlift_linked_data.php' );
-require_once( 'modules/prefixes/wordlift_prefixes.php' );
+require_once('modules/analyzer/wordlift_analyzer.php');
+require_once('modules/linked_data/wordlift_linked_data.php');
+require_once('modules/prefixes/wordlift_prefixes.php');
 
 // Shortcodes
 
-require_once( 'modules/geo_widget/wordlift_geo_widget.php' );
-require_once( 'shortcodes/wordlift_shortcode_chord.php' );
-require_once( 'shortcodes/wordlift_shortcode_geomap.php' );
-require_once( 'shortcodes/wordlift_shortcode_field.php' );
-require_once( 'shortcodes/wordlift_shortcode_faceted_search.php' );
-require_once( 'shortcodes/wordlift_shortcode_navigator.php' );
+require_once('modules/geo_widget/wordlift_geo_widget.php');
+require_once('shortcodes/wordlift_shortcode_chord.php');
+require_once('shortcodes/wordlift_shortcode_geomap.php');
+require_once('shortcodes/wordlift_shortcode_field.php');
+require_once('shortcodes/wordlift_shortcode_faceted_search.php');
+require_once('shortcodes/wordlift_shortcode_navigator.php');
 
-require_once( 'widgets/wordlift_widget_geo.php' );
-require_once( 'widgets/wordlift_widget_chord.php' );
-require_once( 'widgets/wordlift_widget_timeline.php' );
+require_once('widgets/wordlift_widget_geo.php');
+require_once('widgets/wordlift_widget_chord.php');
+require_once('widgets/wordlift_widget_timeline.php');
 
-require_once( 'wordlift_redlink.php' );
+require_once('wordlift_redlink.php');
 
 // Add admin functions.
 // TODO: find a way to make 'admin' UI tests work.
 //if ( is_admin() ) {
 
-require_once( 'admin/wordlift_admin.php' );
-require_once( 'admin/wordlift_admin_edit_post.php' );
-require_once( 'admin/wordlift_admin_save_post.php' );
+require_once('admin/wordlift_admin.php');
+require_once('admin/wordlift_admin_edit_post.php');
+require_once('admin/wordlift_admin_save_post.php');
 
 // add the entities meta box.
-require_once( 'admin/wordlift_admin_meta_box_entities.php' );
+require_once('admin/wordlift_admin_meta_box_entities.php');
 
 // add the entity creation AJAX.
-require_once( 'admin/wordlift_admin_ajax_related_posts.php' );
+require_once('admin/wordlift_admin_ajax_related_posts.php');
 
 // Load the wl_chord TinyMCE button and configuration dialog.
-require_once( 'admin/wordlift_admin_shortcodes.php' );
+require_once('admin/wordlift_admin_shortcodes.php');
 
 // load languages.
 // TODO: the following call gives for granted that the plugin is in the wordlift directory,
 //       we're currently doing this because wordlift is symbolic linked.
-load_plugin_textdomain( 'wordlift', false, '/wordlift/languages' );
+load_plugin_textdomain('wordlift', false, '/wordlift/languages');
 
 
 /**
@@ -528,7 +528,7 @@ 
  */
 function activate_wordlift() {
 
-	require_once plugin_dir_path( __FILE__ ) . 'includes/class-wordlift-activator.php';
+	require_once plugin_dir_path(__FILE__).'includes/class-wordlift-activator.php';
 	Wordlift_Activator::activate();
 	flush_rewrite_rules();
 
@@ -540,20 +540,20 @@ 
  */
 function deactivate_wordlift() {
 
-	require_once plugin_dir_path( __FILE__ ) . 'includes/class-wordlift-deactivator.php';
+	require_once plugin_dir_path(__FILE__).'includes/class-wordlift-deactivator.php';
 	Wordlift_Deactivator::deactivate();
 	flush_rewrite_rules();
 
 }
 
-register_activation_hook( __FILE__, 'activate_wordlift' );
-register_deactivation_hook( __FILE__, 'deactivate_wordlift' );
+register_activation_hook(__FILE__, 'activate_wordlift');
+register_deactivation_hook(__FILE__, 'deactivate_wordlift');
 
 /**
  * The core plugin class that is used to define internationalization,
  * admin-specific hooks, and public-facing site hooks.
  */
-require plugin_dir_path( __FILE__ ) . 'includes/class-wordlift.php';
+require plugin_dir_path(__FILE__).'includes/class-wordlift.php';
 
 /**
  * Begins execution of the plugin.

src/wordlift_constants.php

Indentation +18 added lines, -18 removed lines

@@ -5,14 +5,14 @@ 
 
 // Define the basic options for HTTP calls to REDLINK.
 define( 'WL_REDLINK_API_HTTP_OPTIONS', serialize( array(
-	'timeout'         => 300,
-	'redirection'     => 5,
-	'httpversion'     => '1.1',
-	'blocking'        => true,
-	'cookies'         => array(),
-	'sslverify'       => ( 'false' === getenv( 'WL_SSL_VERIFY_ENABLED' ) ) ? false : true,
-	'sslcertificates' => dirname( __FILE__ ) . '/ssl/ca-bundle.crt',
-	'decompress'      => false,
+    'timeout'         => 300,
+    'redirection'     => 5,
+    'httpversion'     => '1.1',
+    'blocking'        => true,
+    'cookies'         => array(),
+    'sslverify'       => ( 'false' === getenv( 'WL_SSL_VERIFY_ENABLED' ) ) ? false : true,
+    'sslcertificates' => dirname( __FILE__ ) . '/ssl/ca-bundle.crt',
+    'decompress'      => false,
 ) ) );
 
 // Create a unique ID for this request, useful to hook async HTTP requests.
@@ -25,11 +25,11 @@ 
 
 function wl_is_sparql_update_queries_buffering_enabled() {
 
-	if ( isset( $_REQUEST['wl-async'] ) && 'false' === $_REQUEST['wl-async'] ) {
-		return false;
-	}
+    if ( isset( $_REQUEST['wl-async'] ) && 'false' === $_REQUEST['wl-async'] ) {
+        return false;
+    }
 
-	return 'true' !== getenv( 'WL_DISABLE_SPARQL_UPDATE_QUERIES_BUFFERING' );
+    return 'true' !== getenv( 'WL_DISABLE_SPARQL_UPDATE_QUERIES_BUFFERING' );
 }
 
 // Define the meta name used to store the entity URL.
@@ -52,13 +52,13 @@ 
  */
 function wl_prefixes() {
 
-	$items    = wl_prefixes_list();
-	$prefixes = array();
+    $items    = wl_prefixes_list();
+    $prefixes = array();
 
-	foreach ( $items as $item ) {
-		$prefixes[ $item['prefix'] ] = $item['namespace'];
-	}
+    foreach ( $items as $item ) {
+        $prefixes[ $item['prefix'] ] = $item['namespace'];
+    }
 
-	return $prefixes;
+    return $prefixes;
 
 }

Spacing +16 added lines, -16 removed lines

@@ -6,49 +6,49 @@ 
  */
 
 // Define the basic options for HTTP calls to REDLINK.
-define( 'WL_REDLINK_API_HTTP_OPTIONS', serialize( array(
+define('WL_REDLINK_API_HTTP_OPTIONS', serialize(array(
 	'timeout'         => 300,
 	'redirection'     => 5,
 	'httpversion'     => '1.1',
 	'blocking'        => true,
 	'cookies'         => array(),
-	'sslverify'       => ( 'false' === getenv( 'WL_SSL_VERIFY_ENABLED' ) ) ? false : true,
-	'sslcertificates' => dirname( __FILE__ ) . '/ssl/ca-bundle.crt',
+	'sslverify'       => ('false' === getenv('WL_SSL_VERIFY_ENABLED')) ? false : true,
+	'sslcertificates' => dirname(__FILE__).'/ssl/ca-bundle.crt',
 	'decompress'      => false,
-) ) );
+)));
 
 // Create a unique ID for this request, useful to hook async HTTP requests.
-define( 'WL_REQUEST_ID', uniqid( true ) );
+define('WL_REQUEST_ID', uniqid(true));
 
 // Set the temporary files folder.
-defined( 'WL_TEMP_DIR' ) || define( 'WL_TEMP_DIR', get_temp_dir() );
+defined('WL_TEMP_DIR') || define('WL_TEMP_DIR', get_temp_dir());
 
-define( 'WL_ENABLE_SPARQL_UPDATE_QUERIES_BUFFERING', wl_is_sparql_update_queries_buffering_enabled() );
+define('WL_ENABLE_SPARQL_UPDATE_QUERIES_BUFFERING', wl_is_sparql_update_queries_buffering_enabled());
 
 function wl_is_sparql_update_queries_buffering_enabled() {
 
-	if ( isset( $_REQUEST['wl-async'] ) && 'false' === $_REQUEST['wl-async'] ) {
+	if (isset($_REQUEST['wl-async']) && 'false' === $_REQUEST['wl-async']) {
 		return false;
 	}
 
-	return 'true' !== getenv( 'WL_DISABLE_SPARQL_UPDATE_QUERIES_BUFFERING' );
+	return 'true' !== getenv('WL_DISABLE_SPARQL_UPDATE_QUERIES_BUFFERING');
 }
 
 // Define the meta name used to store the entity URL.
-define( 'WL_ENTITY_URL_META_NAME', 'entity_url' );
+define('WL_ENTITY_URL_META_NAME', 'entity_url');
 
 // Max number of recursions when printing microdata.
-define( 'WL_RECURSION_DEPTH_ON_ENTITY_METADATA_PRINTING', 3 );
+define('WL_RECURSION_DEPTH_ON_ENTITY_METADATA_PRINTING', 3);
 
 // 3.13.0, we use by default WLS 1.11 which provides us with the new, faster
 // chunked analysis.
-define( 'WL_CONFIG_WORDLIFT_API_URL_DEFAULT_VALUE', defined( 'WORDLIFT_API_URL' ) ? WORDLIFT_API_URL . '/' : 'https://api.wordlift.it/' );
+define('WL_CONFIG_WORDLIFT_API_URL_DEFAULT_VALUE', defined('WORDLIFT_API_URL') ? WORDLIFT_API_URL . '/' : 'https://api.wordlift.it/');
 
-define( 'WL_CONFIG_TEST_GOOGLE_RICH_SNIPPETS_URL', 'https://developers.google.com/structured-data/testing-tool/?url=' );
+define('WL_CONFIG_TEST_GOOGLE_RICH_SNIPPETS_URL', 'https://developers.google.com/structured-data/testing-tool/?url=');
 
 // If is set to true, there will be additional button in 'Download Your Data' page
 // that will allow users to download their data in JSON-LD format.
-defined( 'WL_CONFIG_DOWNLOAD_GA_CONTENT_DATA' ) || define( 'WL_CONFIG_DOWNLOAD_GA_CONTENT_DATA', false );
+defined('WL_CONFIG_DOWNLOAD_GA_CONTENT_DATA') || define('WL_CONFIG_DOWNLOAD_GA_CONTENT_DATA', false);
 
 
 /**
@@ -61,8 +61,8 @@ 
 	$items    = wl_prefixes_list();
 	$prefixes = array();
 
-	foreach ( $items as $item ) {
-		$prefixes[ $item['prefix'] ] = $item['namespace'];
+	foreach ($items as $item) {
+		$prefixes[$item['prefix']] = $item['namespace'];
 	}
 
 	return $prefixes;

src/wordlift_redlink.php

Indentation +38 added lines, -38 removed lines

@@ -19,56 +19,56 @@
  */
 function rl_execute_sparql_update_query( $query, $queue = WL_ENABLE_SPARQL_UPDATE_QUERIES_BUFFERING ) {
 
-	$log = Wordlift_Log_Service::get_logger( 'rl_execute_sparql_update_query' );
+    $log = Wordlift_Log_Service::get_logger( 'rl_execute_sparql_update_query' );
 
-	if ( get_transient( 'DISABLE_ENTITY_PUSH' ) ) {
-		$log->info('Entity push is disabled.');
+    if ( get_transient( 'DISABLE_ENTITY_PUSH' ) ) {
+        $log->info('Entity push is disabled.');
 
-		return true;
-	}
+        return true;
+    }
 
-	// Queue the update query.
-	if ( $queue ) {
-		$log->debug( 'Queueing query...' );
+    // Queue the update query.
+    if ( $queue ) {
+        $log->debug( 'Queueing query...' );
 
-		Wordlift_Sparql_Service::get_instance()->queue( $query );
+        Wordlift_Sparql_Service::get_instance()->queue( $query );
 
-		return true;
-	}
+        return true;
+    }
 
-	// Get the update end-point.
-	$url = wl_configuration_get_query_update_url();
+    // Get the update end-point.
+    $url = wl_configuration_get_query_update_url();
 
-	// Prepare the request.
-	$args = array_merge_recursive( unserialize( WL_REDLINK_API_HTTP_OPTIONS ), array(
-		'method'  => 'POST',
-		'headers' => array(
-			'Accept'       => 'application/json',
-			'Content-type' => 'application/sparql-update; charset=utf-8',
-		),
-		'body'    => $query,
-	) );
+    // Prepare the request.
+    $args = array_merge_recursive( unserialize( WL_REDLINK_API_HTTP_OPTIONS ), array(
+        'method'  => 'POST',
+        'headers' => array(
+            'Accept'       => 'application/json',
+            'Content-type' => 'application/sparql-update; charset=utf-8',
+        ),
+        'body'    => $query,
+    ) );
 
-	// Send the request.
-	$response = wp_remote_post( $url, $args );
+    // Send the request.
+    $response = wp_remote_post( $url, $args );
 
-	// If an error has been raised, return the error.
-	if ( is_wp_error( $response ) || 200 !== (int) $response['response']['code'] ) {
+    // If an error has been raised, return the error.
+    if ( is_wp_error( $response ) || 200 !== (int) $response['response']['code'] ) {
 
-		$body = ( is_wp_error( $response ) ? $response->get_error_message() : $response['body'] );
+        $body = ( is_wp_error( $response ) ? $response->get_error_message() : $response['body'] );
 
-		$log->warn( "rl_execute_sparql_update_query : error [ url :: $url ][ args :: " );
-		$log->warn( "\n" . var_export( $args, true ) );
-		$log->warn( "[ response :: " );
-		$log->warn( "\n" . var_export( $response, true ) );
-		$log->warn( "][ body :: " );
-		$log->warn( "\n" . $body );
-		$log->warn( "]" );
+        $log->warn( "rl_execute_sparql_update_query : error [ url :: $url ][ args :: " );
+        $log->warn( "\n" . var_export( $args, true ) );
+        $log->warn( "[ response :: " );
+        $log->warn( "\n" . var_export( $response, true ) );
+        $log->warn( "][ body :: " );
+        $log->warn( "\n" . $body );
+        $log->warn( "]" );
 
-		return false;
-	}
+        return false;
+    }
 
-	$log->debug( "Query executed successfully [ query :: $query ]" );
+    $log->debug( "Query executed successfully [ query :: $query ]" );
 
-	return true;
+    return true;
 }

Spacing +19 added lines, -19 removed lines

@@ -17,21 +17,21 @@ 
  *
  * @return bool True if successful otherwise false.
  */
-function rl_execute_sparql_update_query( $query, $queue = WL_ENABLE_SPARQL_UPDATE_QUERIES_BUFFERING ) {
+function rl_execute_sparql_update_query($query, $queue = WL_ENABLE_SPARQL_UPDATE_QUERIES_BUFFERING) {
 
-	$log = Wordlift_Log_Service::get_logger( 'rl_execute_sparql_update_query' );
+	$log = Wordlift_Log_Service::get_logger('rl_execute_sparql_update_query');
 
-	if ( get_transient( 'DISABLE_ENTITY_PUSH' ) ) {
+	if (get_transient('DISABLE_ENTITY_PUSH')) {
 		$log->info('Entity push is disabled.');
 
 		return true;
 	}
 
 	// Queue the update query.
-	if ( $queue ) {
-		$log->debug( 'Queueing query...' );
+	if ($queue) {
+		$log->debug('Queueing query...');
 
-		Wordlift_Sparql_Service::get_instance()->queue( $query );
+		Wordlift_Sparql_Service::get_instance()->queue($query);
 
 		return true;
 	}
@@ -40,35 +40,35 @@ 
 	$url = wl_configuration_get_query_update_url();
 
 	// Prepare the request.
-	$args = array_merge_recursive( unserialize( WL_REDLINK_API_HTTP_OPTIONS ), array(
+	$args = array_merge_recursive(unserialize(WL_REDLINK_API_HTTP_OPTIONS), array(
 		'method'  => 'POST',
 		'headers' => array(
 			'Accept'       => 'application/json',
 			'Content-type' => 'application/sparql-update; charset=utf-8',
 		),
 		'body'    => $query,
-	) );
+	));
 
 	// Send the request.
-	$response = wp_remote_post( $url, $args );
+	$response = wp_remote_post($url, $args);
 
 	// If an error has been raised, return the error.
-	if ( is_wp_error( $response ) || 200 !== (int) $response['response']['code'] ) {
+	if (is_wp_error($response) || 200 !== (int) $response['response']['code']) {
 
-		$body = ( is_wp_error( $response ) ? $response->get_error_message() : $response['body'] );
+		$body = (is_wp_error($response) ? $response->get_error_message() : $response['body']);
 
-		$log->warn( "rl_execute_sparql_update_query : error [ url :: $url ][ args :: " );
-		$log->warn( "\n" . var_export( $args, true ) );
-		$log->warn( "[ response :: " );
-		$log->warn( "\n" . var_export( $response, true ) );
-		$log->warn( "][ body :: " );
-		$log->warn( "\n" . $body );
-		$log->warn( "]" );
+		$log->warn("rl_execute_sparql_update_query : error [ url :: $url ][ args :: ");
+		$log->warn("\n".var_export($args, true));
+		$log->warn("[ response :: ");
+		$log->warn("\n".var_export($response, true));
+		$log->warn("][ body :: ");
+		$log->warn("\n".$body);
+		$log->warn("]");
 
 		return false;
 	}
 
-	$log->debug( "Query executed successfully [ query :: $query ]" );
+	$log->debug("Query executed successfully [ query :: $query ]");
 
 	return true;
 }

src/includes/class-wordlift-relation-service.php

Indentation +371 added lines, -371 removed lines

@@ -18,371 +18,371 @@ 
  */
 class Wordlift_Relation_Service {
 
-	/**
-	 * The singleton instance.
-	 *
-	 * @since  3.15.0
-	 * @access private
-	 * @var \Wordlift_Relation_Service $instance The singleton instance.
-	 */
-	private static $instance;
-
-	/**
-	 * The relation table name in MySQL, set during instantiation.
-	 *
-	 * @since  3.15.0
-	 * @access private
-	 * @var string $relation_table The relation table name.
-	 */
-	private $relation_table;
-
-	/**
-	 * A {@link Wordlift_Log_Service} instance.
-	 *
-	 * @since 3.15.3
-	 *
-	 * @var Wordlift_Log_Service $log A {@link Wordlift_Log_Service} instance.
-	 */
-	private $log;
-
-	/**
-	 * Create a {@link Wordlift_Relation_Service} instance.
-	 *
-	 * @since 3.15.0
-	 */
-	public function __construct() {
-
-		$this->log = Wordlift_Log_Service::get_logger( get_class() );
-
-		global $wpdb;
-
-		// The relations table.
-		$this->relation_table = "{$wpdb->prefix}wl_relation_instances";
-
-		self::$instance = $this;
-
-	}
-
-	/**
-	 * Get the singleton instance.
-	 *
-	 * @since  3.15.0
-	 * @access public
-	 * @return \Wordlift_Relation_Service The {@link Wordlift_Relation_Service}
-	 *                                    singleton instance.
-	 */
-	public static function get_instance() {
-
-		return self::$instance;
-	}
-
-	/**
-	 * Get the articles referencing the specified entity {@link WP_Post}.
-	 *
-	 * @since 3.15.0
-	 *
-	 * @param int|array   $object_id The entity {@link WP_Post}'s id.
-	 * @param string      $fields    The fields to return, 'ids' to only return ids or
-	 *                               '*' to return all fields, by default '*'.
-	 * @param null|string $predicate The predicate (who|what|...), by default all.
-	 * @param null|string $status    The status, by default all.
-	 * @param array       $excludes  An array of ids to exclude from the results.
-	 * @param null|int    $limit     The maximum number of results, by default
-	 *                               no limit.
-	 * @param null|array  $include   The {@link WP_Post}s' ids to include.
-	 *
-	 * @return array|object|null Database query results
-	 */
-	public function get_article_subjects( $object_id, $fields = '*', $predicate = null, $status = null, $excludes = array(), $limit = null, $include = null ) {
-		global $wpdb;
-
-		// The output fields.
-		$actual_fields = self::fields( $fields );
-
-		$this->log->trace( 'Getting article subjects for object ' . implode( ', ', (array) $object_id ) . '...' );
-
-		$objects = $this->article_id_to_entity_id( $object_id );
-
-		// If there are no related objects, return an empty array.
-		if ( empty( $objects ) ) {
-			$this->log->debug( 'No entities found for object ' . implode( ', ', (array) $object_id ) . '.' );
-
-			return array();
-		}
-
-		$this->log->debug( count( $objects ) . ' entity id(s) found for object ' . implode( ', ', (array) $object_id ) . '.' );
-
-		$sql =
-			"
+    /**
+     * The singleton instance.
+     *
+     * @since  3.15.0
+     * @access private
+     * @var \Wordlift_Relation_Service $instance The singleton instance.
+     */
+    private static $instance;
+
+    /**
+     * The relation table name in MySQL, set during instantiation.
+     *
+     * @since  3.15.0
+     * @access private
+     * @var string $relation_table The relation table name.
+     */
+    private $relation_table;
+
+    /**
+     * A {@link Wordlift_Log_Service} instance.
+     *
+     * @since 3.15.3
+     *
+     * @var Wordlift_Log_Service $log A {@link Wordlift_Log_Service} instance.
+     */
+    private $log;
+
+    /**
+     * Create a {@link Wordlift_Relation_Service} instance.
+     *
+     * @since 3.15.0
+     */
+    public function __construct() {
+
+        $this->log = Wordlift_Log_Service::get_logger( get_class() );
+
+        global $wpdb;
+
+        // The relations table.
+        $this->relation_table = "{$wpdb->prefix}wl_relation_instances";
+
+        self::$instance = $this;
+
+    }
+
+    /**
+     * Get the singleton instance.
+     *
+     * @since  3.15.0
+     * @access public
+     * @return \Wordlift_Relation_Service The {@link Wordlift_Relation_Service}
+     *                                    singleton instance.
+     */
+    public static function get_instance() {
+
+        return self::$instance;
+    }
+
+    /**
+     * Get the articles referencing the specified entity {@link WP_Post}.
+     *
+     * @since 3.15.0
+     *
+     * @param int|array   $object_id The entity {@link WP_Post}'s id.
+     * @param string      $fields    The fields to return, 'ids' to only return ids or
+     *                               '*' to return all fields, by default '*'.
+     * @param null|string $predicate The predicate (who|what|...), by default all.
+     * @param null|string $status    The status, by default all.
+     * @param array       $excludes  An array of ids to exclude from the results.
+     * @param null|int    $limit     The maximum number of results, by default
+     *                               no limit.
+     * @param null|array  $include   The {@link WP_Post}s' ids to include.
+     *
+     * @return array|object|null Database query results
+     */
+    public function get_article_subjects( $object_id, $fields = '*', $predicate = null, $status = null, $excludes = array(), $limit = null, $include = null ) {
+        global $wpdb;
+
+        // The output fields.
+        $actual_fields = self::fields( $fields );
+
+        $this->log->trace( 'Getting article subjects for object ' . implode( ', ', (array) $object_id ) . '...' );
+
+        $objects = $this->article_id_to_entity_id( $object_id );
+
+        // If there are no related objects, return an empty array.
+        if ( empty( $objects ) ) {
+            $this->log->debug( 'No entities found for object ' . implode( ', ', (array) $object_id ) . '.' );
+
+            return array();
+        }
+
+        $this->log->debug( count( $objects ) . ' entity id(s) found for object ' . implode( ', ', (array) $object_id ) . '.' );
+
+        $sql =
+            "
 			SELECT DISTINCT p.$actual_fields
 			FROM {$this->relation_table} r
 			INNER JOIN $wpdb->posts p
 				ON p.id = r.subject_id
 			"
-			// Add the status clause.
-			. self::and_status( $status )
-			. self::inner_join_is_article()
-			. self::where_object_id( $objects )
-			// Since `object_id` can be an article ID we need to exclude it from
-			// the results.
-			. self::and_article_not_in( array_merge( $excludes, (array) $object_id ) )
-			. self::and_article_in( $include )
-			. self::and_post_type_in()
-			. self::and_predicate( $predicate )
-			. self::limit( $limit );
-
-
-		return '*' === $actual_fields ? $wpdb->get_results( $sql ) : $wpdb->get_col( $sql );
-	}
-
-	/**
-	 * The `post_type IN` clause.
-	 *
-	 * @since 3.15.3
-	 *
-	 * @return string The `post_type IN` clause.
-	 */
-	private static function and_post_type_in() {
-
-		return " AND p.post_type IN ( '"
-			   . implode(
-				   "','",
-				   array_map( 'esc_sql', Wordlift_Entity_Service::valid_entity_post_types() )
-			   )
-			   . "' )";
-	}
-
-	/**
-	 * Add the limit clause if specified.
-	 *
-	 * @since 3.15.0
-	 *
-	 * @param null|int $limit The maximum number of results.
-	 *
-	 * @return string The limit clause (empty if no limit has been specified).
-	 */
-	private static function limit( $limit = null ) {
-
-		if ( null === $limit ) {
-			return '';
-		}
-
-		return "LIMIT $limit";
-	}
-
-	/**
-	 * Map the provided ids into entities (i.e. return the id if it's an entity
-	 * or get the entities if it's a post).
-	 *
-	 * @since 3.15.0
-	 *
-	 * @param int|array $object_id An array of posts/entities' ids.
-	 *
-	 * @return array An array of entities' ids.
-	 */
-	private function article_id_to_entity_id( $object_id ) {
-
-		$entity_service = Wordlift_Entity_Service::get_instance();
-
-		$relation_service = $this;
-
-		return array_reduce( (array) $object_id, function ( $carry, $item ) use ( $entity_service, $relation_service ) {
-			if ( $entity_service->is_entity( $item ) ) {
-				return array_merge( $carry, (array) $item );
-			}
-
-			return array_merge( $carry, $relation_service->get_objects( $item, 'ids' ) );
-		}, array() );
-
-	}
-
-	/**
-	 * Add the WHERE clause.
-	 *
-	 * @since 3.15.0
-	 *
-	 * @param int|array $object_id An array of {@link WP_Post}s' ids.
-	 *
-	 * @return string The WHERE clause.
-	 */
-	private static function where_object_id( $object_id ) {
-
-		return ' WHERE r.object_id IN ( ' . implode( ',', wp_parse_id_list( (array) $object_id ) ) . ' )';
-	}
-
-	/**
-	 * Add the exclude clause.
-	 *
-	 * @since 3.15.0
-	 *
-	 * @param int|array $exclude An array of {@link WP_Post}s' ids to exclude.
-	 *
-	 * @return string The exclude clause.
-	 */
-	private static function and_article_not_in( $exclude ) {
-
-		return ' AND NOT p.ID IN ( ' . implode( ',', wp_parse_id_list( (array) $exclude ) ) . ' )';
-	}
-
-	/**
-	 * Add the include clause.
-	 *
-	 * @since 3.15.0
-	 *
-	 * @param null|int|array $include An array of {@link WP_Post}s' ids.
-	 *
-	 * @return string An empty string if $include is null otherwise the include
-	 *                clause.
-	 */
-	private static function and_article_in( $include = null ) {
-
-		if ( null === $include ) {
-			return '';
-		}
-
-		return ' AND p.ID IN ( ' . implode( ',', wp_parse_id_list( (array) $include ) ) . ' )';
-	}
-
-	/**
-	 * Get the entities' {@link WP_Post}s' ids referencing the specified {@link WP_Post}.
-	 *
-	 * @since 3.15.0
-	 *
-	 * @param int         $object_id The object {@link WP_Post}'s id.
-	 * @param string      $fields    The fields to return, 'ids' to only return ids or
-	 *                               '*' to return all fields, by default '*'.
-	 * @param null|string $status    The status, by default all.
-	 *
-	 * @return array|object|null Database query results
-	 */
-	public function get_non_article_subjects( $object_id, $fields = '*', $status = null ) {
-		global $wpdb;
-
-		// The output fields.
-		$actual_fields = self::fields( $fields );
-
-		$sql = $wpdb->prepare(
-			"
+            // Add the status clause.
+            . self::and_status( $status )
+            . self::inner_join_is_article()
+            . self::where_object_id( $objects )
+            // Since `object_id` can be an article ID we need to exclude it from
+            // the results.
+            . self::and_article_not_in( array_merge( $excludes, (array) $object_id ) )
+            . self::and_article_in( $include )
+            . self::and_post_type_in()
+            . self::and_predicate( $predicate )
+            . self::limit( $limit );
+
+
+        return '*' === $actual_fields ? $wpdb->get_results( $sql ) : $wpdb->get_col( $sql );
+    }
+
+    /**
+     * The `post_type IN` clause.
+     *
+     * @since 3.15.3
+     *
+     * @return string The `post_type IN` clause.
+     */
+    private static function and_post_type_in() {
+
+        return " AND p.post_type IN ( '"
+                . implode(
+                    "','",
+                    array_map( 'esc_sql', Wordlift_Entity_Service::valid_entity_post_types() )
+                )
+                . "' )";
+    }
+
+    /**
+     * Add the limit clause if specified.
+     *
+     * @since 3.15.0
+     *
+     * @param null|int $limit The maximum number of results.
+     *
+     * @return string The limit clause (empty if no limit has been specified).
+     */
+    private static function limit( $limit = null ) {
+
+        if ( null === $limit ) {
+            return '';
+        }
+
+        return "LIMIT $limit";
+    }
+
+    /**
+     * Map the provided ids into entities (i.e. return the id if it's an entity
+     * or get the entities if it's a post).
+     *
+     * @since 3.15.0
+     *
+     * @param int|array $object_id An array of posts/entities' ids.
+     *
+     * @return array An array of entities' ids.
+     */
+    private function article_id_to_entity_id( $object_id ) {
+
+        $entity_service = Wordlift_Entity_Service::get_instance();
+
+        $relation_service = $this;
+
+        return array_reduce( (array) $object_id, function ( $carry, $item ) use ( $entity_service, $relation_service ) {
+            if ( $entity_service->is_entity( $item ) ) {
+                return array_merge( $carry, (array) $item );
+            }
+
+            return array_merge( $carry, $relation_service->get_objects( $item, 'ids' ) );
+        }, array() );
+
+    }
+
+    /**
+     * Add the WHERE clause.
+     *
+     * @since 3.15.0
+     *
+     * @param int|array $object_id An array of {@link WP_Post}s' ids.
+     *
+     * @return string The WHERE clause.
+     */
+    private static function where_object_id( $object_id ) {
+
+        return ' WHERE r.object_id IN ( ' . implode( ',', wp_parse_id_list( (array) $object_id ) ) . ' )';
+    }
+
+    /**
+     * Add the exclude clause.
+     *
+     * @since 3.15.0
+     *
+     * @param int|array $exclude An array of {@link WP_Post}s' ids to exclude.
+     *
+     * @return string The exclude clause.
+     */
+    private static function and_article_not_in( $exclude ) {
+
+        return ' AND NOT p.ID IN ( ' . implode( ',', wp_parse_id_list( (array) $exclude ) ) . ' )';
+    }
+
+    /**
+     * Add the include clause.
+     *
+     * @since 3.15.0
+     *
+     * @param null|int|array $include An array of {@link WP_Post}s' ids.
+     *
+     * @return string An empty string if $include is null otherwise the include
+     *                clause.
+     */
+    private static function and_article_in( $include = null ) {
+
+        if ( null === $include ) {
+            return '';
+        }
+
+        return ' AND p.ID IN ( ' . implode( ',', wp_parse_id_list( (array) $include ) ) . ' )';
+    }
+
+    /**
+     * Get the entities' {@link WP_Post}s' ids referencing the specified {@link WP_Post}.
+     *
+     * @since 3.15.0
+     *
+     * @param int         $object_id The object {@link WP_Post}'s id.
+     * @param string      $fields    The fields to return, 'ids' to only return ids or
+     *                               '*' to return all fields, by default '*'.
+     * @param null|string $status    The status, by default all.
+     *
+     * @return array|object|null Database query results
+     */
+    public function get_non_article_subjects( $object_id, $fields = '*', $status = null ) {
+        global $wpdb;
+
+        // The output fields.
+        $actual_fields = self::fields( $fields );
+
+        $sql = $wpdb->prepare(
+            "
 			SELECT p.$actual_fields
 			FROM {$this->relation_table} r
 			INNER JOIN $wpdb->posts p
 				ON p.id = r.subject_id
 			"
-			// Add the status clause.
-			. self::and_status( $status )
-			. self::inner_join_is_not_article()
-			. " WHERE r.object_id = %d "
-			. self::and_post_type_in()
-			,
-			$object_id
-		);
-
-		return '*' === $actual_fields ? $wpdb->get_results( $sql ) : $wpdb->get_col( $sql );
-	}
-
-	/**
-	 * Get the entities referenced by the specified {@link WP_Post}.
-	 *
-	 * @since 3.15.0
-	 *
-	 * @param int         $subject_id The {@link WP_Post}'s id.
-	 * @param string      $fields     The fields to return, 'ids' to only return ids or
-	 *                                '*' to return all fields, by default '*'.
-	 * @param null|string $predicate  The predicate (who|what|...), by default all.
-	 * @param null|string $status     The status, by default all.
-	 *
-	 * @return array|object|null Database query results
-	 */
-	public function get_objects( $subject_id, $fields = '*', $predicate = null, $status = null ) {
-		global $wpdb;
-
-		// The output fields.
-		$actual_fields = self::fields( $fields );
-
-		$sql = $wpdb->prepare(
-			"
+            // Add the status clause.
+            . self::and_status( $status )
+            . self::inner_join_is_not_article()
+            . " WHERE r.object_id = %d "
+            . self::and_post_type_in()
+            ,
+            $object_id
+        );
+
+        return '*' === $actual_fields ? $wpdb->get_results( $sql ) : $wpdb->get_col( $sql );
+    }
+
+    /**
+     * Get the entities referenced by the specified {@link WP_Post}.
+     *
+     * @since 3.15.0
+     *
+     * @param int         $subject_id The {@link WP_Post}'s id.
+     * @param string      $fields     The fields to return, 'ids' to only return ids or
+     *                                '*' to return all fields, by default '*'.
+     * @param null|string $predicate  The predicate (who|what|...), by default all.
+     * @param null|string $status     The status, by default all.
+     *
+     * @return array|object|null Database query results
+     */
+    public function get_objects( $subject_id, $fields = '*', $predicate = null, $status = null ) {
+        global $wpdb;
+
+        // The output fields.
+        $actual_fields = self::fields( $fields );
+
+        $sql = $wpdb->prepare(
+            "
 			SELECT p.$actual_fields
 			FROM {$this->relation_table} r
 			INNER JOIN $wpdb->posts p
 				ON p.id = r.object_id
 			"
-			// Add the status clause.
-			. self::and_status( $status )
-			. self::inner_join_is_not_article()
-			. " WHERE r.subject_id = %d "
-			. self::and_post_type_in()
-			. self::and_predicate( $predicate )
-			,
-			$subject_id
-		);
-
-		return '*' === $actual_fields ? $wpdb->get_results( $sql ) : $wpdb->get_col( $sql );
-	}
-
-	/**
-	 * Add the `post_status` clause.
-	 *
-	 * @since 3.15.0
-	 *
-	 * @param null|string|array $status The status values.
-	 *
-	 * @return string An empty string if $status is null, otherwise the status clause.
-	 */
-	private static function and_status( $status = null ) {
-
-		if ( null === $status ) {
-			return '';
-		}
-
-		return " AND p.post_status IN ('" . implode( "', '", array_map( 'esc_sql', (array) $status ) ) . "')";
-	}
-
-	/**
-	 * Add the `predicate` clause.
-	 *
-	 * @since 3.15.0
-	 *
-	 * @param null|string|array $predicate An array of predicates.
-	 *
-	 * @return string An empty string if $predicate is null otherwise the predicate
-	 *                clause.
-	 */
-	private static function and_predicate( $predicate = null ) {
-
-		if ( null === $predicate ) {
-			return '';
-		}
-
-		return " AND r.predicate IN ('" . implode( "', '", array_map( 'esc_sql', (array) $predicate ) ) . "')";
-	}
-
-	/**
-	 * The select fields.
-	 *
-	 * @since 3.15.0
-	 *
-	 * @param string $fields Either 'ids' or '*', by default '*'.
-	 *
-	 * @return string The `id` field if `ids` otherwise `*`.
-	 */
-	private static function fields( $fields = '*' ) {
-
-		// The output fields.
-		return 'ids' === $fields ? 'id' : '*';
-	}
-
-	/**
-	 * The inner join clause for articles.
-	 *
-	 * @since 3.15.0
-	 *
-	 * @return string The articles inner join clause.
-	 */
-	private static function inner_join_is_article() {
-		global $wpdb;
-
-		return $wpdb->prepare(
-			"
+            // Add the status clause.
+            . self::and_status( $status )
+            . self::inner_join_is_not_article()
+            . " WHERE r.subject_id = %d "
+            . self::and_post_type_in()
+            . self::and_predicate( $predicate )
+            ,
+            $subject_id
+        );
+
+        return '*' === $actual_fields ? $wpdb->get_results( $sql ) : $wpdb->get_col( $sql );
+    }
+
+    /**
+     * Add the `post_status` clause.
+     *
+     * @since 3.15.0
+     *
+     * @param null|string|array $status The status values.
+     *
+     * @return string An empty string if $status is null, otherwise the status clause.
+     */
+    private static function and_status( $status = null ) {
+
+        if ( null === $status ) {
+            return '';
+        }
+
+        return " AND p.post_status IN ('" . implode( "', '", array_map( 'esc_sql', (array) $status ) ) . "')";
+    }
+
+    /**
+     * Add the `predicate` clause.
+     *
+     * @since 3.15.0
+     *
+     * @param null|string|array $predicate An array of predicates.
+     *
+     * @return string An empty string if $predicate is null otherwise the predicate
+     *                clause.
+     */
+    private static function and_predicate( $predicate = null ) {
+
+        if ( null === $predicate ) {
+            return '';
+        }
+
+        return " AND r.predicate IN ('" . implode( "', '", array_map( 'esc_sql', (array) $predicate ) ) . "')";
+    }
+
+    /**
+     * The select fields.
+     *
+     * @since 3.15.0
+     *
+     * @param string $fields Either 'ids' or '*', by default '*'.
+     *
+     * @return string The `id` field if `ids` otherwise `*`.
+     */
+    private static function fields( $fields = '*' ) {
+
+        // The output fields.
+        return 'ids' === $fields ? 'id' : '*';
+    }
+
+    /**
+     * The inner join clause for articles.
+     *
+     * @since 3.15.0
+     *
+     * @return string The articles inner join clause.
+     */
+    private static function inner_join_is_article() {
+        global $wpdb;
+
+        return $wpdb->prepare(
+            "
 			INNER JOIN $wpdb->term_relationships tr
 			 ON p.id = tr.object_id
 			INNER JOIN $wpdb->term_taxonomy tt
@@ -392,23 +392,23 @@ 
 			 ON t.term_id = tt.term_id
 			  AND t.slug = %s
 			",
-			'wl_entity_type',
-			'article'
-		);
-	}
-
-	/**
-	 * The inner join clause for non-articles.
-	 *
-	 * @since 3.15.0
-	 *
-	 * @return string The non-articles inner join clause.
-	 */
-	private static function inner_join_is_not_article() {
-		global $wpdb;
-
-		return $wpdb->prepare(
-			"
+            'wl_entity_type',
+            'article'
+        );
+    }
+
+    /**
+     * The inner join clause for non-articles.
+     *
+     * @since 3.15.0
+     *
+     * @return string The non-articles inner join clause.
+     */
+    private static function inner_join_is_not_article() {
+        global $wpdb;
+
+        return $wpdb->prepare(
+            "
 			INNER JOIN $wpdb->term_relationships tr
 			 ON p.id = tr.object_id
 			INNER JOIN $wpdb->term_taxonomy tt
@@ -418,9 +418,9 @@ 
 			 ON t.term_id = tt.term_id
 			  AND NOT t.slug = %s
 			",
-			'wl_entity_type',
-			'article'
-		);
-	}
+            'wl_entity_type',
+            'article'
+        );
+    }
 
 }

Spacing +47 added lines, -47 removed lines

@@ -52,7 +52,7 @@ 
 	 */
 	public function __construct() {
 
-		$this->log = Wordlift_Log_Service::get_logger( get_class() );
+		$this->log = Wordlift_Log_Service::get_logger(get_class());
 
 		global $wpdb;
 
@@ -93,24 +93,24 @@ 
 	 *
 	 * @return array|object|null Database query results
 	 */
-	public function get_article_subjects( $object_id, $fields = '*', $predicate = null, $status = null, $excludes = array(), $limit = null, $include = null ) {
+	public function get_article_subjects($object_id, $fields = '*', $predicate = null, $status = null, $excludes = array(), $limit = null, $include = null) {
 		global $wpdb;
 
 		// The output fields.
-		$actual_fields = self::fields( $fields );
+		$actual_fields = self::fields($fields);
 
-		$this->log->trace( 'Getting article subjects for object ' . implode( ', ', (array) $object_id ) . '...' );
+		$this->log->trace('Getting article subjects for object '.implode(', ', (array) $object_id).'...');
 
-		$objects = $this->article_id_to_entity_id( $object_id );
+		$objects = $this->article_id_to_entity_id($object_id);
 
 		// If there are no related objects, return an empty array.
-		if ( empty( $objects ) ) {
-			$this->log->debug( 'No entities found for object ' . implode( ', ', (array) $object_id ) . '.' );
+		if (empty($objects)) {
+			$this->log->debug('No entities found for object '.implode(', ', (array) $object_id).'.');
 
 			return array();
 		}
 
-		$this->log->debug( count( $objects ) . ' entity id(s) found for object ' . implode( ', ', (array) $object_id ) . '.' );
+		$this->log->debug(count($objects).' entity id(s) found for object '.implode(', ', (array) $object_id).'.');
 
 		$sql =
 			"
@@ -120,19 +120,19 @@ 
 				ON p.id = r.subject_id
 			"
 			// Add the status clause.
-			. self::and_status( $status )
+			. self::and_status($status)
 			. self::inner_join_is_article()
-			. self::where_object_id( $objects )
+			. self::where_object_id($objects)
 			// Since `object_id` can be an article ID we need to exclude it from
 			// the results.
-			. self::and_article_not_in( array_merge( $excludes, (array) $object_id ) )
-			. self::and_article_in( $include )
+			. self::and_article_not_in(array_merge($excludes, (array) $object_id))
+			. self::and_article_in($include)
 			. self::and_post_type_in()
-			. self::and_predicate( $predicate )
-			. self::limit( $limit );
+			. self::and_predicate($predicate)
+			. self::limit($limit);
 
 
-		return '*' === $actual_fields ? $wpdb->get_results( $sql ) : $wpdb->get_col( $sql );
+		return '*' === $actual_fields ? $wpdb->get_results($sql) : $wpdb->get_col($sql);
 	}
 
 	/**
@@ -147,7 +147,7 @@ 
 		return " AND p.post_type IN ( '"
 			   . implode(
 				   "','",
-				   array_map( 'esc_sql', Wordlift_Entity_Service::valid_entity_post_types() )
+				   array_map('esc_sql', Wordlift_Entity_Service::valid_entity_post_types())
 			   )
 			   . "' )";
 	}
@@ -161,9 +161,9 @@ 
 	 *
 	 * @return string The limit clause (empty if no limit has been specified).
 	 */
-	private static function limit( $limit = null ) {
+	private static function limit($limit = null) {
 
-		if ( null === $limit ) {
+		if (null === $limit) {
 			return '';
 		}
 
@@ -180,19 +180,19 @@ 
 	 *
 	 * @return array An array of entities' ids.
 	 */
-	private function article_id_to_entity_id( $object_id ) {
+	private function article_id_to_entity_id($object_id) {
 
 		$entity_service = Wordlift_Entity_Service::get_instance();
 
 		$relation_service = $this;
 
-		return array_reduce( (array) $object_id, function ( $carry, $item ) use ( $entity_service, $relation_service ) {
-			if ( $entity_service->is_entity( $item ) ) {
-				return array_merge( $carry, (array) $item );
+		return array_reduce((array) $object_id, function($carry, $item) use ($entity_service, $relation_service) {
+			if ($entity_service->is_entity($item)) {
+				return array_merge($carry, (array) $item);
 			}
 
-			return array_merge( $carry, $relation_service->get_objects( $item, 'ids' ) );
-		}, array() );
+			return array_merge($carry, $relation_service->get_objects($item, 'ids'));
+		}, array());
 
 	}
 
@@ -205,9 +205,9 @@ 
 	 *
 	 * @return string The WHERE clause.
 	 */
-	private static function where_object_id( $object_id ) {
+	private static function where_object_id($object_id) {
 
-		return ' WHERE r.object_id IN ( ' . implode( ',', wp_parse_id_list( (array) $object_id ) ) . ' )';
+		return ' WHERE r.object_id IN ( '.implode(',', wp_parse_id_list((array) $object_id)).' )';
 	}
 
 	/**
@@ -219,9 +219,9 @@ 
 	 *
 	 * @return string The exclude clause.
 	 */
-	private static function and_article_not_in( $exclude ) {
+	private static function and_article_not_in($exclude) {
 
-		return ' AND NOT p.ID IN ( ' . implode( ',', wp_parse_id_list( (array) $exclude ) ) . ' )';
+		return ' AND NOT p.ID IN ( '.implode(',', wp_parse_id_list((array) $exclude)).' )';
 	}
 
 	/**
@@ -234,13 +234,13 @@ 
 	 * @return string An empty string if $include is null otherwise the include
 	 *                clause.
 	 */
-	private static function and_article_in( $include = null ) {
+	private static function and_article_in($include = null) {
 
-		if ( null === $include ) {
+		if (null === $include) {
 			return '';
 		}
 
-		return ' AND p.ID IN ( ' . implode( ',', wp_parse_id_list( (array) $include ) ) . ' )';
+		return ' AND p.ID IN ( '.implode(',', wp_parse_id_list((array) $include)).' )';
 	}
 
 	/**
@@ -255,11 +255,11 @@ 
 	 *
 	 * @return array|object|null Database query results
 	 */
-	public function get_non_article_subjects( $object_id, $fields = '*', $status = null ) {
+	public function get_non_article_subjects($object_id, $fields = '*', $status = null) {
 		global $wpdb;
 
 		// The output fields.
-		$actual_fields = self::fields( $fields );
+		$actual_fields = self::fields($fields);
 
 		$sql = $wpdb->prepare(
 			"
@@ -269,7 +269,7 @@ 
 				ON p.id = r.subject_id
 			"
 			// Add the status clause.
-			. self::and_status( $status )
+			. self::and_status($status)
 			. self::inner_join_is_not_article()
 			. " WHERE r.object_id = %d "
 			. self::and_post_type_in()
@@ -277,7 +277,7 @@ 
 			$object_id
 		);
 
-		return '*' === $actual_fields ? $wpdb->get_results( $sql ) : $wpdb->get_col( $sql );
+		return '*' === $actual_fields ? $wpdb->get_results($sql) : $wpdb->get_col($sql);
 	}
 
 	/**
@@ -293,11 +293,11 @@ 
 	 *
 	 * @return array|object|null Database query results
 	 */
-	public function get_objects( $subject_id, $fields = '*', $predicate = null, $status = null ) {
+	public function get_objects($subject_id, $fields = '*', $predicate = null, $status = null) {
 		global $wpdb;
 
 		// The output fields.
-		$actual_fields = self::fields( $fields );
+		$actual_fields = self::fields($fields);
 
 		$sql = $wpdb->prepare(
 			"
@@ -307,16 +307,16 @@ 
 				ON p.id = r.object_id
 			"
 			// Add the status clause.
-			. self::and_status( $status )
+			. self::and_status($status)
 			. self::inner_join_is_not_article()
 			. " WHERE r.subject_id = %d "
 			. self::and_post_type_in()
-			. self::and_predicate( $predicate )
+			. self::and_predicate($predicate)
 			,
 			$subject_id
 		);
 
-		return '*' === $actual_fields ? $wpdb->get_results( $sql ) : $wpdb->get_col( $sql );
+		return '*' === $actual_fields ? $wpdb->get_results($sql) : $wpdb->get_col($sql);
 	}
 
 	/**
@@ -328,13 +328,13 @@ 
 	 *
 	 * @return string An empty string if $status is null, otherwise the status clause.
 	 */
-	private static function and_status( $status = null ) {
+	private static function and_status($status = null) {
 
-		if ( null === $status ) {
+		if (null === $status) {
 			return '';
 		}
 
-		return " AND p.post_status IN ('" . implode( "', '", array_map( 'esc_sql', (array) $status ) ) . "')";
+		return " AND p.post_status IN ('".implode("', '", array_map('esc_sql', (array) $status))."')";
 	}
 
 	/**
@@ -347,13 +347,13 @@ 
 	 * @return string An empty string if $predicate is null otherwise the predicate
 	 *                clause.
 	 */
-	private static function and_predicate( $predicate = null ) {
+	private static function and_predicate($predicate = null) {
 
-		if ( null === $predicate ) {
+		if (null === $predicate) {
 			return '';
 		}
 
-		return " AND r.predicate IN ('" . implode( "', '", array_map( 'esc_sql', (array) $predicate ) ) . "')";
+		return " AND r.predicate IN ('".implode("', '", array_map('esc_sql', (array) $predicate))."')";
 	}
 
 	/**
@@ -365,7 +365,7 @@ 
 	 *
 	 * @return string The `id` field if `ids` otherwise `*`.
 	 */
-	private static function fields( $fields = '*' ) {
+	private static function fields($fields = '*') {
 
 		// The output fields.
 		return 'ids' === $fields ? 'id' : '*';

src/includes/class-wordlift-batch-analysis-service.php

Indentation +628 added lines, -628 removed lines

@@ -51,158 +51,158 @@ 
  */
 class Wordlift_Batch_Analysis_Service {
 
-	/**
-	 * The list of states for the Batch Analysis:
-	 *  - STATE_META_KEY: the batch analysis state meta key,
-	 *  - STATE_SUBMIT: a post/page has been submitted for analysis,
-	 *  - STATE_REQUEST: the plugin requested an analysis for the submitted
-	 *      post/page,
-	 *  - STATE_SUCCESS: the analysis has completed successfully,
-	 *  - STATE_ERROR: the analysis returned an error.
-	 *
-	 * @since 3.14.2
-	 */
-	const STATE_META_KEY = '_wl_batch_analysis_state';
-	const STATE_SUBMIT = 0;
-	const STATE_REQUEST = 1;
-	// ### COMPLETE states.
-	const STATE_SUCCESS = 2;
-	const STATE_ERROR = 2;
-
-	/**
-	 * The submit timestamp meta key. A post may have more than one timestamp.
-	 *
-	 * @since 3.14.2
-	 */
-	const SUBMIT_TIMESTAMP_META_KEY = '_wl_batch_analysis_submit_timestamp';
-
-	/**
-	 * The request timestamp meta key. A post may have more than one timestamp.
-	 *
-	 * @since 3.14.2
-	 */
-	const REQUEST_TIMESTAMP_META_KEY = '_wl_batch_analysis_request_timestamp';
-
-	/**
-	 * The complete (success or error) timestamp meta key. A post may have more
-	 * than one timestamp.
-	 *
-	 * @since 3.14.2
-	 */
-	const COMPLETE_TIMESTAMP_META_KEY = '_wl_batch_analysis_complete_timestamp';
-
-	/**
-	 * The link setting meta key. A post may have more than one setting.
-	 *
-	 * @since 3.14.2
-	 */
-	const LINK_META_KEY = '_wl_batch_analysis_link';
-
-	/**
-	 * The warning timestamp meta key. A post has only zero/one value.
-	 *
-	 * @since 3.14.2
-	 */
-	const WARNING_META_KEY = '_wl_batch_analysis_warning';
-
-	/**
-	 * Option name.
-	 *
-	 * @since  3.14.0
-	 */
-	const OPTION_NAME = 'wl_analyze_batch';
-
-	/**
-	 * Name of waiting to be processed queue array inside the option.
-	 *
-	 * @since  3.14.0
-	 */
-	const ANALYZE_QUEUE = 'queue';
-
-	/**
-	 * Name of waiting for response queue array inside the option.
-	 *
-	 * @since  3.14.0
-	 */
-	const RESPONSE_QUEUE = 'processing';
-
-	/**
-	 * The {@link Wordlift} plugin instance.
-	 *
-	 * @since  3.14.0
-	 * @access private
-	 * @var \Wordlift $plugin The {@link Wordlift} plugin instance.
-	 */
-	private $plugin;
-
-	/**
-	 * The {@link Wordlift_Configuration_Service} instance.
-	 *
-	 * @since  3.14.0
-	 * @access private
-	 * @var \Wordlift_Configuration_Service $configuration_service The {@link Wordlift_Configuration_Service} instance.
-	 */
-	private $configuration_service;
-
-	/**
-	 * A {@link Wordlift_Log_Service} instance.
-	 *
-	 * @since  3.14.2
-	 * @access private
-	 * @var \Wordlift_Log_Service $log A {@link Wordlift_Log_Service} instance.
-	 */
-	private $log;
-
-	/**
-	 * The {@link Class_Wordlift_Batch_Analys_Service} instance.
-	 *
-	 * @since 3.14.0
-	 *
-	 * @param \Wordlift                       $plugin                The {@link Wordlift} plugin instance.
-	 * @param \Wordlift_Configuration_Service $configuration_service The {@link Wordlift_Configuration_Service} instance.
-	 */
-	public function __construct( $plugin, $configuration_service ) {
-
-		$this->plugin                = $plugin;
-		$this->configuration_service = $configuration_service;
-		$this->log                   = Wordlift_Log_Service::get_logger( 'Wordlift_Batch_Analysis_Service' );
-
-		add_action( 'wl_async_wl_batch_analysis_request', array(
-			$this,
-			'request',
-		) );
-		add_action( 'wl_async_wl_batch_analysis_complete', array(
-			$this,
-			'complete',
-		) );
-
-	}
-
-	/**
-	 * Get the base SQL statement to submit a post for Batch Analysis.
-	 *
-	 * Functions may use this base SQL and add their own filters.
-	 *
-	 * @since 3.14.2
-	 *
-	 * @param string $link The link setting ('yes'/'no').
-	 *
-	 * @return string The base SQL.
-	 */
-	private function get_sql( $link ) {
-		global $wpdb;
-
-		// Prepare the statement:
-		//  1. Insert into `postmeta` the meta keys and values:
-		//    a) state meta, with value of SUBMIT (0),
-		//    b) submit timestamp, with value of UTC timestamp,
-		//    c) link meta, with the provided value.
-		//  2. Join the current state value, can be used for filters by other
-		//     functions.
-		//  3. Filter by `post`/`page` types.
-		//  4. Filter by `publish` status.
-		return $wpdb->prepare(
-			"
+    /**
+     * The list of states for the Batch Analysis:
+     *  - STATE_META_KEY: the batch analysis state meta key,
+     *  - STATE_SUBMIT: a post/page has been submitted for analysis,
+     *  - STATE_REQUEST: the plugin requested an analysis for the submitted
+     *      post/page,
+     *  - STATE_SUCCESS: the analysis has completed successfully,
+     *  - STATE_ERROR: the analysis returned an error.
+     *
+     * @since 3.14.2
+     */
+    const STATE_META_KEY = '_wl_batch_analysis_state';
+    const STATE_SUBMIT = 0;
+    const STATE_REQUEST = 1;
+    // ### COMPLETE states.
+    const STATE_SUCCESS = 2;
+    const STATE_ERROR = 2;
+
+    /**
+     * The submit timestamp meta key. A post may have more than one timestamp.
+     *
+     * @since 3.14.2
+     */
+    const SUBMIT_TIMESTAMP_META_KEY = '_wl_batch_analysis_submit_timestamp';
+
+    /**
+     * The request timestamp meta key. A post may have more than one timestamp.
+     *
+     * @since 3.14.2
+     */
+    const REQUEST_TIMESTAMP_META_KEY = '_wl_batch_analysis_request_timestamp';
+
+    /**
+     * The complete (success or error) timestamp meta key. A post may have more
+     * than one timestamp.
+     *
+     * @since 3.14.2
+     */
+    const COMPLETE_TIMESTAMP_META_KEY = '_wl_batch_analysis_complete_timestamp';
+
+    /**
+     * The link setting meta key. A post may have more than one setting.
+     *
+     * @since 3.14.2
+     */
+    const LINK_META_KEY = '_wl_batch_analysis_link';
+
+    /**
+     * The warning timestamp meta key. A post has only zero/one value.
+     *
+     * @since 3.14.2
+     */
+    const WARNING_META_KEY = '_wl_batch_analysis_warning';
+
+    /**
+     * Option name.
+     *
+     * @since  3.14.0
+     */
+    const OPTION_NAME = 'wl_analyze_batch';
+
+    /**
+     * Name of waiting to be processed queue array inside the option.
+     *
+     * @since  3.14.0
+     */
+    const ANALYZE_QUEUE = 'queue';
+
+    /**
+     * Name of waiting for response queue array inside the option.
+     *
+     * @since  3.14.0
+     */
+    const RESPONSE_QUEUE = 'processing';
+
+    /**
+     * The {@link Wordlift} plugin instance.
+     *
+     * @since  3.14.0
+     * @access private
+     * @var \Wordlift $plugin The {@link Wordlift} plugin instance.
+     */
+    private $plugin;
+
+    /**
+     * The {@link Wordlift_Configuration_Service} instance.
+     *
+     * @since  3.14.0
+     * @access private
+     * @var \Wordlift_Configuration_Service $configuration_service The {@link Wordlift_Configuration_Service} instance.
+     */
+    private $configuration_service;
+
+    /**
+     * A {@link Wordlift_Log_Service} instance.
+     *
+     * @since  3.14.2
+     * @access private
+     * @var \Wordlift_Log_Service $log A {@link Wordlift_Log_Service} instance.
+     */
+    private $log;
+
+    /**
+     * The {@link Class_Wordlift_Batch_Analys_Service} instance.
+     *
+     * @since 3.14.0
+     *
+     * @param \Wordlift                       $plugin                The {@link Wordlift} plugin instance.
+     * @param \Wordlift_Configuration_Service $configuration_service The {@link Wordlift_Configuration_Service} instance.
+     */
+    public function __construct( $plugin, $configuration_service ) {
+
+        $this->plugin                = $plugin;
+        $this->configuration_service = $configuration_service;
+        $this->log                   = Wordlift_Log_Service::get_logger( 'Wordlift_Batch_Analysis_Service' );
+
+        add_action( 'wl_async_wl_batch_analysis_request', array(
+            $this,
+            'request',
+        ) );
+        add_action( 'wl_async_wl_batch_analysis_complete', array(
+            $this,
+            'complete',
+        ) );
+
+    }
+
+    /**
+     * Get the base SQL statement to submit a post for Batch Analysis.
+     *
+     * Functions may use this base SQL and add their own filters.
+     *
+     * @since 3.14.2
+     *
+     * @param string $link The link setting ('yes'/'no').
+     *
+     * @return string The base SQL.
+     */
+    private function get_sql( $link ) {
+        global $wpdb;
+
+        // Prepare the statement:
+        //  1. Insert into `postmeta` the meta keys and values:
+        //    a) state meta, with value of SUBMIT (0),
+        //    b) submit timestamp, with value of UTC timestamp,
+        //    c) link meta, with the provided value.
+        //  2. Join the current state value, can be used for filters by other
+        //     functions.
+        //  3. Filter by `post`/`page` types.
+        //  4. Filter by `publish` status.
+        return $wpdb->prepare(
+            "
 			INSERT INTO $wpdb->postmeta ( post_id, meta_key, meta_value )
 			SELECT p.ID, metas.*
 			FROM (
@@ -218,517 +218,517 @@ 
 			WHERE p.post_type IN ('post', 'page')
 				AND p.post_status = 'publish'
 			",
-			self::STATE_META_KEY,
-			self::SUBMIT_TIMESTAMP_META_KEY,
-			self::LINK_META_KEY,
-			$link,
-			self::STATE_META_KEY
-		);
-	}
-
-	/**
-	 * Submit for analysis all the posts/pages which do not have annotations
-	 * and haven't been analyzed before.
-	 *
-	 * @since 3.14.2
-	 *
-	 * @param string $link The link setting.
-	 *
-	 * @return false|int The number of submitted {@link WP_Post}s or false on
-	 *                   error.
-	 */
-	public function submit_auto_selected_posts( $link ) {
-		global $wpdb;
-
-		// Submit the posts/pages and return the number of affected results.
-		// We're using a SQL query here because we could have potentially
-		// thousands of rows.
-		$count = $wpdb->query( $wpdb->prepare(
-			$this->get_sql( $link ) .
-			"
+            self::STATE_META_KEY,
+            self::SUBMIT_TIMESTAMP_META_KEY,
+            self::LINK_META_KEY,
+            $link,
+            self::STATE_META_KEY
+        );
+    }
+
+    /**
+     * Submit for analysis all the posts/pages which do not have annotations
+     * and haven't been analyzed before.
+     *
+     * @since 3.14.2
+     *
+     * @param string $link The link setting.
+     *
+     * @return false|int The number of submitted {@link WP_Post}s or false on
+     *                   error.
+     */
+    public function submit_auto_selected_posts( $link ) {
+        global $wpdb;
+
+        // Submit the posts/pages and return the number of affected results.
+        // We're using a SQL query here because we could have potentially
+        // thousands of rows.
+        $count = $wpdb->query( $wpdb->prepare(
+            $this->get_sql( $link ) .
+            "
 				AND batch_analysis_state.meta_value IS NULL
 				AND p.post_content NOT REGEXP %s;
 			",
-			'<[a-z]+ id="urn:[^"]+" class="[^"]+" itemid="[^"]+">'
-		) );
-
-		// Request Batch Analysis (the operation is handled asynchronously).
-		do_action( 'wl_batch_analysis_request' );
-
-		// Divide the count by 3 to get the number of posts/pages queued.
-		return $count / 3;
-	}
-
-	/**
-	 * Submit all posts for analysis.
-	 *
-	 * @since 3.14.5
-	 *
-	 * @param string $link The link setting.
-	 *
-	 * @return false|int The number of submitted {@link WP_Post}s or false on
-	 *                   error.
-	 */
-	public function submit_all_posts( $link ) {
-		global $wpdb;
-
-		// Submit the posts/pages and return the number of affected results.
-		// We're using a SQL query here because we could have potentially
-		// thousands of rows.
-		$count = $wpdb->query( $this->get_sql( $link ) );
-
-		// Request Batch Analysis (the operation is handled asynchronously).
-		do_action( 'wl_batch_analysis_request' );
-
-		// Divide the count by 3 to get the number of posts/pages queued.
-		return $count / 3;
-	}
-
-	/**
-	 * Submit the provided list of {@link WP_Post}s' ids for Batch Analysis.
-	 *
-	 * @since 3.14.2
-	 *
-	 * @param int|array $post_ids A single {@link WP_Post}'s id or an array of
-	 *                            {@link WP_Post}s' ids.
-	 * @param string    $link     The link setting.
-	 *
-	 * @return int The number of submitted {@link WP_Post}s or false on error.
-	 */
-	public function submit( $post_ids, $link ) {
-		global $wpdb;
-
-		// Submit the posts/pages and return the number of affected results.
-		// We're using a SQL query here because we could have potentially
-		// thousands of rows.
-		$count = $wpdb->query(
-			$this->get_sql( $link ) .
-			' AND p.ID IN ( ' . implode( ',', wp_parse_id_list( $post_ids ) ) . ' )'
-		);
-
-		// Request Batch Analysis (the operation is handled asynchronously).
-		do_action( 'wl_batch_analysis_request' );
-
-		// Divide the count by 3 to get the number of posts/pages queued.
-		return $count / 3;
-	}
-
-	/**
-	 * Cancel the Batch Analysis request for the specified {@link WP_Post}s.
-	 *
-	 * @since 3.14.2
-	 *
-	 * @param int|array $post_ids A single {@link WP_Post}'s id or an array of
-	 *                            {@link WP_Post}s' ids.
-	 *
-	 * @return false|int The number of cancelled {@link WP_Post}s or false on
-	 *                   error.
-	 */
-	public function cancel( $post_ids ) {
-		global $wpdb;
-
-		return $wpdb->query( $wpdb->prepare(
-			"
+            '<[a-z]+ id="urn:[^"]+" class="[^"]+" itemid="[^"]+">'
+        ) );
+
+        // Request Batch Analysis (the operation is handled asynchronously).
+        do_action( 'wl_batch_analysis_request' );
+
+        // Divide the count by 3 to get the number of posts/pages queued.
+        return $count / 3;
+    }
+
+    /**
+     * Submit all posts for analysis.
+     *
+     * @since 3.14.5
+     *
+     * @param string $link The link setting.
+     *
+     * @return false|int The number of submitted {@link WP_Post}s or false on
+     *                   error.
+     */
+    public function submit_all_posts( $link ) {
+        global $wpdb;
+
+        // Submit the posts/pages and return the number of affected results.
+        // We're using a SQL query here because we could have potentially
+        // thousands of rows.
+        $count = $wpdb->query( $this->get_sql( $link ) );
+
+        // Request Batch Analysis (the operation is handled asynchronously).
+        do_action( 'wl_batch_analysis_request' );
+
+        // Divide the count by 3 to get the number of posts/pages queued.
+        return $count / 3;
+    }
+
+    /**
+     * Submit the provided list of {@link WP_Post}s' ids for Batch Analysis.
+     *
+     * @since 3.14.2
+     *
+     * @param int|array $post_ids A single {@link WP_Post}'s id or an array of
+     *                            {@link WP_Post}s' ids.
+     * @param string    $link     The link setting.
+     *
+     * @return int The number of submitted {@link WP_Post}s or false on error.
+     */
+    public function submit( $post_ids, $link ) {
+        global $wpdb;
+
+        // Submit the posts/pages and return the number of affected results.
+        // We're using a SQL query here because we could have potentially
+        // thousands of rows.
+        $count = $wpdb->query(
+            $this->get_sql( $link ) .
+            ' AND p.ID IN ( ' . implode( ',', wp_parse_id_list( $post_ids ) ) . ' )'
+        );
+
+        // Request Batch Analysis (the operation is handled asynchronously).
+        do_action( 'wl_batch_analysis_request' );
+
+        // Divide the count by 3 to get the number of posts/pages queued.
+        return $count / 3;
+    }
+
+    /**
+     * Cancel the Batch Analysis request for the specified {@link WP_Post}s.
+     *
+     * @since 3.14.2
+     *
+     * @param int|array $post_ids A single {@link WP_Post}'s id or an array of
+     *                            {@link WP_Post}s' ids.
+     *
+     * @return false|int The number of cancelled {@link WP_Post}s or false on
+     *                   error.
+     */
+    public function cancel( $post_ids ) {
+        global $wpdb;
+
+        return $wpdb->query( $wpdb->prepare(
+            "
 			DELETE FROM $wpdb->postmeta
 			WHERE meta_key = %s
 				AND meta_value = %s
 				AND post_id IN ( " . implode( ',', wp_parse_id_list( $post_ids ) ) . " )
 			",
-			self::STATE_META_KEY,
-			self::STATE_REQUEST
-		) );
+            self::STATE_META_KEY,
+            self::STATE_REQUEST
+        ) );
 
-	}
+    }
 
-	/**
-	 * Request the batch analysis for submitted posts.
-	 *
-	 * @since 3.14.2
-	 */
-	public function request() {
+    /**
+     * Request the batch analysis for submitted posts.
+     *
+     * @since 3.14.2
+     */
+    public function request() {
 
-		$this->log->debug( "Requesting analysis..." );
+        $this->log->debug( "Requesting analysis..." );
 
-		// 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_SUBMIT,
-			'orderby'    => 'ID',
-		) );
+        // 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_SUBMIT,
+            'orderby'    => 'ID',
+        ) );
 
-		// Bail out if there are no submitted posts.
-		if ( empty( $posts ) ) {
-			$this->log->debug( 'No posts to submit found, checking for completed requests...' );
+        // Bail out if there are no submitted posts.
+        if ( empty( $posts ) ) {
+            $this->log->debug( 'No posts to submit found, checking for completed requests...' );
 
-			do_action( 'wl_batch_analysis_complete' );
+            do_action( 'wl_batch_analysis_complete' );
 
-			return;
-		}
+            return;
+        }
 
-		// Send a request for each post.
-		foreach ( $posts as $id ) {
-			$this->log->debug( "Requesting analysis for post $id..." );
+        // Send a request for each post.
+        foreach ( $posts as $id ) {
+            $this->log->debug( "Requesting analysis for post $id..." );
 
-			// Change the state to `REQUEST`.
-			$this->set_state( $id, self::STATE_REQUEST );
+            // Change the state to `REQUEST`.
+            $this->set_state( $id, self::STATE_REQUEST );
 
-			// Send the actual request to the remote service.
-			$result = $this->do_request( $id );
+            // Send the actual request to the remote service.
+            $result = $this->do_request( $id );
 
-			$this->log->debug( "Analysis requested for post $id." );
+            $this->log->debug( "Analysis requested for post $id." );
 
-			// Set an error if we received an error.
-			if ( is_wp_error( $result ) ) {
-				$this->log->error( "Analysis request for post $id returned {$result->get_error_message()}." );
+            // Set an error if we received an error.
+            if ( is_wp_error( $result ) ) {
+                $this->log->error( "Analysis request for post $id returned {$result->get_error_message()}." );
 
-				$this->set_state( $id, self::STATE_ERROR );
-			}
+                $this->set_state( $id, self::STATE_ERROR );
+            }
 
-		}
+        }
 
-		// Call the `wl_batch_analysis_request` action again. This is going
-		// to be handled by the async task.
-		do_action( 'wl_batch_analysis_request' );
+        // Call the `wl_batch_analysis_request` action again. This is going
+        // to be handled by the async task.
+        do_action( 'wl_batch_analysis_request' );
 
-	}
+    }
 
-	/**
-	 * Get the results for the Batch Analysis.
-	 *
-	 * @since 3.14.2
-	 */
-	public function complete() {
+    /**
+     * Get the results for the Batch Analysis.
+     *
+     * @since 3.14.2
+     */
+    public function complete() {
 
-		$this->log->debug( "Requesting results..." );
+        $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',
-		) );
+        // 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',
+        ) );
 
-		// Bail out if there are no submitted posts.
-		if ( empty( $posts ) ) {
-			$this->log->debug( 'No posts in request state found.' );
+        // Bail out if there are no submitted posts.
+        if ( empty( $posts ) ) {
+            $this->log->debug( 'No posts in request state found.' );
 
-			return;
-		}
+            return;
+        }
 
-		// Send a request for each post.
-		foreach ( $posts as $id ) {
-			$this->log->debug( "Requesting results for post $id..." );
+        // 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 );
+            // Send the actual request to the remote service.
+            $response = $this->do_complete( $id );
 
-			$this->log->debug( "Results requested for post $id." );
+            $this->log->debug( "Results requested for post $id." );
 
-			// Set an error if we received an error.
-			if ( ! is_wp_error( $response ) && isset( $response['body'] ) ) {
+            // Set an error if we received an error.
+            if ( ! is_wp_error( $response ) && isset( $response['body'] ) ) {
 
-				$this->log->debug( "Results received for post $id." );
+                $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 ( ! isset( $json->content ) || empty( $json->content ) ) {
-					continue;
-				}
+                // Save the returned content as new revision.
+                $json = json_decode( $response['body'] );
+
+                // Continue if the content isn't set.
+                if ( ! isset( $json->content ) || empty( $json->content ) ) {
+                    continue;
+                }
 
-				$this->set_warning_based_on_content( $id, $json->content );
-
-				$content = wp_slash( $json->content );
-
-				wp_update_post( array(
-					'ID'           => $id,
-					'post_content' => $content,
-				) );
-
-				// Update the status.
-				$this->set_state( $id, self::STATE_SUCCESS );
-
-				$this->log->debug( "Post $id updated with batch analysis results." );
-
-				continue;
-			}
-
-			// @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' );
-
-	}
-
-	/**
-	 * Set a warning flag on the {@link WP_Post} if its content has suspicious
-	 * interpolations.
-	 *
-	 * @since 3.14.2
-	 *
-	 * @param int    $post_id The {@link WP_Post}'s id.
-	 * @param string $content The {@link WP_Post}'s content.
-	 *
-	 * @return string The content (for chaining operations).
-	 */
-	private function set_warning_based_on_content( $post_id, $content ) {
-
-		$matches = array();
-
-		// Check for suspicious interpolations.
-		$warning = 0 < preg_match_all( '/\w<[a-z]+ id="urn:enhancement-[^"]+" class="[^"]+" itemid="[^"]+">/', $content, $matches )
-				   || 0 < preg_match_all( '/<[a-z]+ id="urn:enhancement-[^"]+" class="[^"]+" itemid="[^"]+">\s/', $content, $matches );
-
-		// Set the warning flag accordingly.
-		$this->set_warning( $post_id, $warning );
-
-		return $content;
-	}
-
-	/**
-	 * Clear the warning flag for the specified {@link WP_Post}s.
-	 *
-	 * @since 3.14.2
-	 *
-	 * @param int|array $post_ids A single {@link WP_Post}'s id or an array of
-	 *                            {@link WP_Post}s' ids.
-	 */
-	public function clear_warning( $post_ids ) {
-
-		foreach ( (array) $post_ids as $post_id ) {
-			delete_post_meta( $post_id, self::WARNING_META_KEY );
-		}
-
-	}
-
-	/**
-	 * Set the warning flag for the specified {@link WP_Post}.
-	 *
-	 * @since 3.14.2
-	 *
-	 * @param int  $post_id The {@link WP_Post}'s id.
-	 * @param bool $value   The flag's value.
-	 *
-	 * @return int|bool Meta ID if the key didn't exist, true on successful update,
-	 *                  false on failure.
-	 */
-	private function set_warning( $post_id, $value ) {
-
-		return update_post_meta( $post_id, self::WARNING_META_KEY, ( true === $value ? 'yes' : 'no' ) );
-	}
-
-	/**
-	 * Get the post/page batch analysis state.
-	 *
-	 * @since 3.14.2
-	 *
-	 * @param int $post_id The {@link WP_Post}'s id.
-	 *
-	 * @return int|string The post state or an empty string if not set.
-	 */
-	public function get_state( $post_id ) {
-
-		return get_post_meta( $post_id, self::STATE_META_KEY, true );
-	}
-
-	/**
-	 * Set the post/page batch analysis state.
-	 *
-	 * @since 3.14.2
-	 *
-	 * @param int $post_id The {@link WP_Post}'s id.
-	 * @param int $value   The new state.
-	 *
-	 * @return int|bool Meta ID if the key didn't exist, true on successful update,
-	 *                  false on failure.
-	 */
-	public function set_state( $post_id, $value ) {
-
-		// Update the state.
-		$result = update_post_meta( $post_id, self::STATE_META_KEY, $value );
-
-		// Update timestamps as required.
-		switch ( $value ) {
-
-			// ### REQUEST state.
-			case self::STATE_REQUEST:
-				add_post_meta( $post_id, self::REQUEST_TIMESTAMP_META_KEY, current_time( 'mysql', true ) );
-				break;
-
-			// ### SUCCESS/ERROR state.
-			case self::STATE_SUCCESS:
-			case self::STATE_ERROR:
-				add_post_meta( $post_id, self::COMPLETE_TIMESTAMP_META_KEY, current_time( 'mysql', true ) );
-				break;
-		}
-
-		// Finally return the result.
-		return $result;
-	}
-
-	/**
-	 * Get the link setting for a {@link WP_Post}.
-	 *
-	 * If there are multiple link settings, only the last one is returned.
-	 *
-	 * @since 3.14.2
-	 *
-	 * @param int $post_id The {@link WP_Post}'s id.
-	 *
-	 * @return string The link setting or `default` if not set.
-	 */
-	public function get_link( $post_id ) {
-
-		$values = get_post_meta( $post_id, self::LINK_META_KEY );
-
-		return end( $values ) ?: 'default';
-	}
-
-	/**
-	 * Get the array of post IDS waiting in the queue to start processing.
-	 *
-	 * @since 3.14.0
-	 *
-	 * @return array The waiting to be processed post ids queue.
-	 */
-	public function waiting_for_analysis() {
-
-		return get_posts( array(
-			'posts_per_page' => - 1,
-			'fields'         => 'ids',
-			'post_status'    => 'any',
-			'meta_key'       => self::STATE_META_KEY,
-			'meta_value'     => self::STATE_SUBMIT,
-			'orderby'        => 'ID',
-		) );
-	}
-
-	/**
-	 * Get the array of post IDS waiting for response.
-	 *
-	 * @deprecated
-	 * @since 3.14.0
-	 *
-	 * @return array The waiting for response post ids queue.
-	 */
-	public function waiting_for_response() {
-
-		return get_posts( array(
-			'posts_per_page' => - 1,
-			'fields'         => 'ids',
-			'post_status'    => 'any',
-			'meta_key'       => self::STATE_META_KEY,
-			'meta_value'     => self::STATE_REQUEST,
-			'orderby'        => 'ID',
-		) );
-	}
-
-	/**
-	 * Request the analysis for the specified {@link WP_Post}.
-	 *
-	 * @since 3.14.2
-	 *
-	 * @param int $post_id The {@link WP_Post}'s id.
-	 *
-	 * @return WP_Error|array The response or WP_Error on failure.
-	 */
-	private function do_request( $post_id ) {
-
-		// Get the post.
-		$post = get_post( $post_id );
-
-		// Bail out if the post isn't found.
-		if ( null === $post ) {
-			$this->log->warn( "Post $post_id not found." );
-
-			return new WP_Error( 0, "Cannot find post $post_id." );
-		}
-
-		// Get the link setting.
-		$link = $this->get_link( $post_id );
-
-		$this->log->debug( "Sending analysis request for post $post_id [ link :: $link ]..." );
-
-		// Get the batch analysis URL.
-		$url = $this->configuration_service->get_batch_analysis_url();
-
-		// Prepare the POST parameters.
-		$param = array(
-			'id'              => $post->ID,
-			'key'             => $this->configuration_service->get_key(),
-			'content'         => $post->post_content,
-			'contentLanguage' => $this->configuration_service->get_language_code(),
-			'version'         => $this->plugin->get_version(),
-			'links'           => $link,
-			'scope'           => 'local',
-		);
-
-		// Get the HTTP options.
-		$args = array_merge_recursive( unserialize( WL_REDLINK_API_HTTP_OPTIONS ), array(
-			'method'      => 'POST',
-			'headers'     => array(
-				'Accept'       => 'application/json',
-				'Content-type' => 'application/json; charset=UTF-8',
-			),
-			// we need to downgrade the HTTP version in this case since chunked encoding is dumping numbers in the response.
-			'httpversion' => '1.0',
-			'body'        => wp_json_encode( $param ),
-		) );
-
-		$this->log->debug( "Posting analysis request for post $post_id to $url..." );
-
-		// Post the parameter.
-		return wp_remote_post( $url, $args );
-	}
-
-	/**
-	 * Get the Batch Analysis results for the specified {@link WP_Post}.
-	 *
-	 * @since 3.14.2
-	 *
-	 * @param int $post_id The {@link WP_Post}'s id.
-	 *
-	 * @return WP_Error|array The response or WP_Error on failure.
-	 */
-	private function do_complete( $post_id ) {
-
-		$post = get_post( $post_id );
-
-		if ( null === $post ) {
-			// Post was possibly deleted, just bailout.
-			return new WP_Error( 0, "Post $post_id not found." );
-		}
-
-		$url = $this->configuration_service->get_batch_analysis_url();
-		$key = $this->configuration_service->get_key();
-		$url = $url . '/' . $post->ID . '?key=' . $key;
-
-		return wp_remote_get( $url, unserialize( WL_REDLINK_API_HTTP_OPTIONS ) );
-	}
-
-	/**
-	 * Get the {@link WP_Post}s' ids flagged with warnings.
-	 *
-	 * @since 3.14.2
-	 *
-	 * @return array An array of {@link WP_Post}s' ids.
-	 */
-	public function get_warnings() {
-
-		return get_posts( array(
-			'fields'      => 'ids',
-			'numberposts' => - 1,
-			'post_status' => 'any',
-			'meta_key'    => self::WARNING_META_KEY,
-			'meta_value'  => 'yes',
-		) );
-	}
+                $this->set_warning_based_on_content( $id, $json->content );
+
+                $content = wp_slash( $json->content );
+
+                wp_update_post( array(
+                    'ID'           => $id,
+                    'post_content' => $content,
+                ) );
+
+                // Update the status.
+                $this->set_state( $id, self::STATE_SUCCESS );
+
+                $this->log->debug( "Post $id updated with batch analysis results." );
+
+                continue;
+            }
+
+            // @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' );
+
+    }
+
+    /**
+     * Set a warning flag on the {@link WP_Post} if its content has suspicious
+     * interpolations.
+     *
+     * @since 3.14.2
+     *
+     * @param int    $post_id The {@link WP_Post}'s id.
+     * @param string $content The {@link WP_Post}'s content.
+     *
+     * @return string The content (for chaining operations).
+     */
+    private function set_warning_based_on_content( $post_id, $content ) {
+
+        $matches = array();
+
+        // Check for suspicious interpolations.
+        $warning = 0 < preg_match_all( '/\w<[a-z]+ id="urn:enhancement-[^"]+" class="[^"]+" itemid="[^"]+">/', $content, $matches )
+                   || 0 < preg_match_all( '/<[a-z]+ id="urn:enhancement-[^"]+" class="[^"]+" itemid="[^"]+">\s/', $content, $matches );
+
+        // Set the warning flag accordingly.
+        $this->set_warning( $post_id, $warning );
+
+        return $content;
+    }
+
+    /**
+     * Clear the warning flag for the specified {@link WP_Post}s.
+     *
+     * @since 3.14.2
+     *
+     * @param int|array $post_ids A single {@link WP_Post}'s id or an array of
+     *                            {@link WP_Post}s' ids.
+     */
+    public function clear_warning( $post_ids ) {
+
+        foreach ( (array) $post_ids as $post_id ) {
+            delete_post_meta( $post_id, self::WARNING_META_KEY );
+        }
+
+    }
+
+    /**
+     * Set the warning flag for the specified {@link WP_Post}.
+     *
+     * @since 3.14.2
+     *
+     * @param int  $post_id The {@link WP_Post}'s id.
+     * @param bool $value   The flag's value.
+     *
+     * @return int|bool Meta ID if the key didn't exist, true on successful update,
+     *                  false on failure.
+     */
+    private function set_warning( $post_id, $value ) {
+
+        return update_post_meta( $post_id, self::WARNING_META_KEY, ( true === $value ? 'yes' : 'no' ) );
+    }
+
+    /**
+     * Get the post/page batch analysis state.
+     *
+     * @since 3.14.2
+     *
+     * @param int $post_id The {@link WP_Post}'s id.
+     *
+     * @return int|string The post state or an empty string if not set.
+     */
+    public function get_state( $post_id ) {
+
+        return get_post_meta( $post_id, self::STATE_META_KEY, true );
+    }
+
+    /**
+     * Set the post/page batch analysis state.
+     *
+     * @since 3.14.2
+     *
+     * @param int $post_id The {@link WP_Post}'s id.
+     * @param int $value   The new state.
+     *
+     * @return int|bool Meta ID if the key didn't exist, true on successful update,
+     *                  false on failure.
+     */
+    public function set_state( $post_id, $value ) {
+
+        // Update the state.
+        $result = update_post_meta( $post_id, self::STATE_META_KEY, $value );
+
+        // Update timestamps as required.
+        switch ( $value ) {
+
+            // ### REQUEST state.
+            case self::STATE_REQUEST:
+                add_post_meta( $post_id, self::REQUEST_TIMESTAMP_META_KEY, current_time( 'mysql', true ) );
+                break;
+
+            // ### SUCCESS/ERROR state.
+            case self::STATE_SUCCESS:
+            case self::STATE_ERROR:
+                add_post_meta( $post_id, self::COMPLETE_TIMESTAMP_META_KEY, current_time( 'mysql', true ) );
+                break;
+        }
+
+        // Finally return the result.
+        return $result;
+    }
+
+    /**
+     * Get the link setting for a {@link WP_Post}.
+     *
+     * If there are multiple link settings, only the last one is returned.
+     *
+     * @since 3.14.2
+     *
+     * @param int $post_id The {@link WP_Post}'s id.
+     *
+     * @return string The link setting or `default` if not set.
+     */
+    public function get_link( $post_id ) {
+
+        $values = get_post_meta( $post_id, self::LINK_META_KEY );
+
+        return end( $values ) ?: 'default';
+    }
+
+    /**
+     * Get the array of post IDS waiting in the queue to start processing.
+     *
+     * @since 3.14.0
+     *
+     * @return array The waiting to be processed post ids queue.
+     */
+    public function waiting_for_analysis() {
+
+        return get_posts( array(
+            'posts_per_page' => - 1,
+            'fields'         => 'ids',
+            'post_status'    => 'any',
+            'meta_key'       => self::STATE_META_KEY,
+            'meta_value'     => self::STATE_SUBMIT,
+            'orderby'        => 'ID',
+        ) );
+    }
+
+    /**
+     * Get the array of post IDS waiting for response.
+     *
+     * @deprecated
+     * @since 3.14.0
+     *
+     * @return array The waiting for response post ids queue.
+     */
+    public function waiting_for_response() {
+
+        return get_posts( array(
+            'posts_per_page' => - 1,
+            'fields'         => 'ids',
+            'post_status'    => 'any',
+            'meta_key'       => self::STATE_META_KEY,
+            'meta_value'     => self::STATE_REQUEST,
+            'orderby'        => 'ID',
+        ) );
+    }
+
+    /**
+     * Request the analysis for the specified {@link WP_Post}.
+     *
+     * @since 3.14.2
+     *
+     * @param int $post_id The {@link WP_Post}'s id.
+     *
+     * @return WP_Error|array The response or WP_Error on failure.
+     */
+    private function do_request( $post_id ) {
+
+        // Get the post.
+        $post = get_post( $post_id );
+
+        // Bail out if the post isn't found.
+        if ( null === $post ) {
+            $this->log->warn( "Post $post_id not found." );
+
+            return new WP_Error( 0, "Cannot find post $post_id." );
+        }
+
+        // Get the link setting.
+        $link = $this->get_link( $post_id );
+
+        $this->log->debug( "Sending analysis request for post $post_id [ link :: $link ]..." );
+
+        // Get the batch analysis URL.
+        $url = $this->configuration_service->get_batch_analysis_url();
+
+        // Prepare the POST parameters.
+        $param = array(
+            'id'              => $post->ID,
+            'key'             => $this->configuration_service->get_key(),
+            'content'         => $post->post_content,
+            'contentLanguage' => $this->configuration_service->get_language_code(),
+            'version'         => $this->plugin->get_version(),
+            'links'           => $link,
+            'scope'           => 'local',
+        );
+
+        // Get the HTTP options.
+        $args = array_merge_recursive( unserialize( WL_REDLINK_API_HTTP_OPTIONS ), array(
+            'method'      => 'POST',
+            'headers'     => array(
+                'Accept'       => 'application/json',
+                'Content-type' => 'application/json; charset=UTF-8',
+            ),
+            // we need to downgrade the HTTP version in this case since chunked encoding is dumping numbers in the response.
+            'httpversion' => '1.0',
+            'body'        => wp_json_encode( $param ),
+        ) );
+
+        $this->log->debug( "Posting analysis request for post $post_id to $url..." );
+
+        // Post the parameter.
+        return wp_remote_post( $url, $args );
+    }
+
+    /**
+     * Get the Batch Analysis results for the specified {@link WP_Post}.
+     *
+     * @since 3.14.2
+     *
+     * @param int $post_id The {@link WP_Post}'s id.
+     *
+     * @return WP_Error|array The response or WP_Error on failure.
+     */
+    private function do_complete( $post_id ) {
+
+        $post = get_post( $post_id );
+
+        if ( null === $post ) {
+            // Post was possibly deleted, just bailout.
+            return new WP_Error( 0, "Post $post_id not found." );
+        }
+
+        $url = $this->configuration_service->get_batch_analysis_url();
+        $key = $this->configuration_service->get_key();
+        $url = $url . '/' . $post->ID . '?key=' . $key;
+
+        return wp_remote_get( $url, unserialize( WL_REDLINK_API_HTTP_OPTIONS ) );
+    }
+
+    /**
+     * Get the {@link WP_Post}s' ids flagged with warnings.
+     *
+     * @since 3.14.2
+     *
+     * @return array An array of {@link WP_Post}s' ids.
+     */
+    public function get_warnings() {
+
+        return get_posts( array(
+            'fields'      => 'ids',
+            'numberposts' => - 1,
+            'post_status' => 'any',
+            'meta_key'    => self::WARNING_META_KEY,
+            'meta_value'  => 'yes',
+        ) );
+    }
 
 }

Spacing +104 added lines, -104 removed lines

@@ -161,20 +161,20 @@ 
 	 * @param \Wordlift                       $plugin                The {@link Wordlift} plugin instance.
 	 * @param \Wordlift_Configuration_Service $configuration_service The {@link Wordlift_Configuration_Service} instance.
 	 */
-	public function __construct( $plugin, $configuration_service ) {
+	public function __construct($plugin, $configuration_service) {
 
 		$this->plugin                = $plugin;
 		$this->configuration_service = $configuration_service;
-		$this->log                   = Wordlift_Log_Service::get_logger( 'Wordlift_Batch_Analysis_Service' );
+		$this->log                   = Wordlift_Log_Service::get_logger('Wordlift_Batch_Analysis_Service');
 
-		add_action( 'wl_async_wl_batch_analysis_request', array(
+		add_action('wl_async_wl_batch_analysis_request', array(
 			$this,
 			'request',
-		) );
-		add_action( 'wl_async_wl_batch_analysis_complete', array(
+		));
+		add_action('wl_async_wl_batch_analysis_complete', array(
 			$this,
 			'complete',
-		) );
+		));
 
 	}
 
@@ -189,7 +189,7 @@ 
 	 *
 	 * @return string The base SQL.
 	 */
-	private function get_sql( $link ) {
+	private function get_sql($link) {
 		global $wpdb;
 
 		// Prepare the statement:
@@ -237,23 +237,23 @@ 
 	 * @return false|int The number of submitted {@link WP_Post}s or false on
 	 *                   error.
 	 */
-	public function submit_auto_selected_posts( $link ) {
+	public function submit_auto_selected_posts($link) {
 		global $wpdb;
 
 		// Submit the posts/pages and return the number of affected results.
 		// We're using a SQL query here because we could have potentially
 		// thousands of rows.
-		$count = $wpdb->query( $wpdb->prepare(
-			$this->get_sql( $link ) .
+		$count = $wpdb->query($wpdb->prepare(
+			$this->get_sql($link).
 			"
 				AND batch_analysis_state.meta_value IS NULL
 				AND p.post_content NOT REGEXP %s;
 			",
 			'<[a-z]+ id="urn:[^"]+" class="[^"]+" itemid="[^"]+">'
-		) );
+		));
 
 		// Request Batch Analysis (the operation is handled asynchronously).
-		do_action( 'wl_batch_analysis_request' );
+		do_action('wl_batch_analysis_request');
 
 		// Divide the count by 3 to get the number of posts/pages queued.
 		return $count / 3;
@@ -269,16 +269,16 @@ 
 	 * @return false|int The number of submitted {@link WP_Post}s or false on
 	 *                   error.
 	 */
-	public function submit_all_posts( $link ) {
+	public function submit_all_posts($link) {
 		global $wpdb;
 
 		// Submit the posts/pages and return the number of affected results.
 		// We're using a SQL query here because we could have potentially
 		// thousands of rows.
-		$count = $wpdb->query( $this->get_sql( $link ) );
+		$count = $wpdb->query($this->get_sql($link));
 
 		// Request Batch Analysis (the operation is handled asynchronously).
-		do_action( 'wl_batch_analysis_request' );
+		do_action('wl_batch_analysis_request');
 
 		// Divide the count by 3 to get the number of posts/pages queued.
 		return $count / 3;
@@ -295,19 +295,19 @@ 
 	 *
 	 * @return int The number of submitted {@link WP_Post}s or false on error.
 	 */
-	public function submit( $post_ids, $link ) {
+	public function submit($post_ids, $link) {
 		global $wpdb;
 
 		// Submit the posts/pages and return the number of affected results.
 		// We're using a SQL query here because we could have potentially
 		// thousands of rows.
 		$count = $wpdb->query(
-			$this->get_sql( $link ) .
-			' AND p.ID IN ( ' . implode( ',', wp_parse_id_list( $post_ids ) ) . ' )'
+			$this->get_sql($link).
+			' AND p.ID IN ( '.implode(',', wp_parse_id_list($post_ids)).' )'
 		);
 
 		// Request Batch Analysis (the operation is handled asynchronously).
-		do_action( 'wl_batch_analysis_request' );
+		do_action('wl_batch_analysis_request');
 
 		// Divide the count by 3 to get the number of posts/pages queued.
 		return $count / 3;
@@ -324,19 +324,19 @@ 
 	 * @return false|int The number of cancelled {@link WP_Post}s or false on
 	 *                   error.
 	 */
-	public function cancel( $post_ids ) {
+	public function cancel($post_ids) {
 		global $wpdb;
 
-		return $wpdb->query( $wpdb->prepare(
+		return $wpdb->query($wpdb->prepare(
 			"
 			DELETE FROM $wpdb->postmeta
 			WHERE meta_key = %s
 				AND meta_value = %s
-				AND post_id IN ( " . implode( ',', wp_parse_id_list( $post_ids ) ) . " )
+				AND post_id IN ( ".implode(',', wp_parse_id_list($post_ids))." )
 			",
 			self::STATE_META_KEY,
 			self::STATE_REQUEST
-		) );
+		));
 
 	}
 
@@ -347,49 +347,49 @@ 
 	 */
 	public function request() {
 
-		$this->log->debug( "Requesting analysis..." );
+		$this->log->debug("Requesting analysis...");
 
 		// By default 5 posts of any post type are returned.
-		$posts = get_posts( array(
+		$posts = get_posts(array(
 			'fields'     => 'ids',
 			'meta_key'   => self::STATE_META_KEY,
 			'meta_value' => self::STATE_SUBMIT,
 			'orderby'    => 'ID',
-		) );
+		));
 
 		// Bail out if there are no submitted posts.
-		if ( empty( $posts ) ) {
-			$this->log->debug( 'No posts to submit found, checking for completed requests...' );
+		if (empty($posts)) {
+			$this->log->debug('No posts to submit found, checking for completed requests...');
 
-			do_action( 'wl_batch_analysis_complete' );
+			do_action('wl_batch_analysis_complete');
 
 			return;
 		}
 
 		// Send a request for each post.
-		foreach ( $posts as $id ) {
-			$this->log->debug( "Requesting analysis for post $id..." );
+		foreach ($posts as $id) {
+			$this->log->debug("Requesting analysis for post $id...");
 
 			// Change the state to `REQUEST`.
-			$this->set_state( $id, self::STATE_REQUEST );
+			$this->set_state($id, self::STATE_REQUEST);
 
 			// Send the actual request to the remote service.
-			$result = $this->do_request( $id );
+			$result = $this->do_request($id);
 
-			$this->log->debug( "Analysis requested for post $id." );
+			$this->log->debug("Analysis requested for post $id.");
 
 			// Set an error if we received an error.
-			if ( is_wp_error( $result ) ) {
-				$this->log->error( "Analysis request for post $id returned {$result->get_error_message()}." );
+			if (is_wp_error($result)) {
+				$this->log->error("Analysis request for post $id returned {$result->get_error_message()}.");
 
-				$this->set_state( $id, self::STATE_ERROR );
+				$this->set_state($id, self::STATE_ERROR);
 			}
 
 		}
 
 		// Call the `wl_batch_analysis_request` action again. This is going
 		// to be handled by the async task.
-		do_action( 'wl_batch_analysis_request' );
+		do_action('wl_batch_analysis_request');
 
 	}
 
@@ -400,58 +400,58 @@ 
 	 */
 	public function complete() {
 
-		$this->log->debug( "Requesting results..." );
+		$this->log->debug("Requesting results...");
 
 		// By default 5 posts of any post type are returned.
-		$posts = get_posts( array(
+		$posts = get_posts(array(
 			'fields'     => 'ids',
 			'meta_key'   => self::STATE_META_KEY,
 			'meta_value' => self::STATE_REQUEST,
 			'orderby'    => 'ID',
-		) );
+		));
 
 		// Bail out if there are no submitted posts.
-		if ( empty( $posts ) ) {
-			$this->log->debug( 'No posts in request state found.' );
+		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..." );
+		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 );
+			$response = $this->do_complete($id);
 
-			$this->log->debug( "Results requested for post $id." );
+			$this->log->debug("Results requested for post $id.");
 
 			// Set an error if we received an error.
-			if ( ! is_wp_error( $response ) && isset( $response['body'] ) ) {
+			if ( ! is_wp_error($response) && isset($response['body'])) {
 
-				$this->log->debug( "Results received for post $id." );
+				$this->log->debug("Results received for post $id.");
 
 				// Save the returned content as new revision.
-				$json = json_decode( $response['body'] );
+				$json = json_decode($response['body']);
 
 				// Continue if the content isn't set.
-				if ( ! isset( $json->content ) || empty( $json->content ) ) {
+				if ( ! isset($json->content) || empty($json->content)) {
 					continue;
 				}
 
-				$this->set_warning_based_on_content( $id, $json->content );
+				$this->set_warning_based_on_content($id, $json->content);
 
-				$content = wp_slash( $json->content );
+				$content = wp_slash($json->content);
 
-				wp_update_post( array(
+				wp_update_post(array(
 					'ID'           => $id,
 					'post_content' => $content,
-				) );
+				));
 
 				// Update the status.
-				$this->set_state( $id, self::STATE_SUCCESS );
+				$this->set_state($id, self::STATE_SUCCESS);
 
-				$this->log->debug( "Post $id updated with batch analysis results." );
+				$this->log->debug("Post $id updated with batch analysis results.");
 
 				continue;
 			}
@@ -463,7 +463,7 @@ 
 
 		// Call the `wl_batch_analysis_request` action again. This is going
 		// to be handled by the async task.
-		do_action( 'wl_batch_analysis_complete' );
+		do_action('wl_batch_analysis_complete');
 
 	}
 
@@ -478,16 +478,16 @@ 
 	 *
 	 * @return string The content (for chaining operations).
 	 */
-	private function set_warning_based_on_content( $post_id, $content ) {
+	private function set_warning_based_on_content($post_id, $content) {
 
 		$matches = array();
 
 		// Check for suspicious interpolations.
-		$warning = 0 < preg_match_all( '/\w<[a-z]+ id="urn:enhancement-[^"]+" class="[^"]+" itemid="[^"]+">/', $content, $matches )
-				   || 0 < preg_match_all( '/<[a-z]+ id="urn:enhancement-[^"]+" class="[^"]+" itemid="[^"]+">\s/', $content, $matches );
+		$warning = 0 < preg_match_all('/\w<[a-z]+ id="urn:enhancement-[^"]+" class="[^"]+" itemid="[^"]+">/', $content, $matches)
+				   || 0 < preg_match_all('/<[a-z]+ id="urn:enhancement-[^"]+" class="[^"]+" itemid="[^"]+">\s/', $content, $matches);
 
 		// Set the warning flag accordingly.
-		$this->set_warning( $post_id, $warning );
+		$this->set_warning($post_id, $warning);
 
 		return $content;
 	}
@@ -500,10 +500,10 @@ 
 	 * @param int|array $post_ids A single {@link WP_Post}'s id or an array of
 	 *                            {@link WP_Post}s' ids.
 	 */
-	public function clear_warning( $post_ids ) {
+	public function clear_warning($post_ids) {
 
-		foreach ( (array) $post_ids as $post_id ) {
-			delete_post_meta( $post_id, self::WARNING_META_KEY );
+		foreach ((array) $post_ids as $post_id) {
+			delete_post_meta($post_id, self::WARNING_META_KEY);
 		}
 
 	}
@@ -519,9 +519,9 @@ 
 	 * @return int|bool Meta ID if the key didn't exist, true on successful update,
 	 *                  false on failure.
 	 */
-	private function set_warning( $post_id, $value ) {
+	private function set_warning($post_id, $value) {
 
-		return update_post_meta( $post_id, self::WARNING_META_KEY, ( true === $value ? 'yes' : 'no' ) );
+		return update_post_meta($post_id, self::WARNING_META_KEY, (true === $value ? 'yes' : 'no'));
 	}
 
 	/**
@@ -533,9 +533,9 @@ 
 	 *
 	 * @return int|string The post state or an empty string if not set.
 	 */
-	public function get_state( $post_id ) {
+	public function get_state($post_id) {
 
-		return get_post_meta( $post_id, self::STATE_META_KEY, true );
+		return get_post_meta($post_id, self::STATE_META_KEY, true);
 	}
 
 	/**
@@ -549,23 +549,23 @@ 
 	 * @return int|bool Meta ID if the key didn't exist, true on successful update,
 	 *                  false on failure.
 	 */
-	public function set_state( $post_id, $value ) {
+	public function set_state($post_id, $value) {
 
 		// Update the state.
-		$result = update_post_meta( $post_id, self::STATE_META_KEY, $value );
+		$result = update_post_meta($post_id, self::STATE_META_KEY, $value);
 
 		// Update timestamps as required.
-		switch ( $value ) {
+		switch ($value) {
 
 			// ### REQUEST state.
 			case self::STATE_REQUEST:
-				add_post_meta( $post_id, self::REQUEST_TIMESTAMP_META_KEY, current_time( 'mysql', true ) );
+				add_post_meta($post_id, self::REQUEST_TIMESTAMP_META_KEY, current_time('mysql', true));
 				break;
 
 			// ### SUCCESS/ERROR state.
 			case self::STATE_SUCCESS:
 			case self::STATE_ERROR:
-				add_post_meta( $post_id, self::COMPLETE_TIMESTAMP_META_KEY, current_time( 'mysql', true ) );
+				add_post_meta($post_id, self::COMPLETE_TIMESTAMP_META_KEY, current_time('mysql', true));
 				break;
 		}
 
@@ -584,11 +584,11 @@ 
 	 *
 	 * @return string The link setting or `default` if not set.
 	 */
-	public function get_link( $post_id ) {
+	public function get_link($post_id) {
 
-		$values = get_post_meta( $post_id, self::LINK_META_KEY );
+		$values = get_post_meta($post_id, self::LINK_META_KEY);
 
-		return end( $values ) ?: 'default';
+		return end($values) ?: 'default';
 	}
 
 	/**
@@ -600,14 +600,14 @@ 
 	 */
 	public function waiting_for_analysis() {
 
-		return get_posts( array(
-			'posts_per_page' => - 1,
+		return get_posts(array(
+			'posts_per_page' => -1,
 			'fields'         => 'ids',
 			'post_status'    => 'any',
 			'meta_key'       => self::STATE_META_KEY,
 			'meta_value'     => self::STATE_SUBMIT,
 			'orderby'        => 'ID',
-		) );
+		));
 	}
 
 	/**
@@ -620,14 +620,14 @@ 
 	 */
 	public function waiting_for_response() {
 
-		return get_posts( array(
-			'posts_per_page' => - 1,
+		return get_posts(array(
+			'posts_per_page' => -1,
 			'fields'         => 'ids',
 			'post_status'    => 'any',
 			'meta_key'       => self::STATE_META_KEY,
 			'meta_value'     => self::STATE_REQUEST,
 			'orderby'        => 'ID',
-		) );
+		));
 	}
 
 	/**
@@ -639,22 +639,22 @@ 
 	 *
 	 * @return WP_Error|array The response or WP_Error on failure.
 	 */
-	private function do_request( $post_id ) {
+	private function do_request($post_id) {
 
 		// Get the post.
-		$post = get_post( $post_id );
+		$post = get_post($post_id);
 
 		// Bail out if the post isn't found.
-		if ( null === $post ) {
-			$this->log->warn( "Post $post_id not found." );
+		if (null === $post) {
+			$this->log->warn("Post $post_id not found.");
 
-			return new WP_Error( 0, "Cannot find post $post_id." );
+			return new WP_Error(0, "Cannot find post $post_id.");
 		}
 
 		// Get the link setting.
-		$link = $this->get_link( $post_id );
+		$link = $this->get_link($post_id);
 
-		$this->log->debug( "Sending analysis request for post $post_id [ link :: $link ]..." );
+		$this->log->debug("Sending analysis request for post $post_id [ link :: $link ]...");
 
 		// Get the batch analysis URL.
 		$url = $this->configuration_service->get_batch_analysis_url();
@@ -671,7 +671,7 @@ 
 		);
 
 		// Get the HTTP options.
-		$args = array_merge_recursive( unserialize( WL_REDLINK_API_HTTP_OPTIONS ), array(
+		$args = array_merge_recursive(unserialize(WL_REDLINK_API_HTTP_OPTIONS), array(
 			'method'      => 'POST',
 			'headers'     => array(
 				'Accept'       => 'application/json',
@@ -679,13 +679,13 @@ 
 			),
 			// we need to downgrade the HTTP version in this case since chunked encoding is dumping numbers in the response.
 			'httpversion' => '1.0',
-			'body'        => wp_json_encode( $param ),
-		) );
+			'body'        => wp_json_encode($param),
+		));
 
-		$this->log->debug( "Posting analysis request for post $post_id to $url..." );
+		$this->log->debug("Posting analysis request for post $post_id to $url...");
 
 		// Post the parameter.
-		return wp_remote_post( $url, $args );
+		return wp_remote_post($url, $args);
 	}
 
 	/**
@@ -697,20 +697,20 @@ 
 	 *
 	 * @return WP_Error|array The response or WP_Error on failure.
 	 */
-	private function do_complete( $post_id ) {
+	private function do_complete($post_id) {
 
-		$post = get_post( $post_id );
+		$post = get_post($post_id);
 
-		if ( null === $post ) {
+		if (null === $post) {
 			// Post was possibly deleted, just bailout.
-			return new WP_Error( 0, "Post $post_id not found." );
+			return new WP_Error(0, "Post $post_id not found.");
 		}
 
 		$url = $this->configuration_service->get_batch_analysis_url();
 		$key = $this->configuration_service->get_key();
-		$url = $url . '/' . $post->ID . '?key=' . $key;
+		$url = $url.'/'.$post->ID.'?key='.$key;
 
-		return wp_remote_get( $url, unserialize( WL_REDLINK_API_HTTP_OPTIONS ) );
+		return wp_remote_get($url, unserialize(WL_REDLINK_API_HTTP_OPTIONS));
 	}
 
 	/**
@@ -722,13 +722,13 @@ 
 	 */
 	public function get_warnings() {
 
-		return get_posts( array(
+		return get_posts(array(
 			'fields'      => 'ids',
-			'numberposts' => - 1,
+			'numberposts' => -1,
 			'post_status' => 'any',
 			'meta_key'    => self::WARNING_META_KEY,
 			'meta_value'  => 'yes',
-		) );
+		));
 	}
 
 }

src/includes/wp-async-task/class-wordlift-batch-analysis-complete-async-task.php

Indentation +45 added lines, -45 removed lines

@@ -18,59 +18,59 @@
  */
 class Wordlift_Batch_Analysis_Complete_Async_Task extends Wordlift_Async_Task {
 
-	/**
-	 * The protected $action property should be set to the action to which you
-	 * wish to attach the asynchronous task. For example, if you want to spin
-	 * off an asynchronous task whenever a post gets saved, you would set this
-	 * to save_post.
-	 *
-	 * @since  3.14.2
-	 * @access protected
-	 * @var string $action The action to which you wish to attach the
-	 *                     asynchronous task.
-	 */
-	protected $action = 'wl_batch_analysis_complete';
+    /**
+     * The protected $action property should be set to the action to which you
+     * wish to attach the asynchronous task. For example, if you want to spin
+     * off an asynchronous task whenever a post gets saved, you would set this
+     * to save_post.
+     *
+     * @since  3.14.2
+     * @access protected
+     * @var string $action The action to which you wish to attach the
+     *                     asynchronous task.
+     */
+    protected $action = 'wl_batch_analysis_complete';
 
-	/**
-	 * A {@link Wordlift_Log_Service} instance.
-	 *
-	 * @since  3.14.2
-	 * @access private
-	 * @var \Wordlift_Log_Service $log A {@link Wordlift_Log_Service} instance.
-	 */
-	private $log;
+    /**
+     * A {@link Wordlift_Log_Service} instance.
+     *
+     * @since  3.14.2
+     * @access private
+     * @var \Wordlift_Log_Service $log A {@link Wordlift_Log_Service} instance.
+     */
+    private $log;
 
-	/**
-	 * Create a {@link Wordlift_Sparql_Query_Async_Task} instance.
-	 *
-	 * @since 3.14.2
-	 *
-	 * @param int $auth_level The authentication level to use (see above)
-	 */
-	public function __construct( $auth_level = self::BOTH ) {
-		parent::__construct( $auth_level );
+    /**
+     * Create a {@link Wordlift_Sparql_Query_Async_Task} instance.
+     *
+     * @since 3.14.2
+     *
+     * @param int $auth_level The authentication level to use (see above)
+     */
+    public function __construct( $auth_level = self::BOTH ) {
+        parent::__construct( $auth_level );
 
-		$this->log = Wordlift_Log_Service::get_logger( 'Wordlift_Batch_Analysis_Complete_Async_Task' );
+        $this->log = Wordlift_Log_Service::get_logger( 'Wordlift_Batch_Analysis_Complete_Async_Task' );
 
-	}
+    }
 
-	/**
-	 * @inheritdoc
-	 */
-	protected function prepare_data( $data ) {
+    /**
+     * @inheritdoc
+     */
+    protected function prepare_data( $data ) {
 
-		// Return the link setting.
-		return array();
-	}
+        // Return the link setting.
+        return array();
+    }
 
-	/**
-	 * @inheritdoc
-	 */
-	protected function run_action() {
+    /**
+     * @inheritdoc
+     */
+    protected function run_action() {
 
-		// Run the asynchronous action.
-		do_action( "wl_async_$this->action" );
+        // Run the asynchronous action.
+        do_action( "wl_async_$this->action" );
 
-	}
+    }
 
 }

Spacing +5 added lines, -5 removed lines

@@ -47,17 +47,17 @@ 
 	 *
 	 * @param int $auth_level The authentication level to use (see above)
 	 */
-	public function __construct( $auth_level = self::BOTH ) {
-		parent::__construct( $auth_level );
+	public function __construct($auth_level = self::BOTH) {
+		parent::__construct($auth_level);
 
-		$this->log = Wordlift_Log_Service::get_logger( 'Wordlift_Batch_Analysis_Complete_Async_Task' );
+		$this->log = Wordlift_Log_Service::get_logger('Wordlift_Batch_Analysis_Complete_Async_Task');
 
 	}
 
 	/**
 	 * @inheritdoc
 	 */
-	protected function prepare_data( $data ) {
+	protected function prepare_data($data) {
 
 		// Return the link setting.
 		return array();
@@ -69,7 +69,7 @@ 
 	protected function run_action() {
 
 		// Run the asynchronous action.
-		do_action( "wl_async_$this->action" );
+		do_action("wl_async_$this->action");
 
 	}
 

src/includes/wp-async-task/class-wordlift-sparql-query-async-task.php

Indentation +51 added lines, -51 removed lines

@@ -18,68 +18,68 @@
  */
 class Wordlift_Sparql_Query_Async_Task extends Wordlift_Async_Task {
 
-	/**
-	 * The protected $action property should be set to the action to which you
-	 * wish to attach the asynchronous task. For example, if you want to spin
-	 * off an asynchronous task whenever a post gets saved, you would set this
-	 * to save_post.
-	 *
-	 * @since  3.13.2
-	 * @access protected
-	 * @var string $action The action to which you wish to attach the
-	 *                     asynchronous task.
-	 */
-	protected $action = 'wl_run_sparql_query';
+    /**
+     * The protected $action property should be set to the action to which you
+     * wish to attach the asynchronous task. For example, if you want to spin
+     * off an asynchronous task whenever a post gets saved, you would set this
+     * to save_post.
+     *
+     * @since  3.13.2
+     * @access protected
+     * @var string $action The action to which you wish to attach the
+     *                     asynchronous task.
+     */
+    protected $action = 'wl_run_sparql_query';
 
-	/**
-	 * A {@link Wordlift_Log_Service} instance.
-	 *
-	 * @since  3.13.2
-	 * @access private
-	 * @var \Wordlift_Log_Service $log A {@link Wordlift_Log_Service} instance.
-	 */
-	private $log;
+    /**
+     * A {@link Wordlift_Log_Service} instance.
+     *
+     * @since  3.13.2
+     * @access private
+     * @var \Wordlift_Log_Service $log A {@link Wordlift_Log_Service} instance.
+     */
+    private $log;
 
-	/**
-	 * Create a {@link Wordlift_Sparql_Query_Async_Task} instance.
-	 *
-	 * @since 3.13.2
-	 *
-	 * @param int $auth_level The authentication level to use (see above)
-	 */
-	public function __construct( $auth_level = self::BOTH ) {
-		parent::__construct( $auth_level );
+    /**
+     * Create a {@link Wordlift_Sparql_Query_Async_Task} instance.
+     *
+     * @since 3.13.2
+     *
+     * @param int $auth_level The authentication level to use (see above)
+     */
+    public function __construct( $auth_level = self::BOTH ) {
+        parent::__construct( $auth_level );
 
-		$this->log = Wordlift_Log_Service::get_logger( 'Wordlift_Sparql_Query_Async_Task' );
+        $this->log = Wordlift_Log_Service::get_logger( 'Wordlift_Sparql_Query_Async_Task' );
 
-	}
+    }
 
 
-	/**
-	 * @inheritdoc
-	 */
-	protected function prepare_data( $data ) {
+    /**
+     * @inheritdoc
+     */
+    protected function prepare_data( $data ) {
 
-		// Return the request id, which is used to get the sparql queries stored
-		// in the temporary files.
-		return array( 'request_id' => $data[0] );
-	}
+        // Return the request id, which is used to get the sparql queries stored
+        // in the temporary files.
+        return array( 'request_id' => $data[0] );
+    }
 
-	/**
-	 * @inheritdoc
-	 */
-	protected function run_action() {
+    /**
+     * @inheritdoc
+     */
+    protected function run_action() {
 
-		// Bail out if there's no request id.
-		if ( ! isset( $_POST['request_id'] ) ) {
-			$this->log->warn( 'Request Id not found.' );
+        // Bail out if there's no request id.
+        if ( ! isset( $_POST['request_id'] ) ) {
+            $this->log->warn( 'Request Id not found.' );
 
-			return;
-		}
+            return;
+        }
 
-		// Run the asynchronous action.
-		do_action( "wl_async_$this->action", $_POST['request_id'] );
+        // Run the asynchronous action.
+        do_action( "wl_async_$this->action", $_POST['request_id'] );
 
-	}
+    }
 
 }

Spacing +8 added lines, -8 removed lines

@@ -47,10 +47,10 @@ 
 	 *
 	 * @param int $auth_level The authentication level to use (see above)
 	 */
-	public function __construct( $auth_level = self::BOTH ) {
-		parent::__construct( $auth_level );
+	public function __construct($auth_level = self::BOTH) {
+		parent::__construct($auth_level);
 
-		$this->log = Wordlift_Log_Service::get_logger( 'Wordlift_Sparql_Query_Async_Task' );
+		$this->log = Wordlift_Log_Service::get_logger('Wordlift_Sparql_Query_Async_Task');
 
 	}
 
@@ -58,11 +58,11 @@ 
 	/**
 	 * @inheritdoc
 	 */
-	protected function prepare_data( $data ) {
+	protected function prepare_data($data) {
 
 		// Return the request id, which is used to get the sparql queries stored
 		// in the temporary files.
-		return array( 'request_id' => $data[0] );
+		return array('request_id' => $data[0]);
 	}
 
 	/**
@@ -71,14 +71,14 @@ 
 	protected function run_action() {
 
 		// Bail out if there's no request id.
-		if ( ! isset( $_POST['request_id'] ) ) {
-			$this->log->warn( 'Request Id not found.' );
+		if ( ! isset($_POST['request_id'])) {
+			$this->log->warn('Request Id not found.');
 
 			return;
 		}
 
 		// Run the asynchronous action.
-		do_action( "wl_async_$this->action", $_POST['request_id'] );
+		do_action("wl_async_$this->action", $_POST['request_id']);
 
 	}
 

src/includes/wp-async-task/class-wordlift-async-task.php

Indentation +286 added lines, -286 removed lines

@@ -9,292 +9,292 @@
 
 abstract class Wordlift_Async_Task {
 
-	/**
-	 * Constant identifier for a task that should be available to logged-in users
-	 *
-	 * See constructor documentation for more details.
-	 */
-	const LOGGED_IN = 1;
-
-	/**
-	 * Constant identifier for a task that should be available to logged-out users
-	 *
-	 * See constructor documentation for more details.
-	 */
-	const LOGGED_OUT = 2;
-
-	/**
-	 * Constant identifier for a task that should be available to all users regardless of auth status
-	 *
-	 * See constructor documentation for more details.
-	 */
-	const BOTH = 3;
-
-	/**
-	 * This is the argument count for the main action set in the constructor. It
-	 * is set to an arbitrarily high value of twenty, but can be overridden if
-	 * necessary
-	 *
-	 * @var int
-	 */
-	protected $argument_count = 20;
-
-	/**
-	 * Priority to fire intermediate action.
-	 *
-	 * @var int
-	 */
-	protected $priority = 10;
-
-	/**
-	 * @var string
-	 */
-	protected $action;
-
-	/**
-	 * @var array
-	 */
-	protected $_body_data;
-
-	/**
-	 * A {@link Wordlift_Log_Service} instance.
-	 *
-	 * @since  3.15.0
-	 * @access private
-	 * @var \Wordlift_Log_Service $log A {@link Wordlift_Log_Service} instance.
-	 */
-	private $log;
-
-	/**
-	 * Constructor to wire up the necessary actions
-	 *
-	 * Which hooks the asynchronous postback happens on can be set by the
-	 * $auth_level parameter. There are essentially three options: logged in users
-	 * only, logged out users only, or both. Set this when you instantiate an
-	 * object by using one of the three class constants to do so:
-	 *  - LOGGED_IN
-	 *  - LOGGED_OUT
-	 *  - BOTH
-	 * $auth_level defaults to BOTH
-	 *
-	 * @throws Exception If the class' $action value hasn't been set
-	 *
-	 * @param int $auth_level The authentication level to use (see above)
-	 */
-	public function __construct( $auth_level = self::BOTH ) {
-
-		$this->log = Wordlift_Log_Service::get_logger( get_class() );
-
-		if ( empty( $this->action ) ) {
-			throw new Exception( 'Action not defined for class ' . __CLASS__ );
-		}
-		add_action( $this->action, array(
-			$this,
-			'launch',
-		), (int) $this->priority, (int) $this->argument_count );
-		if ( $auth_level & self::LOGGED_IN ) {
-			add_action( "admin_post_wl_async_$this->action", array(
-				$this,
-				'handle_postback',
-			) );
-		}
-		if ( $auth_level & self::LOGGED_OUT ) {
-			add_action( "admin_post_nopriv_wl_async_$this->action", array(
-				$this,
-				'handle_postback',
-			) );
-		}
-	}
-
-	/**
-	 * Add the shutdown action for launching the real postback if we don't
-	 * get an exception thrown by prepare_data().
-	 *
-	 * @uses func_get_args() To grab any arguments passed by the action
-	 */
-	public function launch() {
-		$data = func_get_args();
-		try {
-			$data = $this->prepare_data( $data );
-		} catch ( Exception $e ) {
-			return;
-		}
-
-		$data['action'] = "wl_async_$this->action";
-		$data['_nonce'] = $this->create_async_nonce();
-
-		$this->_body_data = $data;
-
-		if ( ! has_action( 'shutdown', array(
-			$this,
-			'launch_on_shutdown',
-		) )
-		) {
-			add_action( 'shutdown', array( $this, 'launch_on_shutdown' ) );
-		}
-	}
-
-	/**
-	 * Launch the request on the WordPress shutdown hook
-	 *
-	 * On VIP we got into data races due to the postback sometimes completing
-	 * faster than the data could propogate to the database server cluster.
-	 * This made WordPress get empty data sets from the database without
-	 * failing. On their advice, we're moving the actual firing of the async
-	 * postback to the shutdown hook. Supposedly that will ensure that the
-	 * data at least has time to get into the object cache.
-	 *
-	 * @uses $_COOKIE        To send a cookie header for async postback
-	 * @uses apply_filters()
-	 * @uses admin_url()
-	 * @uses wp_remote_post()
-	 */
-	public function launch_on_shutdown() {
-
-		$this->log->debug( 'Launching Async Task...' );
-
-		if ( ! empty( $this->_body_data ) ) {
-			$cookies = array();
-			foreach ( $_COOKIE as $name => $value ) {
-				$cookies[] = "$name=" . urlencode( is_array( $value ) ? serialize( $value ) : $value );
-			}
-
-			$request_args = array(
-				'timeout'   => 0.01,
-				'blocking'  => false,
-				'sslverify' => apply_filters( 'https_local_ssl_verify', false ),
-				'body'      => $this->_body_data,
-				'headers'   => array(
-					'cookie' => implode( '; ', $cookies ),
-				),
-			);
-
-			$url = get_site_url( null, 'wl-api' );
-
-			$this->log->debug( "Posting URL $url..." );
-
-			$result = wp_remote_post( $url, $request_args );
-
-			if ( is_wp_error( $result ) ) {
-				$this->log->error( 'Posting URL returned an error: ' . $result->get_error_message() );
-			}
-		}
-	}
-
-	/**
-	 * Verify the postback is valid, then fire any scheduled events.
-	 *
-	 * @uses $_POST['_nonce']
-	 * @uses is_user_logged_in()
-	 * @uses add_filter()
-	 * @uses wp_die()
-	 */
-	public function handle_postback() {
-		if ( isset( $_POST['_nonce'] ) && $this->verify_async_nonce( $_POST['_nonce'] ) ) {
-			if ( ! is_user_logged_in() ) {
-				$this->action = "nopriv_$this->action";
-			}
-			$this->run_action();
-		}
-
-		add_filter( 'wp_die_handler', function () {
-			die();
-		} );
-		wp_die();
-	}
-
-	/**
-	 * Create a random, one time use token.
-	 *
-	 * Based entirely on wp_create_nonce() but does not tie the nonce to the
-	 * current logged-in user.
-	 *
-	 * @uses wp_nonce_tick()
-	 * @uses wp_hash()
-	 *
-	 * @return string The one-time use token
-	 */
-	protected function create_async_nonce() {
-		$action = $this->get_nonce_action();
-		$i      = wp_nonce_tick();
-
-		return substr( wp_hash( $i . $action . get_class( $this ), 'nonce' ), - 12, 10 );
-	}
-
-	/**
-	 * Verify that the correct nonce was used within the time limit.
-	 *
-	 * @uses wp_nonce_tick()
-	 * @uses wp_hash()
-	 *
-	 * @param string $nonce Nonce to be verified
-	 *
-	 * @return bool Whether the nonce check passed or failed
-	 */
-	protected function verify_async_nonce( $nonce ) {
-		$action = $this->get_nonce_action();
-		$i      = wp_nonce_tick();
-
-		// Nonce generated 0-12 hours ago
-		if ( substr( wp_hash( $i . $action . get_class( $this ), 'nonce' ), - 12, 10 ) == $nonce ) {
-			return 1;
-		}
-
-		// Nonce generated 12-24 hours ago
-		if ( substr( wp_hash( ( $i - 1 ) . $action . get_class( $this ), 'nonce' ), - 12, 10 ) == $nonce ) {
-			return 2;
-		}
-
-		// Invalid nonce
-		return false;
-	}
-
-	/**
-	 * Get a nonce action based on the $action property of the class
-	 *
-	 * @return string The nonce action for the current instance
-	 */
-	protected function get_nonce_action() {
-		$action = $this->action;
-		if ( substr( $action, 0, 7 ) === 'nopriv_' ) {
-			$action = substr( $action, 7 );
-		}
-		$action = "wl_async_$action";
-
-		return $action;
-	}
-
-	/**
-	 * Prepare any data to be passed to the asynchronous postback
-	 *
-	 * The array this function receives will be a numerically keyed array from
-	 * func_get_args(). It is expected that you will return an associative array
-	 * so that the $_POST values used in the asynchronous call will make sense.
-	 *
-	 * The array you send back may or may not have anything to do with the data
-	 * passed into this method. It all depends on the implementation details and
-	 * what data is needed in the asynchronous postback.
-	 *
-	 * Do not set values for 'action' or '_nonce', as those will get overwritten
-	 * later in launch().
-	 *
-	 * @throws Exception If the postback should not occur for any reason
-	 *
-	 * @param array $data The raw data received by the launch method
-	 *
-	 * @return array The prepared data
-	 */
-	abstract protected function prepare_data( $data );
-
-	/**
-	 * Run the do_action function for the asynchronous postback.
-	 *
-	 * This method needs to fetch and sanitize any and all data from the $_POST
-	 * superglobal and provide them to the do_action call.
-	 *
-	 * The action should be constructed as "wl_async_task_$this->action"
-	 */
-	abstract protected function run_action();
+    /**
+     * Constant identifier for a task that should be available to logged-in users
+     *
+     * See constructor documentation for more details.
+     */
+    const LOGGED_IN = 1;
+
+    /**
+     * Constant identifier for a task that should be available to logged-out users
+     *
+     * See constructor documentation for more details.
+     */
+    const LOGGED_OUT = 2;
+
+    /**
+     * Constant identifier for a task that should be available to all users regardless of auth status
+     *
+     * See constructor documentation for more details.
+     */
+    const BOTH = 3;
+
+    /**
+     * This is the argument count for the main action set in the constructor. It
+     * is set to an arbitrarily high value of twenty, but can be overridden if
+     * necessary
+     *
+     * @var int
+     */
+    protected $argument_count = 20;
+
+    /**
+     * Priority to fire intermediate action.
+     *
+     * @var int
+     */
+    protected $priority = 10;
+
+    /**
+     * @var string
+     */
+    protected $action;
+
+    /**
+     * @var array
+     */
+    protected $_body_data;
+
+    /**
+     * A {@link Wordlift_Log_Service} instance.
+     *
+     * @since  3.15.0
+     * @access private
+     * @var \Wordlift_Log_Service $log A {@link Wordlift_Log_Service} instance.
+     */
+    private $log;
+
+    /**
+     * Constructor to wire up the necessary actions
+     *
+     * Which hooks the asynchronous postback happens on can be set by the
+     * $auth_level parameter. There are essentially three options: logged in users
+     * only, logged out users only, or both. Set this when you instantiate an
+     * object by using one of the three class constants to do so:
+     *  - LOGGED_IN
+     *  - LOGGED_OUT
+     *  - BOTH
+     * $auth_level defaults to BOTH
+     *
+     * @throws Exception If the class' $action value hasn't been set
+     *
+     * @param int $auth_level The authentication level to use (see above)
+     */
+    public function __construct( $auth_level = self::BOTH ) {
+
+        $this->log = Wordlift_Log_Service::get_logger( get_class() );
+
+        if ( empty( $this->action ) ) {
+            throw new Exception( 'Action not defined for class ' . __CLASS__ );
+        }
+        add_action( $this->action, array(
+            $this,
+            'launch',
+        ), (int) $this->priority, (int) $this->argument_count );
+        if ( $auth_level & self::LOGGED_IN ) {
+            add_action( "admin_post_wl_async_$this->action", array(
+                $this,
+                'handle_postback',
+            ) );
+        }
+        if ( $auth_level & self::LOGGED_OUT ) {
+            add_action( "admin_post_nopriv_wl_async_$this->action", array(
+                $this,
+                'handle_postback',
+            ) );
+        }
+    }
+
+    /**
+     * Add the shutdown action for launching the real postback if we don't
+     * get an exception thrown by prepare_data().
+     *
+     * @uses func_get_args() To grab any arguments passed by the action
+     */
+    public function launch() {
+        $data = func_get_args();
+        try {
+            $data = $this->prepare_data( $data );
+        } catch ( Exception $e ) {
+            return;
+        }
+
+        $data['action'] = "wl_async_$this->action";
+        $data['_nonce'] = $this->create_async_nonce();
+
+        $this->_body_data = $data;
+
+        if ( ! has_action( 'shutdown', array(
+            $this,
+            'launch_on_shutdown',
+        ) )
+        ) {
+            add_action( 'shutdown', array( $this, 'launch_on_shutdown' ) );
+        }
+    }
+
+    /**
+     * Launch the request on the WordPress shutdown hook
+     *
+     * On VIP we got into data races due to the postback sometimes completing
+     * faster than the data could propogate to the database server cluster.
+     * This made WordPress get empty data sets from the database without
+     * failing. On their advice, we're moving the actual firing of the async
+     * postback to the shutdown hook. Supposedly that will ensure that the
+     * data at least has time to get into the object cache.
+     *
+     * @uses $_COOKIE        To send a cookie header for async postback
+     * @uses apply_filters()
+     * @uses admin_url()
+     * @uses wp_remote_post()
+     */
+    public function launch_on_shutdown() {
+
+        $this->log->debug( 'Launching Async Task...' );
+
+        if ( ! empty( $this->_body_data ) ) {
+            $cookies = array();
+            foreach ( $_COOKIE as $name => $value ) {
+                $cookies[] = "$name=" . urlencode( is_array( $value ) ? serialize( $value ) : $value );
+            }
+
+            $request_args = array(
+                'timeout'   => 0.01,
+                'blocking'  => false,
+                'sslverify' => apply_filters( 'https_local_ssl_verify', false ),
+                'body'      => $this->_body_data,
+                'headers'   => array(
+                    'cookie' => implode( '; ', $cookies ),
+                ),
+            );
+
+            $url = get_site_url( null, 'wl-api' );
+
+            $this->log->debug( "Posting URL $url..." );
+
+            $result = wp_remote_post( $url, $request_args );
+
+            if ( is_wp_error( $result ) ) {
+                $this->log->error( 'Posting URL returned an error: ' . $result->get_error_message() );
+            }
+        }
+    }
+
+    /**
+     * Verify the postback is valid, then fire any scheduled events.
+     *
+     * @uses $_POST['_nonce']
+     * @uses is_user_logged_in()
+     * @uses add_filter()
+     * @uses wp_die()
+     */
+    public function handle_postback() {
+        if ( isset( $_POST['_nonce'] ) && $this->verify_async_nonce( $_POST['_nonce'] ) ) {
+            if ( ! is_user_logged_in() ) {
+                $this->action = "nopriv_$this->action";
+            }
+            $this->run_action();
+        }
+
+        add_filter( 'wp_die_handler', function () {
+            die();
+        } );
+        wp_die();
+    }
+
+    /**
+     * Create a random, one time use token.
+     *
+     * Based entirely on wp_create_nonce() but does not tie the nonce to the
+     * current logged-in user.
+     *
+     * @uses wp_nonce_tick()
+     * @uses wp_hash()
+     *
+     * @return string The one-time use token
+     */
+    protected function create_async_nonce() {
+        $action = $this->get_nonce_action();
+        $i      = wp_nonce_tick();
+
+        return substr( wp_hash( $i . $action . get_class( $this ), 'nonce' ), - 12, 10 );
+    }
+
+    /**
+     * Verify that the correct nonce was used within the time limit.
+     *
+     * @uses wp_nonce_tick()
+     * @uses wp_hash()
+     *
+     * @param string $nonce Nonce to be verified
+     *
+     * @return bool Whether the nonce check passed or failed
+     */
+    protected function verify_async_nonce( $nonce ) {
+        $action = $this->get_nonce_action();
+        $i      = wp_nonce_tick();
+
+        // Nonce generated 0-12 hours ago
+        if ( substr( wp_hash( $i . $action . get_class( $this ), 'nonce' ), - 12, 10 ) == $nonce ) {
+            return 1;
+        }
+
+        // Nonce generated 12-24 hours ago
+        if ( substr( wp_hash( ( $i - 1 ) . $action . get_class( $this ), 'nonce' ), - 12, 10 ) == $nonce ) {
+            return 2;
+        }
+
+        // Invalid nonce
+        return false;
+    }
+
+    /**
+     * Get a nonce action based on the $action property of the class
+     *
+     * @return string The nonce action for the current instance
+     */
+    protected function get_nonce_action() {
+        $action = $this->action;
+        if ( substr( $action, 0, 7 ) === 'nopriv_' ) {
+            $action = substr( $action, 7 );
+        }
+        $action = "wl_async_$action";
+
+        return $action;
+    }
+
+    /**
+     * Prepare any data to be passed to the asynchronous postback
+     *
+     * The array this function receives will be a numerically keyed array from
+     * func_get_args(). It is expected that you will return an associative array
+     * so that the $_POST values used in the asynchronous call will make sense.
+     *
+     * The array you send back may or may not have anything to do with the data
+     * passed into this method. It all depends on the implementation details and
+     * what data is needed in the asynchronous postback.
+     *
+     * Do not set values for 'action' or '_nonce', as those will get overwritten
+     * later in launch().
+     *
+     * @throws Exception If the postback should not occur for any reason
+     *
+     * @param array $data The raw data received by the launch method
+     *
+     * @return array The prepared data
+     */
+    abstract protected function prepare_data( $data );
+
+    /**
+     * Run the do_action function for the asynchronous postback.
+     *
+     * This method needs to fetch and sanitize any and all data from the $_POST
+     * superglobal and provide them to the do_action call.
+     *
+     * The action should be constructed as "wl_async_task_$this->action"
+     */
+    abstract protected function run_action();
 
 }
 

Spacing +38 added lines, -38 removed lines

@@ -81,28 +81,28 @@ 
 	 *
 	 * @param int $auth_level The authentication level to use (see above)
 	 */
-	public function __construct( $auth_level = self::BOTH ) {
+	public function __construct($auth_level = self::BOTH) {
 
-		$this->log = Wordlift_Log_Service::get_logger( get_class() );
+		$this->log = Wordlift_Log_Service::get_logger(get_class());
 
-		if ( empty( $this->action ) ) {
-			throw new Exception( 'Action not defined for class ' . __CLASS__ );
+		if (empty($this->action)) {
+			throw new Exception('Action not defined for class '.__CLASS__);
 		}
-		add_action( $this->action, array(
+		add_action($this->action, array(
 			$this,
 			'launch',
-		), (int) $this->priority, (int) $this->argument_count );
-		if ( $auth_level & self::LOGGED_IN ) {
-			add_action( "admin_post_wl_async_$this->action", array(
+		), (int) $this->priority, (int) $this->argument_count);
+		if ($auth_level & self::LOGGED_IN) {
+			add_action("admin_post_wl_async_$this->action", array(
 				$this,
 				'handle_postback',
-			) );
+			));
 		}
-		if ( $auth_level & self::LOGGED_OUT ) {
-			add_action( "admin_post_nopriv_wl_async_$this->action", array(
+		if ($auth_level & self::LOGGED_OUT) {
+			add_action("admin_post_nopriv_wl_async_$this->action", array(
 				$this,
 				'handle_postback',
-			) );
+			));
 		}
 	}
 
@@ -115,8 +115,8 @@ 
 	public function launch() {
 		$data = func_get_args();
 		try {
-			$data = $this->prepare_data( $data );
-		} catch ( Exception $e ) {
+			$data = $this->prepare_data($data);
+		} catch (Exception $e) {
 			return;
 		}
 
@@ -125,12 +125,12 @@ 
 
 		$this->_body_data = $data;
 
-		if ( ! has_action( 'shutdown', array(
+		if ( ! has_action('shutdown', array(
 			$this,
 			'launch_on_shutdown',
-		) )
+		))
 		) {
-			add_action( 'shutdown', array( $this, 'launch_on_shutdown' ) );
+			add_action('shutdown', array($this, 'launch_on_shutdown'));
 		}
 	}
 
@@ -151,32 +151,32 @@ 
 	 */
 	public function launch_on_shutdown() {
 
-		$this->log->debug( 'Launching Async Task...' );
+		$this->log->debug('Launching Async Task...');
 
-		if ( ! empty( $this->_body_data ) ) {
+		if ( ! empty($this->_body_data)) {
 			$cookies = array();
-			foreach ( $_COOKIE as $name => $value ) {
-				$cookies[] = "$name=" . urlencode( is_array( $value ) ? serialize( $value ) : $value );
+			foreach ($_COOKIE as $name => $value) {
+				$cookies[] = "$name=".urlencode(is_array($value) ? serialize($value) : $value);
 			}
 
 			$request_args = array(
 				'timeout'   => 0.01,
 				'blocking'  => false,
-				'sslverify' => apply_filters( 'https_local_ssl_verify', false ),
+				'sslverify' => apply_filters('https_local_ssl_verify', false),
 				'body'      => $this->_body_data,
 				'headers'   => array(
-					'cookie' => implode( '; ', $cookies ),
+					'cookie' => implode('; ', $cookies),
 				),
 			);
 
-			$url = get_site_url( null, 'wl-api' );
+			$url = get_site_url(null, 'wl-api');
 
-			$this->log->debug( "Posting URL $url..." );
+			$this->log->debug("Posting URL $url...");
 
-			$result = wp_remote_post( $url, $request_args );
+			$result = wp_remote_post($url, $request_args);
 
-			if ( is_wp_error( $result ) ) {
-				$this->log->error( 'Posting URL returned an error: ' . $result->get_error_message() );
+			if (is_wp_error($result)) {
+				$this->log->error('Posting URL returned an error: '.$result->get_error_message());
 			}
 		}
 	}
@@ -190,14 +190,14 @@ 
 	 * @uses wp_die()
 	 */
 	public function handle_postback() {
-		if ( isset( $_POST['_nonce'] ) && $this->verify_async_nonce( $_POST['_nonce'] ) ) {
-			if ( ! is_user_logged_in() ) {
+		if (isset($_POST['_nonce']) && $this->verify_async_nonce($_POST['_nonce'])) {
+			if ( ! is_user_logged_in()) {
 				$this->action = "nopriv_$this->action";
 			}
 			$this->run_action();
 		}
 
-		add_filter( 'wp_die_handler', function () {
+		add_filter('wp_die_handler', function() {
 			die();
 		} );
 		wp_die();
@@ -218,7 +218,7 @@ 
 		$action = $this->get_nonce_action();
 		$i      = wp_nonce_tick();
 
-		return substr( wp_hash( $i . $action . get_class( $this ), 'nonce' ), - 12, 10 );
+		return substr(wp_hash($i.$action.get_class($this), 'nonce'), - 12, 10);
 	}
 
 	/**
@@ -231,17 +231,17 @@ 
 	 *
 	 * @return bool Whether the nonce check passed or failed
 	 */
-	protected function verify_async_nonce( $nonce ) {
+	protected function verify_async_nonce($nonce) {
 		$action = $this->get_nonce_action();
 		$i      = wp_nonce_tick();
 
 		// Nonce generated 0-12 hours ago
-		if ( substr( wp_hash( $i . $action . get_class( $this ), 'nonce' ), - 12, 10 ) == $nonce ) {
+		if (substr(wp_hash($i.$action.get_class($this), 'nonce'), - 12, 10) == $nonce) {
 			return 1;
 		}
 
 		// Nonce generated 12-24 hours ago
-		if ( substr( wp_hash( ( $i - 1 ) . $action . get_class( $this ), 'nonce' ), - 12, 10 ) == $nonce ) {
+		if (substr(wp_hash(($i - 1).$action.get_class($this), 'nonce'), - 12, 10) == $nonce) {
 			return 2;
 		}
 
@@ -256,8 +256,8 @@ 
 	 */
 	protected function get_nonce_action() {
 		$action = $this->action;
-		if ( substr( $action, 0, 7 ) === 'nopriv_' ) {
-			$action = substr( $action, 7 );
+		if (substr($action, 0, 7) === 'nopriv_') {
+			$action = substr($action, 7);
 		}
 		$action = "wl_async_$action";
 
@@ -284,7 +284,7 @@ 
 	 *
 	 * @return array The prepared data
 	 */
-	abstract protected function prepare_data( $data );
+	abstract protected function prepare_data($data);
 
 	/**
 	 * Run the do_action function for the asynchronous postback.

src/includes/wp-async-task/class-wordlift-batch-analysis-request-async-task.php

Indentation +45 added lines, -45 removed lines

@@ -18,59 +18,59 @@
  */
 class Wordlift_Batch_Analysis_Request_Async_Task extends Wordlift_Async_Task {
 
-	/**
-	 * The protected $action property should be set to the action to which you
-	 * wish to attach the asynchronous task. For example, if you want to spin
-	 * off an asynchronous task whenever a post gets saved, you would set this
-	 * to save_post.
-	 *
-	 * @since  3.14.2
-	 * @access protected
-	 * @var string $action The action to which you wish to attach the
-	 *                     asynchronous task.
-	 */
-	protected $action = 'wl_batch_analysis_request';
+    /**
+     * The protected $action property should be set to the action to which you
+     * wish to attach the asynchronous task. For example, if you want to spin
+     * off an asynchronous task whenever a post gets saved, you would set this
+     * to save_post.
+     *
+     * @since  3.14.2
+     * @access protected
+     * @var string $action The action to which you wish to attach the
+     *                     asynchronous task.
+     */
+    protected $action = 'wl_batch_analysis_request';
 
-	/**
-	 * A {@link Wordlift_Log_Service} instance.
-	 *
-	 * @since  3.14.2
-	 * @access private
-	 * @var \Wordlift_Log_Service $log A {@link Wordlift_Log_Service} instance.
-	 */
-	private $log;
+    /**
+     * A {@link Wordlift_Log_Service} instance.
+     *
+     * @since  3.14.2
+     * @access private
+     * @var \Wordlift_Log_Service $log A {@link Wordlift_Log_Service} instance.
+     */
+    private $log;
 
-	/**
-	 * Create a {@link Wordlift_Sparql_Query_Async_Task} instance.
-	 *
-	 * @since 3.14.2
-	 *
-	 * @param int $auth_level The authentication level to use (see above)
-	 */
-	public function __construct( $auth_level = self::BOTH ) {
-		parent::__construct( $auth_level );
+    /**
+     * Create a {@link Wordlift_Sparql_Query_Async_Task} instance.
+     *
+     * @since 3.14.2
+     *
+     * @param int $auth_level The authentication level to use (see above)
+     */
+    public function __construct( $auth_level = self::BOTH ) {
+        parent::__construct( $auth_level );
 
-		$this->log = Wordlift_Log_Service::get_logger( 'Wordlift_Batch_Analysis_Request_Async_Task' );
+        $this->log = Wordlift_Log_Service::get_logger( 'Wordlift_Batch_Analysis_Request_Async_Task' );
 
-	}
+    }
 
-	/**
-	 * @inheritdoc
-	 */
-	protected function prepare_data( $data ) {
+    /**
+     * @inheritdoc
+     */
+    protected function prepare_data( $data ) {
 
-		// Return the link setting.
-		return array();
-	}
+        // Return the link setting.
+        return array();
+    }
 
-	/**
-	 * @inheritdoc
-	 */
-	protected function run_action() {
+    /**
+     * @inheritdoc
+     */
+    protected function run_action() {
 
-		// Run the asynchronous action.
-		do_action( "wl_async_$this->action" );
+        // Run the asynchronous action.
+        do_action( "wl_async_$this->action" );
 
-	}
+    }
 
 }

Spacing +5 added lines, -5 removed lines

@@ -47,17 +47,17 @@ 
 	 *
 	 * @param int $auth_level The authentication level to use (see above)
 	 */
-	public function __construct( $auth_level = self::BOTH ) {
-		parent::__construct( $auth_level );
+	public function __construct($auth_level = self::BOTH) {
+		parent::__construct($auth_level);
 
-		$this->log = Wordlift_Log_Service::get_logger( 'Wordlift_Batch_Analysis_Request_Async_Task' );
+		$this->log = Wordlift_Log_Service::get_logger('Wordlift_Batch_Analysis_Request_Async_Task');
 
 	}
 
 	/**
 	 * @inheritdoc
 	 */
-	protected function prepare_data( $data ) {
+	protected function prepare_data($data) {
 
 		// Return the link setting.
 		return array();
@@ -69,7 +69,7 @@ 
 	protected function run_action() {
 
 		// Run the asynchronous action.
-		do_action( "wl_async_$this->action" );
+		do_action("wl_async_$this->action");
 
 	}