iqltechnologies / brighty

plugins/woocommerce/packages/action-scheduler/classes/ActionScheduler_Compatibility.php

Indentation +87 added lines, -87 removed lines

@@ -5,105 +5,105 @@
  */
 class ActionScheduler_Compatibility {
 
-	/**
-	 * Converts a shorthand byte value to an integer byte value.
-	 *
-	 * Wrapper for wp_convert_hr_to_bytes(), moved to load.php in WordPress 4.6 from media.php
-	 *
-	 * @link https://secure.php.net/manual/en/function.ini-get.php
-	 * @link https://secure.php.net/manual/en/faq.using.php#faq.using.shorthandbytes
-	 *
-	 * @param string $value A (PHP ini) byte value, either shorthand or ordinary.
-	 * @return int An integer byte value.
-	 */
-	public static function convert_hr_to_bytes( $value ) {
-		if ( function_exists( 'wp_convert_hr_to_bytes' ) ) {
-			return wp_convert_hr_to_bytes( $value );
-		}
+    /**
+     * Converts a shorthand byte value to an integer byte value.
+     *
+     * Wrapper for wp_convert_hr_to_bytes(), moved to load.php in WordPress 4.6 from media.php
+     *
+     * @link https://secure.php.net/manual/en/function.ini-get.php
+     * @link https://secure.php.net/manual/en/faq.using.php#faq.using.shorthandbytes
+     *
+     * @param string $value A (PHP ini) byte value, either shorthand or ordinary.
+     * @return int An integer byte value.
+     */
+    public static function convert_hr_to_bytes( $value ) {
+        if ( function_exists( 'wp_convert_hr_to_bytes' ) ) {
+            return wp_convert_hr_to_bytes( $value );
+        }
 
-		$value = strtolower( trim( $value ) );
-		$bytes = (int) $value;
+        $value = strtolower( trim( $value ) );
+        $bytes = (int) $value;
 
-		if ( false !== strpos( $value, 'g' ) ) {
-			$bytes *= GB_IN_BYTES;
-		} elseif ( false !== strpos( $value, 'm' ) ) {
-			$bytes *= MB_IN_BYTES;
-		} elseif ( false !== strpos( $value, 'k' ) ) {
-			$bytes *= KB_IN_BYTES;
-		}
+        if ( false !== strpos( $value, 'g' ) ) {
+            $bytes *= GB_IN_BYTES;
+        } elseif ( false !== strpos( $value, 'm' ) ) {
+            $bytes *= MB_IN_BYTES;
+        } elseif ( false !== strpos( $value, 'k' ) ) {
+            $bytes *= KB_IN_BYTES;
+        }
 
-		// Deal with large (float) values which run into the maximum integer size.
-		return min( $bytes, PHP_INT_MAX );
-	}
+        // Deal with large (float) values which run into the maximum integer size.
+        return min( $bytes, PHP_INT_MAX );
+    }
 
-	/**
-	 * Attempts to raise the PHP memory limit for memory intensive processes.
-	 *
-	 * Only allows raising the existing limit and prevents lowering it.
-	 *
-	 * Wrapper for wp_raise_memory_limit(), added in WordPress v4.6.0
-	 *
-	 * @return bool|int|string The limit that was set or false on failure.
-	 */
-	public static function raise_memory_limit() {
-		if ( function_exists( 'wp_raise_memory_limit' ) ) {
-			return wp_raise_memory_limit( 'admin' );
-		}
+    /**
+     * Attempts to raise the PHP memory limit for memory intensive processes.
+     *
+     * Only allows raising the existing limit and prevents lowering it.
+     *
+     * Wrapper for wp_raise_memory_limit(), added in WordPress v4.6.0
+     *
+     * @return bool|int|string The limit that was set or false on failure.
+     */
+    public static function raise_memory_limit() {
+        if ( function_exists( 'wp_raise_memory_limit' ) ) {
+            return wp_raise_memory_limit( 'admin' );
+        }
 
-		$current_limit     = @ini_get( 'memory_limit' );
-		$current_limit_int = self::convert_hr_to_bytes( $current_limit );
+        $current_limit     = @ini_get( 'memory_limit' );
+        $current_limit_int = self::convert_hr_to_bytes( $current_limit );
 
-		if ( -1 === $current_limit_int ) {
-			return false;
-		}
+        if ( -1 === $current_limit_int ) {
+            return false;
+        }
 
-		$wp_max_limit       = WP_MAX_MEMORY_LIMIT;
-		$wp_max_limit_int   = self::convert_hr_to_bytes( $wp_max_limit );
-		$filtered_limit     = apply_filters( 'admin_memory_limit', $wp_max_limit );
-		$filtered_limit_int = self::convert_hr_to_bytes( $filtered_limit );
+        $wp_max_limit       = WP_MAX_MEMORY_LIMIT;
+        $wp_max_limit_int   = self::convert_hr_to_bytes( $wp_max_limit );
+        $filtered_limit     = apply_filters( 'admin_memory_limit', $wp_max_limit );
+        $filtered_limit_int = self::convert_hr_to_bytes( $filtered_limit );
 
-		if ( -1 === $filtered_limit_int || ( $filtered_limit_int > $wp_max_limit_int && $filtered_limit_int > $current_limit_int ) ) {
-			if ( false !== @ini_set( 'memory_limit', $filtered_limit ) ) {
-				return $filtered_limit;
-			} else {
-				return false;
-			}
-		} elseif ( -1 === $wp_max_limit_int || $wp_max_limit_int > $current_limit_int ) {
-			if ( false !== @ini_set( 'memory_limit', $wp_max_limit ) ) {
-				return $wp_max_limit;
-			} else {
-				return false;
-			}
-		}
-		return false;
-	}
+        if ( -1 === $filtered_limit_int || ( $filtered_limit_int > $wp_max_limit_int && $filtered_limit_int > $current_limit_int ) ) {
+            if ( false !== @ini_set( 'memory_limit', $filtered_limit ) ) {
+                return $filtered_limit;
+            } else {
+                return false;
+            }
+        } elseif ( -1 === $wp_max_limit_int || $wp_max_limit_int > $current_limit_int ) {
+            if ( false !== @ini_set( 'memory_limit', $wp_max_limit ) ) {
+                return $wp_max_limit;
+            } else {
+                return false;
+            }
+        }
+        return false;
+    }
 
-	/**
-	 * Attempts to raise the PHP timeout for time intensive processes.
-	 *
-	 * Only allows raising the existing limit and prevents lowering it. Wrapper for wc_set_time_limit(), when available.
-	 *
-	 * @param int $limit The time limit in seconds.
-	 */
-	public static function raise_time_limit( $limit = 0 ) {
-		$limit = (int) $limit;
-		$max_execution_time = (int) ini_get( 'max_execution_time' );
+    /**
+     * Attempts to raise the PHP timeout for time intensive processes.
+     *
+     * Only allows raising the existing limit and prevents lowering it. Wrapper for wc_set_time_limit(), when available.
+     *
+     * @param int $limit The time limit in seconds.
+     */
+    public static function raise_time_limit( $limit = 0 ) {
+        $limit = (int) $limit;
+        $max_execution_time = (int) ini_get( 'max_execution_time' );
 
-		/*
+        /*
 		 * If the max execution time is already unlimited (zero), or if it exceeds or is equal to the proposed
 		 * limit, there is no reason for us to make further changes (we never want to lower it).
 		 */
-		if (
-			0 === $max_execution_time
-			|| ( $max_execution_time >= $limit && $limit !== 0 )
-		) {
-			return;
-		}
+        if (
+            0 === $max_execution_time
+            || ( $max_execution_time >= $limit && $limit !== 0 )
+        ) {
+            return;
+        }
 
-		if ( function_exists( 'wc_set_time_limit' ) ) {
-			wc_set_time_limit( $limit );
-		} elseif ( function_exists( 'set_time_limit' ) && false === strpos( ini_get( 'disable_functions' ), 'set_time_limit' ) && ! ini_get( 'safe_mode' ) ) { // phpcs:ignore PHPCompatibility.IniDirectives.RemovedIniDirectives.safe_modeDeprecatedRemoved
-			@set_time_limit( $limit ); // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged
-		}
-	}
+        if ( function_exists( 'wc_set_time_limit' ) ) {
+            wc_set_time_limit( $limit );
+        } elseif ( function_exists( 'set_time_limit' ) && false === strpos( ini_get( 'disable_functions' ), 'set_time_limit' ) && ! ini_get( 'safe_mode' ) ) { // phpcs:ignore PHPCompatibility.IniDirectives.RemovedIniDirectives.safe_modeDeprecatedRemoved
+            @set_time_limit( $limit ); // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged
+        }
+    }
 }

Spacing +25 added lines, -25 removed lines

@@ -16,24 +16,24 @@ 
 	 * @param string $value A (PHP ini) byte value, either shorthand or ordinary.
 	 * @return int An integer byte value.
 	 */
