Prospress command example for WP-CLI

prospress-command.php

<?php

/**
 * Prospress command for CLI actions.
 */
class Prospress_Command extends WP_CLI_Command {

	/**
	 * Run scheduler
	 *
	 * @subcommand run-scheduler
	 */
	public function run_scheduler( $args, $assoc_args ) {

		// Get scheduled tasks to run
		$scheduled_tasks = array();

		$total = count( $scheduled_tasks );

		\WP_CLI::line( sprintf( _n( 'Found %d scheduled tasks', 'Found %d scheduled task', $total, 'prospress' ), $total ) );

		$progress_bar = \WP_CLI\Utils\make_progress_bar(
			sprintf( _n( 'Running %d tasks', 'Running %d tasks', $total, 'prospress' ), number_format_i18n( $total ) ),
			$total
		);

		$counter = 0;

		foreach ( $scheduled_tasks as $scheduled_task ) {
			try {
				// Do something
				$success = true;

				if ( ! $success ) {
					\WP_CLI::warning( 'Some problem happened' );
				} else {
					// Success!
				}

				$counter++;

				$progress_bar->tick();

				// Every 100 tasks, clean memory
				if ( 0 === ( $counter % 100 ) ) {
					$this->stop_the_insanity();
				}
			} catch ( \Exception $e ) {
				\WP_CLI::error( 'Some big problem happened' );
			}
		}

		$progress_bar->finish();

		\WP_CLI::success( __( 'Scheduled task queue cleared.', 'prospress' ) );

	}

	/**
	 * Sleep and help avoid hitting memory limit
	 *
	 * @param int $sleep_time Amount of seconds to sleep
	 */
	protected function stop_the_insanity( $sleep_time = 0 ) {

		\WP_CLI::warning( sprintf( '..... Stopped the insanity for %d %s.....', $sleep_time, _n( 'second', 'seconds', $sleep_time ) ) );

		if ( 0 < $sleep_time ) {
			sleep( $sleep_time );
		}

		/**
		 * @var $wpdb            \wpdb
		 * @var $wp_object_cache \WP_Object_Cache
		 */
		global $wpdb, $wp_object_cache;

		$wpdb->queries = array(); // or define( 'WP_IMPORTING', true );

		if ( ! is_object( $wp_object_cache ) ) {
			return;
		}

		$wp_object_cache->group_ops      = array();
		$wp_object_cache->stats          = array();
		$wp_object_cache->memcache_debug = array();
		$wp_object_cache->cache          = array();

		if ( is_callable( array( $wp_object_cache, '__remoteset' ) ) ) {
			call_user_func( array( $wp_object_cache, '__remoteset' ) ); // important
		}

	}

}

\WP_CLI::add_command( 'prospress', 'Prospress_Command' );