insideout10 / wordlift-plugin

src/wordlift/task/background/class-background-task.php

Spacing +15 added lines, -15 removed lines

@@ -34,24 +34,24 @@ 
 	/**
 	 * @param Task $task
 	 */
-	public function __construct( $task ) {
-		$this->action        = sha1( get_class( $task ) );
+	public function __construct($task) {
+		$this->action        = sha1(get_class($task));
 		$this->option_prefix = "_{$this->action}_";
 
 		parent::__construct();
 
 		// Set the current state.
-		if ( self::STATE_STARTED === $this->get_state() ) {
-			$this->state = new Background_Task_Started_State( $this, $task );
+		if (self::STATE_STARTED === $this->get_state()) {
+			$this->state = new Background_Task_Started_State($this, $task);
 		} else {
-			$this->state = new Background_Task_Stopped_State( $this );
+			$this->state = new Background_Task_Stopped_State($this);
 		}
 
 		$this->task = $task;
 	}
 
-	public static function create( $task ) {
-		return new self( $task );
+	public static function create($task) {
+		return new self($task);
 	}
 
 	public function get_option_prefix() {
@@ -69,9 +69,9 @@ 
 	 *
 	 * @return int[]|false The next post IDs or false if there are no more.
 	 */
-	protected function task( $item ) {
+	protected function task($item) {
 
-		return $this->state->task( $item );
+		return $this->state->task($item);
 	}
 
 	/**
@@ -79,7 +79,7 @@ 
 	 */
 	public function start() {
 		$this->state->leave();
-		$this->state = new Background_Task_Started_State( $this, $this->task );
+		$this->state = new Background_Task_Started_State($this, $this->task);
 		$this->state->enter();
 	}
 
@@ -88,7 +88,7 @@ 
 	 */
 	public function stop() {
 		$this->state->leave();
-		$this->state = new Background_Task_Stopped_State( $this );
+		$this->state = new Background_Task_Stopped_State($this);
 		$this->state->enter();
 	}
 
@@ -102,7 +102,7 @@ 
 	 * @return string Either self::STARTED_STATE or self::STOPPED_STATE (default).
 	 */
 	public function get_state() {
-		return get_option( $this->option_prefix . 'state', self::STATE_STOPPED );
+		return get_option($this->option_prefix.'state', self::STATE_STOPPED);
 	}
 
 	/**
@@ -112,10 +112,10 @@ 
 	 *
 	 * @return bool
 	 */
-	public function set_state( $value ) {
+	public function set_state($value) {
 		return null === $value
-			? delete_option( $this->option_prefix . 'state' )
-			: update_option( $this->option_prefix . 'state', $value, true );
+			? delete_option($this->option_prefix.'state')
+			: update_option($this->option_prefix.'state', $value, true);
 	}
 
 	public function get_info() {

Indentation +114 added lines, -114 removed lines

@@ -7,119 +7,119 @@
 
 class Background_Task extends Wordlift_Plugin_WP_Background_Process {
 
-	const STATE_STARTED = 'started';
-	const STATE_STOPPED = 'stopped';
-
-	/**
-	 * The current state of the task, started or stopped.
-	 *
-	 * @var Background_Task_State $state
-	 */
-	private $state;
-
-	/**
-	 * The actual task.
-	 *
-	 * @var Task $task
-	 */
-	private $task;
-
-	/**
-	 * The prefix to store the state and other information in WP's options table, determined at instantiation.
-	 *
-	 * @var string $option_prefix
-	 */
-	private $option_prefix;
-
-	/**
-	 * @param Task $task
-	 */
-	public function __construct( $task ) {
-		$this->action        = sha1( get_class( $task ) );
-		$this->option_prefix = "_{$this->action}_";
-
-		parent::__construct();
-
-		// Set the current state.
-		if ( self::STATE_STARTED === $this->get_state() ) {
-			$this->state = new Background_Task_Started_State( $this, $task );
-		} else {
-			$this->state = new Background_Task_Stopped_State( $this );
-		}
-
-		$this->task = $task;
-	}
-
-	public static function create( $task ) {
-		return new self( $task );
-	}
-
-	public function get_option_prefix() {
-		return $this->option_prefix;
-	}
-
-	/**
-	 * This function is called:
-	 *  - To start a new Synchronization, by passing a {@link Sync_Start_Message} instance.
-	 *  - To synchronize a post, by passing a numeric ID.
-	 *
-	 * This function returns the parameter for the next call or NULL if there are no more posts to process.
-	 *
-	 * @param mixed $item Queue item to iterate over.
-	 *
-	 * @return int[]|false The next post IDs or false if there are no more.
-	 */
-	protected function task( $item ) {
-
-		return $this->state->task( $item );
-	}
-
-	/**
-	 * Transition to the started state.
-	 */
-	public function start() {
-		$this->state->leave();
-		$this->state = new Background_Task_Started_State( $this, $this->task );
-		$this->state->enter();
-	}
-
-	/**
-	 * Transition to the stopped state.
-	 */
-	public function stop() {
-		$this->state->leave();
-		$this->state = new Background_Task_Stopped_State( $this );
-		$this->state->enter();
-	}
-
-	public function resume() {
-		$this->state->resume();
-	}
-
-	/**
-	 * Get the current state.
-	 *
-	 * @return string Either self::STARTED_STATE or self::STOPPED_STATE (default).
-	 */
-	public function get_state() {
-		return get_option( $this->option_prefix . 'state', self::STATE_STOPPED );
-	}
-
-	/**
-	 * Persist the current state.
-	 *
-	 * @param string $value
-	 *
-	 * @return bool
-	 */
-	public function set_state( $value ) {
-		return null === $value
-			? delete_option( $this->option_prefix . 'state' )
-			: update_option( $this->option_prefix . 'state', $value, true );
-	}
-
-	public function get_info() {
-		return $this->state->get_info();
-	}
+    const STATE_STARTED = 'started';
+    const STATE_STOPPED = 'stopped';
+
+    /**
+     * The current state of the task, started or stopped.
+     *
+     * @var Background_Task_State $state
+     */
+    private $state;
+
+    /**
+     * The actual task.
+     *
+     * @var Task $task
+     */
+    private $task;
+
+    /**
+     * The prefix to store the state and other information in WP's options table, determined at instantiation.
+     *
+     * @var string $option_prefix
+     */
+    private $option_prefix;
+
+    /**
+     * @param Task $task
+     */
+    public function __construct( $task ) {
+        $this->action        = sha1( get_class( $task ) );
+        $this->option_prefix = "_{$this->action}_";
+
+        parent::__construct();
+
+        // Set the current state.
+        if ( self::STATE_STARTED === $this->get_state() ) {
+            $this->state = new Background_Task_Started_State( $this, $task );
+        } else {
+            $this->state = new Background_Task_Stopped_State( $this );
+        }
+
+        $this->task = $task;
+    }
+
+    public static function create( $task ) {
+        return new self( $task );
+    }
+
+    public function get_option_prefix() {
+        return $this->option_prefix;
+    }
+
+    /**
+     * This function is called:
+     *  - To start a new Synchronization, by passing a {@link Sync_Start_Message} instance.
+     *  - To synchronize a post, by passing a numeric ID.
+     *
+     * This function returns the parameter for the next call or NULL if there are no more posts to process.
+     *
+     * @param mixed $item Queue item to iterate over.
+     *
+     * @return int[]|false The next post IDs or false if there are no more.
+     */
+    protected function task( $item ) {
+
+        return $this->state->task( $item );
+    }
+
+    /**
+     * Transition to the started state.
+     */
+    public function start() {
+        $this->state->leave();
+        $this->state = new Background_Task_Started_State( $this, $this->task );
+        $this->state->enter();
+    }
+
+    /**
+     * Transition to the stopped state.
+     */
+    public function stop() {
+        $this->state->leave();
+        $this->state = new Background_Task_Stopped_State( $this );
+        $this->state->enter();
+    }
+
+    public function resume() {
+        $this->state->resume();
+    }
+
+    /**
+     * Get the current state.
+     *
+     * @return string Either self::STARTED_STATE or self::STOPPED_STATE (default).
+     */
+    public function get_state() {
+        return get_option( $this->option_prefix . 'state', self::STATE_STOPPED );
+    }
+
+    /**
+     * Persist the current state.
+     *
+     * @param string $value
+     *
+     * @return bool
+     */
+    public function set_state( $value ) {
+        return null === $value
+            ? delete_option( $this->option_prefix . 'state' )
+            : update_option( $this->option_prefix . 'state', $value, true );
+    }
+
+    public function get_info() {
+        return $this->state->get_info();
+    }
 
 }

src/wordlift/cleanup/index.php

Indentation +2 added lines, -2 removed lines

@@ -12,12 +12,12 @@
 use Wordlift\Task\Background\Background_Task_Route;
 
 if ( ! defined( 'ABSPATH' ) ) {
-	exit;
+    exit;
 }
 
 // Check if the feature is enabled.
 if ( ! apply_filters( 'wl_feature__enable__cleanup', false ) ) {
-	return;
+    return;
 }
 
 $task = new All_Posts_Task( array( 'Wordlift\Cleanup\Post_Handler', 'fix' ) );

Spacing +6 added lines, -6 removed lines

@@ -11,17 +11,17 @@
 use Wordlift\Task\Background\Background_Task_Page;
 use Wordlift\Task\Background\Background_Task_Route;
 
-if ( ! defined( 'ABSPATH' ) ) {
+if ( ! defined('ABSPATH')) {
 	exit;
 }
 
 // Check if the feature is enabled.
-if ( ! apply_filters( 'wl_feature__enable__cleanup', false ) ) {
+if ( ! apply_filters('wl_feature__enable__cleanup', false)) {
 	return;
 }
 
-$task = new All_Posts_Task( array( 'Wordlift\Cleanup\Post_Handler', 'fix' ) );
+$task = new All_Posts_Task(array('Wordlift\Cleanup\Post_Handler', 'fix'));
 
-$background_task       = Background_Task::create( $task );
-$background_task_route = Background_Task_Route::create( $background_task, '/cleanup' );
-Background_Task_Page::create( __( 'Cleanup', 'wordlift' ), 'cleanup', $background_task_route );
+$background_task       = Background_Task::create($task);
+$background_task_route = Background_Task_Route::create($background_task, '/cleanup');
+Background_Task_Page::create(__('Cleanup', 'wordlift'), 'cleanup', $background_task_route);

src/wordlift/entity/remote-entity-importer/class-remote-entity-importer-factory.php

Spacing +3 added lines, -3 removed lines

@@ -12,10 +12,10 @@
 	 *
 	 * @return Remote_Entity_Importer
 	 */
-	public static function from_entity( $entity ) {
+	public static function from_entity($entity) {
 
-		if ( $entity instanceof Valid_Remote_Entity ) {
-			return new Valid_Remote_Entity_Importer( $entity );
+		if ($entity instanceof Valid_Remote_Entity) {
+			return new Valid_Remote_Entity_Importer($entity);
 		}
 
 		return new Invalid_Remote_Entity_Importer();

Indentation +11 added lines, -11 removed lines

@@ -7,17 +7,17 @@
 
 class Remote_Entity_Importer_Factory {
 
-	/**
-	 * @param $entity Remote_Entity
-	 *
-	 * @return Remote_Entity_Importer
-	 */
-	public static function from_entity( $entity ) {
+    /**
+     * @param $entity Remote_Entity
+     *
+     * @return Remote_Entity_Importer
+     */
+    public static function from_entity( $entity ) {
 
-		if ( $entity instanceof Valid_Remote_Entity ) {
-			return new Valid_Remote_Entity_Importer( $entity );
-		}
+        if ( $entity instanceof Valid_Remote_Entity ) {
+            return new Valid_Remote_Entity_Importer( $entity );
+        }
 
-		return new Invalid_Remote_Entity_Importer();
-	}
+        return new Invalid_Remote_Entity_Importer();
+    }
 }

src/includes/analytics/class-wordlift-analytics-connect.php

Indentation +76 added lines, -76 removed lines

@@ -14,88 +14,88 @@
  */
 class Wordlift_Analytics_Connect {
 
-	const HANDLE = 'wordlift';
+    const HANDLE = 'wordlift';
 
-	/**
-	 * Gets an array of related entities with their post IDs and titles.
-	 *
-	 * @method get_analytics_event_data
-	 * @since  3.21.0
-	 *
-	 * @param int $post_id post id we want related data for.
-	 *
-	 * @return array
-	 */
-	public static function get_analytics_event_data( $post_id ) {
-		// If no ID was passed get current ID.
-		if ( ! $post_id ) {
-			$post_id = get_queried_object_id();
-		}
-		/**
-		 * TODO: set/get this from cache.
-		 */
-		$related_items = array();
-		$related_ids   = wl_core_get_related_entity_ids( $post_id );
+    /**
+     * Gets an array of related entities with their post IDs and titles.
+     *
+     * @method get_analytics_event_data
+     * @since  3.21.0
+     *
+     * @param int $post_id post id we want related data for.
+     *
+     * @return array
+     */
+    public static function get_analytics_event_data( $post_id ) {
+        // If no ID was passed get current ID.
+        if ( ! $post_id ) {
+            $post_id = get_queried_object_id();
+        }
+        /**
+         * TODO: set/get this from cache.
+         */
+        $related_items = array();
+        $related_ids   = wl_core_get_related_entity_ids( $post_id );
 
-		$entity_service = Wordlift_Entity_Service::get_instance();
-		// If the current item is also an entity then add it to the list of IDs.
-		if ( $entity_service->is_entity( $post_id ) ) {
-			$related_ids[] = $post_id;
-		}
-		$entity_type_service = Wordlift_Entity_Type_Service::get_instance();
-		// Get the post titles of related items and connect them in an array.
-		foreach ( $related_ids as $related_id ) {
-			$type  = $entity_type_service->get( $related_id );
-			$type  = isset( $type['uri'] ) ? $type['uri'] : 'unknown';
-			$label = $entity_service->get_labels( $related_id );
-			$label = $label[0];
+        $entity_service = Wordlift_Entity_Service::get_instance();
+        // If the current item is also an entity then add it to the list of IDs.
+        if ( $entity_service->is_entity( $post_id ) ) {
+            $related_ids[] = $post_id;
+        }
+        $entity_type_service = Wordlift_Entity_Type_Service::get_instance();
+        // Get the post titles of related items and connect them in an array.
+        foreach ( $related_ids as $related_id ) {
+            $type  = $entity_type_service->get( $related_id );
+            $type  = isset( $type['uri'] ) ? $type['uri'] : 'unknown';
+            $label = $entity_service->get_labels( $related_id );
+            $label = $label[0];
 
-			$related_items[ $related_id ] = array(
-				'uri'   => $entity_service->get_uri( $related_id ),
-				'type'  => $type,
-				'label' => $label,
-			);
-		}
+            $related_items[ $related_id ] = array(
+                'uri'   => $entity_service->get_uri( $related_id ),
+                'type'  => $type,
+                'label' => $label,
+            );
+        }
 
-		return $related_items;
-	}
+        return $related_items;
+    }
 
-	/**
-	 * Gets the configuration data assosiated with the analytics settings. For
-	 * frontend script use primarily.
-	 *
-	 * @method get_analytics_config_data
-	 * @since  3.21.0
-	 * @return array
-	 */
-	public static function get_analytics_config_data() {
-		$configuration_service = Wordlift_Configuration_Service::get_instance();
-		// get some values from the config service.
-		$config = array(
-			'entity_uri_dimension'  => $configuration_service->get_analytics_entity_uri_dimension(),
-			'entity_type_dimension' => $configuration_service->get_analytics_entity_type_dimension(),
-		);
+    /**
+     * Gets the configuration data assosiated with the analytics settings. For
+     * frontend script use primarily.
+     *
+     * @method get_analytics_config_data
+     * @since  3.21.0
+     * @return array
+     */
+    public static function get_analytics_config_data() {
+        $configuration_service = Wordlift_Configuration_Service::get_instance();
+        // get some values from the config service.
+        $config = array(
+            'entity_uri_dimension'  => $configuration_service->get_analytics_entity_uri_dimension(),
+            'entity_type_dimension' => $configuration_service->get_analytics_entity_type_dimension(),
+        );
 
-		return $config;
-	}
+        return $config;
+    }
 
-	/**
-	 * Enqueues our scripts for the frontend analytics handling and attaches
-	 * any data we will want to use there.
-	 *
-	 * @method enqueue_scripts
-	 * @since  3.21.0
-	 */
-	public function enqueue_scripts() {
-		$entity_data = self::get_analytics_event_data( get_the_ID() );
-		// Bail early if there is no event data that we would send.
-		if ( ! $entity_data ) {
-			return;
-		}
-		$data = self::get_analytics_config_data();
+    /**
+     * Enqueues our scripts for the frontend analytics handling and attaches
+     * any data we will want to use there.
+     *
+     * @method enqueue_scripts
+     * @since  3.21.0
+     */
+    public function enqueue_scripts() {
+        $entity_data = self::get_analytics_event_data( get_the_ID() );
+        // Bail early if there is no event data that we would send.
+        if ( ! $entity_data ) {
+            return;
+        }
+        $data = self::get_analytics_config_data();
 
-		// Uses the analytics code in the main WordLift plugin.
-		wp_localize_script( self::HANDLE, 'wordliftAnalyticsConfigData', $data );
-		wp_localize_script( self::HANDLE, 'wordliftAnalyticsEntityData', $entity_data );
-	}
+        // Uses the analytics code in the main WordLift plugin.
+        wp_localize_script( self::HANDLE, 'wordliftAnalyticsConfigData', $data );
+        wp_localize_script( self::HANDLE, 'wordliftAnalyticsEntityData', $entity_data );
+    }
 }

Spacing +14 added lines, -14 removed lines

@@ -26,32 +26,32 @@ 
 	 *
 	 * @return array
 	 */
-	public static function get_analytics_event_data( $post_id ) {
+	public static function get_analytics_event_data($post_id) {
 		// If no ID was passed get current ID.
-		if ( ! $post_id ) {
+		if ( ! $post_id) {
 			$post_id = get_queried_object_id();
 		}
 		/**
 		 * TODO: set/get this from cache.
 		 */
 		$related_items = array();
-		$related_ids   = wl_core_get_related_entity_ids( $post_id );
+		$related_ids   = wl_core_get_related_entity_ids($post_id);
 
 		$entity_service = Wordlift_Entity_Service::get_instance();
 		// If the current item is also an entity then add it to the list of IDs.
-		if ( $entity_service->is_entity( $post_id ) ) {
+		if ($entity_service->is_entity($post_id)) {
 			$related_ids[] = $post_id;
 		}
 		$entity_type_service = Wordlift_Entity_Type_Service::get_instance();
 		// Get the post titles of related items and connect them in an array.
-		foreach ( $related_ids as $related_id ) {
-			$type  = $entity_type_service->get( $related_id );
-			$type  = isset( $type['uri'] ) ? $type['uri'] : 'unknown';
-			$label = $entity_service->get_labels( $related_id );
+		foreach ($related_ids as $related_id) {
+			$type  = $entity_type_service->get($related_id);
+			$type  = isset($type['uri']) ? $type['uri'] : 'unknown';
+			$label = $entity_service->get_labels($related_id);
 			$label = $label[0];
 
-			$related_items[ $related_id ] = array(
-				'uri'   => $entity_service->get_uri( $related_id ),
+			$related_items[$related_id] = array(
+				'uri'   => $entity_service->get_uri($related_id),
 				'type'  => $type,
 				'label' => $label,
 			);
@@ -87,15 +87,15 @@ 
 	 * @since  3.21.0
 	 */
 	public function enqueue_scripts() {
-		$entity_data = self::get_analytics_event_data( get_the_ID() );
+		$entity_data = self::get_analytics_event_data(get_the_ID());
 		// Bail early if there is no event data that we would send.
-		if ( ! $entity_data ) {
+		if ( ! $entity_data) {
 			return;
 		}
 		$data = self::get_analytics_config_data();
 
 		// Uses the analytics code in the main WordLift plugin.
-		wp_localize_script( self::HANDLE, 'wordliftAnalyticsConfigData', $data );
-		wp_localize_script( self::HANDLE, 'wordliftAnalyticsEntityData', $entity_data );
+		wp_localize_script(self::HANDLE, 'wordliftAnalyticsConfigData', $data);
+		wp_localize_script(self::HANDLE, 'wordliftAnalyticsEntityData', $entity_data);
 	}
 }

src/modules/acf4so/vendor/autoload.php

Spacing +1 added lines, -1 removed lines

@@ -2,6 +2,6 @@
 
 // autoload.php @generated by Composer
 
-require_once __DIR__ . '/composer/autoload_real.php';
+require_once __DIR__.'/composer/autoload_real.php';
 
 return ComposerAutoloaderInit9b4e3e175e03285e60ba6309cc2e3477::getLoader();

src/wordlift/class-object-type-enum.php

Spacing +7 added lines, -7 removed lines

@@ -13,8 +13,8 @@ 
 	// value.
 	const UNKNOWN = 4;
 
-	public static function to_string( $object_type_enum ) {
-		switch ( $object_type_enum ) {
+	public static function to_string($object_type_enum) {
+		switch ($object_type_enum) {
 			case 0:
 				return 'post';
 			case 1:
@@ -30,8 +30,8 @@ 
 		return null;
 	}
 
-	public static function from_string( $object_type_name ) {
-		switch ( $object_type_name ) {
+	public static function from_string($object_type_name) {
+		switch ($object_type_name) {
 			case 'post':
 				return 0;
 			case 'term':
@@ -45,12 +45,12 @@ 
 		return 4;
 	}
 
-	public static function from_wordpress_instance( $instance ) {
-		if ( ! is_object( $instance ) ) {
+	public static function from_wordpress_instance($instance) {
+		if ( ! is_object($instance)) {
 			return null;
 		}
 
-		switch ( get_class( $instance ) ) {
+		switch (get_class($instance)) {
 			case 'WP_Post':
 				return self::POST;
 			case 'WP_Term':

Indentation +49 added lines, -49 removed lines

@@ -4,62 +4,62 @@
 
 class Object_Type_Enum {
 
-	const POST     = 0;
-	const TERM     = 1;
-	const HOMEPAGE = 2;
-	const USER     = 3;
+    const POST     = 0;
+    const TERM     = 1;
+    const HOMEPAGE = 2;
+    const USER     = 3;
 
-	// Enum constant to represent currently unknown
-	// value.
-	const UNKNOWN = 4;
+    // Enum constant to represent currently unknown
+    // value.
+    const UNKNOWN = 4;
 
-	public static function to_string( $object_type_enum ) {
-		switch ( $object_type_enum ) {
-			case 0:
-				return 'post';
-			case 1:
-				return 'term';
-			case 2:
-				return 'home';
-			case 3:
-				return 'user';
-			case 4:
-				return 'unkn';
-		}
+    public static function to_string( $object_type_enum ) {
+        switch ( $object_type_enum ) {
+            case 0:
+                return 'post';
+            case 1:
+                return 'term';
+            case 2:
+                return 'home';
+            case 3:
+                return 'user';
+            case 4:
+                return 'unkn';
+        }
 
-		return null;
-	}
+        return null;
+    }
 
-	public static function from_string( $object_type_name ) {
-		switch ( $object_type_name ) {
-			case 'post':
-				return 0;
-			case 'term':
-				return 1;
-			case 'home':
-				return 2;
-			case 'user':
-				return 3;
-		}
+    public static function from_string( $object_type_name ) {
+        switch ( $object_type_name ) {
+            case 'post':
+                return 0;
+            case 'term':
+                return 1;
+            case 'home':
+                return 2;
+            case 'user':
+                return 3;
+        }
 
-		return 4;
-	}
+        return 4;
+    }
 
-	public static function from_wordpress_instance( $instance ) {
-		if ( ! is_object( $instance ) ) {
-			return null;
-		}
+    public static function from_wordpress_instance( $instance ) {
+        if ( ! is_object( $instance ) ) {
+            return null;
+        }
 
-		switch ( get_class( $instance ) ) {
-			case 'WP_Post':
-				return self::POST;
-			case 'WP_Term':
-				return self::TERM;
-			case 'WP_User':
-				return self::USER;
-		}
+        switch ( get_class( $instance ) ) {
+            case 'WP_Post':
+                return self::POST;
+            case 'WP_Term':
+                return self::TERM;
+            case 'WP_User':
+                return self::USER;
+        }
 
-		return null;
-	}
+        return null;
+    }
 
 }

src/wordlift/api/class-api-service-ext.php

Indentation +4 added lines, -4 removed lines

@@ -3,10 +3,10 @@
 namespace Wordlift\Api;
 
 interface Api_Service_Ext {
-	/**
-	 * @return Me_Response
-	 */
-	public function me();
+    /**
+     * @return Me_Response
+     */
+    public function me();
 }
 
 /**

src/vendor/deliciousbrains/wp-background-processing/classes/wp-background-process.php

Indentation +487 added lines, -487 removed lines

@@ -13,492 +13,492 @@
  */
 abstract class WP_Background_Process extends WP_Async_Request {
 
-	/**
-	 * Action
-	 *
-	 * (default value: 'background_process')
-	 *
-	 * @var string
-	 * @access protected
-	 */
-	protected $action = 'background_process';
-
-	/**
-	 * Start time of current process.
-	 *
-	 * (default value: 0)
-	 *
-	 * @var int
-	 * @access protected
-	 */
-	protected $start_time = 0;
-
-	/**
-	 * Cron_hook_identifier
-	 *
-	 * @var mixed
-	 * @access protected
-	 */
-	protected $cron_hook_identifier;
-
-	/**
-	 * Cron_interval_identifier
-	 *
-	 * @var mixed
-	 * @access protected
-	 */
-	protected $cron_interval_identifier;
-
-	/**
-	 * Initiate new background process
-	 */
-	public function __construct() {
-		parent::__construct();
-
-		$this->cron_hook_identifier     = $this->identifier . '_cron';
-		$this->cron_interval_identifier = $this->identifier . '_cron_interval';
-
-		add_action( $this->cron_hook_identifier, array( $this, 'handle_cron_healthcheck' ) );
-		add_filter( 'cron_schedules', array( $this, 'schedule_cron_healthcheck' ) );
-	}
-
-	/**
-	 * Dispatch
-	 *
-	 * @access public
-	 * @return void
-	 */
-	public function dispatch() {
-		// Schedule the cron healthcheck.
-		$this->schedule_event();
-
-		// Perform remote post.
-		return parent::dispatch();
-	}
-
-	/**
-	 * Push to queue
-	 *
-	 * @param mixed $data Data.
-	 *
-	 * @return $this
-	 */
-	public function push_to_queue( $data ) {
-		$this->data[] = $data;
-
-		return $this;
-	}
-
-	/**
-	 * Save queue
-	 *
-	 * @return $this
-	 */
-	public function save() {
-		$key = $this->generate_key();
-
-		if ( ! empty( $this->data ) ) {
-			update_site_option( $key, $this->data );
-		}
-
-		return $this;
-	}
-
-	/**
-	 * Update queue
-	 *
-	 * @param string $key  Key.
-	 * @param array  $data Data.
-	 *
-	 * @return $this
-	 */
-	public function update( $key, $data ) {
-		if ( ! empty( $data ) ) {
-			update_site_option( $key, $data );
-		}
-
-		return $this;
-	}
-
-	/**
-	 * Delete queue
-	 *
-	 * @param string $key Key.
-	 *
-	 * @return $this
-	 */
-	public function delete( $key ) {
-		delete_site_option( $key );
-
-		return $this;
-	}
-
-	/**
-	 * Generate key
-	 *
-	 * Generates a unique key based on microtime. Queue items are
-	 * given a unique key so that they can be merged upon save.
-	 *
-	 * @param int $length Length.
-	 *
-	 * @return string
-	 */
-	protected function generate_key( $length = 64 ) {
-		$unique  = md5( microtime() . rand() );
-		$prepend = $this->identifier . '_batch_';
-
-		return substr( $prepend . $unique, 0, $length );
-	}
-
-	/**
-	 * Maybe process queue
-	 *
-	 * Checks whether data exists within the queue and that
-	 * the process is not already running.
-	 */
-	public function maybe_handle() {
-		// Don't lock up other requests while processing
-		session_write_close();
-
-		if ( $this->is_process_running() ) {
-			// Background process already running.
-			wp_die();
-		}
-
-		if ( $this->is_queue_empty() ) {
-			// No data to process.
-			wp_die();
-		}
-
-		check_ajax_referer( $this->identifier, 'nonce' );
-
-		$this->handle();
-
-		wp_die();
-	}
-
-	/**
-	 * Is queue empty
-	 *
-	 * @return bool
-	 */
-	protected function is_queue_empty() {
-		global $wpdb;
-
-		$table  = $wpdb->options;
-		$column = '';
-
-		if ( is_multisite() ) {
-			$table  = $wpdb->sitemeta;
-			$column = 'meta_key';
-		}
-
-		$key = $wpdb->esc_like( $this->identifier . '_batch_' ) . '%';
-
-		$count = $wpdb->get_var(
-			$wpdb->prepare(
-				"SELECT COUNT(*) FROM {$table} WHERE {$column} LIKE %s", // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-				$key
-			)
-		);
-
-		return ( $count > 0 ) ? false : true;
-	}
-
-	/**
-	 * Is process running
-	 *
-	 * Check whether the current process is already running
-	 * in a background process.
-	 */
-	protected function is_process_running() {
-		if ( get_site_transient( $this->identifier . '_process_lock' ) ) {
-			// Process already running.
-			return true;
-		}
-
-		return false;
-	}
-
-	/**
-	 * Lock process
-	 *
-	 * Lock the process so that multiple instances can't run simultaneously.
-	 * Override if applicable, but the duration should be greater than that
-	 * defined in the time_exceeded() method.
-	 */
-	protected function lock_process() {
-		$this->start_time = time(); // Set start time of current process.
-
-		$lock_duration = ( property_exists( $this, 'queue_lock_time' ) ) ? $this->queue_lock_time : 60; // 1 minute
-		$lock_duration = apply_filters( $this->identifier . '_queue_lock_time', $lock_duration );
-
-		set_site_transient( $this->identifier . '_process_lock', microtime(), $lock_duration );
-	}
-
-	/**
-	 * Unlock process
-	 *
-	 * Unlock the process so that other instances can spawn.
-	 *
-	 * @return $this
-	 */
-	protected function unlock_process() {
-		delete_site_transient( $this->identifier . '_process_lock' );
-
-		return $this;
-	}
-
-	/**
-	 * Get batch
-	 *
-	 * @return stdClass Return the first batch from the queue
-	 */
-	protected function get_batch() {
-		global $wpdb;
-
-		$table        = $wpdb->options;
-		$column       = 'option_name';
-		$key_column   = 'option_id';
-		$value_column = 'option_value';
-
-		if ( is_multisite() ) {
-			$table        = $wpdb->sitemeta;
-			$column       = 'meta_key';
-			$key_column   = 'meta_id';
-			$value_column = 'meta_value';
-		}
-
-		$key = $wpdb->esc_like( $this->identifier . '_batch_' ) . '%';
-
-		$query = $wpdb->get_row(
-			$wpdb->prepare(
-				"SELECT * FROM {$table} WHERE {$column} LIKE %s ORDER BY {$key_column} ASC LIMIT 1", // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-				$key
-			)
-		);
-
-		$batch       = new stdClass();
-		$batch->key  = $query->$column;
-		$batch->data = maybe_unserialize( $query->$value_column );
-
-		return $batch;
-	}
-
-	/**
-	 * Handle
-	 *
-	 * Pass each queue item to the task handler, while remaining
-	 * within server memory and time limit constraints.
-	 */
-	protected function handle() {
-		$this->lock_process();
-
-		do {
-			$batch = $this->get_batch();
-
-			foreach ( $batch->data as $key => $value ) {
-				$task = $this->task( $value );
-
-				if ( false !== $task ) {
-					$batch->data[ $key ] = $task;
-				} else {
-					unset( $batch->data[ $key ] );
-				}
-
-				if ( $this->time_exceeded() || $this->memory_exceeded() ) {
-					// Batch limits reached.
-					break;
-				}
-			}
-
-			// Update or delete current batch.
-			if ( ! empty( $batch->data ) ) {
-				$this->update( $batch->key, $batch->data );
-			} else {
-				$this->delete( $batch->key );
-			}
-		} while ( ! $this->time_exceeded() && ! $this->memory_exceeded() && ! $this->is_queue_empty() );
-
-		$this->unlock_process();
-
-		// Start next batch or complete process.
-		if ( ! $this->is_queue_empty() ) {
-			$this->dispatch();
-		} else {
-			$this->complete();
-		}
-
-		wp_die();
-	}
-
-	/**
-	 * Memory exceeded
-	 *
-	 * Ensures the batch process never exceeds 90%
-	 * of the maximum WordPress memory.
-	 *
-	 * @return bool
-	 */
-	protected function memory_exceeded() {
-		$memory_limit   = $this->get_memory_limit() * 0.9; // 90% of max memory
-		$current_memory = memory_get_usage( true );
-		$return         = false;
-
-		if ( $current_memory >= $memory_limit ) {
-			$return = true;
-		}
-
-		return apply_filters( $this->identifier . '_memory_exceeded', $return );
-	}
-
-	/**
-	 * Get memory limit
-	 *
-	 * @return int
-	 */
-	protected function get_memory_limit() {
-		if ( function_exists( 'ini_get' ) ) {
-			$memory_limit = ini_get( 'memory_limit' );
-		} else {
-			// Sensible default.
-			$memory_limit = '128M';
-		}
-
-		if ( ! $memory_limit || - 1 === intval( $memory_limit ) ) {
-			// Unlimited, set to 32GB.
-			$memory_limit = '32000M';
-		}
-
-		return wp_convert_hr_to_bytes( $memory_limit );
-	}
-
-	/**
-	 * Time exceeded.
-	 *
-	 * Ensures the batch never exceeds a sensible time limit.
-	 * A timeout limit of 30s is common on shared hosting.
-	 *
-	 * @return bool
-	 */
-	protected function time_exceeded() {
-		$finish = $this->start_time + apply_filters( $this->identifier . '_default_time_limit', 20 ); // 20 seconds
-		$return = false;
-
-		if ( time() >= $finish ) {
-			$return = true;
-		}
-
-		return apply_filters( $this->identifier . '_time_exceeded', $return );
-	}
-
-	/**
-	 * Complete.
-	 *
-	 * Override if applicable, but ensure that the below actions are
-	 * performed, or, call parent::complete().
-	 */
-	protected function complete() {
-		// Unschedule the cron healthcheck.
-		$this->clear_scheduled_event();
-	}
-
-	/**
-	 * Schedule cron healthcheck
-	 *
-	 * @access public
-	 *
-	 * @param mixed $schedules Schedules.
-	 *
-	 * @return mixed
-	 */
-	public function schedule_cron_healthcheck( $schedules ) {
-		$interval = apply_filters( $this->identifier . '_cron_interval', 5 );
-
-		if ( property_exists( $this, 'cron_interval' ) ) {
-			$interval = apply_filters( $this->identifier . '_cron_interval', $this->cron_interval );
-		}
-
-		// Adds every 5 minutes to the existing schedules.
-		$schedules[ $this->identifier . '_cron_interval' ] = array(
-			'interval' => MINUTE_IN_SECONDS * $interval,
-			'display'  => sprintf( __( 'Every %d Minutes' ), $interval ),
-		);
-
-		return $schedules;
-	}
-
-	/**
-	 * Handle cron healthcheck
-	 *
-	 * Restart the background process if not already running
-	 * and data exists in the queue.
-	 */
-	public function handle_cron_healthcheck() {
-		if ( $this->is_process_running() ) {
-			// Background process already running.
-			exit;
-		}
-
-		if ( $this->is_queue_empty() ) {
-			// No data to process.
-			$this->clear_scheduled_event();
-			exit;
-		}
-
-		$this->handle();
-
-		exit;
-	}
-
-	/**
-	 * Schedule event
-	 */
-	protected function schedule_event() {
-		if ( ! wp_next_scheduled( $this->cron_hook_identifier ) ) {
-			wp_schedule_event( time(), $this->cron_interval_identifier, $this->cron_hook_identifier );
-		}
-	}
-
-	/**
-	 * Clear scheduled event
-	 */
-	protected function clear_scheduled_event() {
-		$timestamp = wp_next_scheduled( $this->cron_hook_identifier );
-
-		if ( $timestamp ) {
-			wp_unschedule_event( $timestamp, $this->cron_hook_identifier );
-		}
-	}
-
-	/**
-	 * Cancel Process
-	 *
-	 * Stop processing queue items, clear cronjob and delete batch.
-	 */
-	public function cancel_process() {
-		if ( ! $this->is_queue_empty() ) {
-			$batch = $this->get_batch();
-
-			$this->delete( $batch->key );
-
-			wp_clear_scheduled_hook( $this->cron_hook_identifier );
-		}
-
-	}
-
-	/**
-	 * Task
-	 *
-	 * Override this method to perform any actions required on each
-	 * queue item. Return the modified item for further processing
-	 * in the next pass through. Or, return false to remove the
-	 * item from the queue.
-	 *
-	 * @param mixed $item Queue item to iterate over.
-	 *
-	 * @return mixed
-	 */
-	abstract protected function task( $item );
+    /**
+     * Action
+     *
+     * (default value: 'background_process')
+     *
+     * @var string
+     * @access protected
+     */
+    protected $action = 'background_process';
+
+    /**
+     * Start time of current process.
+     *
+     * (default value: 0)
+     *
+     * @var int
+     * @access protected
+     */
+    protected $start_time = 0;
+
+    /**
+     * Cron_hook_identifier
+     *
+     * @var mixed
+     * @access protected
+     */
+    protected $cron_hook_identifier;
+
+    /**
+     * Cron_interval_identifier
+     *
+     * @var mixed
+     * @access protected
+     */
+    protected $cron_interval_identifier;
+
+    /**
+     * Initiate new background process
+     */
+    public function __construct() {
+        parent::__construct();
+
+        $this->cron_hook_identifier     = $this->identifier . '_cron';
+        $this->cron_interval_identifier = $this->identifier . '_cron_interval';
+
+        add_action( $this->cron_hook_identifier, array( $this, 'handle_cron_healthcheck' ) );
+        add_filter( 'cron_schedules', array( $this, 'schedule_cron_healthcheck' ) );
+    }
+
+    /**
+     * Dispatch
+     *
+     * @access public
+     * @return void
+     */
+    public function dispatch() {
+        // Schedule the cron healthcheck.
+        $this->schedule_event();
+
+        // Perform remote post.
+        return parent::dispatch();
+    }
+
+    /**
+     * Push to queue
+     *
+     * @param mixed $data Data.
+     *
+     * @return $this
+     */
+    public function push_to_queue( $data ) {
+        $this->data[] = $data;
+
+        return $this;
+    }
+
+    /**
+     * Save queue
+     *
+     * @return $this
+     */
+    public function save() {
+        $key = $this->generate_key();
+
+        if ( ! empty( $this->data ) ) {
+            update_site_option( $key, $this->data );
+        }
+
+        return $this;
+    }
+
+    /**
+     * Update queue
+     *
+     * @param string $key  Key.
+     * @param array  $data Data.
+     *
+     * @return $this
+     */
+    public function update( $key, $data ) {
+        if ( ! empty( $data ) ) {
+            update_site_option( $key, $data );
+        }
+
+        return $this;
+    }
+
+    /**
+     * Delete queue
+     *
+     * @param string $key Key.
+     *
+     * @return $this
+     */
+    public function delete( $key ) {
+        delete_site_option( $key );
+
+        return $this;
+    }
+
+    /**
+     * Generate key
+     *
+     * Generates a unique key based on microtime. Queue items are
+     * given a unique key so that they can be merged upon save.
+     *
+     * @param int $length Length.
+     *
+     * @return string
+     */
+    protected function generate_key( $length = 64 ) {
+        $unique  = md5( microtime() . rand() );
+        $prepend = $this->identifier . '_batch_';
+
+        return substr( $prepend . $unique, 0, $length );
+    }
+
+    /**
+     * Maybe process queue
+     *
+     * Checks whether data exists within the queue and that
+     * the process is not already running.
+     */
+    public function maybe_handle() {
+        // Don't lock up other requests while processing
+        session_write_close();
+
+        if ( $this->is_process_running() ) {
+            // Background process already running.
+            wp_die();
+        }
+
+        if ( $this->is_queue_empty() ) {
+            // No data to process.
+            wp_die();
+        }
+
+        check_ajax_referer( $this->identifier, 'nonce' );
+
+        $this->handle();
+
+        wp_die();
+    }
+
+    /**
+     * Is queue empty
+     *
+     * @return bool
+     */
+    protected function is_queue_empty() {
+        global $wpdb;
+
+        $table  = $wpdb->options;
+        $column = '';
+
+        if ( is_multisite() ) {
+            $table  = $wpdb->sitemeta;
+            $column = 'meta_key';
+        }
+
+        $key = $wpdb->esc_like( $this->identifier . '_batch_' ) . '%';
+
+        $count = $wpdb->get_var(
+            $wpdb->prepare(
+                "SELECT COUNT(*) FROM {$table} WHERE {$column} LIKE %s", // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
+                $key
+            )
+        );
+
+        return ( $count > 0 ) ? false : true;
+    }
+
+    /**
+     * Is process running
+     *
+     * Check whether the current process is already running
+     * in a background process.
+     */
+    protected function is_process_running() {
+        if ( get_site_transient( $this->identifier . '_process_lock' ) ) {
+            // Process already running.
+            return true;
+        }
+
+        return false;
+    }
+
+    /**
+     * Lock process
+     *
+     * Lock the process so that multiple instances can't run simultaneously.
+     * Override if applicable, but the duration should be greater than that
+     * defined in the time_exceeded() method.
+     */
+    protected function lock_process() {
+        $this->start_time = time(); // Set start time of current process.
+
+        $lock_duration = ( property_exists( $this, 'queue_lock_time' ) ) ? $this->queue_lock_time : 60; // 1 minute
+        $lock_duration = apply_filters( $this->identifier . '_queue_lock_time', $lock_duration );
+
+        set_site_transient( $this->identifier . '_process_lock', microtime(), $lock_duration );
+    }
+
+    /**
+     * Unlock process
+     *
+     * Unlock the process so that other instances can spawn.
+     *
+     * @return $this
+     */
+    protected function unlock_process() {
+        delete_site_transient( $this->identifier . '_process_lock' );
+
+        return $this;
+    }
+
+    /**
+     * Get batch
+     *
+     * @return stdClass Return the first batch from the queue
+     */
+    protected function get_batch() {
+        global $wpdb;
+
+        $table        = $wpdb->options;
+        $column       = 'option_name';
+        $key_column   = 'option_id';
+        $value_column = 'option_value';
+
+        if ( is_multisite() ) {
+            $table        = $wpdb->sitemeta;
+            $column       = 'meta_key';
+            $key_column   = 'meta_id';
+            $value_column = 'meta_value';
+        }
+
+        $key = $wpdb->esc_like( $this->identifier . '_batch_' ) . '%';
+
+        $query = $wpdb->get_row(
+            $wpdb->prepare(
+                "SELECT * FROM {$table} WHERE {$column} LIKE %s ORDER BY {$key_column} ASC LIMIT 1", // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
+                $key
+            )
+        );
+
+        $batch       = new stdClass();
+        $batch->key  = $query->$column;
+        $batch->data = maybe_unserialize( $query->$value_column );
+
+        return $batch;
+    }
+
+    /**
+     * Handle
+     *
+     * Pass each queue item to the task handler, while remaining
+     * within server memory and time limit constraints.
+     */
+    protected function handle() {
+        $this->lock_process();
+
+        do {
+            $batch = $this->get_batch();
+
+            foreach ( $batch->data as $key => $value ) {
+                $task = $this->task( $value );
+
+                if ( false !== $task ) {
+                    $batch->data[ $key ] = $task;
+                } else {
+                    unset( $batch->data[ $key ] );
+                }
+
+                if ( $this->time_exceeded() || $this->memory_exceeded() ) {
+                    // Batch limits reached.
+                    break;
+                }
+            }
+
+            // Update or delete current batch.
+            if ( ! empty( $batch->data ) ) {
+                $this->update( $batch->key, $batch->data );
+            } else {
+                $this->delete( $batch->key );
+            }
+        } while ( ! $this->time_exceeded() && ! $this->memory_exceeded() && ! $this->is_queue_empty() );
+
+        $this->unlock_process();
+
+        // Start next batch or complete process.
+        if ( ! $this->is_queue_empty() ) {
+            $this->dispatch();
+        } else {
+            $this->complete();
+        }
+
+        wp_die();
+    }
+
+    /**
+     * Memory exceeded
+     *
+     * Ensures the batch process never exceeds 90%
+     * of the maximum WordPress memory.
+     *
+     * @return bool
+     */
+    protected function memory_exceeded() {
+        $memory_limit   = $this->get_memory_limit() * 0.9; // 90% of max memory
+        $current_memory = memory_get_usage( true );
+        $return         = false;
+
+        if ( $current_memory >= $memory_limit ) {
+            $return = true;
+        }
+
+        return apply_filters( $this->identifier . '_memory_exceeded', $return );
+    }
+
+    /**
+     * Get memory limit
+     *
+     * @return int
+     */
+    protected function get_memory_limit() {
+        if ( function_exists( 'ini_get' ) ) {
+            $memory_limit = ini_get( 'memory_limit' );
+        } else {
+            // Sensible default.
+            $memory_limit = '128M';
+        }
+
+        if ( ! $memory_limit || - 1 === intval( $memory_limit ) ) {
+            // Unlimited, set to 32GB.
+            $memory_limit = '32000M';
+        }
+
+        return wp_convert_hr_to_bytes( $memory_limit );
+    }
+
+    /**
+     * Time exceeded.
+     *
+     * Ensures the batch never exceeds a sensible time limit.
+     * A timeout limit of 30s is common on shared hosting.
+     *
+     * @return bool
+     */
+    protected function time_exceeded() {
+        $finish = $this->start_time + apply_filters( $this->identifier . '_default_time_limit', 20 ); // 20 seconds
+        $return = false;
+
+        if ( time() >= $finish ) {
+            $return = true;
+        }
+
+        return apply_filters( $this->identifier . '_time_exceeded', $return );
+    }
+
+    /**
+     * Complete.
+     *
+     * Override if applicable, but ensure that the below actions are
+     * performed, or, call parent::complete().
+     */
+    protected function complete() {
+        // Unschedule the cron healthcheck.
+        $this->clear_scheduled_event();
+    }
+
+    /**
+     * Schedule cron healthcheck
+     *
+     * @access public
+     *
+     * @param mixed $schedules Schedules.
+     *
+     * @return mixed
+     */
+    public function schedule_cron_healthcheck( $schedules ) {
+        $interval = apply_filters( $this->identifier . '_cron_interval', 5 );
+
+        if ( property_exists( $this, 'cron_interval' ) ) {
+            $interval = apply_filters( $this->identifier . '_cron_interval', $this->cron_interval );
+        }
+
+        // Adds every 5 minutes to the existing schedules.
+        $schedules[ $this->identifier . '_cron_interval' ] = array(
+            'interval' => MINUTE_IN_SECONDS * $interval,
+            'display'  => sprintf( __( 'Every %d Minutes' ), $interval ),
+        );
+
+        return $schedules;
+    }
+
+    /**
+     * Handle cron healthcheck
+     *
+     * Restart the background process if not already running
+     * and data exists in the queue.
+     */
+    public function handle_cron_healthcheck() {
+        if ( $this->is_process_running() ) {
+            // Background process already running.
+            exit;
+        }
+
+        if ( $this->is_queue_empty() ) {
+            // No data to process.
+            $this->clear_scheduled_event();
+            exit;
+        }
+
+        $this->handle();
+
+        exit;
+    }
+
+    /**
+     * Schedule event
+     */
+    protected function schedule_event() {
+        if ( ! wp_next_scheduled( $this->cron_hook_identifier ) ) {
+            wp_schedule_event( time(), $this->cron_interval_identifier, $this->cron_hook_identifier );
+        }
+    }
+
+    /**
+     * Clear scheduled event
+     */
+    protected function clear_scheduled_event() {
+        $timestamp = wp_next_scheduled( $this->cron_hook_identifier );
+
+        if ( $timestamp ) {
+            wp_unschedule_event( $timestamp, $this->cron_hook_identifier );
+        }
+    }
+
+    /**
+     * Cancel Process
+     *
+     * Stop processing queue items, clear cronjob and delete batch.
+     */
+    public function cancel_process() {
+        if ( ! $this->is_queue_empty() ) {
+            $batch = $this->get_batch();
+
+            $this->delete( $batch->key );
+
+            wp_clear_scheduled_hook( $this->cron_hook_identifier );
+        }
+
+    }
+
+    /**
+     * Task
+     *
+     * Override this method to perform any actions required on each
+     * queue item. Return the modified item for further processing
+     * in the next pass through. Or, return false to remove the
+     * item from the queue.
+     *
+     * @param mixed $item Queue item to iterate over.
+     *
+     * @return mixed
+     */
+    abstract protected function task( $item );
 
 }

Spacing +68 added lines, -68 removed lines

@@ -55,11 +55,11 @@ 
 	public function __construct() {
 		parent::__construct();
 
-		$this->cron_hook_identifier     = $this->identifier . '_cron';
-		$this->cron_interval_identifier = $this->identifier . '_cron_interval';
+		$this->cron_hook_identifier     = $this->identifier.'_cron';
+		$this->cron_interval_identifier = $this->identifier.'_cron_interval';
 
-		add_action( $this->cron_hook_identifier, array( $this, 'handle_cron_healthcheck' ) );
-		add_filter( 'cron_schedules', array( $this, 'schedule_cron_healthcheck' ) );
+		add_action($this->cron_hook_identifier, array($this, 'handle_cron_healthcheck'));
+		add_filter('cron_schedules', array($this, 'schedule_cron_healthcheck'));
 	}
 
 	/**
@@ -83,7 +83,7 @@ 
 	 *
 	 * @return $this
 	 */
-	public function push_to_queue( $data ) {
+	public function push_to_queue($data) {
 		$this->data[] = $data;
 
 		return $this;
@@ -97,8 +97,8 @@ 
 	public function save() {
 		$key = $this->generate_key();
 
-		if ( ! empty( $this->data ) ) {
-			update_site_option( $key, $this->data );
+		if ( ! empty($this->data)) {
+			update_site_option($key, $this->data);
 		}
 
 		return $this;
@@ -112,9 +112,9 @@ 
 	 *
 	 * @return $this
 	 */
-	public function update( $key, $data ) {
-		if ( ! empty( $data ) ) {
-			update_site_option( $key, $data );
+	public function update($key, $data) {
+		if ( ! empty($data)) {
+			update_site_option($key, $data);
 		}
 
 		return $this;
@@ -127,8 +127,8 @@ 
 	 *
 	 * @return $this
 	 */
-	public function delete( $key ) {
-		delete_site_option( $key );
+	public function delete($key) {
+		delete_site_option($key);
 
 		return $this;
 	}
@@ -143,11 +143,11 @@ 
 	 *
 	 * @return string
 	 */
-	protected function generate_key( $length = 64 ) {
-		$unique  = md5( microtime() . rand() );
-		$prepend = $this->identifier . '_batch_';
+	protected function generate_key($length = 64) {
+		$unique  = md5(microtime().rand());
+		$prepend = $this->identifier.'_batch_';
 
-		return substr( $prepend . $unique, 0, $length );
+		return substr($prepend.$unique, 0, $length);
 	}
 
 	/**
@@ -160,17 +160,17 @@ 
 		// Don't lock up other requests while processing
 		session_write_close();
 
-		if ( $this->is_process_running() ) {
+		if ($this->is_process_running()) {
 			// Background process already running.
 			wp_die();
 		}
 
-		if ( $this->is_queue_empty() ) {
+		if ($this->is_queue_empty()) {
 			// No data to process.
 			wp_die();
 		}
 
-		check_ajax_referer( $this->identifier, 'nonce' );
+		check_ajax_referer($this->identifier, 'nonce');
 
 		$this->handle();
 
@@ -188,12 +188,12 @@ 
 		$table  = $wpdb->options;
 		$column = '';
 
-		if ( is_multisite() ) {
+		if (is_multisite()) {
 			$table  = $wpdb->sitemeta;
 			$column = 'meta_key';
 		}
 
-		$key = $wpdb->esc_like( $this->identifier . '_batch_' ) . '%';
+		$key = $wpdb->esc_like($this->identifier.'_batch_').'%';
 
 		$count = $wpdb->get_var(
 			$wpdb->prepare(
@@ -202,7 +202,7 @@ 
 			)
 		);
 
-		return ( $count > 0 ) ? false : true;
+		return ($count > 0) ? false : true;
 	}
 
 	/**
@@ -212,7 +212,7 @@ 
 	 * in a background process.
 	 */
 	protected function is_process_running() {
-		if ( get_site_transient( $this->identifier . '_process_lock' ) ) {
+		if (get_site_transient($this->identifier.'_process_lock')) {
 			// Process already running.
 			return true;
 		}
@@ -230,10 +230,10 @@ 
 	protected function lock_process() {
 		$this->start_time = time(); // Set start time of current process.
 
-		$lock_duration = ( property_exists( $this, 'queue_lock_time' ) ) ? $this->queue_lock_time : 60; // 1 minute
-		$lock_duration = apply_filters( $this->identifier . '_queue_lock_time', $lock_duration );
+		$lock_duration = (property_exists($this, 'queue_lock_time')) ? $this->queue_lock_time : 60; // 1 minute
+		$lock_duration = apply_filters($this->identifier.'_queue_lock_time', $lock_duration);
 
-		set_site_transient( $this->identifier . '_process_lock', microtime(), $lock_duration );
+		set_site_transient($this->identifier.'_process_lock', microtime(), $lock_duration);
 	}
 
 	/**
@@ -244,7 +244,7 @@ 
 	 * @return $this
 	 */
 	protected function unlock_process() {
-		delete_site_transient( $this->identifier . '_process_lock' );
+		delete_site_transient($this->identifier.'_process_lock');
 
 		return $this;
 	}
@@ -262,14 +262,14 @@ 
 		$key_column   = 'option_id';
 		$value_column = 'option_value';
 
-		if ( is_multisite() ) {
+		if (is_multisite()) {
 			$table        = $wpdb->sitemeta;
 			$column       = 'meta_key';
 			$key_column   = 'meta_id';
 			$value_column = 'meta_value';
 		}
 
-		$key = $wpdb->esc_like( $this->identifier . '_batch_' ) . '%';
+		$key = $wpdb->esc_like($this->identifier.'_batch_').'%';
 
 		$query = $wpdb->get_row(
 			$wpdb->prepare(
@@ -280,7 +280,7 @@ 
 
 		$batch       = new stdClass();
 		$batch->key  = $query->$column;
-		$batch->data = maybe_unserialize( $query->$value_column );
+		$batch->data = maybe_unserialize($query->$value_column);
 
 		return $batch;
 	}
@@ -297,33 +297,33 @@ 
 		do {
 			$batch = $this->get_batch();
 
-			foreach ( $batch->data as $key => $value ) {
-				$task = $this->task( $value );
+			foreach ($batch->data as $key => $value) {
+				$task = $this->task($value);
 
-				if ( false !== $task ) {
-					$batch->data[ $key ] = $task;
+				if (false !== $task) {
+					$batch->data[$key] = $task;
 				} else {
-					unset( $batch->data[ $key ] );
+					unset($batch->data[$key]);
 				}
 
-				if ( $this->time_exceeded() || $this->memory_exceeded() ) {
+				if ($this->time_exceeded() || $this->memory_exceeded()) {
 					// Batch limits reached.
 					break;
 				}
 			}
 
 			// Update or delete current batch.
-			if ( ! empty( $batch->data ) ) {
-				$this->update( $batch->key, $batch->data );
+			if ( ! empty($batch->data)) {
+				$this->update($batch->key, $batch->data);
 			} else {
-				$this->delete( $batch->key );
+				$this->delete($batch->key);
 			}
-		} while ( ! $this->time_exceeded() && ! $this->memory_exceeded() && ! $this->is_queue_empty() );
+		} while ( ! $this->time_exceeded() && ! $this->memory_exceeded() && ! $this->is_queue_empty());
 
 		$this->unlock_process();
 
 		// Start next batch or complete process.
-		if ( ! $this->is_queue_empty() ) {
+		if ( ! $this->is_queue_empty()) {
 			$this->dispatch();
 		} else {
 			$this->complete();
@@ -342,14 +342,14 @@ 
 	 */
 	protected function memory_exceeded() {
 		$memory_limit   = $this->get_memory_limit() * 0.9; // 90% of max memory
-		$current_memory = memory_get_usage( true );
+		$current_memory = memory_get_usage(true);
 		$return         = false;
 
-		if ( $current_memory >= $memory_limit ) {
+		if ($current_memory >= $memory_limit) {
 			$return = true;
 		}
 
-		return apply_filters( $this->identifier . '_memory_exceeded', $return );
+		return apply_filters($this->identifier.'_memory_exceeded', $return);
 	}
 
 	/**
@@ -358,19 +358,19 @@ 
 	 * @return int
 	 */
 	protected function get_memory_limit() {
-		if ( function_exists( 'ini_get' ) ) {
-			$memory_limit = ini_get( 'memory_limit' );
+		if (function_exists('ini_get')) {
+			$memory_limit = ini_get('memory_limit');
 		} else {
 			// Sensible default.
 			$memory_limit = '128M';
 		}
 
-		if ( ! $memory_limit || - 1 === intval( $memory_limit ) ) {
+		if ( ! $memory_limit || - 1 === intval($memory_limit)) {
 			// Unlimited, set to 32GB.
 			$memory_limit = '32000M';
 		}
 
-		return wp_convert_hr_to_bytes( $memory_limit );
+		return wp_convert_hr_to_bytes($memory_limit);
 	}
 
 	/**
@@ -382,14 +382,14 @@ 
 	 * @return bool
 	 */
 	protected function time_exceeded() {
-		$finish = $this->start_time + apply_filters( $this->identifier . '_default_time_limit', 20 ); // 20 seconds
+		$finish = $this->start_time + apply_filters($this->identifier.'_default_time_limit', 20); // 20 seconds
 		$return = false;
 
-		if ( time() >= $finish ) {
+		if (time() >= $finish) {
 			$return = true;
 		}
 
-		return apply_filters( $this->identifier . '_time_exceeded', $return );
+		return apply_filters($this->identifier.'_time_exceeded', $return);
 	}
 
 	/**
@@ -412,17 +412,17 @@ 
 	 *
 	 * @return mixed
 	 */
-	public function schedule_cron_healthcheck( $schedules ) {
-		$interval = apply_filters( $this->identifier . '_cron_interval', 5 );
+	public function schedule_cron_healthcheck($schedules) {
+		$interval = apply_filters($this->identifier.'_cron_interval', 5);
 
-		if ( property_exists( $this, 'cron_interval' ) ) {
-			$interval = apply_filters( $this->identifier . '_cron_interval', $this->cron_interval );
+		if (property_exists($this, 'cron_interval')) {
+			$interval = apply_filters($this->identifier.'_cron_interval', $this->cron_interval);
 		}
 
 		// Adds every 5 minutes to the existing schedules.
-		$schedules[ $this->identifier . '_cron_interval' ] = array(
+		$schedules[$this->identifier.'_cron_interval'] = array(
 			'interval' => MINUTE_IN_SECONDS * $interval,
-			'display'  => sprintf( __( 'Every %d Minutes' ), $interval ),
+			'display'  => sprintf(__('Every %d Minutes'), $interval),
 		);
 
 		return $schedules;
@@ -435,12 +435,12 @@ 
 	 * and data exists in the queue.
 	 */
 	public function handle_cron_healthcheck() {
-		if ( $this->is_process_running() ) {
+		if ($this->is_process_running()) {
 			// Background process already running.
 			exit;
 		}
 
-		if ( $this->is_queue_empty() ) {
+		if ($this->is_queue_empty()) {
 			// No data to process.
 			$this->clear_scheduled_event();
 			exit;
@@ -455,8 +455,8 @@ 
 	 * Schedule event
 	 */
 	protected function schedule_event() {
-		if ( ! wp_next_scheduled( $this->cron_hook_identifier ) ) {
-			wp_schedule_event( time(), $this->cron_interval_identifier, $this->cron_hook_identifier );
+		if ( ! wp_next_scheduled($this->cron_hook_identifier)) {
+			wp_schedule_event(time(), $this->cron_interval_identifier, $this->cron_hook_identifier);
 		}
 	}
 
@@ -464,10 +464,10 @@ 
 	 * Clear scheduled event
 	 */
 	protected function clear_scheduled_event() {
-		$timestamp = wp_next_scheduled( $this->cron_hook_identifier );
+		$timestamp = wp_next_scheduled($this->cron_hook_identifier);
 
-		if ( $timestamp ) {
-			wp_unschedule_event( $timestamp, $this->cron_hook_identifier );
+		if ($timestamp) {
+			wp_unschedule_event($timestamp, $this->cron_hook_identifier);
 		}
 	}
 
@@ -477,12 +477,12 @@ 
 	 * Stop processing queue items, clear cronjob and delete batch.
 	 */
 	public function cancel_process() {
-		if ( ! $this->is_queue_empty() ) {
+		if ( ! $this->is_queue_empty()) {
 			$batch = $this->get_batch();
 
-			$this->delete( $batch->key );
+			$this->delete($batch->key);
 
-			wp_clear_scheduled_hook( $this->cron_hook_identifier );
+			wp_clear_scheduled_hook($this->cron_hook_identifier);
 		}
 
 	}
@@ -499,6 +499,6 @@ 
 	 *
 	 * @return mixed
 	 */
-	abstract protected function task( $item );
+	abstract protected function task($item);
 
 }

src/vendor/composer/platform_check.php

Indentation +15 added lines, -15 removed lines

@@ -5,22 +5,22 @@
 $issues = array();
 
 if ( ! ( PHP_VERSION_ID >= 50200 ) ) {
-	$issues[] = 'Your Composer dependencies require a PHP version ">= 5.2.0". You are running ' . PHP_VERSION . '.';
+    $issues[] = 'Your Composer dependencies require a PHP version ">= 5.2.0". You are running ' . PHP_VERSION . '.';
 }
 
 if ( $issues ) {
-	if ( ! headers_sent() ) {
-		header( 'HTTP/1.1 500 Internal Server Error' );
-	}
-	if ( ! ini_get( 'display_errors' ) ) {
-		if ( PHP_SAPI === 'cli' || PHP_SAPI === 'phpdbg' ) {
-			fwrite( STDERR, 'Composer detected issues in your platform:' . PHP_EOL . PHP_EOL . implode( PHP_EOL, $issues ) . PHP_EOL . PHP_EOL );
-		} elseif ( ! headers_sent() ) {
-			echo 'Composer detected issues in your platform:' . PHP_EOL . PHP_EOL . str_replace( 'You are running ' . PHP_VERSION . '.', '', implode( PHP_EOL, $issues ) ) . PHP_EOL . PHP_EOL;
-		}
-	}
-	trigger_error(
-		'Composer detected issues in your platform: ' . implode( ' ', $issues ),
-		E_USER_ERROR
-	);
+    if ( ! headers_sent() ) {
+        header( 'HTTP/1.1 500 Internal Server Error' );
+    }
+    if ( ! ini_get( 'display_errors' ) ) {
+        if ( PHP_SAPI === 'cli' || PHP_SAPI === 'phpdbg' ) {
+            fwrite( STDERR, 'Composer detected issues in your platform:' . PHP_EOL . PHP_EOL . implode( PHP_EOL, $issues ) . PHP_EOL . PHP_EOL );
+        } elseif ( ! headers_sent() ) {
+            echo 'Composer detected issues in your platform:' . PHP_EOL . PHP_EOL . str_replace( 'You are running ' . PHP_VERSION . '.', '', implode( PHP_EOL, $issues ) ) . PHP_EOL . PHP_EOL;
+        }
+    }
+    trigger_error(
+        'Composer detected issues in your platform: ' . implode( ' ', $issues ),
+        E_USER_ERROR
+    );
 }

Spacing +11 added lines, -11 removed lines

@@ -4,23 +4,23 @@
 
 $issues = array();
 
-if ( ! ( PHP_VERSION_ID >= 50200 ) ) {
-	$issues[] = 'Your Composer dependencies require a PHP version ">= 5.2.0". You are running ' . PHP_VERSION . '.';
+if ( ! (PHP_VERSION_ID >= 50200)) {
+	$issues[] = 'Your Composer dependencies require a PHP version ">= 5.2.0". You are running '.PHP_VERSION.'.';
 }
 
-if ( $issues ) {
-	if ( ! headers_sent() ) {
-		header( 'HTTP/1.1 500 Internal Server Error' );
+if ($issues) {
+	if ( ! headers_sent()) {
+		header('HTTP/1.1 500 Internal Server Error');
 	}
-	if ( ! ini_get( 'display_errors' ) ) {
-		if ( PHP_SAPI === 'cli' || PHP_SAPI === 'phpdbg' ) {
-			fwrite( STDERR, 'Composer detected issues in your platform:' . PHP_EOL . PHP_EOL . implode( PHP_EOL, $issues ) . PHP_EOL . PHP_EOL );
-		} elseif ( ! headers_sent() ) {
-			echo 'Composer detected issues in your platform:' . PHP_EOL . PHP_EOL . str_replace( 'You are running ' . PHP_VERSION . '.', '', implode( PHP_EOL, $issues ) ) . PHP_EOL . PHP_EOL;
+	if ( ! ini_get('display_errors')) {
+		if (PHP_SAPI === 'cli' || PHP_SAPI === 'phpdbg') {
+			fwrite(STDERR, 'Composer detected issues in your platform:'.PHP_EOL.PHP_EOL.implode(PHP_EOL, $issues).PHP_EOL.PHP_EOL);
+		} elseif ( ! headers_sent()) {
+			echo 'Composer detected issues in your platform:'.PHP_EOL.PHP_EOL.str_replace('You are running '.PHP_VERSION.'.', '', implode(PHP_EOL, $issues)).PHP_EOL.PHP_EOL;
 		}
 	}
 	trigger_error(
-		'Composer detected issues in your platform: ' . implode( ' ', $issues ),
+		'Composer detected issues in your platform: '.implode(' ', $issues),
 		E_USER_ERROR
 	);
 }