-	public static function convert_hr_to_bytes( $value ) {
-		if ( function_exists( 'wp_convert_hr_to_bytes' ) ) {
-			return wp_convert_hr_to_bytes( $value );
+	public static function convert_hr_to_bytes($value) {
+		if (function_exists('wp_convert_hr_to_bytes')) {
+			return wp_convert_hr_to_bytes($value);
 		}
 
-		$value = strtolower( trim( $value ) );
+		$value = strtolower(trim($value));
 		$bytes = (int) $value;
 
-		if ( false !== strpos( $value, 'g' ) ) {
+		if (false !== strpos($value, 'g')) {
 			$bytes *= GB_IN_BYTES;
-		} elseif ( false !== strpos( $value, 'm' ) ) {
+		} elseif (false !== strpos($value, 'm')) {
 			$bytes *= MB_IN_BYTES;
-		} elseif ( false !== strpos( $value, 'k' ) ) {
+		} elseif (false !== strpos($value, 'k')) {
 			$bytes *= KB_IN_BYTES;
 		}
 
 		// Deal with large (float) values which run into the maximum integer size.
-		return min( $bytes, PHP_INT_MAX );
+		return min($bytes, PHP_INT_MAX);
 	}
 
 	/**
@@ -46,30 +46,30 @@ 
 	 * @return bool|int|string The limit that was set or false on failure.
 	 */
 	public static function raise_memory_limit() {
-		if ( function_exists( 'wp_raise_memory_limit' ) ) {
-			return wp_raise_memory_limit( 'admin' );
+		if (function_exists('wp_raise_memory_limit')) {
+			return wp_raise_memory_limit('admin');
 		}
 
-		$current_limit     = @ini_get( 'memory_limit' );
-		$current_limit_int = self::convert_hr_to_bytes( $current_limit );
+		$current_limit     = @ini_get('memory_limit');
+		$current_limit_int = self::convert_hr_to_bytes($current_limit);
 
 		if ( -1 === $current_limit_int ) {
 			return false;
 		}
 
 		$wp_max_limit       = WP_MAX_MEMORY_LIMIT;
-		$wp_max_limit_int   = self::convert_hr_to_bytes( $wp_max_limit );
-		$filtered_limit     = apply_filters( 'admin_memory_limit', $wp_max_limit );
-		$filtered_limit_int = self::convert_hr_to_bytes( $filtered_limit );
+		$wp_max_limit_int   = self::convert_hr_to_bytes($wp_max_limit);
+		$filtered_limit     = apply_filters('admin_memory_limit', $wp_max_limit);
+		$filtered_limit_int = self::convert_hr_to_bytes($filtered_limit);
 
-		if ( -1 === $filtered_limit_int || ( $filtered_limit_int > $wp_max_limit_int && $filtered_limit_int > $current_limit_int ) ) {
-			if ( false !== @ini_set( 'memory_limit', $filtered_limit ) ) {
+		if ( -1 === $filtered_limit_int || ($filtered_limit_int > $wp_max_limit_int && $filtered_limit_int > $current_limit_int) ) {
+			if (false !== @ini_set('memory_limit', $filtered_limit)) {
 				return $filtered_limit;
 			} else {
 				return false;
 			}
 		} elseif ( -1 === $wp_max_limit_int || $wp_max_limit_int > $current_limit_int ) {
-			if ( false !== @ini_set( 'memory_limit', $wp_max_limit ) ) {
+			if (false !== @ini_set('memory_limit', $wp_max_limit)) {
 				return $wp_max_limit;
 			} else {
 				return false;
@@ -85,9 +85,9 @@ 
 	 *
 	 * @param int $limit The time limit in seconds.
 	 */
-	public static function raise_time_limit( $limit = 0 ) {
+	public static function raise_time_limit($limit = 0) {
 		$limit = (int) $limit;
-		$max_execution_time = (int) ini_get( 'max_execution_time' );
+		$max_execution_time = (int) ini_get('max_execution_time');
 
 		/*
 		 * If the max execution time is already unlimited (zero), or if it exceeds or is equal to the proposed
@@ -95,15 +95,15 @@ 
 		 */
 		if (
 			0 === $max_execution_time
-			|| ( $max_execution_time >= $limit && $limit !== 0 )
+			|| ($max_execution_time >= $limit && $limit !== 0)
 		) {
 			return;
 		}
 
-		if ( function_exists( 'wc_set_time_limit' ) ) {
-			wc_set_time_limit( $limit );
-		} elseif ( function_exists( 'set_time_limit' ) && false === strpos( ini_get( 'disable_functions' ), 'set_time_limit' ) && ! ini_get( 'safe_mode' ) ) { // phpcs:ignore PHPCompatibility.IniDirectives.RemovedIniDirectives.safe_modeDeprecatedRemoved
-			@set_time_limit( $limit ); // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged
+		if (function_exists('wc_set_time_limit')) {
+			wc_set_time_limit($limit);
+		} elseif (function_exists('set_time_limit') && false === strpos(ini_get('disable_functions'), 'set_time_limit') && !ini_get('safe_mode')) { // phpcs:ignore PHPCompatibility.IniDirectives.RemovedIniDirectives.safe_modeDeprecatedRemoved
+			@set_time_limit($limit); // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged
 		}
 	}
 }

plugins/woocommerce/packages/action-scheduler/classes/WP_CLI/ActionScheduler_WPCLI_QueueRunner.php

Indentation +185 added lines, -185 removed lines

@@ -9,189 +9,189 @@
  */
 class ActionScheduler_WPCLI_QueueRunner extends ActionScheduler_Abstract_QueueRunner {
 
-	/** @var array */
-	protected $actions;
-
-	/** @var  ActionScheduler_ActionClaim */
-	protected $claim;
-
-	/** @var \cli\progress\Bar */
-	protected $progress_bar;
-
-	/**
-	 * ActionScheduler_WPCLI_QueueRunner constructor.
-	 *
-	 * @param ActionScheduler_Store             $store
-	 * @param ActionScheduler_FatalErrorMonitor $monitor
-	 * @param ActionScheduler_QueueCleaner      $cleaner
-	 *
-	 * @throws Exception When this is not run within WP CLI
-	 */
-	public function __construct( ActionScheduler_Store $store = null, ActionScheduler_FatalErrorMonitor $monitor = null, ActionScheduler_QueueCleaner $cleaner = null ) {
-		if ( ! ( defined( 'WP_CLI' ) && WP_CLI ) ) {
-			/* translators: %s php class name */
-			throw new Exception( sprintf( __( 'The %s class can only be run within WP CLI.', 'woocommerce' ), __CLASS__ ) );
-		}
-
-		parent::__construct( $store, $monitor, $cleaner );
-	}
-
-	/**
-	 * Set up the Queue before processing.
-	 *
-	 * @author Jeremy Pry
-	 *
-	 * @param int    $batch_size The batch size to process.
-	 * @param array  $hooks      The hooks being used to filter the actions claimed in this batch.
-	 * @param string $group      The group of actions to claim with this batch.
-	 * @param bool   $force      Whether to force running even with too many concurrent processes.
-	 *
-	 * @return int The number of actions that will be run.
-	 * @throws \WP_CLI\ExitException When there are too many concurrent batches.
-	 */
-	public function setup( $batch_size, $hooks = array(), $group = '', $force = false ) {
-		$this->run_cleanup();
-		$this->add_hooks();
-
-		// Check to make sure there aren't too many concurrent processes running.
-		if ( $this->has_maximum_concurrent_batches() ) {
-			if ( $force ) {
-				WP_CLI::warning( __( 'There are too many concurrent batches, but the run is forced to continue.', 'woocommerce' ) );
-			} else {
-				WP_CLI::error( __( 'There are too many concurrent batches.', 'woocommerce' ) );
-			}
-		}
-
-		// Stake a claim and store it.
-		$this->claim = $this->store->stake_claim( $batch_size, null, $hooks, $group );
-		$this->monitor->attach( $this->claim );
-		$this->actions = $this->claim->get_actions();
-
-		return count( $this->actions );
-	}
-
-	/**
-	 * Add our hooks to the appropriate actions.
-	 *
-	 * @author Jeremy Pry
-	 */
-	protected function add_hooks() {
-		add_action( 'action_scheduler_before_execute', array( $this, 'before_execute' ) );
-		add_action( 'action_scheduler_after_execute', array( $this, 'after_execute' ), 10, 2 );
-		add_action( 'action_scheduler_failed_execution', array( $this, 'action_failed' ), 10, 2 );
-	}
-
-	/**
-	 * Set up the WP CLI progress bar.
-	 *
-	 * @author Jeremy Pry
-	 */
-	protected function setup_progress_bar() {
-		$count              = count( $this->actions );
-		$this->progress_bar = new ProgressBar(
-			/* translators: %d: amount of actions */
-			sprintf( _n( 'Running %d action', 'Running %d actions', $count, 'woocommerce' ), number_format_i18n( $count ) ),
-			$count
-		);
-	}
-
-	/**
-	 * Process actions in the queue.
-	 *
-	 * @author Jeremy Pry
-	 *
-	 * @param string $context Optional runner context. Default 'WP CLI'.
-	 *
-	 * @return int The number of actions processed.
-	 */
-	public function run( $context = 'WP CLI' ) {
-		do_action( 'action_scheduler_before_process_queue' );
-		$this->setup_progress_bar();
-		foreach ( $this->actions as $action_id ) {
-			// Error if we lost the claim.
-			if ( ! in_array( $action_id, $this->store->find_actions_by_claim_id( $this->claim->get_id() ) ) ) {
-				WP_CLI::warning( __( 'The claim has been lost. Aborting current batch.', 'woocommerce' ) );
-				break;
-			}
-
-			$this->process_action( $action_id, $context );
-			$this->progress_bar->tick();
-		}
-
-		$completed = $this->progress_bar->current();
-		$this->progress_bar->finish();
-		$this->store->release_claim( $this->claim );
-		do_action( 'action_scheduler_after_process_queue' );
-
-		return $completed;
-	}
-
-	/**
-	 * Handle WP CLI message when the action is starting.
-	 *
-	 * @author Jeremy Pry
-	 *
-	 * @param $action_id
-	 */
-	public function before_execute( $action_id ) {
-		/* translators: %s refers to the action ID */
-		WP_CLI::log( sprintf( __( 'Started processing action %s', 'woocommerce' ), $action_id ) );
-	}
-
-	/**
-	 * Handle WP CLI message when the action has completed.
-	 *
-	 * @author Jeremy Pry
-	 *
-	 * @param int $action_id
-	 * @param null|ActionScheduler_Action $action The instance of the action. Default to null for backward compatibility.
-	 */
-	public function after_execute( $action_id, $action = null ) {
-		// backward compatibility
-		if ( null === $action ) {
-			$action = $this->store->fetch_action( $action_id );
-		}
-		/* translators: 1: action ID 2: hook name */
-		WP_CLI::log( sprintf( __( 'Completed processing action %1$s with hook: %2$s', 'woocommerce' ), $action_id, $action->get_hook() ) );
-	}
-
-	/**
-	 * Handle WP CLI message when the action has failed.
-	 *
-	 * @author Jeremy Pry
-	 *
-	 * @param int       $action_id
-	 * @param Exception $exception
-	 * @throws \WP_CLI\ExitException With failure message.
-	 */
-	public function action_failed( $action_id, $exception ) {
-		WP_CLI::error(
-			/* translators: 1: action ID 2: exception message */
-			sprintf( __( 'Error processing action %1$s: %2$s', 'woocommerce' ), $action_id, $exception->getMessage() ),
-			false
-		);
-	}
-
-	/**
-	 * Sleep and help avoid hitting memory limit
-	 *
-	 * @param int $sleep_time Amount of seconds to sleep
-	 * @deprecated 3.0.0
-	 */
-	protected function stop_the_insanity( $sleep_time = 0 ) {
-		_deprecated_function( 'ActionScheduler_WPCLI_QueueRunner::stop_the_insanity', '3.0.0', 'ActionScheduler_DataController::free_memory' );
-
-		ActionScheduler_DataController::free_memory();
-	}
-
-	/**
-	 * Maybe trigger the stop_the_insanity() method to free up memory.
-	 */
-	protected function maybe_stop_the_insanity() {
-		// The value returned by progress_bar->current() might be padded. Remove padding, and convert to int.
-		$current_iteration = intval( trim( $this->progress_bar->current() ) );
-		if ( 0 === $current_iteration % 50 ) {
-			$this->stop_the_insanity();
-		}
-	}
+    /** @var array */
+    protected $actions;
+
+    /** @var  ActionScheduler_ActionClaim */
+    protected $claim;
+
+    /** @var \cli\progress\Bar */
+    protected $progress_bar;
+
+    /**
+     * ActionScheduler_WPCLI_QueueRunner constructor.
+     *
+     * @param ActionScheduler_Store             $store
+     * @param ActionScheduler_FatalErrorMonitor $monitor
+     * @param ActionScheduler_QueueCleaner      $cleaner
+     *
+     * @throws Exception When this is not run within WP CLI
+     */
+    public function __construct( ActionScheduler_Store $store = null, ActionScheduler_FatalErrorMonitor $monitor = null, ActionScheduler_QueueCleaner $cleaner = null ) {
+        if ( ! ( defined( 'WP_CLI' ) && WP_CLI ) ) {
+            /* translators: %s php class name */
+            throw new Exception( sprintf( __( 'The %s class can only be run within WP CLI.', 'woocommerce' ), __CLASS__ ) );
+        }
+
+        parent::__construct( $store, $monitor, $cleaner );
+    }
+
+    /**
+     * Set up the Queue before processing.
+     *
+     * @author Jeremy Pry
+     *
+     * @param int    $batch_size The batch size to process.
+     * @param array  $hooks      The hooks being used to filter the actions claimed in this batch.
+     * @param string $group      The group of actions to claim with this batch.
+     * @param bool   $force      Whether to force running even with too many concurrent processes.
+     *
+     * @return int The number of actions that will be run.
+     * @throws \WP_CLI\ExitException When there are too many concurrent batches.
+     */
+    public function setup( $batch_size, $hooks = array(), $group = '', $force = false ) {
+        $this->run_cleanup();
+        $this->add_hooks();
+
+        // Check to make sure there aren't too many concurrent processes running.
+        if ( $this->has_maximum_concurrent_batches() ) {
+            if ( $force ) {
+                WP_CLI::warning( __( 'There are too many concurrent batches, but the run is forced to continue.', 'woocommerce' ) );
+            } else {
+                WP_CLI::error( __( 'There are too many concurrent batches.', 'woocommerce' ) );
+            }
+        }
+
+        // Stake a claim and store it.
+        $this->claim = $this->store->stake_claim( $batch_size, null, $hooks, $group );
+        $this->monitor->attach( $this->claim );
+        $this->actions = $this->claim->get_actions();
+
+        return count( $this->actions );
+    }
+
+    /**
+     * Add our hooks to the appropriate actions.
+     *
+     * @author Jeremy Pry
+     */
+    protected function add_hooks() {
+        add_action( 'action_scheduler_before_execute', array( $this, 'before_execute' ) );
+        add_action( 'action_scheduler_after_execute', array( $this, 'after_execute' ), 10, 2 );
+        add_action( 'action_scheduler_failed_execution', array( $this, 'action_failed' ), 10, 2 );
+    }
+
+    /**
+     * Set up the WP CLI progress bar.
+     *
+     * @author Jeremy Pry
+     */
+    protected function setup_progress_bar() {
+        $count              = count( $this->actions );
+        $this->progress_bar = new ProgressBar(
+            /* translators: %d: amount of actions */
+            sprintf( _n( 'Running %d action', 'Running %d actions', $count, 'woocommerce' ), number_format_i18n( $count ) ),
+            $count
+        );
+    }
+
+    /**
+     * Process actions in the queue.
+     *
+     * @author Jeremy Pry
+     *
+     * @param string $context Optional runner context. Default 'WP CLI'.
+     *
+     * @return int The number of actions processed.
+     */
+    public function run( $context = 'WP CLI' ) {
+        do_action( 'action_scheduler_before_process_queue' );
+        $this->setup_progress_bar();
+        foreach ( $this->actions as $action_id ) {
+            // Error if we lost the claim.
+            if ( ! in_array( $action_id, $this->store->find_actions_by_claim_id( $this->claim->get_id() ) ) ) {
+                WP_CLI::warning( __( 'The claim has been lost. Aborting current batch.', 'woocommerce' ) );
+                break;
+            }
+
+            $this->process_action( $action_id, $context );
+            $this->progress_bar->tick();
+        }
+
+        $completed = $this->progress_bar->current();
+        $this->progress_bar->finish();
+        $this->store->release_claim( $this->claim );
+        do_action( 'action_scheduler_after_process_queue' );
+
+        return $completed;
+    }
+
+    /**
+     * Handle WP CLI message when the action is starting.
+     *
+     * @author Jeremy Pry
+     *
+     * @param $action_id
+     */
+    public function before_execute( $action_id ) {
+        /* translators: %s refers to the action ID */
+        WP_CLI::log( sprintf( __( 'Started processing action %s', 'woocommerce' ), $action_id ) );
+    }
+
+    /**
+     * Handle WP CLI message when the action has completed.
+     *
+     * @author Jeremy Pry
+     *
+     * @param int $action_id
+     * @param null|ActionScheduler_Action $action The instance of the action. Default to null for backward compatibility.
+     */
+    public function after_execute( $action_id, $action = null ) {
+        // backward compatibility
+        if ( null === $action ) {
+            $action = $this->store->fetch_action( $action_id );
+        }
+        /* translators: 1: action ID 2: hook name */
+        WP_CLI::log( sprintf( __( 'Completed processing action %1$s with hook: %2$s', 'woocommerce' ), $action_id, $action->get_hook() ) );
+    }
+
+    /**
+     * Handle WP CLI message when the action has failed.
+     *
+     * @author Jeremy Pry
+     *
+     * @param int       $action_id
+     * @param Exception $exception
+     * @throws \WP_CLI\ExitException With failure message.
+     */
+    public function action_failed( $action_id, $exception ) {
+        WP_CLI::error(
+            /* translators: 1: action ID 2: exception message */
+            sprintf( __( 'Error processing action %1$s: %2$s', 'woocommerce' ), $action_id, $exception->getMessage() ),
+            false
+        );
+    }
+
+    /**
+     * Sleep and help avoid hitting memory limit
+     *
+     * @param int $sleep_time Amount of seconds to sleep
+     * @deprecated 3.0.0
+     */
+    protected function stop_the_insanity( $sleep_time = 0 ) {
+        _deprecated_function( 'ActionScheduler_WPCLI_QueueRunner::stop_the_insanity', '3.0.0', 'ActionScheduler_DataController::free_memory' );
+
+        ActionScheduler_DataController::free_memory();
+    }
+
+    /**
+     * Maybe trigger the stop_the_insanity() method to free up memory.
+     */
+    protected function maybe_stop_the_insanity() {
+        // The value returned by progress_bar->current() might be padded. Remove padding, and convert to int.
+        $current_iteration = intval( trim( $this->progress_bar->current() ) );
+        if ( 0 === $current_iteration % 50 ) {
+            $this->stop_the_insanity();
+        }
+    }
 }

Spacing +37 added lines, -37 removed lines

@@ -27,13 +27,13 @@ 
 	 *
 	 * @throws Exception When this is not run within WP CLI
 	 */
-	public function __construct( ActionScheduler_Store $store = null, ActionScheduler_FatalErrorMonitor $monitor = null, ActionScheduler_QueueCleaner $cleaner = null ) {
-		if ( ! ( defined( 'WP_CLI' ) && WP_CLI ) ) {
+	public function __construct(ActionScheduler_Store $store = null, ActionScheduler_FatalErrorMonitor $monitor = null, ActionScheduler_QueueCleaner $cleaner = null) {
+		if (!(defined('WP_CLI') && WP_CLI)) {
 			/* translators: %s php class name */
-			throw new Exception( sprintf( __( 'The %s class can only be run within WP CLI.', 'woocommerce' ), __CLASS__ ) );
+			throw new Exception(sprintf(__('The %s class can only be run within WP CLI.', 'woocommerce'), __CLASS__));
 		}
 
-		parent::__construct( $store, $monitor, $cleaner );
+		parent::__construct($store, $monitor, $cleaner);
 	}
 
 	/**
@@ -49,25 +49,25 @@ 
 	 * @return int The number of actions that will be run.
 	 * @throws \WP_CLI\ExitException When there are too many concurrent batches.
 	 */
-	public function setup( $batch_size, $hooks = array(), $group = '', $force = false ) {
+	public function setup($batch_size, $hooks = array(), $group = '', $force = false) {
 		$this->run_cleanup();
 		$this->add_hooks();
 
 		// Check to make sure there aren't too many concurrent processes running.
-		if ( $this->has_maximum_concurrent_batches() ) {
-			if ( $force ) {
-				WP_CLI::warning( __( 'There are too many concurrent batches, but the run is forced to continue.', 'woocommerce' ) );
+		if ($this->has_maximum_concurrent_batches()) {
+			if ($force) {
+				WP_CLI::warning(__('There are too many concurrent batches, but the run is forced to continue.', 'woocommerce'));
 			} else {
-				WP_CLI::error( __( 'There are too many concurrent batches.', 'woocommerce' ) );
+				WP_CLI::error(__('There are too many concurrent batches.', 'woocommerce'));
 			}
 		}
 
 		// Stake a claim and store it.
-		$this->claim = $this->store->stake_claim( $batch_size, null, $hooks, $group );
-		$this->monitor->attach( $this->claim );
+		$this->claim = $this->store->stake_claim($batch_size, null, $hooks, $group);
+		$this->monitor->attach($this->claim);
 		$this->actions = $this->claim->get_actions();
 
-		return count( $this->actions );
+		return count($this->actions);
 	}
 
 	/**
@@ -76,9 +76,9 @@ 
 	 * @author Jeremy Pry
 	 */
 	protected function add_hooks() {
-		add_action( 'action_scheduler_before_execute', array( $this, 'before_execute' ) );
-		add_action( 'action_scheduler_after_execute', array( $this, 'after_execute' ), 10, 2 );
-		add_action( 'action_scheduler_failed_execution', array( $this, 'action_failed' ), 10, 2 );
+		add_action('action_scheduler_before_execute', array($this, 'before_execute'));
+		add_action('action_scheduler_after_execute', array($this, 'after_execute'), 10, 2);
+		add_action('action_scheduler_failed_execution', array($this, 'action_failed'), 10, 2);
 	}
 
 	/**
@@ -87,10 +87,10 @@ 
 	 * @author Jeremy Pry
 	 */
 	protected function setup_progress_bar() {
-		$count              = count( $this->actions );
+		$count              = count($this->actions);
 		$this->progress_bar = new ProgressBar(
 			/* translators: %d: amount of actions */
-			sprintf( _n( 'Running %d action', 'Running %d actions', $count, 'woocommerce' ), number_format_i18n( $count ) ),
+			sprintf(_n('Running %d action', 'Running %d actions', $count, 'woocommerce'), number_format_i18n($count)),
 			$count
 		);
 	}
@@ -104,24 +104,24 @@ 
 	 *
 	 * @return int The number of actions processed.
 	 */
-	public function run( $context = 'WP CLI' ) {
-		do_action( 'action_scheduler_before_process_queue' );
+	public function run($context = 'WP CLI') {
+		do_action('action_scheduler_before_process_queue');
 		$this->setup_progress_bar();
-		foreach ( $this->actions as $action_id ) {
+		foreach ($this->actions as $action_id) {
 			// Error if we lost the claim.
-			if ( ! in_array( $action_id, $this->store->find_actions_by_claim_id( $this->claim->get_id() ) ) ) {
-				WP_CLI::warning( __( 'The claim has been lost. Aborting current batch.', 'woocommerce' ) );
+			if (!in_array($action_id, $this->store->find_actions_by_claim_id($this->claim->get_id()))) {
+				WP_CLI::warning(__('The claim has been lost. Aborting current batch.', 'woocommerce'));
 				break;
 			}
 
-			$this->process_action( $action_id, $context );
+			$this->process_action($action_id, $context);
 			$this->progress_bar->tick();
 		}
 
 		$completed = $this->progress_bar->current();
 		$this->progress_bar->finish();
-		$this->store->release_claim( $this->claim );
-		do_action( 'action_scheduler_after_process_queue' );
+		$this->store->release_claim($this->claim);
+		do_action('action_scheduler_after_process_queue');
 
 		return $completed;
 	}
@@ -133,9 +133,9 @@ 
 	 *
 	 * @param $action_id
 	 */
-	public function before_execute( $action_id ) {
+	public function before_execute($action_id) {
 		/* translators: %s refers to the action ID */
-		WP_CLI::log( sprintf( __( 'Started processing action %s', 'woocommerce' ), $action_id ) );
+		WP_CLI::log(sprintf(__('Started processing action %s', 'woocommerce'), $action_id));
 	}
 
 	/**
@@ -146,13 +146,13 @@ 
 	 * @param int $action_id
 	 * @param null|ActionScheduler_Action $action The instance of the action. Default to null for backward compatibility.
 	 */
-	public function after_execute( $action_id, $action = null ) {
+	public function after_execute($action_id, $action = null) {
 		// backward compatibility
-		if ( null === $action ) {
-			$action = $this->store->fetch_action( $action_id );
+		if (null === $action) {
+			$action = $this->store->fetch_action($action_id);
 		}
 		/* translators: 1: action ID 2: hook name */
-		WP_CLI::log( sprintf( __( 'Completed processing action %1$s with hook: %2$s', 'woocommerce' ), $action_id, $action->get_hook() ) );
+		WP_CLI::log(sprintf(__('Completed processing action %1$s with hook: %2$s', 'woocommerce'), $action_id, $action->get_hook()));
 	}
 
 	/**
@@ -164,10 +164,10 @@ 
 	 * @param Exception $exception
 	 * @throws \WP_CLI\ExitException With failure message.
 	 */
-	public function action_failed( $action_id, $exception ) {
+	public function action_failed($action_id, $exception) {
 		WP_CLI::error(
 			/* translators: 1: action ID 2: exception message */
-			sprintf( __( 'Error processing action %1$s: %2$s', 'woocommerce' ), $action_id, $exception->getMessage() ),
+			sprintf(__('Error processing action %1$s: %2$s', 'woocommerce'), $action_id, $exception->getMessage()),
 			false
 		);
 	}
@@ -178,8 +178,8 @@ 
 	 * @param int $sleep_time Amount of seconds to sleep
 	 * @deprecated 3.0.0
 	 */
-	protected function stop_the_insanity( $sleep_time = 0 ) {
-		_deprecated_function( 'ActionScheduler_WPCLI_QueueRunner::stop_the_insanity', '3.0.0', 'ActionScheduler_DataController::free_memory' );
+	protected function stop_the_insanity($sleep_time = 0) {
+		_deprecated_function('ActionScheduler_WPCLI_QueueRunner::stop_the_insanity', '3.0.0', 'ActionScheduler_DataController::free_memory');
 
 		ActionScheduler_DataController::free_memory();
 	}
@@ -189,8 +189,8 @@ 
 	 */
 	protected function maybe_stop_the_insanity() {
 		// The value returned by progress_bar->current() might be padded. Remove padding, and convert to int.
-		$current_iteration = intval( trim( $this->progress_bar->current() ) );
-		if ( 0 === $current_iteration % 50 ) {
+		$current_iteration = intval(trim($this->progress_bar->current()));
+		if (0 === $current_iteration % 50) {
 			$this->stop_the_insanity();
 		}
 	}

plugins/woocommerce/packages/action-scheduler/classes/WP_CLI/ActionScheduler_WPCLI_Scheduler_command.php

Indentation +180 added lines, -180 removed lines

@@ -5,184 +5,184 @@
  */
 class ActionScheduler_WPCLI_Scheduler_command extends WP_CLI_Command {
 
-	/**
-	 * Force tables schema creation for Action Scheduler
-	 *
-	 * ## OPTIONS
-	 *
-	 * @param array $args Positional arguments.
-	 * @param array $assoc_args Keyed arguments.
-	 *
-	 * @subcommand fix-schema
-	 */
-	public function fix_schema( $args, $assoc_args ) {
-		$schema_classes = array( ActionScheduler_LoggerSchema::class, ActionScheduler_StoreSchema::class );
-
-		foreach ( $schema_classes as $classname ) {
-			if ( is_subclass_of( $classname, ActionScheduler_Abstract_Schema::class ) ) {
-				$obj = new $classname();
-				$obj->init();
-				$obj->register_tables( true );
-
-				WP_CLI::success(
-					sprintf(
-						/* translators: %s refers to the schema name*/
-						__( 'Registered schema for %s', 'woocommerce' ),
-						$classname
-					)
-				);
-			}
-		}
-	}
-
-	/**
-	 * Run the Action Scheduler
-	 *
-	 * ## OPTIONS
-	 *
-	 * [--batch-size=<size>]
-	 * : The maximum number of actions to run. Defaults to 100.
-	 *
-	 * [--batches=<size>]
-	 * : Limit execution to a number of batches. Defaults to 0, meaning batches will continue being executed until all actions are complete.
-	 *
-	 * [--cleanup-batch-size=<size>]
-	 * : The maximum number of actions to clean up. Defaults to the value of --batch-size.
-	 *
-	 * [--hooks=<hooks>]
-	 * : Only run actions with the specified hook. Omitting this option runs actions with any hook. Define multiple hooks as a comma separated string (without spaces), e.g. `--hooks=hook_one,hook_two,hook_three`
-	 *
-	 * [--group=<group>]
-	 * : Only run actions from the specified group. Omitting this option runs actions from all groups.
-	 *
-	 * [--free-memory-on=<count>]
-	 * : The number of actions to process between freeing memory. 0 disables freeing memory. Default 50.
-	 *
-	 * [--pause=<seconds>]
-	 * : The number of seconds to pause when freeing memory. Default no pause.
-	 *
-	 * [--force]
-	 * : Whether to force execution despite the maximum number of concurrent processes being exceeded.
-	 *
-	 * @param array $args Positional arguments.
-	 * @param array $assoc_args Keyed arguments.
-	 * @throws \WP_CLI\ExitException When an error occurs.
-	 *
-	 * @subcommand run
-	 */
-	public function run( $args, $assoc_args ) {
-		// Handle passed arguments.
-		$batch   = absint( \WP_CLI\Utils\get_flag_value( $assoc_args, 'batch-size', 100 ) );
-		$batches = absint( \WP_CLI\Utils\get_flag_value( $assoc_args, 'batches', 0 ) );
-		$clean   = absint( \WP_CLI\Utils\get_flag_value( $assoc_args, 'cleanup-batch-size', $batch ) );
-		$hooks   = explode( ',', WP_CLI\Utils\get_flag_value( $assoc_args, 'hooks', '' ) );
-		$hooks   = array_filter( array_map( 'trim', $hooks ) );
-		$group   = \WP_CLI\Utils\get_flag_value( $assoc_args, 'group', '' );
-		$free_on = \WP_CLI\Utils\get_flag_value( $assoc_args, 'free-memory-on', 50 );
-		$sleep   = \WP_CLI\Utils\get_flag_value( $assoc_args, 'pause', 0 );
-		$force   = \WP_CLI\Utils\get_flag_value( $assoc_args, 'force', false );
-
-		ActionScheduler_DataController::set_free_ticks( $free_on );
-		ActionScheduler_DataController::set_sleep_time( $sleep );
-
-		$batches_completed = 0;
-		$actions_completed = 0;
-		$unlimited         = $batches === 0;
-
-		try {
-			// Custom queue cleaner instance.
-			$cleaner = new ActionScheduler_QueueCleaner( null, $clean );
-
-			// Get the queue runner instance
-			$runner = new ActionScheduler_WPCLI_QueueRunner( null, null, $cleaner );
-
-			// Determine how many tasks will be run in the first batch.
-			$total = $runner->setup( $batch, $hooks, $group, $force );
-
-			// Run actions for as long as possible.
-			while ( $total > 0 ) {
-				$this->print_total_actions( $total );
-				$actions_completed += $runner->run();
-				$batches_completed++;
-
-				// Maybe set up tasks for the next batch.
-				$total = ( $unlimited || $batches_completed < $batches ) ? $runner->setup( $batch, $hooks, $group, $force ) : 0;
-			}
-		} catch ( Exception $e ) {
-			$this->print_error( $e );
-		}
-
-		$this->print_total_batches( $batches_completed );
-		$this->print_success( $actions_completed );
-	}
-
-	/**
-	 * Print WP CLI message about how many actions are about to be processed.
-	 *
-	 * @author Jeremy Pry
-	 *
-	 * @param int $total
-	 */
-	protected function print_total_actions( $total ) {
-		WP_CLI::log(
-			sprintf(
-				/* translators: %d refers to how many scheduled taks were found to run */
-				_n( 'Found %d scheduled task', 'Found %d scheduled tasks', $total, 'woocommerce' ),
-				number_format_i18n( $total )
-			)
-		);
-	}
-
-	/**
-	 * Print WP CLI message about how many batches of actions were processed.
-	 *
-	 * @author Jeremy Pry
-	 *
-	 * @param int $batches_completed
-	 */
-	protected function print_total_batches( $batches_completed ) {
-		WP_CLI::log(
-			sprintf(
-				/* translators: %d refers to the total number of batches executed */
-				_n( '%d batch executed.', '%d batches executed.', $batches_completed, 'woocommerce' ),
-				number_format_i18n( $batches_completed )
-			)
-		);
-	}
-
-	/**
-	 * Convert an exception into a WP CLI error.
-	 *
-	 * @author Jeremy Pry
-	 *
-	 * @param Exception $e The error object.
-	 *
-	 * @throws \WP_CLI\ExitException
-	 */
-	protected function print_error( Exception $e ) {
-		WP_CLI::error(
-			sprintf(
-				/* translators: %s refers to the exception error message */
-				__( 'There was an error running the action scheduler: %s', 'woocommerce' ),
-				$e->getMessage()
-			)
-		);
-	}
-
-	/**
-	 * Print a success message with the number of completed actions.
-	 *
-	 * @author Jeremy Pry
-	 *
-	 * @param int $actions_completed
-	 */
-	protected function print_success( $actions_completed ) {
-		WP_CLI::success(
-			sprintf(
-				/* translators: %d refers to the total number of taskes completed */
-				_n( '%d scheduled task completed.', '%d scheduled tasks completed.', $actions_completed, 'woocommerce' ),
-				number_format_i18n( $actions_completed )
-			)
-		);
-	}
+    /**
+     * Force tables schema creation for Action Scheduler
+     *
+     * ## OPTIONS
+     *
+     * @param array $args Positional arguments.
+     * @param array $assoc_args Keyed arguments.
+     *
+     * @subcommand fix-schema
+     */
+    public function fix_schema( $args, $assoc_args ) {
+        $schema_classes = array( ActionScheduler_LoggerSchema::class, ActionScheduler_StoreSchema::class );
+
+        foreach ( $schema_classes as $classname ) {
+            if ( is_subclass_of( $classname, ActionScheduler_Abstract_Schema::class ) ) {
+                $obj = new $classname();
+                $obj->init();
+                $obj->register_tables( true );
+
+                WP_CLI::success(
+                    sprintf(
+                        /* translators: %s refers to the schema name*/
+                        __( 'Registered schema for %s', 'woocommerce' ),
+                        $classname
+                    )
+                );
+            }
+        }
+    }
+
+    /**
+     * Run the Action Scheduler
+     *
+     * ## OPTIONS
+     *
+     * [--batch-size=<size>]
+     * : The maximum number of actions to run. Defaults to 100.
+     *
+     * [--batches=<size>]
+     * : Limit execution to a number of batches. Defaults to 0, meaning batches will continue being executed until all actions are complete.
+     *
+     * [--cleanup-batch-size=<size>]
+     * : The maximum number of actions to clean up. Defaults to the value of --batch-size.
+     *
+     * [--hooks=<hooks>]
+     * : Only run actions with the specified hook. Omitting this option runs actions with any hook. Define multiple hooks as a comma separated string (without spaces), e.g. `--hooks=hook_one,hook_two,hook_three`
+     *
+     * [--group=<group>]
+     * : Only run actions from the specified group. Omitting this option runs actions from all groups.
+     *
+     * [--free-memory-on=<count>]
+     * : The number of actions to process between freeing memory. 0 disables freeing memory. Default 50.
+     *
+     * [--pause=<seconds>]
+     * : The number of seconds to pause when freeing memory. Default no pause.
+     *
+     * [--force]
+     * : Whether to force execution despite the maximum number of concurrent processes being exceeded.
+     *
+     * @param array $args Positional arguments.
+     * @param array $assoc_args Keyed arguments.
+     * @throws \WP_CLI\ExitException When an error occurs.
+     *
+     * @subcommand run
+     */
+    public function run( $args, $assoc_args ) {
+        // Handle passed arguments.
+        $batch   = absint( \WP_CLI\Utils\get_flag_value( $assoc_args, 'batch-size', 100 ) );
+        $batches = absint( \WP_CLI\Utils\get_flag_value( $assoc_args, 'batches', 0 ) );
+        $clean   = absint( \WP_CLI\Utils\get_flag_value( $assoc_args, 'cleanup-batch-size', $batch ) );
+        $hooks   = explode( ',', WP_CLI\Utils\get_flag_value( $assoc_args, 'hooks', '' ) );
+        $hooks   = array_filter( array_map( 'trim', $hooks ) );
+        $group   = \WP_CLI\Utils\get_flag_value( $assoc_args, 'group', '' );
+        $free_on = \WP_CLI\Utils\get_flag_value( $assoc_args, 'free-memory-on', 50 );
+        $sleep   = \WP_CLI\Utils\get_flag_value( $assoc_args, 'pause', 0 );
+        $force   = \WP_CLI\Utils\get_flag_value( $assoc_args, 'force', false );
+
+        ActionScheduler_DataController::set_free_ticks( $free_on );
+        ActionScheduler_DataController::set_sleep_time( $sleep );
+
+        $batches_completed = 0;
+        $actions_completed = 0;
+        $unlimited         = $batches === 0;
+
+        try {
+            // Custom queue cleaner instance.
+            $cleaner = new ActionScheduler_QueueCleaner( null, $clean );
+
+            // Get the queue runner instance
+            $runner = new ActionScheduler_WPCLI_QueueRunner( null, null, $cleaner );
+
+            // Determine how many tasks will be run in the first batch.
+            $total = $runner->setup( $batch, $hooks, $group, $force );
+
+            // Run actions for as long as possible.
+            while ( $total > 0 ) {
+                $this->print_total_actions( $total );
+                $actions_completed += $runner->run();
+                $batches_completed++;
+
+                // Maybe set up tasks for the next batch.
+                $total = ( $unlimited || $batches_completed < $batches ) ? $runner->setup( $batch, $hooks, $group, $force ) : 0;
+            }
+        } catch ( Exception $e ) {
+            $this->print_error( $e );
+        }
+
+        $this->print_total_batches( $batches_completed );
+        $this->print_success( $actions_completed );
+    }
+
+    /**
+     * Print WP CLI message about how many actions are about to be processed.
+     *
+     * @author Jeremy Pry
+     *
+     * @param int $total
+     */
+    protected function print_total_actions( $total ) {
+        WP_CLI::log(
+            sprintf(
+                /* translators: %d refers to how many scheduled taks were found to run */
+                _n( 'Found %d scheduled task', 'Found %d scheduled tasks', $total, 'woocommerce' ),
+                number_format_i18n( $total )
+            )
+        );
+    }
+
+    /**
+     * Print WP CLI message about how many batches of actions were processed.
+     *
+     * @author Jeremy Pry
+     *
+     * @param int $batches_completed
+     */
+    protected function print_total_batches( $batches_completed ) {
+        WP_CLI::log(
+            sprintf(
+                /* translators: %d refers to the total number of batches executed */
+                _n( '%d batch executed.', '%d batches executed.', $batches_completed, 'woocommerce' ),
+                number_format_i18n( $batches_completed )
+            )
+        );
+    }
+
+    /**
+     * Convert an exception into a WP CLI error.
+     *
+     * @author Jeremy Pry
+     *
+     * @param Exception $e The error object.
+     *
+     * @throws \WP_CLI\ExitException
+     */
+    protected function print_error( Exception $e ) {
+        WP_CLI::error(
+            sprintf(
+                /* translators: %s refers to the exception error message */
+                __( 'There was an error running the action scheduler: %s', 'woocommerce' ),
+                $e->getMessage()
+            )
+        );
+    }
+
+    /**
+     * Print a success message with the number of completed actions.
+     *
+     * @author Jeremy Pry
+     *
+     * @param int $actions_completed
+     */
+    protected function print_success( $actions_completed ) {
+        WP_CLI::success(
+            sprintf(
+                /* translators: %d refers to the total number of taskes completed */
+                _n( '%d scheduled task completed.', '%d scheduled tasks completed.', $actions_completed, 'woocommerce' ),
+                number_format_i18n( $actions_completed )
+            )
+        );
+    }
 }

Spacing +40 added lines, -40 removed lines

@@ -15,19 +15,19 @@ 
 	 *
 	 * @subcommand fix-schema
 	 */
-	public function fix_schema( $args, $assoc_args ) {
-		$schema_classes = array( ActionScheduler_LoggerSchema::class, ActionScheduler_StoreSchema::class );
+	public function fix_schema($args, $assoc_args) {
+		$schema_classes = array(ActionScheduler_LoggerSchema::class, ActionScheduler_StoreSchema::class);
 
-		foreach ( $schema_classes as $classname ) {
-			if ( is_subclass_of( $classname, ActionScheduler_Abstract_Schema::class ) ) {
+		foreach ($schema_classes as $classname) {
+			if (is_subclass_of($classname, ActionScheduler_Abstract_Schema::class)) {
 				$obj = new $classname();
 				$obj->init();
-				$obj->register_tables( true );
+				$obj->register_tables(true);
 
 				WP_CLI::success(
 					sprintf(
 						/* translators: %s refers to the schema name*/
-						__( 'Registered schema for %s', 'woocommerce' ),
+						__('Registered schema for %s', 'woocommerce'),
 						$classname
 					)
 				);
@@ -70,20 +70,20 @@ 
 	 *
 	 * @subcommand run
 	 */
-	public function run( $args, $assoc_args ) {
+	public function run($args, $assoc_args) {
 		// Handle passed arguments.
-		$batch   = absint( \WP_CLI\Utils\get_flag_value( $assoc_args, 'batch-size', 100 ) );
-		$batches = absint( \WP_CLI\Utils\get_flag_value( $assoc_args, 'batches', 0 ) );
-		$clean   = absint( \WP_CLI\Utils\get_flag_value( $assoc_args, 'cleanup-batch-size', $batch ) );
-		$hooks   = explode( ',', WP_CLI\Utils\get_flag_value( $assoc_args, 'hooks', '' ) );
-		$hooks   = array_filter( array_map( 'trim', $hooks ) );
-		$group   = \WP_CLI\Utils\get_flag_value( $assoc_args, 'group', '' );
-		$free_on = \WP_CLI\Utils\get_flag_value( $assoc_args, 'free-memory-on', 50 );
-		$sleep   = \WP_CLI\Utils\get_flag_value( $assoc_args, 'pause', 0 );
-		$force   = \WP_CLI\Utils\get_flag_value( $assoc_args, 'force', false );
-
-		ActionScheduler_DataController::set_free_ticks( $free_on );
-		ActionScheduler_DataController::set_sleep_time( $sleep );
+		$batch   = absint(\WP_CLI\Utils\get_flag_value($assoc_args, 'batch-size', 100));
+		$batches = absint(\WP_CLI\Utils\get_flag_value($assoc_args, 'batches', 0));
+		$clean   = absint(\WP_CLI\Utils\get_flag_value($assoc_args, 'cleanup-batch-size', $batch));
+		$hooks   = explode(',', WP_CLI\Utils\get_flag_value($assoc_args, 'hooks', ''));
+		$hooks   = array_filter(array_map('trim', $hooks));
+		$group   = \WP_CLI\Utils\get_flag_value($assoc_args, 'group', '');
+		$free_on = \WP_CLI\Utils\get_flag_value($assoc_args, 'free-memory-on', 50);
+		$sleep   = \WP_CLI\Utils\get_flag_value($assoc_args, 'pause', 0);
+		$force   = \WP_CLI\Utils\get_flag_value($assoc_args, 'force', false);
+
+		ActionScheduler_DataController::set_free_ticks($free_on);
+		ActionScheduler_DataController::set_sleep_time($sleep);
 
 		$batches_completed = 0;
 		$actions_completed = 0;
@@ -91,29 +91,29 @@ 
 
 		try {
 			// Custom queue cleaner instance.
-			$cleaner = new ActionScheduler_QueueCleaner( null, $clean );
+			$cleaner = new ActionScheduler_QueueCleaner(null, $clean);
 
 			// Get the queue runner instance
-			$runner = new ActionScheduler_WPCLI_QueueRunner( null, null, $cleaner );
+			$runner = new ActionScheduler_WPCLI_QueueRunner(null, null, $cleaner);
 
 			// Determine how many tasks will be run in the first batch.
-			$total = $runner->setup( $batch, $hooks, $group, $force );
+			$total = $runner->setup($batch, $hooks, $group, $force);
 
 			// Run actions for as long as possible.
-			while ( $total > 0 ) {
-				$this->print_total_actions( $total );
+			while ($total > 0) {
+				$this->print_total_actions($total);
 				$actions_completed += $runner->run();
 				$batches_completed++;
 
 				// Maybe set up tasks for the next batch.
-				$total = ( $unlimited || $batches_completed < $batches ) ? $runner->setup( $batch, $hooks, $group, $force ) : 0;
+				$total = ($unlimited || $batches_completed < $batches) ? $runner->setup($batch, $hooks, $group, $force) : 0;
 			}
-		} catch ( Exception $e ) {
-			$this->print_error( $e );
+		} catch (Exception $e) {
+			$this->print_error($e);
 		}
 
-		$this->print_total_batches( $batches_completed );
-		$this->print_success( $actions_completed );
+		$this->print_total_batches($batches_completed);
+		$this->print_success($actions_completed);
 	}
 
 	/**
@@ -123,12 +123,12 @@ 
 	 *
 	 * @param int $total
 	 */
-	protected function print_total_actions( $total ) {
+	protected function print_total_actions($total) {
 		WP_CLI::log(
 			sprintf(
 				/* translators: %d refers to how many scheduled taks were found to run */
-				_n( 'Found %d scheduled task', 'Found %d scheduled tasks', $total, 'woocommerce' ),
-				number_format_i18n( $total )
+				_n('Found %d scheduled task', 'Found %d scheduled tasks', $total, 'woocommerce'),
+				number_format_i18n($total)
 			)
 		);
 	}
@@ -140,12 +140,12 @@ 
 	 *
 	 * @param int $batches_completed
 	 */
-	protected function print_total_batches( $batches_completed ) {
+	protected function print_total_batches($batches_completed) {
 		WP_CLI::log(
 			sprintf(
 				/* translators: %d refers to the total number of batches executed */
-				_n( '%d batch executed.', '%d batches executed.', $batches_completed, 'woocommerce' ),
-				number_format_i18n( $batches_completed )
+				_n('%d batch executed.', '%d batches executed.', $batches_completed, 'woocommerce'),
+				number_format_i18n($batches_completed)
 			)
 		);
 	}
@@ -159,11 +159,11 @@ 
 	 *
 	 * @throws \WP_CLI\ExitException
 	 */
-	protected function print_error( Exception $e ) {
+	protected function print_error(Exception $e) {
 		WP_CLI::error(
 			sprintf(
 				/* translators: %s refers to the exception error message */
-				__( 'There was an error running the action scheduler: %s', 'woocommerce' ),
+				__('There was an error running the action scheduler: %s', 'woocommerce'),
 				$e->getMessage()
 			)
 		);
@@ -176,12 +176,12 @@ 
 	 *
 	 * @param int $actions_completed
 	 */
-	protected function print_success( $actions_completed ) {
+	protected function print_success($actions_completed) {
 		WP_CLI::success(
 			sprintf(
 				/* translators: %d refers to the total number of taskes completed */
-				_n( '%d scheduled task completed.', '%d scheduled tasks completed.', $actions_completed, 'woocommerce' ),
-				number_format_i18n( $actions_completed )
+				_n('%d scheduled task completed.', '%d scheduled tasks completed.', $actions_completed, 'woocommerce'),
+				number_format_i18n($actions_completed)
 			)
 		);
 	}

plugins/woocommerce/packages/action-scheduler/classes/WP_CLI/ProgressBar.php

Indentation +99 added lines, -99 removed lines

@@ -17,103 +17,103 @@
  */
 class ProgressBar {
 
-	/** @var integer */
-	protected $total_ticks;
-
-	/** @var integer */
-	protected $count;
-
-	/** @var integer */
-	protected $interval;
-
-	/** @var string */
-	protected $message;
-
-	/** @var \cli\progress\Bar */
-	protected $progress_bar;
-
-	/**
-	 * ProgressBar constructor.
-	 *
-	 * @param string  $message    Text to display before the progress bar.
-	 * @param integer $count      Total number of ticks to be performed.
-	 * @param integer $interval   Optional. The interval in milliseconds between updates. Default 100.
- 	 *
-	 * @throws Exception When this is not run within WP CLI
-	 */
-	public function __construct( $message, $count, $interval = 100 ) {
-		if ( ! ( defined( 'WP_CLI' ) && WP_CLI ) ) {
-			/* translators: %s php class name */
-			throw new \Exception( sprintf( __( 'The %s class can only be run within WP CLI.', 'woocommerce' ), __CLASS__ ) );
-		}
-
-		$this->total_ticks = 0;
-		$this->message     = $message;
-		$this->count       = $count;
-		$this->interval    = $interval;
-	}
-
-	/**
-	 * Increment the progress bar ticks.
-	 */
-	public function tick() {
-		if ( null === $this->progress_bar ) {
-			$this->setup_progress_bar();
-		}
-
-		$this->progress_bar->tick();
-		$this->total_ticks++;
-
-		do_action( 'action_scheduler/progress_tick', $this->total_ticks );
-	}
-
-	/**
-	 * Get the progress bar tick count.
-	 *
-	 * @return int
-	 */
-	public function current() {
-		return $this->progress_bar ? $this->progress_bar->current() : 0;
-	}
-
-	/**
-	 * Finish the current progress bar.
-	 */
-	public function finish() {
-		if ( null !== $this->progress_bar ) {
-			$this->progress_bar->finish();
-		}
-
-		$this->progress_bar = null;
-	}
-
-	/**
-	 * Set the message used when creating the progress bar.
-	 *
-	 * @param string $message The message to be used when the next progress bar is created.
-	 */
-	public function set_message( $message ) {
-		$this->message = $message;
-	}
-
-	/**
-	 * Set the count for a new progress bar.
-	 *
-	 * @param integer $count The total number of ticks expected to complete.
-	 */
-	public function set_count( $count ) {
-		$this->count = $count;
-		$this->finish();
-	}
-
-	/**
-	 * Set up the progress bar.
-	 */
-	protected function setup_progress_bar() {
-		$this->progress_bar = \WP_CLI\Utils\make_progress_bar(
-			$this->message,
-			$this->count,
-			$this->interval
-		);
-	}
+    /** @var integer */
+    protected $total_ticks;
+
+    /** @var integer */
+    protected $count;
+
+    /** @var integer */
+    protected $interval;
+
+    /** @var string */
+    protected $message;
+
+    /** @var \cli\progress\Bar */
+    protected $progress_bar;
+
+    /**
+     * ProgressBar constructor.
+     *
+     * @param string  $message    Text to display before the progress bar.
+     * @param integer $count      Total number of ticks to be performed.
+     * @param integer $interval   Optional. The interval in milliseconds between updates. Default 100.
+     *
+     * @throws Exception When this is not run within WP CLI
+     */
+    public function __construct( $message, $count, $interval = 100 ) {
+        if ( ! ( defined( 'WP_CLI' ) && WP_CLI ) ) {
+            /* translators: %s php class name */
+            throw new \Exception( sprintf( __( 'The %s class can only be run within WP CLI.', 'woocommerce' ), __CLASS__ ) );
+        }
+
+        $this->total_ticks = 0;
+        $this->message     = $message;
+        $this->count       = $count;
+        $this->interval    = $interval;
+    }
+
+    /**
+     * Increment the progress bar ticks.
+     */
+    public function tick() {
+        if ( null === $this->progress_bar ) {
+            $this->setup_progress_bar();
+        }
+
+        $this->progress_bar->tick();
+        $this->total_ticks++;
+
+        do_action( 'action_scheduler/progress_tick', $this->total_ticks );
+    }
+
+    /**
+     * Get the progress bar tick count.
+     *
+     * @return int
+     */
+    public function current() {
+        return $this->progress_bar ? $this->progress_bar->current() : 0;
+    }
+
+    /**
+     * Finish the current progress bar.
+     */
+    public function finish() {
+        if ( null !== $this->progress_bar ) {
+            $this->progress_bar->finish();
+        }
+
+        $this->progress_bar = null;
+    }
+
+    /**
+     * Set the message used when creating the progress bar.
+     *
+     * @param string $message The message to be used when the next progress bar is created.
+     */
+    public function set_message( $message ) {
+        $this->message = $message;
+    }
+
+    /**
+     * Set the count for a new progress bar.
+     *
+     * @param integer $count The total number of ticks expected to complete.
+     */
+    public function set_count( $count ) {
+        $this->count = $count;
+        $this->finish();
+    }
+
+    /**
+     * Set up the progress bar.
+     */
+    protected function setup_progress_bar() {
+        $this->progress_bar = \WP_CLI\Utils\make_progress_bar(
+            $this->message,
+            $this->count,
+            $this->interval
+        );
+    }
 }

Spacing +8 added lines, -8 removed lines

@@ -41,10 +41,10 @@ 
  	 *
 	 * @throws Exception When this is not run within WP CLI
 	 */
-	public function __construct( $message, $count, $interval = 100 ) {
-		if ( ! ( defined( 'WP_CLI' ) && WP_CLI ) ) {
+	public function __construct($message, $count, $interval = 100) {
+		if (!(defined('WP_CLI') && WP_CLI)) {
 			/* translators: %s php class name */
-			throw new \Exception( sprintf( __( 'The %s class can only be run within WP CLI.', 'woocommerce' ), __CLASS__ ) );
+			throw new \Exception(sprintf(__('The %s class can only be run within WP CLI.', 'woocommerce'), __CLASS__));
 		}
 
 		$this->total_ticks = 0;
@@ -57,14 +57,14 @@ 
 	 * Increment the progress bar ticks.
 	 */
 	public function tick() {
-		if ( null === $this->progress_bar ) {
+		if (null === $this->progress_bar) {
 			$this->setup_progress_bar();
 		}
 
 		$this->progress_bar->tick();
 		$this->total_ticks++;
 
-		do_action( 'action_scheduler/progress_tick', $this->total_ticks );
+		do_action('action_scheduler/progress_tick', $this->total_ticks);
 	}
 
 	/**
@@ -80,7 +80,7 @@ 
 	 * Finish the current progress bar.
 	 */
 	public function finish() {
-		if ( null !== $this->progress_bar ) {
+		if (null !== $this->progress_bar) {
 			$this->progress_bar->finish();
 		}
 
@@ -92,7 +92,7 @@ 
 	 *
 	 * @param string $message The message to be used when the next progress bar is created.
 	 */
-	public function set_message( $message ) {
+	public function set_message($message) {
 		$this->message = $message;
 	}
 
@@ -101,7 +101,7 @@ 
 	 *
 	 * @param integer $count The total number of ticks expected to complete.
 	 */
-	public function set_count( $count ) {
+	public function set_count($count) {
 		$this->count = $count;
 		$this->finish();
 	}

plugins/woocommerce/packages/action-scheduler/classes/WP_CLI/Migration_Command.php

Indentation +124 added lines, -124 removed lines

@@ -21,128 +21,128 @@
  */
 class Migration_Command extends WP_CLI_Command {
 
-	/** @var int */
-	private $total_processed = 0;
-
-	/**
-	 * Register the command with WP-CLI
-	 */
-	public function register() {
-		if ( ! defined( 'WP_CLI' ) || ! WP_CLI ) {
-			return;
-		}
-
-		WP_CLI::add_command( 'action-scheduler migrate', [ $this, 'migrate' ], [
-			'shortdesc' => 'Migrates actions to the DB tables store',
-			'synopsis'  => [
-				[
-					'type'        => 'assoc',
-					'name'        => 'batch-size',
-					'optional'    => true,
-					'default'     => 100,
-					'description' => 'The number of actions to process in each batch',
-				],
-				[
-					'type'        => 'assoc',
-					'name'        => 'free-memory-on',
-					'optional'    => true,
-					'default'     => 50,
-					'description' => 'The number of actions to process between freeing memory. 0 disables freeing memory',
-				],
-				[
-					'type'        => 'assoc',
-					'name'        => 'pause',
-					'optional'    => true,
-					'default'     => 0,
-					'description' => 'The number of seconds to pause when freeing memory',
-				],
-				[
-					'type'        => 'flag',
-					'name'        => 'dry-run',
-					'optional'    => true,
-					'description' => 'Reports on the actions that would have been migrated, but does not change any data',
-				],
-			],
-		] );
-	}
-
-	/**
-	 * Process the data migration.
-	 *
-	 * @param array $positional_args Required for WP CLI. Not used in migration.
-	 * @param array $assoc_args Optional arguments.
-	 *
-	 * @return void
-	 */
-	public function migrate( $positional_args, $assoc_args ) {
-		$this->init_logging();
-
-		$config = $this->get_migration_config( $assoc_args );
-		$runner = new Runner( $config );
-		$runner->init_destination();
-
-		$batch_size = isset( $assoc_args[ 'batch-size' ] ) ? (int) $assoc_args[ 'batch-size' ] : 100;
-		$free_on    = isset( $assoc_args[ 'free-memory-on' ] ) ? (int) $assoc_args[ 'free-memory-on' ] : 50;
-		$sleep      = isset( $assoc_args[ 'pause' ] ) ? (int) $assoc_args[ 'pause' ] : 0;
-		\ActionScheduler_DataController::set_free_ticks( $free_on );
-		\ActionScheduler_DataController::set_sleep_time( $sleep );
-
-		do {
-			$actions_processed     = $runner->run( $batch_size );
-			$this->total_processed += $actions_processed;
-		} while ( $actions_processed > 0 );
-
-		if ( ! $config->get_dry_run() ) {
-			// let the scheduler know that there's nothing left to do
-			$scheduler = new Scheduler();
-			$scheduler->mark_complete();
-		}
-
-		WP_CLI::success( sprintf( '%s complete. %d actions processed.', $config->get_dry_run() ? 'Dry run' : 'Migration', $this->total_processed ) );
-	}
-
-	/**
-	 * Build the config object used to create the Runner
-	 *
-	 * @param array $args Optional arguments.
-	 *
-	 * @return ActionScheduler\Migration\Config
-	 */
-	private function get_migration_config( $args ) {
-		$args = wp_parse_args( $args, [
-			'dry-run' => false,
-		] );
-
-		$config = Controller::instance()->get_migration_config_object();
-		$config->set_dry_run( ! empty( $args[ 'dry-run' ] ) );
-
-		return $config;
-	}
-
-	/**
-	 * Hook command line logging into migration actions.
-	 */
-	private function init_logging() {
-		add_action( 'action_scheduler/migrate_action_dry_run', function ( $action_id ) {
-			WP_CLI::debug( sprintf( 'Dry-run: migrated action %d', $action_id ) );
-		}, 10, 1 );
-		add_action( 'action_scheduler/no_action_to_migrate', function ( $action_id ) {
-			WP_CLI::debug( sprintf( 'No action found to migrate for ID %d', $action_id ) );
-		}, 10, 1 );
-		add_action( 'action_scheduler/migrate_action_failed', function ( $action_id ) {
-			WP_CLI::warning( sprintf( 'Failed migrating action with ID %d', $action_id ) );
-		}, 10, 1 );
-		add_action( 'action_scheduler/migrate_action_incomplete', function ( $source_id, $destination_id ) {
-			WP_CLI::warning( sprintf( 'Unable to remove source action with ID %d after migrating to new ID %d', $source_id, $destination_id ) );
-		}, 10, 2 );
-		add_action( 'action_scheduler/migrated_action', function ( $source_id, $destination_id ) {
-			WP_CLI::debug( sprintf( 'Migrated source action with ID %d to new store with ID %d', $source_id, $destination_id ) );
-		}, 10, 2 );
-		add_action( 'action_scheduler/migration_batch_starting', function ( $batch ) {
-			WP_CLI::debug( 'Beginning migration of batch: ' . print_r( $batch, true ) );
-		}, 10, 1 );
-		add_action( 'action_scheduler/migration_batch_complete', function ( $batch ) {
-			WP_CLI::log( sprintf( 'Completed migration of %d actions', count( $batch ) ) );
-		}, 10, 1 );
-	}
+    /** @var int */
+    private $total_processed = 0;
+
+    /**
+     * Register the command with WP-CLI
+     */
+    public function register() {
+        if ( ! defined( 'WP_CLI' ) || ! WP_CLI ) {
+            return;
+        }
+
+        WP_CLI::add_command( 'action-scheduler migrate', [ $this, 'migrate' ], [
+            'shortdesc' => 'Migrates actions to the DB tables store',
+            'synopsis'  => [
+                [
+                    'type'        => 'assoc',
+                    'name'        => 'batch-size',
+                    'optional'    => true,
+                    'default'     => 100,
+                    'description' => 'The number of actions to process in each batch',
+                ],
+                [
+                    'type'        => 'assoc',
+                    'name'        => 'free-memory-on',
+                    'optional'    => true,
+                    'default'     => 50,
+                    'description' => 'The number of actions to process between freeing memory. 0 disables freeing memory',
+                ],
+                [
+                    'type'        => 'assoc',
+                    'name'        => 'pause',
+                    'optional'    => true,
+                    'default'     => 0,
+                    'description' => 'The number of seconds to pause when freeing memory',
+                ],
+                [
+                    'type'        => 'flag',
+                    'name'        => 'dry-run',
+                    'optional'    => true,
+                    'description' => 'Reports on the actions that would have been migrated, but does not change any data',
+                ],
+            ],
+        ] );
+    }
+
+    /**
+     * Process the data migration.
+     *
+     * @param array $positional_args Required for WP CLI. Not used in migration.
+     * @param array $assoc_args Optional arguments.
+     *
+     * @return void
+     */
+    public function migrate( $positional_args, $assoc_args ) {
+        $this->init_logging();
+
+        $config = $this->get_migration_config( $assoc_args );
+        $runner = new Runner( $config );
+        $runner->init_destination();
+
+        $batch_size = isset( $assoc_args[ 'batch-size' ] ) ? (int) $assoc_args[ 'batch-size' ] : 100;
+        $free_on    = isset( $assoc_args[ 'free-memory-on' ] ) ? (int) $assoc_args[ 'free-memory-on' ] : 50;
+        $sleep      = isset( $assoc_args[ 'pause' ] ) ? (int) $assoc_args[ 'pause' ] : 0;
+        \ActionScheduler_DataController::set_free_ticks( $free_on );
+        \ActionScheduler_DataController::set_sleep_time( $sleep );
+
+        do {
+            $actions_processed     = $runner->run( $batch_size );
+            $this->total_processed += $actions_processed;
+        } while ( $actions_processed > 0 );
+
+        if ( ! $config->get_dry_run() ) {
+            // let the scheduler know that there's nothing left to do
+            $scheduler = new Scheduler();
+            $scheduler->mark_complete();
+        }
+
+        WP_CLI::success( sprintf( '%s complete. %d actions processed.', $config->get_dry_run() ? 'Dry run' : 'Migration', $this->total_processed ) );
+    }
+
+    /**
+     * Build the config object used to create the Runner
+     *
+     * @param array $args Optional arguments.
+     *
+     * @return ActionScheduler\Migration\Config
+     */
+    private function get_migration_config( $args ) {
+        $args = wp_parse_args( $args, [
+            'dry-run' => false,
+        ] );
+
+        $config = Controller::instance()->get_migration_config_object();
+        $config->set_dry_run( ! empty( $args[ 'dry-run' ] ) );
+
+        return $config;
+    }
+
+    /**
+     * Hook command line logging into migration actions.
+     */
+    private function init_logging() {
+        add_action( 'action_scheduler/migrate_action_dry_run', function ( $action_id ) {
+            WP_CLI::debug( sprintf( 'Dry-run: migrated action %d', $action_id ) );
+        }, 10, 1 );
+        add_action( 'action_scheduler/no_action_to_migrate', function ( $action_id ) {
+            WP_CLI::debug( sprintf( 'No action found to migrate for ID %d', $action_id ) );
+        }, 10, 1 );
+        add_action( 'action_scheduler/migrate_action_failed', function ( $action_id ) {
+            WP_CLI::warning( sprintf( 'Failed migrating action with ID %d', $action_id ) );
+        }, 10, 1 );
+        add_action( 'action_scheduler/migrate_action_incomplete', function ( $source_id, $destination_id ) {
+            WP_CLI::warning( sprintf( 'Unable to remove source action with ID %d after migrating to new ID %d', $source_id, $destination_id ) );
+        }, 10, 2 );
+        add_action( 'action_scheduler/migrated_action', function ( $source_id, $destination_id ) {
+            WP_CLI::debug( sprintf( 'Migrated source action with ID %d to new store with ID %d', $source_id, $destination_id ) );
+        }, 10, 2 );
+        add_action( 'action_scheduler/migration_batch_starting', function ( $batch ) {
+            WP_CLI::debug( 'Beginning migration of batch: ' . print_r( $batch, true ) );
+        }, 10, 1 );
+        add_action( 'action_scheduler/migration_batch_complete', function ( $batch ) {
+            WP_CLI::log( sprintf( 'Completed migration of %d actions', count( $batch ) ) );
+        }, 10, 1 );
+    }
 }

Spacing +40 added lines, -40 removed lines

@@ -28,11 +28,11 @@ 
 	 * Register the command with WP-CLI
 	 */
 	public function register() {
-		if ( ! defined( 'WP_CLI' ) || ! WP_CLI ) {
+		if (!defined('WP_CLI') || !WP_CLI) {
 			return;
 		}
 
-		WP_CLI::add_command( 'action-scheduler migrate', [ $this, 'migrate' ], [
+		WP_CLI::add_command('action-scheduler migrate', [$this, 'migrate'], [
 			'shortdesc' => 'Migrates actions to the DB tables store',
 			'synopsis'  => [
 				[
@@ -63,7 +63,7 @@ 
 					'description' => 'Reports on the actions that would have been migrated, but does not change any data',
 				],
 			],
-		] );
+		]);
 	}
 
 	/**
@@ -74,31 +74,31 @@ 
 	 *
 	 * @return void
 	 */
-	public function migrate( $positional_args, $assoc_args ) {
+	public function migrate($positional_args, $assoc_args) {
 		$this->init_logging();
 
-		$config = $this->get_migration_config( $assoc_args );
-		$runner = new Runner( $config );
+		$config = $this->get_migration_config($assoc_args);
+		$runner = new Runner($config);
 		$runner->init_destination();
 
-		$batch_size = isset( $assoc_args[ 'batch-size' ] ) ? (int) $assoc_args[ 'batch-size' ] : 100;
-		$free_on    = isset( $assoc_args[ 'free-memory-on' ] ) ? (int) $assoc_args[ 'free-memory-on' ] : 50;
-		$sleep      = isset( $assoc_args[ 'pause' ] ) ? (int) $assoc_args[ 'pause' ] : 0;
-		\ActionScheduler_DataController::set_free_ticks( $free_on );
-		\ActionScheduler_DataController::set_sleep_time( $sleep );
+		$batch_size = isset($assoc_args['batch-size']) ? (int) $assoc_args['batch-size'] : 100;
+		$free_on    = isset($assoc_args['free-memory-on']) ? (int) $assoc_args['free-memory-on'] : 50;
+		$sleep      = isset($assoc_args['pause']) ? (int) $assoc_args['pause'] : 0;
+		\ActionScheduler_DataController::set_free_ticks($free_on);
+		\ActionScheduler_DataController::set_sleep_time($sleep);
 
 		do {
-			$actions_processed     = $runner->run( $batch_size );
+			$actions_processed = $runner->run($batch_size);
 			$this->total_processed += $actions_processed;
-		} while ( $actions_processed > 0 );
+		} while ($actions_processed > 0);
 
-		if ( ! $config->get_dry_run() ) {
+		if (!$config->get_dry_run()) {
 			// let the scheduler know that there's nothing left to do
 			$scheduler = new Scheduler();
 			$scheduler->mark_complete();
 		}
 
-		WP_CLI::success( sprintf( '%s complete. %d actions processed.', $config->get_dry_run() ? 'Dry run' : 'Migration', $this->total_processed ) );
+		WP_CLI::success(sprintf('%s complete. %d actions processed.', $config->get_dry_run() ? 'Dry run' : 'Migration', $this->total_processed));
 	}
 
 	/**
@@ -108,13 +108,13 @@ 
 	 *
 	 * @return ActionScheduler\Migration\Config
 	 */
-	private function get_migration_config( $args ) {
-		$args = wp_parse_args( $args, [
+	private function get_migration_config($args) {
+		$args = wp_parse_args($args, [
 			'dry-run' => false,
-		] );
+		]);
 
 		$config = Controller::instance()->get_migration_config_object();
-		$config->set_dry_run( ! empty( $args[ 'dry-run' ] ) );
+		$config->set_dry_run(!empty($args['dry-run']));
 
 		return $config;
 	}
@@ -123,26 +123,26 @@ 
 	 * Hook command line logging into migration actions.
 	 */
 	private function init_logging() {
-		add_action( 'action_scheduler/migrate_action_dry_run', function ( $action_id ) {
-			WP_CLI::debug( sprintf( 'Dry-run: migrated action %d', $action_id ) );
-		}, 10, 1 );
-		add_action( 'action_scheduler/no_action_to_migrate', function ( $action_id ) {
-			WP_CLI::debug( sprintf( 'No action found to migrate for ID %d', $action_id ) );
-		}, 10, 1 );
-		add_action( 'action_scheduler/migrate_action_failed', function ( $action_id ) {
-			WP_CLI::warning( sprintf( 'Failed migrating action with ID %d', $action_id ) );
-		}, 10, 1 );
-		add_action( 'action_scheduler/migrate_action_incomplete', function ( $source_id, $destination_id ) {
-			WP_CLI::warning( sprintf( 'Unable to remove source action with ID %d after migrating to new ID %d', $source_id, $destination_id ) );
-		}, 10, 2 );
-		add_action( 'action_scheduler/migrated_action', function ( $source_id, $destination_id ) {
-			WP_CLI::debug( sprintf( 'Migrated source action with ID %d to new store with ID %d', $source_id, $destination_id ) );
-		}, 10, 2 );
-		add_action( 'action_scheduler/migration_batch_starting', function ( $batch ) {
-			WP_CLI::debug( 'Beginning migration of batch: ' . print_r( $batch, true ) );
-		}, 10, 1 );
-		add_action( 'action_scheduler/migration_batch_complete', function ( $batch ) {
-			WP_CLI::log( sprintf( 'Completed migration of %d actions', count( $batch ) ) );
-		}, 10, 1 );
+		add_action('action_scheduler/migrate_action_dry_run', function($action_id) {
+			WP_CLI::debug(sprintf('Dry-run: migrated action %d', $action_id));
+		}, 10, 1);
+		add_action('action_scheduler/no_action_to_migrate', function($action_id) {
+			WP_CLI::debug(sprintf('No action found to migrate for ID %d', $action_id));
+		}, 10, 1);
+		add_action('action_scheduler/migrate_action_failed', function($action_id) {
+			WP_CLI::warning(sprintf('Failed migrating action with ID %d', $action_id));
+		}, 10, 1);
+		add_action('action_scheduler/migrate_action_incomplete', function($source_id, $destination_id) {
+			WP_CLI::warning(sprintf('Unable to remove source action with ID %d after migrating to new ID %d', $source_id, $destination_id));
+		}, 10, 2);
+		add_action('action_scheduler/migrated_action', function($source_id, $destination_id) {
+			WP_CLI::debug(sprintf('Migrated source action with ID %d to new store with ID %d', $source_id, $destination_id));
+		}, 10, 2);
+		add_action('action_scheduler/migration_batch_starting', function($batch) {
+			WP_CLI::debug('Beginning migration of batch: ' . print_r($batch, true));
+		}, 10, 1);
+		add_action('action_scheduler/migration_batch_complete', function($batch) {
+			WP_CLI::log(sprintf('Completed migration of %d actions', count($batch)));
+		}, 10, 1);
 	}
 }

plugins/woocommerce/packages/action-scheduler/classes/ActionScheduler_ActionFactory.php

Indentation +159 added lines, -159 removed lines

@@ -5,175 +5,175 @@
  */
 class ActionScheduler_ActionFactory {
 
-	/**
-	 * @param string $status The action's status in the data store
-	 * @param string $hook The hook to trigger when this action runs
-	 * @param array $args Args to pass to callbacks when the hook is triggered
-	 * @param ActionScheduler_Schedule $schedule The action's schedule
-	 * @param string $group A group to put the action in
-	 *
-	 * @return ActionScheduler_Action An instance of the stored action
-	 */
-	public function get_stored_action( $status, $hook, array $args = array(), ActionScheduler_Schedule $schedule = null, $group = '' ) {
+    /**
+     * @param string $status The action's status in the data store
+     * @param string $hook The hook to trigger when this action runs
+     * @param array $args Args to pass to callbacks when the hook is triggered
+     * @param ActionScheduler_Schedule $schedule The action's schedule
+     * @param string $group A group to put the action in
+     *
+     * @return ActionScheduler_Action An instance of the stored action
+     */
+    public function get_stored_action( $status, $hook, array $args = array(), ActionScheduler_Schedule $schedule = null, $group = '' ) {
 
-		switch ( $status ) {
-			case ActionScheduler_Store::STATUS_PENDING :
-				$action_class = 'ActionScheduler_Action';
-				break;
-			case ActionScheduler_Store::STATUS_CANCELED :
-				$action_class = 'ActionScheduler_CanceledAction';
-				if ( ! is_null( $schedule ) && ! is_a( $schedule, 'ActionScheduler_CanceledSchedule' ) && ! is_a( $schedule, 'ActionScheduler_NullSchedule' ) ) {
-					$schedule = new ActionScheduler_CanceledSchedule( $schedule->get_date() );
-				}
-				break;
-			default :
-				$action_class = 'ActionScheduler_FinishedAction';
-				break;
-		}
+        switch ( $status ) {
+            case ActionScheduler_Store::STATUS_PENDING :
+                $action_class = 'ActionScheduler_Action';
+                break;
+            case ActionScheduler_Store::STATUS_CANCELED :
+                $action_class = 'ActionScheduler_CanceledAction';
+                if ( ! is_null( $schedule ) && ! is_a( $schedule, 'ActionScheduler_CanceledSchedule' ) && ! is_a( $schedule, 'ActionScheduler_NullSchedule' ) ) {
+                    $schedule = new ActionScheduler_CanceledSchedule( $schedule->get_date() );
+                }
+                break;
+            default :
+                $action_class = 'ActionScheduler_FinishedAction';
+                break;
+        }
 
-		$action_class = apply_filters( 'action_scheduler_stored_action_class', $action_class, $status, $hook, $args, $schedule, $group );
+        $action_class = apply_filters( 'action_scheduler_stored_action_class', $action_class, $status, $hook, $args, $schedule, $group );
 
-		$action = new $action_class( $hook, $args, $schedule, $group );
+        $action = new $action_class( $hook, $args, $schedule, $group );
 
-		/**
-		 * Allow 3rd party code to change the instantiated action for a given hook, args, schedule and group.
-		 *
-		 * @param ActionScheduler_Action $action The instantiated action.
-		 * @param string $hook The instantiated action's hook.
-		 * @param array $args The instantiated action's args.
-		 * @param ActionScheduler_Schedule $schedule The instantiated action's schedule.
-		 * @param string $group The instantiated action's group.
-		 */
-		return apply_filters( 'action_scheduler_stored_action_instance', $action, $hook, $args, $schedule, $group );
-	}
+        /**
+         * Allow 3rd party code to change the instantiated action for a given hook, args, schedule and group.
+         *
+         * @param ActionScheduler_Action $action The instantiated action.
+         * @param string $hook The instantiated action's hook.
+         * @param array $args The instantiated action's args.
+         * @param ActionScheduler_Schedule $schedule The instantiated action's schedule.
+         * @param string $group The instantiated action's group.
+         */
+        return apply_filters( 'action_scheduler_stored_action_instance', $action, $hook, $args, $schedule, $group );
+    }
 
-	/**
-	 * Enqueue an action to run one time, as soon as possible (rather a specific scheduled time).
-	 *
-	 * This method creates a new action with the NULLSchedule. This schedule maps to a MySQL datetime string of
-	 * 0000-00-00 00:00:00. This is done to create a psuedo "async action" type that is fully backward compatible.
-	 * Existing queries to claim actions claim by date, meaning actions scheduled for 0000-00-00 00:00:00 will
-	 * always be claimed prior to actions scheduled for a specific date. This makes sure that any async action is
-	 * given priority in queue processing. This has the added advantage of making sure async actions can be
-	 * claimed by both the existing WP Cron and WP CLI runners, as well as a new async request runner.
-	 *
-	 * @param string $hook The hook to trigger when this action runs
-	 * @param array $args Args to pass when the hook is triggered
-	 * @param string $group A group to put the action in
-	 *
-	 * @return int The ID of the stored action
-	 */
-	public function async( $hook, $args = array(), $group = '' ) {
-		$schedule = new ActionScheduler_NullSchedule();
-		$action = new ActionScheduler_Action( $hook, $args, $schedule, $group );
-		return $this->store( $action );
-	}
+    /**
+     * Enqueue an action to run one time, as soon as possible (rather a specific scheduled time).
+     *
+     * This method creates a new action with the NULLSchedule. This schedule maps to a MySQL datetime string of
+     * 0000-00-00 00:00:00. This is done to create a psuedo "async action" type that is fully backward compatible.
+     * Existing queries to claim actions claim by date, meaning actions scheduled for 0000-00-00 00:00:00 will
+     * always be claimed prior to actions scheduled for a specific date. This makes sure that any async action is
+     * given priority in queue processing. This has the added advantage of making sure async actions can be
+     * claimed by both the existing WP Cron and WP CLI runners, as well as a new async request runner.
+     *
+     * @param string $hook The hook to trigger when this action runs
+     * @param array $args Args to pass when the hook is triggered
+     * @param string $group A group to put the action in
+     *
+     * @return int The ID of the stored action
+     */
+    public function async( $hook, $args = array(), $group = '' ) {
+        $schedule = new ActionScheduler_NullSchedule();
+        $action = new ActionScheduler_Action( $hook, $args, $schedule, $group );
+        return $this->store( $action );
+    }
 
-	/**
-	 * @param string $hook The hook to trigger when this action runs
-	 * @param array $args Args to pass when the hook is triggered
-	 * @param int $when Unix timestamp when the action will run
-	 * @param string $group A group to put the action in
-	 *
-	 * @return int The ID of the stored action
-	 */
-	public function single( $hook, $args = array(), $when = null, $group = '' ) {
-		$date = as_get_datetime_object( $when );
-		$schedule = new ActionScheduler_SimpleSchedule( $date );
-		$action = new ActionScheduler_Action( $hook, $args, $schedule, $group );
-		return $this->store( $action );
-	}
+    /**
+     * @param string $hook The hook to trigger when this action runs
+     * @param array $args Args to pass when the hook is triggered
+     * @param int $when Unix timestamp when the action will run
+     * @param string $group A group to put the action in
+     *
+     * @return int The ID of the stored action
+     */
+    public function single( $hook, $args = array(), $when = null, $group = '' ) {
+        $date = as_get_datetime_object( $when );
+        $schedule = new ActionScheduler_SimpleSchedule( $date );
+        $action = new ActionScheduler_Action( $hook, $args, $schedule, $group );
+        return $this->store( $action );
+    }
 
-	/**
-	 * Create the first instance of an action recurring on a given interval.
-	 *
-	 * @param string $hook The hook to trigger when this action runs
-	 * @param array $args Args to pass when the hook is triggered
-	 * @param int $first Unix timestamp for the first run
-	 * @param int $interval Seconds between runs
-	 * @param string $group A group to put the action in
-	 *
-	 * @return int The ID of the stored action
-	 */
-	public function recurring( $hook, $args = array(), $first = null, $interval = null, $group = '' ) {
-		if ( empty($interval) ) {
-			return $this->single( $hook, $args, $first, $group );
-		}
-		$date = as_get_datetime_object( $first );
-		$schedule = new ActionScheduler_IntervalSchedule( $date, $interval );
-		$action = new ActionScheduler_Action( $hook, $args, $schedule, $group );
-		return $this->store( $action );
-	}
+    /**
+     * Create the first instance of an action recurring on a given interval.
+     *
+     * @param string $hook The hook to trigger when this action runs
+     * @param array $args Args to pass when the hook is triggered
+     * @param int $first Unix timestamp for the first run
+     * @param int $interval Seconds between runs
+     * @param string $group A group to put the action in
+     *
+     * @return int The ID of the stored action
+     */
+    public function recurring( $hook, $args = array(), $first = null, $interval = null, $group = '' ) {
+        if ( empty($interval) ) {
+            return $this->single( $hook, $args, $first, $group );
+        }
+        $date = as_get_datetime_object( $first );
+        $schedule = new ActionScheduler_IntervalSchedule( $date, $interval );
+        $action = new ActionScheduler_Action( $hook, $args, $schedule, $group );
+        return $this->store( $action );
+    }
 
-	/**
-	 * Create the first instance of an action recurring on a Cron schedule.
-	 *
-	 * @param string $hook The hook to trigger when this action runs
-	 * @param array $args Args to pass when the hook is triggered
-	 * @param int $base_timestamp The first instance of the action will be scheduled
-	 *        to run at a time calculated after this timestamp matching the cron
-	 *        expression. This can be used to delay the first instance of the action.
-	 * @param int $schedule A cron definition string
-	 * @param string $group A group to put the action in
-	 *
-	 * @return int The ID of the stored action
-	 */
-	public function cron( $hook, $args = array(), $base_timestamp = null, $schedule = null, $group = '' ) {
-		if ( empty($schedule) ) {
-			return $this->single( $hook, $args, $base_timestamp, $group );
-		}
-		$date = as_get_datetime_object( $base_timestamp );
-		$cron = CronExpression::factory( $schedule );
-		$schedule = new ActionScheduler_CronSchedule( $date, $cron );
-		$action = new ActionScheduler_Action( $hook, $args, $schedule, $group );
-		return $this->store( $action );
-	}
+    /**
+     * Create the first instance of an action recurring on a Cron schedule.
+     *
+     * @param string $hook The hook to trigger when this action runs
+     * @param array $args Args to pass when the hook is triggered
+     * @param int $base_timestamp The first instance of the action will be scheduled
+     *        to run at a time calculated after this timestamp matching the cron
+     *        expression. This can be used to delay the first instance of the action.
+     * @param int $schedule A cron definition string
+     * @param string $group A group to put the action in
+     *
+     * @return int The ID of the stored action
+     */
+    public function cron( $hook, $args = array(), $base_timestamp = null, $schedule = null, $group = '' ) {
+        if ( empty($schedule) ) {
+            return $this->single( $hook, $args, $base_timestamp, $group );
+        }
+        $date = as_get_datetime_object( $base_timestamp );
+        $cron = CronExpression::factory( $schedule );
+        $schedule = new ActionScheduler_CronSchedule( $date, $cron );
+        $action = new ActionScheduler_Action( $hook, $args, $schedule, $group );
+        return $this->store( $action );
+    }
 
-	/**
-	 * Create a successive instance of a recurring or cron action.
-	 *
-	 * Importantly, the action will be rescheduled to run based on the current date/time.
-	 * That means when the action is scheduled to run in the past, the next scheduled date
-	 * will be pushed forward. For example, if a recurring action set to run every hour
-	 * was scheduled to run 5 seconds ago, it will be next scheduled for 1 hour in the
-	 * future, which is 1 hour and 5 seconds from when it was last scheduled to run.
-	 *
-	 * Alternatively, if the action is scheduled to run in the future, and is run early,
-	 * likely via manual intervention, then its schedule will change based on the time now.
-	 * For example, if a recurring action set to run every day, and is run 12 hours early,
-	 * it will run again in 24 hours, not 36 hours.
-	 *
-	 * This slippage is less of an issue with Cron actions, as the specific run time can
-	 * be set for them to run, e.g. 1am each day. In those cases, and entire period would
-	 * need to be missed before there was any change is scheduled, e.g. in the case of an
-	 * action scheduled for 1am each day, the action would need to run an entire day late.
-	 *
-	 * @param ActionScheduler_Action $action The existing action.
-	 *
-	 * @return string The ID of the stored action
-	 * @throws InvalidArgumentException If $action is not a recurring action.
-	 */
-	public function repeat( $action ) {
-		$schedule = $action->get_schedule();
-		$next     = $schedule->get_next( as_get_datetime_object() );
+    /**
+     * Create a successive instance of a recurring or cron action.
+     *
+     * Importantly, the action will be rescheduled to run based on the current date/time.
+     * That means when the action is scheduled to run in the past, the next scheduled date
+     * will be pushed forward. For example, if a recurring action set to run every hour
+     * was scheduled to run 5 seconds ago, it will be next scheduled for 1 hour in the
+     * future, which is 1 hour and 5 seconds from when it was last scheduled to run.
+     *
+     * Alternatively, if the action is scheduled to run in the future, and is run early,
+     * likely via manual intervention, then its schedule will change based on the time now.
+     * For example, if a recurring action set to run every day, and is run 12 hours early,
+     * it will run again in 24 hours, not 36 hours.
+     *
+     * This slippage is less of an issue with Cron actions, as the specific run time can
+     * be set for them to run, e.g. 1am each day. In those cases, and entire period would
+     * need to be missed before there was any change is scheduled, e.g. in the case of an
+     * action scheduled for 1am each day, the action would need to run an entire day late.
+     *
+     * @param ActionScheduler_Action $action The existing action.
+     *
+     * @return string The ID of the stored action
+     * @throws InvalidArgumentException If $action is not a recurring action.
+     */
+    public function repeat( $action ) {
+        $schedule = $action->get_schedule();
+        $next     = $schedule->get_next( as_get_datetime_object() );
 
-		if ( is_null( $next ) || ! $schedule->is_recurring() ) {
-			throw new InvalidArgumentException( __( 'Invalid action - must be a recurring action.', 'woocommerce' ) );
-		}
+        if ( is_null( $next ) || ! $schedule->is_recurring() ) {
+            throw new InvalidArgumentException( __( 'Invalid action - must be a recurring action.', 'woocommerce' ) );
+        }
 
-		$schedule_class = get_class( $schedule );
-		$new_schedule = new $schedule( $next, $schedule->get_recurrence(), $schedule->get_first_date() );
-		$new_action = new ActionScheduler_Action( $action->get_hook(), $action->get_args(), $new_schedule, $action->get_group() );
-		return $this->store( $new_action );
-	}
+        $schedule_class = get_class( $schedule );
+        $new_schedule = new $schedule( $next, $schedule->get_recurrence(), $schedule->get_first_date() );
+        $new_action = new ActionScheduler_Action( $action->get_hook(), $action->get_args(), $new_schedule, $action->get_group() );
+        return $this->store( $new_action );
+    }
 
-	/**
-	 * @param ActionScheduler_Action $action
-	 *
-	 * @return int The ID of the stored action
-	 */
-	protected function store( ActionScheduler_Action $action ) {
-		$store = ActionScheduler_Store::instance();
-		return $store->save_action( $action );
-	}
+    /**
+     * @param ActionScheduler_Action $action
+     *
+     * @return int The ID of the stored action
+     */
+    protected function store( ActionScheduler_Action $action ) {
+        $store = ActionScheduler_Store::instance();
+        return $store->save_action( $action );
+    }
 }

Spacing +40 added lines, -40 removed lines

@@ -14,16 +14,16 @@ 
 	 *
 	 * @return ActionScheduler_Action An instance of the stored action
 	 */
-	public function get_stored_action( $status, $hook, array $args = array(), ActionScheduler_Schedule $schedule = null, $group = '' ) {
+	public function get_stored_action($status, $hook, array $args = array(), ActionScheduler_Schedule $schedule = null, $group = '') {
 
-		switch ( $status ) {
+		switch ($status) {
 			case ActionScheduler_Store::STATUS_PENDING :
 				$action_class = 'ActionScheduler_Action';
 				break;
 			case ActionScheduler_Store::STATUS_CANCELED :
 				$action_class = 'ActionScheduler_CanceledAction';
-				if ( ! is_null( $schedule ) && ! is_a( $schedule, 'ActionScheduler_CanceledSchedule' ) && ! is_a( $schedule, 'ActionScheduler_NullSchedule' ) ) {
-					$schedule = new ActionScheduler_CanceledSchedule( $schedule->get_date() );
+				if (!is_null($schedule) && !is_a($schedule, 'ActionScheduler_CanceledSchedule') && !is_a($schedule, 'ActionScheduler_NullSchedule')) {
+					$schedule = new ActionScheduler_CanceledSchedule($schedule->get_date());
 				}
 				break;
 			default :
@@ -31,9 +31,9 @@ 
 				break;
 		}
 
-		$action_class = apply_filters( 'action_scheduler_stored_action_class', $action_class, $status, $hook, $args, $schedule, $group );
+		$action_class = apply_filters('action_scheduler_stored_action_class', $action_class, $status, $hook, $args, $schedule, $group);
 
-		$action = new $action_class( $hook, $args, $schedule, $group );
+		$action = new $action_class($hook, $args, $schedule, $group);
 
 		/**
 		 * Allow 3rd party code to change the instantiated action for a given hook, args, schedule and group.
@@ -44,7 +44,7 @@ 
 		 * @param ActionScheduler_Schedule $schedule The instantiated action's schedule.
 		 * @param string $group The instantiated action's group.
 		 */
-		return apply_filters( 'action_scheduler_stored_action_instance', $action, $hook, $args, $schedule, $group );
+		return apply_filters('action_scheduler_stored_action_instance', $action, $hook, $args, $schedule, $group);
 	}
 
 	/**
@@ -63,10 +63,10 @@ 
 	 *
 	 * @return int The ID of the stored action
 	 */
-	public function async( $hook, $args = array(), $group = '' ) {
+	public function async($hook, $args = array(), $group = '') {
 		$schedule = new ActionScheduler_NullSchedule();
-		$action = new ActionScheduler_Action( $hook, $args, $schedule, $group );
-		return $this->store( $action );
+		$action = new ActionScheduler_Action($hook, $args, $schedule, $group);
+		return $this->store($action);
 	}
 
 	/**
@@ -77,11 +77,11 @@ 
 	 *
 	 * @return int The ID of the stored action
 	 */
-	public function single( $hook, $args = array(), $when = null, $group = '' ) {
-		$date = as_get_datetime_object( $when );
-		$schedule = new ActionScheduler_SimpleSchedule( $date );
-		$action = new ActionScheduler_Action( $hook, $args, $schedule, $group );
-		return $this->store( $action );
+	public function single($hook, $args = array(), $when = null, $group = '') {
+		$date = as_get_datetime_object($when);
+		$schedule = new ActionScheduler_SimpleSchedule($date);
+		$action = new ActionScheduler_Action($hook, $args, $schedule, $group);
+		return $this->store($action);
 	}
 
 	/**
@@ -95,14 +95,14 @@ 
 	 *
 	 * @return int The ID of the stored action
 	 */
-	public function recurring( $hook, $args = array(), $first = null, $interval = null, $group = '' ) {
-		if ( empty($interval) ) {
-			return $this->single( $hook, $args, $first, $group );
+	public function recurring($hook, $args = array(), $first = null, $interval = null, $group = '') {
+		if (empty($interval)) {
+			return $this->single($hook, $args, $first, $group);
 		}
-		$date = as_get_datetime_object( $first );
-		$schedule = new ActionScheduler_IntervalSchedule( $date, $interval );
-		$action = new ActionScheduler_Action( $hook, $args, $schedule, $group );
-		return $this->store( $action );
+		$date = as_get_datetime_object($first);
+		$schedule = new ActionScheduler_IntervalSchedule($date, $interval);
+		$action = new ActionScheduler_Action($hook, $args, $schedule, $group);
+		return $this->store($action);
 	}
 
 	/**
@@ -118,15 +118,15 @@ 
 	 *
 	 * @return int The ID of the stored action
 	 */
-	public function cron( $hook, $args = array(), $base_timestamp = null, $schedule = null, $group = '' ) {
-		if ( empty($schedule) ) {
-			return $this->single( $hook, $args, $base_timestamp, $group );
+	public function cron($hook, $args = array(), $base_timestamp = null, $schedule = null, $group = '') {
+		if (empty($schedule)) {
+			return $this->single($hook, $args, $base_timestamp, $group);
 		}
-		$date = as_get_datetime_object( $base_timestamp );
-		$cron = CronExpression::factory( $schedule );
-		$schedule = new ActionScheduler_CronSchedule( $date, $cron );
-		$action = new ActionScheduler_Action( $hook, $args, $schedule, $group );
-		return $this->store( $action );
+		$date = as_get_datetime_object($base_timestamp);
+		$cron = CronExpression::factory($schedule);
+		$schedule = new ActionScheduler_CronSchedule($date, $cron);
+		$action = new ActionScheduler_Action($hook, $args, $schedule, $group);
+		return $this->store($action);
 	}
 
 	/**
@@ -153,18 +153,18 @@ 
 	 * @return string The ID of the stored action
 	 * @throws InvalidArgumentException If $action is not a recurring action.
 	 */
-	public function repeat( $action ) {
+	public function repeat($action) {
 		$schedule = $action->get_schedule();
-		$next     = $schedule->get_next( as_get_datetime_object() );
+		$next     = $schedule->get_next(as_get_datetime_object());
 
-		if ( is_null( $next ) || ! $schedule->is_recurring() ) {
-			throw new InvalidArgumentException( __( 'Invalid action - must be a recurring action.', 'woocommerce' ) );
+		if (is_null($next) || !$schedule->is_recurring()) {
+			throw new InvalidArgumentException(__('Invalid action - must be a recurring action.', 'woocommerce'));
 		}
 
-		$schedule_class = get_class( $schedule );
-		$new_schedule = new $schedule( $next, $schedule->get_recurrence(), $schedule->get_first_date() );
-		$new_action = new ActionScheduler_Action( $action->get_hook(), $action->get_args(), $new_schedule, $action->get_group() );
-		return $this->store( $new_action );
+		$schedule_class = get_class($schedule);
+		$new_schedule = new $schedule($next, $schedule->get_recurrence(), $schedule->get_first_date());
+		$new_action = new ActionScheduler_Action($action->get_hook(), $action->get_args(), $new_schedule, $action->get_group());
+		return $this->store($new_action);
 	}
 
 	/**
@@ -172,8 +172,8 @@ 
 	 *
 	 * @return int The ID of the stored action
 	 */
-	protected function store( ActionScheduler_Action $action ) {
+	protected function store(ActionScheduler_Action $action) {
 		$store = ActionScheduler_Store::instance();
-		return $store->save_action( $action );
+		return $store->save_action($action);
 	}
 }

plugins/woocommerce/packages/action-scheduler/classes/ActionScheduler_NullLogEntry.php

Indentation +4 added lines, -4 removed lines

@@ -4,8 +4,8 @@
  * Class ActionScheduler_NullLogEntry
  */
 class ActionScheduler_NullLogEntry extends ActionScheduler_LogEntry {
-	public function __construct( $action_id = '', $message = '' ) {
-		// nothing to see here
-	}
+    public function __construct( $action_id = '', $message = '' ) {
+        // nothing to see here
+    }
 }
- 
\ No newline at end of file
+    
\ No newline at end of file

Spacing +1 added lines, -1 removed lines

@@ -4,7 +4,7 @@
  * Class ActionScheduler_NullLogEntry
  */
 class ActionScheduler_NullLogEntry extends ActionScheduler_LogEntry {
-	public function __construct( $action_id = '', $message = '' ) {
+	public function __construct($action_id = '', $message = '') {
 		// nothing to see here
 	}
 }

plugins/woocommerce/packages/action-scheduler/classes/ActionScheduler_wcSystemStatus.php

Indentation +130 added lines, -130 removed lines

@@ -5,105 +5,105 @@ 
  */
 class ActionScheduler_wcSystemStatus {
 
-	/**
-	 * The active data stores
-	 *
-	 * @var ActionScheduler_Store
-	 */
-	protected $store;
-
-	/**
-	 * Constructor method for ActionScheduler_wcSystemStatus.
-	 *
-	 * @param ActionScheduler_Store $store Active store object.
-	 *
-	 * @return void
-	 */
-	public function __construct( $store ) {
-		$this->store = $store;
-	}
-
-	/**
-	 * Display action data, including number of actions grouped by status and the oldest & newest action in each status.
-	 *
-	 * Helpful to identify issues, like a clogged queue.
-	 */
-	public function render() {
-		$action_counts     = $this->store->action_counts();
-		$status_labels     = $this->store->get_status_labels();
-		$oldest_and_newest = $this->get_oldest_and_newest( array_keys( $status_labels ) );
-
-		$this->get_template( $status_labels, $action_counts, $oldest_and_newest );
-	}
-
-	/**
-	 * Get oldest and newest scheduled dates for a given set of statuses.
-	 *
-	 * @param array $status_keys Set of statuses to find oldest & newest action for.
-	 * @return array
-	 */
-	protected function get_oldest_and_newest( $status_keys ) {
-
-		$oldest_and_newest = array();
-
-		foreach ( $status_keys as $status ) {
-			$oldest_and_newest[ $status ] = array(
-				'oldest' => '–',
-				'newest' => '–',
-			);
-
-			if ( 'in-progress' === $status ) {
-				continue;
-			}
-
-			$oldest_and_newest[ $status ]['oldest'] = $this->get_action_status_date( $status, 'oldest' );
-			$oldest_and_newest[ $status ]['newest'] = $this->get_action_status_date( $status, 'newest' );
-		}
-
-		return $oldest_and_newest;
-	}
-
-	/**
-	 * Get oldest or newest scheduled date for a given status.
-	 *
-	 * @param string $status Action status label/name string.
-	 * @param string $date_type Oldest or Newest.
-	 * @return DateTime
-	 */
-	protected function get_action_status_date( $status, $date_type = 'oldest' ) {
-
-		$order = 'oldest' === $date_type ? 'ASC' : 'DESC';
-
-		$action = $this->store->query_actions(
-			array(
-				'claimed'  => false,
-				'status'   => $status,
-				'per_page' => 1,
-				'order'    => $order,
-			)
-		);
-
-		if ( ! empty( $action ) ) {
-			$date_object = $this->store->get_date( $action[0] );
-			$action_date = $date_object->format( 'Y-m-d H:i:s O' );
-		} else {
-			$action_date = '–';
-		}
-
-		return $action_date;
-	}
-
-	/**
-	 * Get oldest or newest scheduled date for a given status.
-	 *
-	 * @param array $status_labels Set of statuses to find oldest & newest action for.
-	 * @param array $action_counts Number of actions grouped by status.
-	 * @param array $oldest_and_newest Date of the oldest and newest action with each status.
-	 */
-	protected function get_template( $status_labels, $action_counts, $oldest_and_newest ) {
-		$as_version   = ActionScheduler_Versions::instance()->latest_version();
-		$as_datastore = get_class( ActionScheduler_Store::instance() );
-		?>
+    /**
+     * The active data stores
+     *
+     * @var ActionScheduler_Store
+     */
+    protected $store;
+
+    /**
+     * Constructor method for ActionScheduler_wcSystemStatus.
+     *
+     * @param ActionScheduler_Store $store Active store object.
+     *
+     * @return void
+     */
+    public function __construct( $store ) {
+        $this->store = $store;
+    }
+
+    /**
+     * Display action data, including number of actions grouped by status and the oldest & newest action in each status.
+     *
+     * Helpful to identify issues, like a clogged queue.
+     */
+    public function render() {
+        $action_counts     = $this->store->action_counts();
+        $status_labels     = $this->store->get_status_labels();
+        $oldest_and_newest = $this->get_oldest_and_newest( array_keys( $status_labels ) );
+
+        $this->get_template( $status_labels, $action_counts, $oldest_and_newest );
+    }
+
+    /**
+     * Get oldest and newest scheduled dates for a given set of statuses.
+     *
+     * @param array $status_keys Set of statuses to find oldest & newest action for.
+     * @return array
+     */
+    protected function get_oldest_and_newest( $status_keys ) {
+
+        $oldest_and_newest = array();
+
+        foreach ( $status_keys as $status ) {
+            $oldest_and_newest[ $status ] = array(
+                'oldest' => '–',
+                'newest' => '–',
+            );
+
+            if ( 'in-progress' === $status ) {
+                continue;
+            }
+
+            $oldest_and_newest[ $status ]['oldest'] = $this->get_action_status_date( $status, 'oldest' );
+            $oldest_and_newest[ $status ]['newest'] = $this->get_action_status_date( $status, 'newest' );
+        }
+
+        return $oldest_and_newest;
+    }
+
+    /**
+     * Get oldest or newest scheduled date for a given status.
+     *
+     * @param string $status Action status label/name string.
+     * @param string $date_type Oldest or Newest.
+     * @return DateTime
+     */
+    protected function get_action_status_date( $status, $date_type = 'oldest' ) {
+
+        $order = 'oldest' === $date_type ? 'ASC' : 'DESC';
+
+        $action = $this->store->query_actions(
+            array(
+                'claimed'  => false,
+                'status'   => $status,
+                'per_page' => 1,
+                'order'    => $order,
+            )
+        );
+
+        if ( ! empty( $action ) ) {
+            $date_object = $this->store->get_date( $action[0] );
+            $action_date = $date_object->format( 'Y-m-d H:i:s O' );
+        } else {
+            $action_date = '–';
+        }
+
+        return $action_date;
+    }
+
+    /**
+     * Get oldest or newest scheduled date for a given status.
+     *
+     * @param array $status_labels Set of statuses to find oldest & newest action for.
+     * @param array $action_counts Number of actions grouped by status.
+     * @param array $oldest_and_newest Date of the oldest and newest action with each status.
+     */
+    protected function get_template( $status_labels, $action_counts, $oldest_and_newest ) {
+        $as_version   = ActionScheduler_Versions::instance()->latest_version();
+        $as_datastore = get_class( ActionScheduler_Store::instance() );
+        ?>
 
 		<table class="wc_status_table widefat" cellspacing="0">
 			<thead>
@@ -128,39 +128,39 @@ 
 			</thead>
 			<tbody>
 				<?php
-				foreach ( $action_counts as $status => $count ) {
-					// WC uses the 3rd column for export, so we need to display more data in that (hidden when viewed as part of the table) and add an empty 2nd column.
-					printf(
-						'<tr><td>%1$s</td><td>&nbsp;</td><td>%2$s<span style="display: none;">, Oldest: %3$s, Newest: %4$s</span></td><td>%3$s</td><td>%4$s</td></tr>',
-						esc_html( $status_labels[ $status ] ),
-						esc_html( number_format_i18n( $count ) ),
-						esc_html( $oldest_and_newest[ $status ]['oldest'] ),
-						esc_html( $oldest_and_newest[ $status ]['newest'] )
-					);
-				}
-				?>
+                foreach ( $action_counts as $status => $count ) {
+                    // WC uses the 3rd column for export, so we need to display more data in that (hidden when viewed as part of the table) and add an empty 2nd column.
+                    printf(
+                        '<tr><td>%1$s</td><td>&nbsp;</td><td>%2$s<span style="display: none;">, Oldest: %3$s, Newest: %4$s</span></td><td>%3$s</td><td>%4$s</td></tr>',
+                        esc_html( $status_labels[ $status ] ),
+                        esc_html( number_format_i18n( $count ) ),
+                        esc_html( $oldest_and_newest[ $status ]['oldest'] ),
+                        esc_html( $oldest_and_newest[ $status ]['newest'] )
+                    );
+                }
+                ?>
 			</tbody>
 		</table>
 
 		<?php
-	}
-
-	/**
-	 * Is triggered when invoking inaccessible methods in an object context.
-	 *
-	 * @param string $name Name of method called.
-	 * @param array  $arguments Parameters to invoke the method with.
-	 *
-	 * @return mixed
-	 * @link https://php.net/manual/en/language.oop5.overloading.php#language.oop5.overloading.methods
-	 */
-	public function __call( $name, $arguments ) {
-		switch ( $name ) {
-			case 'print':
-				_deprecated_function( __CLASS__ . '::print()', '2.2.4', __CLASS__ . '::render()' );
-				return call_user_func_array( array( $this, 'render' ), $arguments );
-		}
-
-		return null;
-	}
+    }
+
+    /**
+     * Is triggered when invoking inaccessible methods in an object context.
+     *
+     * @param string $name Name of method called.
+     * @param array  $arguments Parameters to invoke the method with.
+     *
+     * @return mixed
+     * @link https://php.net/manual/en/language.oop5.overloading.php#language.oop5.overloading.methods
+     */
+    public function __call( $name, $arguments ) {
+        switch ( $name ) {
+            case 'print':
+                _deprecated_function( __CLASS__ . '::print()', '2.2.4', __CLASS__ . '::render()' );
+                return call_user_func_array( array( $this, 'render' ), $arguments );
+        }
+
+        return null;
+    }
 }

Spacing +33 added lines, -33 removed lines

@@ -19,7 +19,7 @@ 
 	 *
 	 * @return void
 	 */
-	public function __construct( $store ) {
+	public function __construct($store) {
 		$this->store = $store;
 	}
 
@@ -31,9 +31,9 @@ 
 	public function render() {
 		$action_counts     = $this->store->action_counts();
 		$status_labels     = $this->store->get_status_labels();
-		$oldest_and_newest = $this->get_oldest_and_newest( array_keys( $status_labels ) );
+		$oldest_and_newest = $this->get_oldest_and_newest(array_keys($status_labels));
 
-		$this->get_template( $status_labels, $action_counts, $oldest_and_newest );
+		$this->get_template($status_labels, $action_counts, $oldest_and_newest);
 	}
 
 	/**
@@ -42,22 +42,22 @@ 
 	 * @param array $status_keys Set of statuses to find oldest & newest action for.
 	 * @return array
 	 */
-	protected function get_oldest_and_newest( $status_keys ) {
+	protected function get_oldest_and_newest($status_keys) {
 
 		$oldest_and_newest = array();
 
-		foreach ( $status_keys as $status ) {
-			$oldest_and_newest[ $status ] = array(
+		foreach ($status_keys as $status) {
+			$oldest_and_newest[$status] = array(
 				'oldest' => '–',
 				'newest' => '–',
 			);
 
-			if ( 'in-progress' === $status ) {
+			if ('in-progress' === $status) {
 				continue;
 			}
 
-			$oldest_and_newest[ $status ]['oldest'] = $this->get_action_status_date( $status, 'oldest' );
-			$oldest_and_newest[ $status ]['newest'] = $this->get_action_status_date( $status, 'newest' );
+			$oldest_and_newest[$status]['oldest'] = $this->get_action_status_date($status, 'oldest');
+			$oldest_and_newest[$status]['newest'] = $this->get_action_status_date($status, 'newest');
 		}
 
 		return $oldest_and_newest;
@@ -70,7 +70,7 @@ 
 	 * @param string $date_type Oldest or Newest.
 	 * @return DateTime
 	 */
-	protected function get_action_status_date( $status, $date_type = 'oldest' ) {
+	protected function get_action_status_date($status, $date_type = 'oldest') {
 
 		$order = 'oldest' === $date_type ? 'ASC' : 'DESC';
 
@@ -83,9 +83,9 @@ 
 			)
 		);
 
-		if ( ! empty( $action ) ) {
-			$date_object = $this->store->get_date( $action[0] );
-			$action_date = $date_object->format( 'Y-m-d H:i:s O' );
+		if (!empty($action)) {
+			$date_object = $this->store->get_date($action[0]);
+			$action_date = $date_object->format('Y-m-d H:i:s O');
 		} else {
 			$action_date = '–';
 		}
@@ -100,42 +100,42 @@ 
 	 * @param array $action_counts Number of actions grouped by status.
 	 * @param array $oldest_and_newest Date of the oldest and newest action with each status.
 	 */
-	protected function get_template( $status_labels, $action_counts, $oldest_and_newest ) {
+	protected function get_template($status_labels, $action_counts, $oldest_and_newest) {
 		$as_version   = ActionScheduler_Versions::instance()->latest_version();
-		$as_datastore = get_class( ActionScheduler_Store::instance() );
+		$as_datastore = get_class(ActionScheduler_Store::instance());
 		?>
 
 		<table class="wc_status_table widefat" cellspacing="0">
 			<thead>
 				<tr>
-					<th colspan="5" data-export-label="Action Scheduler"><h2><?php esc_html_e( 'Action Scheduler', 'woocommerce' ); ?><?php echo wc_help_tip( esc_html__( 'This section shows details of Action Scheduler.', 'woocommerce' ) ); ?></h2></th>
+					<th colspan="5" data-export-label="Action Scheduler"><h2><?php esc_html_e('Action Scheduler', 'woocommerce'); ?><?php echo wc_help_tip(esc_html__('This section shows details of Action Scheduler.', 'woocommerce')); ?></h2></th>
 				</tr>
 				<tr>
-					<td colspan="2" data-export-label="Version"><?php esc_html_e( 'Version:', 'woocommerce' ); ?></td>
-					<td colspan="3"><?php echo esc_html( $as_version ); ?></td>
+					<td colspan="2" data-export-label="Version"><?php esc_html_e('Version:', 'woocommerce'); ?></td>
+					<td colspan="3"><?php echo esc_html($as_version); ?></td>
 				</tr>
 				<tr>
-					<td colspan="2" data-export-label="Data store"><?php esc_html_e( 'Data store:', 'woocommerce' ); ?></td>
-					<td colspan="3"><?php echo esc_html( $as_datastore ); ?></td>
+					<td colspan="2" data-export-label="Data store"><?php esc_html_e('Data store:', 'woocommerce'); ?></td>
+					<td colspan="3"><?php echo esc_html($as_datastore); ?></td>
 				</tr>
 				<tr>
-					<td><strong><?php esc_html_e( 'Action Status', 'woocommerce' ); ?></strong></td>
+					<td><strong><?php esc_html_e('Action Status', 'woocommerce'); ?></strong></td>
 					<td class="help">&nbsp;</td>
-					<td><strong><?php esc_html_e( 'Count', 'woocommerce' ); ?></strong></td>
-					<td><strong><?php esc_html_e( 'Oldest Scheduled Date', 'woocommerce' ); ?></strong></td>
-					<td><strong><?php esc_html_e( 'Newest Scheduled Date', 'woocommerce' ); ?></strong></td>
+					<td><strong><?php esc_html_e('Count', 'woocommerce'); ?></strong></td>
+					<td><strong><?php esc_html_e('Oldest Scheduled Date', 'woocommerce'); ?></strong></td>
+					<td><strong><?php esc_html_e('Newest Scheduled Date', 'woocommerce'); ?></strong></td>
 				</tr>
 			</thead>
 			<tbody>
 				<?php
-				foreach ( $action_counts as $status => $count ) {
+				foreach ($action_counts as $status => $count) {
 					// WC uses the 3rd column for export, so we need to display more data in that (hidden when viewed as part of the table) and add an empty 2nd column.
 					printf(
 						'<tr><td>%1$s</td><td>&nbsp;</td><td>%2$s<span style="display: none;">, Oldest: %3$s, Newest: %4$s</span></td><td>%3$s</td><td>%4$s</td></tr>',
-						esc_html( $status_labels[ $status ] ),
-						esc_html( number_format_i18n( $count ) ),
-						esc_html( $oldest_and_newest[ $status ]['oldest'] ),
-						esc_html( $oldest_and_newest[ $status ]['newest'] )
+						esc_html($status_labels[$status]),
+						esc_html(number_format_i18n($count)),
+						esc_html($oldest_and_newest[$status]['oldest']),
+						esc_html($oldest_and_newest[$status]['newest'])
 					);
 				}
 				?>
@@ -154,11 +154,11 @@ 
 	 * @return mixed
 	 * @link https://php.net/manual/en/language.oop5.overloading.php#language.oop5.overloading.methods
 	 */
-	public function __call( $name, $arguments ) {
-		switch ( $name ) {
+	public function __call($name, $arguments) {
+		switch ($name) {
 			case 'print':
-				_deprecated_function( __CLASS__ . '::print()', '2.2.4', __CLASS__ . '::render()' );
-				return call_user_func_array( array( $this, 'render' ), $arguments );
+				_deprecated_function(__CLASS__ . '::print()', '2.2.4', __CLASS__ . '::render()');
+				return call_user_func_array(array($this, 'render'), $arguments);
 		}
 
 		return null;

plugins/woocommerce/packages/action-scheduler/classes/migration/Runner.php

Indentation +120 added lines, -120 removed lines

@@ -13,124 +13,124 @@
  * @codeCoverageIgnore
  */
 class Runner {
-	/** @var ActionScheduler_Store */
-	private $source_store;
-
-	/** @var ActionScheduler_Store */
-	private $destination_store;
-
-	/** @var ActionScheduler_Logger */
-	private $source_logger;
-
-	/** @var ActionScheduler_Logger */
-	private $destination_logger;
-
-	/** @var BatchFetcher */
-	private $batch_fetcher;
-
-	/** @var ActionMigrator */
-	private $action_migrator;
-
-	/** @var LogMigrator */
-	private $log_migrator;
-
-	/** @var ProgressBar */
-	private $progress_bar;
-
-	/**
-	 * Runner constructor.
-	 *
-	 * @param Config $config Migration configuration object.
-	 */
-	public function __construct( Config $config ) {
-		$this->source_store       = $config->get_source_store();
-		$this->destination_store  = $config->get_destination_store();
-		$this->source_logger      = $config->get_source_logger();
-		$this->destination_logger = $config->get_destination_logger();
-
-		$this->batch_fetcher = new BatchFetcher( $this->source_store );
-		if ( $config->get_dry_run() ) {
-			$this->log_migrator    = new DryRun_LogMigrator( $this->source_logger, $this->destination_logger );
-			$this->action_migrator = new DryRun_ActionMigrator( $this->source_store, $this->destination_store, $this->log_migrator );
-		} else {
-			$this->log_migrator    = new LogMigrator( $this->source_logger, $this->destination_logger );
-			$this->action_migrator = new ActionMigrator( $this->source_store, $this->destination_store, $this->log_migrator );
-		}
-
-		if ( defined( 'WP_CLI' ) && WP_CLI ) {
-			$this->progress_bar = $config->get_progress_bar();
-		}
-	}
-
-	/**
-	 * Run migration batch.
-	 *
-	 * @param int $batch_size Optional batch size. Default 10.
-	 *
-	 * @return int Size of batch processed.
-	 */
-	public function run( $batch_size = 10 ) {
-		$batch = $this->batch_fetcher->fetch( $batch_size );
-		$batch_size = count( $batch );
-
-		if ( ! $batch_size ) {
-			return 0;
-		}
-
-		if ( $this->progress_bar ) {
-			/* translators: %d: amount of actions */
-			$this->progress_bar->set_message( sprintf( _n( 'Migrating %d action', 'Migrating %d actions', $batch_size, 'woocommerce' ), number_format_i18n( $batch_size ) ) );
-			$this->progress_bar->set_count( $batch_size );
-		}
-
-		$this->migrate_actions( $batch );
-
-		return $batch_size;
-	}
-
-	/**
-	 * Migration a batch of actions.
-	 *
-	 * @param array $action_ids List of action IDs to migrate.
-	 */
-	public function migrate_actions( array $action_ids ) {
-		do_action( 'action_scheduler/migration_batch_starting', $action_ids );
-
-		\ActionScheduler::logger()->unhook_stored_action();
-		$this->destination_logger->unhook_stored_action();
-
-		foreach ( $action_ids as $source_action_id ) {
-			$destination_action_id = $this->action_migrator->migrate( $source_action_id );
-			if ( $destination_action_id ) {
-				$this->destination_logger->log( $destination_action_id, sprintf(
-					/* translators: 1: source action ID 2: source store class 3: destination action ID 4: destination store class */
-					__( 'Migrated action with ID %1$d in %2$s to ID %3$d in %4$s', 'woocommerce' ),
-					$source_action_id,
-					get_class( $this->source_store ),
-					$destination_action_id,
-					get_class( $this->destination_store )
-				) );
-			}
-
-			if ( $this->progress_bar ) {
-				$this->progress_bar->tick();
-			}
-		}
-
-		if ( $this->progress_bar ) {
-			$this->progress_bar->finish();
-		}
-
-		\ActionScheduler::logger()->hook_stored_action();
-
-		do_action( 'action_scheduler/migration_batch_complete', $action_ids );
-	}
-
-	/**
-	 * Initialize destination store and logger.
-	 */
-	public function init_destination() {
-		$this->destination_store->init();
-		$this->destination_logger->init();
-	}
+    /** @var ActionScheduler_Store */
+    private $source_store;
+
+    /** @var ActionScheduler_Store */
+    private $destination_store;
+
+    /** @var ActionScheduler_Logger */
+    private $source_logger;
+
+    /** @var ActionScheduler_Logger */
+    private $destination_logger;
+
+    /** @var BatchFetcher */
+    private $batch_fetcher;
+
+    /** @var ActionMigrator */
+    private $action_migrator;
+
+    /** @var LogMigrator */
+    private $log_migrator;
+
+    /** @var ProgressBar */
+    private $progress_bar;
+
+    /**
+     * Runner constructor.
+     *
+     * @param Config $config Migration configuration object.
+     */
+    public function __construct( Config $config ) {
+        $this->source_store       = $config->get_source_store();
+        $this->destination_store  = $config->get_destination_store();
+        $this->source_logger      = $config->get_source_logger();
+        $this->destination_logger = $config->get_destination_logger();
+
+        $this->batch_fetcher = new BatchFetcher( $this->source_store );
+        if ( $config->get_dry_run() ) {
+            $this->log_migrator    = new DryRun_LogMigrator( $this->source_logger, $this->destination_logger );
+            $this->action_migrator = new DryRun_ActionMigrator( $this->source_store, $this->destination_store, $this->log_migrator );
+        } else {
+            $this->log_migrator    = new LogMigrator( $this->source_logger, $this->destination_logger );
+            $this->action_migrator = new ActionMigrator( $this->source_store, $this->destination_store, $this->log_migrator );
+        }
+
+        if ( defined( 'WP_CLI' ) && WP_CLI ) {
+            $this->progress_bar = $config->get_progress_bar();
+        }
+    }
+
+    /**
+     * Run migration batch.
+     *
+     * @param int $batch_size Optional batch size. Default 10.
+     *
+     * @return int Size of batch processed.
+     */
+    public function run( $batch_size = 10 ) {
+        $batch = $this->batch_fetcher->fetch( $batch_size );
+        $batch_size = count( $batch );
+
+        if ( ! $batch_size ) {
+            return 0;
+        }
+
+        if ( $this->progress_bar ) {
+            /* translators: %d: amount of actions */
+            $this->progress_bar->set_message( sprintf( _n( 'Migrating %d action', 'Migrating %d actions', $batch_size, 'woocommerce' ), number_format_i18n( $batch_size ) ) );
+            $this->progress_bar->set_count( $batch_size );
+        }
+
+        $this->migrate_actions( $batch );
+
+        return $batch_size;
+    }
+
+    /**
+     * Migration a batch of actions.
+     *
+     * @param array $action_ids List of action IDs to migrate.
+     */
+    public function migrate_actions( array $action_ids ) {
+        do_action( 'action_scheduler/migration_batch_starting', $action_ids );
+
+        \ActionScheduler::logger()->unhook_stored_action();
+        $this->destination_logger->unhook_stored_action();
+
+        foreach ( $action_ids as $source_action_id ) {
+            $destination_action_id = $this->action_migrator->migrate( $source_action_id );
+            if ( $destination_action_id ) {
+                $this->destination_logger->log( $destination_action_id, sprintf(
+                    /* translators: 1: source action ID 2: source store class 3: destination action ID 4: destination store class */
+                    __( 'Migrated action with ID %1$d in %2$s to ID %3$d in %4$s', 'woocommerce' ),
+                    $source_action_id,
+                    get_class( $this->source_store ),
+                    $destination_action_id,
+                    get_class( $this->destination_store )
+                ) );
+            }
+
+            if ( $this->progress_bar ) {
+                $this->progress_bar->tick();
+            }
+        }
+
+        if ( $this->progress_bar ) {
+            $this->progress_bar->finish();
+        }
+
+        \ActionScheduler::logger()->hook_stored_action();
+
+        do_action( 'action_scheduler/migration_batch_complete', $action_ids );
+    }
+
+    /**
+     * Initialize destination store and logger.
+     */
+    public function init_destination() {
+        $this->destination_store->init();
+        $this->destination_logger->init();
+    }
 }

Spacing +29 added lines, -29 removed lines

@@ -42,22 +42,22 @@ 
 	 *
 	 * @param Config $config Migration configuration object.
 	 */
-	public function __construct( Config $config ) {
+	public function __construct(Config $config) {
 		$this->source_store       = $config->get_source_store();
 		$this->destination_store  = $config->get_destination_store();
 		$this->source_logger      = $config->get_source_logger();
 		$this->destination_logger = $config->get_destination_logger();
 
-		$this->batch_fetcher = new BatchFetcher( $this->source_store );
-		if ( $config->get_dry_run() ) {
-			$this->log_migrator    = new DryRun_LogMigrator( $this->source_logger, $this->destination_logger );
-			$this->action_migrator = new DryRun_ActionMigrator( $this->source_store, $this->destination_store, $this->log_migrator );
+		$this->batch_fetcher = new BatchFetcher($this->source_store);
+		if ($config->get_dry_run()) {
+			$this->log_migrator    = new DryRun_LogMigrator($this->source_logger, $this->destination_logger);
+			$this->action_migrator = new DryRun_ActionMigrator($this->source_store, $this->destination_store, $this->log_migrator);
 		} else {
-			$this->log_migrator    = new LogMigrator( $this->source_logger, $this->destination_logger );
-			$this->action_migrator = new ActionMigrator( $this->source_store, $this->destination_store, $this->log_migrator );
+			$this->log_migrator    = new LogMigrator($this->source_logger, $this->destination_logger);
+			$this->action_migrator = new ActionMigrator($this->source_store, $this->destination_store, $this->log_migrator);
 		}
 
-		if ( defined( 'WP_CLI' ) && WP_CLI ) {
+		if (defined('WP_CLI') && WP_CLI) {
 			$this->progress_bar = $config->get_progress_bar();
 		}
 	}
@@ -69,21 +69,21 @@ 
 	 *
 	 * @return int Size of batch processed.
 	 */
-	public function run( $batch_size = 10 ) {
-		$batch = $this->batch_fetcher->fetch( $batch_size );
-		$batch_size = count( $batch );
+	public function run($batch_size = 10) {
+		$batch = $this->batch_fetcher->fetch($batch_size);
+		$batch_size = count($batch);
 
-		if ( ! $batch_size ) {
+		if (!$batch_size) {
 			return 0;
 		}
 
-		if ( $this->progress_bar ) {
+		if ($this->progress_bar) {
 			/* translators: %d: amount of actions */
-			$this->progress_bar->set_message( sprintf( _n( 'Migrating %d action', 'Migrating %d actions', $batch_size, 'woocommerce' ), number_format_i18n( $batch_size ) ) );
-			$this->progress_bar->set_count( $batch_size );
+			$this->progress_bar->set_message(sprintf(_n('Migrating %d action', 'Migrating %d actions', $batch_size, 'woocommerce'), number_format_i18n($batch_size)));
+			$this->progress_bar->set_count($batch_size);
 		}
 
-		$this->migrate_actions( $batch );
+		$this->migrate_actions($batch);
 
 		return $batch_size;
 	}
@@ -93,37 +93,37 @@ 
 	 *
 	 * @param array $action_ids List of action IDs to migrate.
 	 */
-	public function migrate_actions( array $action_ids ) {
-		do_action( 'action_scheduler/migration_batch_starting', $action_ids );
+	public function migrate_actions(array $action_ids) {
+		do_action('action_scheduler/migration_batch_starting', $action_ids);
 
 		\ActionScheduler::logger()->unhook_stored_action();
 		$this->destination_logger->unhook_stored_action();
 
-		foreach ( $action_ids as $source_action_id ) {
-			$destination_action_id = $this->action_migrator->migrate( $source_action_id );
-			if ( $destination_action_id ) {
-				$this->destination_logger->log( $destination_action_id, sprintf(
+		foreach ($action_ids as $source_action_id) {
+			$destination_action_id = $this->action_migrator->migrate($source_action_id);
+			if ($destination_action_id) {
+				$this->destination_logger->log($destination_action_id, sprintf(
 					/* translators: 1: source action ID 2: source store class 3: destination action ID 4: destination store class */
-					__( 'Migrated action with ID %1$d in %2$s to ID %3$d in %4$s', 'woocommerce' ),
+					__('Migrated action with ID %1$d in %2$s to ID %3$d in %4$s', 'woocommerce'),
 					$source_action_id,
-					get_class( $this->source_store ),
+					get_class($this->source_store),
 					$destination_action_id,
-					get_class( $this->destination_store )
-				) );
+					get_class($this->destination_store)
+				));
 			}
 
-			if ( $this->progress_bar ) {
+			if ($this->progress_bar) {
 				$this->progress_bar->tick();
 			}
 		}
 
-		if ( $this->progress_bar ) {
+		if ($this->progress_bar) {
 			$this->progress_bar->finish();
 		}
 
 		\ActionScheduler::logger()->hook_stored_action();
 
-		do_action( 'action_scheduler/migration_batch_complete', $action_ids );
+		do_action('action_scheduler/migration_batch_complete', $action_ids);
 	}
 
 	/**