AyeCode / invoicing

includes/libraries/action-scheduler/classes/actions/ActionScheduler_NullAction.php

Indentation +7 added lines, -7 removed lines

@@ -5,12 +5,12 @@
  */
 class ActionScheduler_NullAction extends ActionScheduler_Action {
 
-	public function __construct( $hook = '', array $args = array(), ActionScheduler_Schedule $schedule = NULL ) {
-		$this->set_schedule( new ActionScheduler_NullSchedule() );
-	}
+    public function __construct( $hook = '', array $args = array(), ActionScheduler_Schedule $schedule = NULL ) {
+        $this->set_schedule( new ActionScheduler_NullSchedule() );
+    }
 
-	public function execute() {
-		// don't execute
-	}
+    public function execute() {
+        // don't execute
+    }
 }
- 
\ No newline at end of file
+    
\ No newline at end of file

includes/libraries/action-scheduler/classes/ActionScheduler_AdminView.php

Indentation +145 added lines, -145 removed lines

@@ -6,149 +6,149 @@
  */
 class ActionScheduler_AdminView extends ActionScheduler_AdminView_Deprecated {
 
-	private static $admin_view = NULL;
-
-	private static $screen_id = 'tools_page_action-scheduler';
-
-	/** @var ActionScheduler_ListTable */
-	protected $list_table;
-
-	/**
-	 * @return ActionScheduler_AdminView
-	 * @codeCoverageIgnore
-	 */
-	public static function instance() {
-
-		if ( empty( self::$admin_view ) ) {
-			$class = apply_filters('action_scheduler_admin_view_class', 'ActionScheduler_AdminView');
-			self::$admin_view = new $class();
-		}
-
-		return self::$admin_view;
-	}
-
-	/**
-	 * @codeCoverageIgnore
-	 */
-	public function init() {
-		if ( is_admin() && ( ! defined( 'DOING_AJAX' ) || false == DOING_AJAX ) ) {
-
-			if ( class_exists( 'WooCommerce' ) ) {
-				add_action( 'woocommerce_admin_status_content_action-scheduler', array( $this, 'render_admin_ui' ) );
-				add_action( 'woocommerce_system_status_report', array( $this, 'system_status_report' ) );
-				add_filter( 'woocommerce_admin_status_tabs', array( $this, 'register_system_status_tab' ) );
-			}
-
-			add_action( 'admin_menu', array( $this, 'register_menu' ) );
-
-			add_action( 'current_screen', array( $this, 'add_help_tabs' ) );
-		}
-	}
-
-	public function system_status_report() {
-		$table = new ActionScheduler_wcSystemStatus( ActionScheduler::store() );
-		$table->render();
-	}
-
-	/**
-	 * Registers action-scheduler into WooCommerce > System status.
-	 *
-	 * @param array $tabs An associative array of tab key => label.
-	 * @return array $tabs An associative array of tab key => label, including Action Scheduler's tabs
-	 */
-	public function register_system_status_tab( array $tabs ) {
-		$tabs['action-scheduler'] = __( 'Scheduled Actions', 'action-scheduler' );
-
-		return $tabs;
-	}
-
-	/**
-	 * Include Action Scheduler's administration under the Tools menu.
-	 *
-	 * A menu under the Tools menu is important for backward compatibility (as that's
-	 * where it started), and also provides more convenient access than the WooCommerce
-	 * System Status page, and for sites where WooCommerce isn't active.
-	 */
-	public function register_menu() {
-		$hook_suffix = add_submenu_page(
-			'tools.php',
-			__( 'Scheduled Actions', 'action-scheduler' ),
-			__( 'Scheduled Actions', 'action-scheduler' ),
-			'manage_options',
-			'action-scheduler',
-			array( $this, 'render_admin_ui' )
-		);
-		add_action( 'load-' . $hook_suffix , array( $this, 'process_admin_ui' ) );
-	}
-
-	/**
-	 * Triggers processing of any pending actions.
-	 */
-	public function process_admin_ui() {
-		$this->get_list_table();
-	}
-
-	/**
-	 * Renders the Admin UI
-	 */
-	public function render_admin_ui() {
-		$table = $this->get_list_table();
-		$table->display_page();
-	}
-
-	/**
-	 * Get the admin UI object and process any requested actions.
-	 *
-	 * @return ActionScheduler_ListTable
-	 */
-	protected function get_list_table() {
-		if ( null === $this->list_table ) {
-			$this->list_table = new ActionScheduler_ListTable( ActionScheduler::store(), ActionScheduler::logger(), ActionScheduler::runner() );
-			$this->list_table->process_actions();
-		}
-
-		return $this->list_table;
-	}
-
-	/**
-	 * Provide more information about the screen and its data in the help tab.
-	 */
-	public function add_help_tabs() {
-		$screen = get_current_screen();
-
-		if ( ! $screen || self::$screen_id != $screen->id ) {
-			return;
-		}
-
-		$as_version = ActionScheduler_Versions::instance()->latest_version();
-		$screen->add_help_tab(
-			array(
-				'id'      => 'action_scheduler_about',
-				'title'   => __( 'About', 'action-scheduler' ),
-				'content' =>
-					'<h2>' . sprintf( __( 'About Action Scheduler %s', 'action-scheduler' ), $as_version ) . '</h2>' .
-					'<p>' .
-						__( 'Action Scheduler is a scalable, traceable job queue for background processing large sets of actions. Action Scheduler works by triggering an action hook to run at some time in the future. Scheduled actions can also be scheduled to run on a recurring schedule.', 'action-scheduler' ) .
-					'</p>',
-			)
-		);
-
-		$screen->add_help_tab(
-			array(
-				'id'      => 'action_scheduler_columns',
-				'title'   => __( 'Columns', 'action-scheduler' ),
-				'content' =>
-					'<h2>' . __( 'Scheduled Action Columns', 'action-scheduler' ) . '</h2>' .
-					'<ul>' .
-					sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Hook', 'action-scheduler' ), __( 'Name of the action hook that will be triggered.', 'action-scheduler' ) ) .
-					sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Status', 'action-scheduler' ), __( 'Action statuses are Pending, Complete, Canceled, Failed', 'action-scheduler' ) ) .
-					sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Arguments', 'action-scheduler' ), __( 'Optional data array passed to the action hook.', 'action-scheduler' ) ) .
-					sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Group', 'action-scheduler' ), __( 'Optional action group.', 'action-scheduler' ) ) .
-					sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Recurrence', 'action-scheduler' ), __( 'The action\'s schedule frequency.', 'action-scheduler' ) ) .
-					sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Scheduled', 'action-scheduler' ), __( 'The date/time the action is/was scheduled to run.', 'action-scheduler' ) ) .
-					sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Log', 'action-scheduler' ), __( 'Activity log for the action.', 'action-scheduler' ) ) .
-					'</ul>',
-			)
-		);
-	}
+    private static $admin_view = NULL;
+
+    private static $screen_id = 'tools_page_action-scheduler';
+
+    /** @var ActionScheduler_ListTable */
+    protected $list_table;
+
+    /**
+     * @return ActionScheduler_AdminView
+     * @codeCoverageIgnore
+     */
+    public static function instance() {
+
+        if ( empty( self::$admin_view ) ) {
+            $class = apply_filters('action_scheduler_admin_view_class', 'ActionScheduler_AdminView');
+            self::$admin_view = new $class();
+        }
+
+        return self::$admin_view;
+    }
+
+    /**
+     * @codeCoverageIgnore
+     */
+    public function init() {
+        if ( is_admin() && ( ! defined( 'DOING_AJAX' ) || false == DOING_AJAX ) ) {
+
+            if ( class_exists( 'WooCommerce' ) ) {
+                add_action( 'woocommerce_admin_status_content_action-scheduler', array( $this, 'render_admin_ui' ) );
+                add_action( 'woocommerce_system_status_report', array( $this, 'system_status_report' ) );
+                add_filter( 'woocommerce_admin_status_tabs', array( $this, 'register_system_status_tab' ) );
+            }
+
+            add_action( 'admin_menu', array( $this, 'register_menu' ) );
+
+            add_action( 'current_screen', array( $this, 'add_help_tabs' ) );
+        }
+    }
+
+    public function system_status_report() {
+        $table = new ActionScheduler_wcSystemStatus( ActionScheduler::store() );
+        $table->render();
+    }
+
+    /**
+     * Registers action-scheduler into WooCommerce > System status.
+     *
+     * @param array $tabs An associative array of tab key => label.
+     * @return array $tabs An associative array of tab key => label, including Action Scheduler's tabs
+     */
+    public function register_system_status_tab( array $tabs ) {
+        $tabs['action-scheduler'] = __( 'Scheduled Actions', 'action-scheduler' );
+
+        return $tabs;
+    }
+
+    /**
+     * Include Action Scheduler's administration under the Tools menu.
+     *
+     * A menu under the Tools menu is important for backward compatibility (as that's
+     * where it started), and also provides more convenient access than the WooCommerce
+     * System Status page, and for sites where WooCommerce isn't active.
+     */
+    public function register_menu() {
+        $hook_suffix = add_submenu_page(
+            'tools.php',
+            __( 'Scheduled Actions', 'action-scheduler' ),
+            __( 'Scheduled Actions', 'action-scheduler' ),
+            'manage_options',
+            'action-scheduler',
+            array( $this, 'render_admin_ui' )
+        );
+        add_action( 'load-' . $hook_suffix , array( $this, 'process_admin_ui' ) );
+    }
+
+    /**
+     * Triggers processing of any pending actions.
+     */
+    public function process_admin_ui() {
+        $this->get_list_table();
+    }
+
+    /**
+     * Renders the Admin UI
+     */
+    public function render_admin_ui() {
+        $table = $this->get_list_table();
+        $table->display_page();
+    }
+
+    /**
+     * Get the admin UI object and process any requested actions.
+     *
+     * @return ActionScheduler_ListTable
+     */
+    protected function get_list_table() {
+        if ( null === $this->list_table ) {
+            $this->list_table = new ActionScheduler_ListTable( ActionScheduler::store(), ActionScheduler::logger(), ActionScheduler::runner() );
+            $this->list_table->process_actions();
+        }
+
+        return $this->list_table;
+    }
+
+    /**
+     * Provide more information about the screen and its data in the help tab.
+     */
+    public function add_help_tabs() {
+        $screen = get_current_screen();
+
+        if ( ! $screen || self::$screen_id != $screen->id ) {
+            return;
+        }
+
+        $as_version = ActionScheduler_Versions::instance()->latest_version();
+        $screen->add_help_tab(
+            array(
+                'id'      => 'action_scheduler_about',
+                'title'   => __( 'About', 'action-scheduler' ),
+                'content' =>
+                    '<h2>' . sprintf( __( 'About Action Scheduler %s', 'action-scheduler' ), $as_version ) . '</h2>' .
+                    '<p>' .
+                        __( 'Action Scheduler is a scalable, traceable job queue for background processing large sets of actions. Action Scheduler works by triggering an action hook to run at some time in the future. Scheduled actions can also be scheduled to run on a recurring schedule.', 'action-scheduler' ) .
+                    '</p>',
+            )
+        );
+
+        $screen->add_help_tab(
+            array(
+                'id'      => 'action_scheduler_columns',
+                'title'   => __( 'Columns', 'action-scheduler' ),
+                'content' =>
+                    '<h2>' . __( 'Scheduled Action Columns', 'action-scheduler' ) . '</h2>' .
+                    '<ul>' .
+                    sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Hook', 'action-scheduler' ), __( 'Name of the action hook that will be triggered.', 'action-scheduler' ) ) .
+                    sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Status', 'action-scheduler' ), __( 'Action statuses are Pending, Complete, Canceled, Failed', 'action-scheduler' ) ) .
+                    sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Arguments', 'action-scheduler' ), __( 'Optional data array passed to the action hook.', 'action-scheduler' ) ) .
+                    sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Group', 'action-scheduler' ), __( 'Optional action group.', 'action-scheduler' ) ) .
+                    sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Recurrence', 'action-scheduler' ), __( 'The action\'s schedule frequency.', 'action-scheduler' ) ) .
+                    sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Scheduled', 'action-scheduler' ), __( 'The date/time the action is/was scheduled to run.', 'action-scheduler' ) ) .
+                    sprintf( '<li><strong>%1$s</strong>: %2$s</li>', __( 'Log', 'action-scheduler' ), __( 'Activity log for the action.', 'action-scheduler' ) ) .
+                    '</ul>',
+            )
+        );
+    }
 }

includes/libraries/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' ) ) {
-					$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' ) ) {
+                    $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 string 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 string 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 string 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 string 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 string 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 string 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 string 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 string 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.', 'action-scheduler' ) );
-		}
+        if ( is_null( $next ) || ! $schedule->is_recurring() ) {
+            throw new InvalidArgumentException( __( 'Invalid action - must be a recurring action.', 'action-scheduler' ) );
+        }
 
-		$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 string 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 string The ID of the stored action
+     */
+    protected function store( ActionScheduler_Action $action ) {
+        $store = ActionScheduler_Store::instance();
+        return $store->save_action( $action );
+    }
 }

includes/libraries/action-scheduler/classes/migration/BatchFetcher.php

Indentation +61 added lines, -61 removed lines

@@ -16,71 +16,71 @@
  * @codeCoverageIgnore
  */
 class BatchFetcher {
-	/** var ActionScheduler_Store */
-	private $store;
+    /** var ActionScheduler_Store */
+    private $store;
 
-	/**
-	 * BatchFetcher constructor.
-	 *
-	 * @param ActionScheduler_Store $source_store Source store object.
-	 */
-	public function __construct( Store $source_store ) {
-		$this->store = $source_store;
-	}
+    /**
+     * BatchFetcher constructor.
+     *
+     * @param ActionScheduler_Store $source_store Source store object.
+     */
+    public function __construct( Store $source_store ) {
+        $this->store = $source_store;
+    }
 
-	/**
-	 * Retrieve a list of actions.
-	 *
-	 * @param int $count The number of actions to retrieve
-	 *
-	 * @return int[] A list of action IDs
-	 */
-	public function fetch( $count = 10 ) {
-		foreach ( $this->get_query_strategies( $count ) as $query ) {
-			$action_ids = $this->store->query_actions( $query );
-			if ( ! empty( $action_ids ) ) {
-				return $action_ids;
-			}
-		}
+    /**
+     * Retrieve a list of actions.
+     *
+     * @param int $count The number of actions to retrieve
+     *
+     * @return int[] A list of action IDs
+     */
+    public function fetch( $count = 10 ) {
+        foreach ( $this->get_query_strategies( $count ) as $query ) {
+            $action_ids = $this->store->query_actions( $query );
+            if ( ! empty( $action_ids ) ) {
+                return $action_ids;
+            }
+        }
 
-		return [];
-	}
+        return [];
+    }
 
-	/**
-	 * Generate a list of prioritized of action search parameters.
-	 *
-	 * @param int $count Number of actions to find.
-	 *
-	 * @return array
-	 */
-	private function get_query_strategies( $count ) {
-		$now  = as_get_datetime_object();
-		$args = [
-			'date'     => $now,
-			'per_page' => $count,
-			'offset'   => 0,
-			'orderby'  => 'date',
-			'order'    => 'ASC',
-		];
+    /**
+     * Generate a list of prioritized of action search parameters.
+     *
+     * @param int $count Number of actions to find.
+     *
+     * @return array
+     */
+    private function get_query_strategies( $count ) {
+        $now  = as_get_datetime_object();
+        $args = [
+            'date'     => $now,
+            'per_page' => $count,
+            'offset'   => 0,
+            'orderby'  => 'date',
+            'order'    => 'ASC',
+        ];
 
-		$priorities = [
-			Store::STATUS_PENDING,
-			Store::STATUS_FAILED,
-			Store::STATUS_CANCELED,
-			Store::STATUS_COMPLETE,
-			Store::STATUS_RUNNING,
-			'', // any other unanticipated status
-		];
+        $priorities = [
+            Store::STATUS_PENDING,
+            Store::STATUS_FAILED,
+            Store::STATUS_CANCELED,
+            Store::STATUS_COMPLETE,
+            Store::STATUS_RUNNING,
+            '', // any other unanticipated status
+        ];
 
-		foreach ( $priorities as $status ) {
-			yield wp_parse_args( [
-				'status'       => $status,
-				'date_compare' => '<=',
-			], $args );
-			yield wp_parse_args( [
-				'status'       => $status,
-				'date_compare' => '>=',
-			], $args );
-		}
-	}
+        foreach ( $priorities as $status ) {
+            yield wp_parse_args( [
+                'status'       => $status,
+                'date_compare' => '<=',
+            ], $args );
+            yield wp_parse_args( [
+                'status'       => $status,
+                'date_compare' => '>=',
+            ], $args );
+        }
+    }
 }
\ No newline at end of file

includes/libraries/action-scheduler/classes/migration/Config.php

Indentation +148 added lines, -148 removed lines

@@ -17,152 +17,152 @@
  * A config builder for the ActionScheduler\Migration\Runner class
  */
 class Config {
-	/** @var ActionScheduler_Store */
-	private $source_store;
-
-	/** @var ActionScheduler_Logger */
-	private $source_logger;
-
-	/** @var ActionScheduler_Store */
-	private $destination_store;
-
-	/** @var ActionScheduler_Logger */
-	private $destination_logger;
-
-	/** @var Progress bar */
-	private $progress_bar;
-
-	/** @var bool */
-	private $dry_run = false;
-
-	/**
-	 * Config constructor.
-	 */
-	public function __construct() {
-
-	}
-
-	/**
-	 * Get the configured source store.
-	 *
-	 * @return ActionScheduler_Store
-	 */
-	public function get_source_store() {
-		if ( empty( $this->source_store ) ) {
-			throw new \RuntimeException( __( 'Source store must be configured before running a migration', 'action-scheduler' ) );
-		}
-
-		return $this->source_store;
-	}
-
-	/**
-	 * Set the configured source store.
-	 *
-	 * @param ActionScheduler_Store $store Source store object.
-	 */
-	public function set_source_store( Store $store ) {
-		$this->source_store = $store;
-	}
-
-	/**
-	 * Get the configured source loger.
-	 *
-	 * @return ActionScheduler_Logger
-	 */
-	public function get_source_logger() {
-		if ( empty( $this->source_logger ) ) {
-			throw new \RuntimeException( __( 'Source logger must be configured before running a migration', 'action-scheduler' ) );
-		}
-
-		return $this->source_logger;
-	}
-
-	/**
-	 * Set the configured source logger.
-	 *
-	 * @param ActionScheduler_Logger $logger
-	 */
-	public function set_source_logger( Logger $logger ) {
-		$this->source_logger = $logger;
-	}
-
-	/**
-	 * Get the configured destination store.
-	 *
-	 * @return ActionScheduler_Store
-	 */
-	public function get_destination_store() {
-		if ( empty( $this->destination_store ) ) {
-			throw new \RuntimeException( __( 'Destination store must be configured before running a migration', 'action-scheduler' ) );
-		}
-
-		return $this->destination_store;
-	}
-
-	/**
-	 * Set the configured destination store.
-	 *
-	 * @param ActionScheduler_Store $store
-	 */
-	public function set_destination_store( Store $store ) {
-		$this->destination_store = $store;
-	}
-
-	/**
-	 * Get the configured destination logger.
-	 *
-	 * @return ActionScheduler_Logger
-	 */
-	public function get_destination_logger() {
-		if ( empty( $this->destination_logger ) ) {
-			throw new \RuntimeException( __( 'Destination logger must be configured before running a migration', 'action-scheduler' ) );
-		}
-
-		return $this->destination_logger;
-	}
-
-	/**
-	 * Set the configured destination logger.
-	 *
-	 * @param ActionScheduler_Logger $logger
-	 */
-	public function set_destination_logger( Logger $logger ) {
-		$this->destination_logger = $logger;
-	}
-
-	/**
-	 * Get flag indicating whether it's a dry run.
-	 *
-	 * @return bool
-	 */
-	public function get_dry_run() {
-		return $this->dry_run;
-	}
-
-	/**
-	 * Set flag indicating whether it's a dry run.
-	 *
-	 * @param bool $dry_run
-	 */
-	public function set_dry_run( $dry_run ) {
-		$this->dry_run = (bool) $dry_run;
-	}
-
-	/**
-	 * Get progress bar object.
-	 *
-	 * @return ActionScheduler\WPCLI\ProgressBar
-	 */
-	public function get_progress_bar() {
-		return $this->progress_bar;
-	}
-
-	/**
-	 * Set progress bar object.
-	 *
-	 * @param ActionScheduler\WPCLI\ProgressBar $progress_bar
-	 */
-	public function set_progress_bar( ProgressBar $progress_bar ) {
-		$this->progress_bar = $progress_bar;
-	}
+    /** @var ActionScheduler_Store */
+    private $source_store;
+
+    /** @var ActionScheduler_Logger */
+    private $source_logger;
+
+    /** @var ActionScheduler_Store */
+    private $destination_store;
+
+    /** @var ActionScheduler_Logger */
+    private $destination_logger;
+
+    /** @var Progress bar */
+    private $progress_bar;
+
+    /** @var bool */
+    private $dry_run = false;
+
+    /**
+     * Config constructor.
+     */
+    public function __construct() {
+
+    }
+
+    /**
+     * Get the configured source store.
+     *
+     * @return ActionScheduler_Store
+     */
+    public function get_source_store() {
+        if ( empty( $this->source_store ) ) {
+            throw new \RuntimeException( __( 'Source store must be configured before running a migration', 'action-scheduler' ) );
+        }
+
+        return $this->source_store;
+    }
+
+    /**
+     * Set the configured source store.
+     *
+     * @param ActionScheduler_Store $store Source store object.
+     */
+    public function set_source_store( Store $store ) {
+        $this->source_store = $store;
+    }
+
+    /**
+     * Get the configured source loger.
+     *
+     * @return ActionScheduler_Logger
+     */
+    public function get_source_logger() {
+        if ( empty( $this->source_logger ) ) {
+            throw new \RuntimeException( __( 'Source logger must be configured before running a migration', 'action-scheduler' ) );
+        }
+
+        return $this->source_logger;
+    }
+
+    /**
+     * Set the configured source logger.
+     *
+     * @param ActionScheduler_Logger $logger
+     */
+    public function set_source_logger( Logger $logger ) {
+        $this->source_logger = $logger;
+    }
+
+    /**
+     * Get the configured destination store.
+     *
+     * @return ActionScheduler_Store
+     */
+    public function get_destination_store() {
+        if ( empty( $this->destination_store ) ) {
+            throw new \RuntimeException( __( 'Destination store must be configured before running a migration', 'action-scheduler' ) );
+        }
+
+        return $this->destination_store;
+    }
+
+    /**
+     * Set the configured destination store.
+     *
+     * @param ActionScheduler_Store $store
+     */
+    public function set_destination_store( Store $store ) {
+        $this->destination_store = $store;
+    }
+
+    /**
+     * Get the configured destination logger.
+     *
+     * @return ActionScheduler_Logger
+     */
+    public function get_destination_logger() {
+        if ( empty( $this->destination_logger ) ) {
+            throw new \RuntimeException( __( 'Destination logger must be configured before running a migration', 'action-scheduler' ) );
+        }
+
+        return $this->destination_logger;
+    }
+
+    /**
+     * Set the configured destination logger.
+     *
+     * @param ActionScheduler_Logger $logger
+     */
+    public function set_destination_logger( Logger $logger ) {
+        $this->destination_logger = $logger;
+    }
+
+    /**
+     * Get flag indicating whether it's a dry run.
+     *
+     * @return bool
+     */
+    public function get_dry_run() {
+        return $this->dry_run;
+    }
+
+    /**
+     * Set flag indicating whether it's a dry run.
+     *
+     * @param bool $dry_run
+     */
+    public function set_dry_run( $dry_run ) {
+        $this->dry_run = (bool) $dry_run;
+    }
+
+    /**
+     * Get progress bar object.
+     *
+     * @return ActionScheduler\WPCLI\ProgressBar
+     */
+    public function get_progress_bar() {
+        return $this->progress_bar;
+    }
+
+    /**
+     * Set progress bar object.
+     *
+     * @param ActionScheduler\WPCLI\ProgressBar $progress_bar
+     */
+    public function set_progress_bar( ProgressBar $progress_bar ) {
+        $this->progress_bar = $progress_bar;
+    }
 }

includes/libraries/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, 'action-scheduler' ), 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', 'action-scheduler' ),
-					$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, 'action-scheduler' ), 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', 'action-scheduler' ),
+                    $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();
+    }
 }

includes/libraries/action-scheduler/classes/migration/LogMigrator.php

Indentation +28 added lines, -28 removed lines

@@ -15,35 +15,35 @@
  * @codeCoverageIgnore
  */
 class LogMigrator {
-	/** @var ActionScheduler_Logger */
-	private $source;
+    /** @var ActionScheduler_Logger */
+    private $source;
 
-	/** @var ActionScheduler_Logger */
-	private $destination;
+    /** @var ActionScheduler_Logger */
+    private $destination;
 
-	/**
-	 * ActionMigrator constructor.
-	 *
-	 * @param ActionScheduler_Logger $source_logger Source logger object.
-	 * @param ActionScheduler_Logger $destination_Logger Destination logger object.
-	 */
-	public function __construct( ActionScheduler_Logger $source_logger, ActionScheduler_Logger $destination_Logger ) {
-		$this->source      = $source_logger;
-		$this->destination = $destination_Logger;
-	}
+    /**
+     * ActionMigrator constructor.
+     *
+     * @param ActionScheduler_Logger $source_logger Source logger object.
+     * @param ActionScheduler_Logger $destination_Logger Destination logger object.
+     */
+    public function __construct( ActionScheduler_Logger $source_logger, ActionScheduler_Logger $destination_Logger ) {
+        $this->source      = $source_logger;
+        $this->destination = $destination_Logger;
+    }
 
-	/**
-	 * Migrate an action log.
-	 *
-	 * @param int $source_action_id Source logger object.
-	 * @param int $destination_action_id Destination logger object.
-	 */
-	public function migrate( $source_action_id, $destination_action_id ) {
-		$logs = $this->source->get_logs( $source_action_id );
-		foreach ( $logs as $log ) {
-			if ( $log->get_action_id() == $source_action_id ) {
-				$this->destination->log( $destination_action_id, $log->get_message(), $log->get_date() );
-			}
-		}
-	}
+    /**
+     * Migrate an action log.
+     *
+     * @param int $source_action_id Source logger object.
+     * @param int $destination_action_id Destination logger object.
+     */
+    public function migrate( $source_action_id, $destination_action_id ) {
+        $logs = $this->source->get_logs( $source_action_id );
+        foreach ( $logs as $log ) {
+            if ( $log->get_action_id() == $source_action_id ) {
+                $this->destination->log( $destination_action_id, $log->get_message(), $log->get_date() );
+            }
+        }
+    }
 }

includes/libraries/action-scheduler/classes/migration/Scheduler.php

Indentation +111 added lines, -111 removed lines

@@ -13,116 +13,116 @@
  * @codeCoverageIgnore
  */
 class Scheduler {
-	/** Migration action hook. */
-	const HOOK            = 'action_scheduler/migration_hook';
-
-	/** Migration action group. */
-	const GROUP           = 'action-scheduler-migration';
-
-	/**
-	 * Set up the callback for the scheduled job.
-	 */
-	public function hook() {
-		add_action( self::HOOK, array( $this, 'run_migration' ), 10, 0 );
-	}
-
-	/**
-	 * Remove the callback for the scheduled job.
-	 */
-	public function unhook() {
-		remove_action( self::HOOK, array( $this, 'run_migration' ), 10 );
-	}
-
-	/**
-	 * The migration callback.
-	 */
-	public function run_migration() {
-		$migration_runner = $this->get_migration_runner();
-		$count            = $migration_runner->run( $this->get_batch_size() );
-
-		if ( $count === 0 ) {
-			$this->mark_complete();
-		} else {
-			$this->schedule_migration( time() + $this->get_schedule_interval() );
-		}
-	}
-
-	/**
-	 * Mark the migration complete.
-	 */
-	public function mark_complete() {
-		$this->unschedule_migration();
-
-		\ActionScheduler_DataController::mark_migration_complete();
-		do_action( 'action_scheduler/migration_complete' );
-	}
-
-	/**
-	 * Get a flag indicating whether the migration is scheduled.
-	 *
-	 * @return bool Whether there is a pending action in the store to handle the migration
-	 */
-	public function is_migration_scheduled() {
-		$next = as_next_scheduled_action( self::HOOK );
-
-		return ! empty( $next );
-	}
-
-	/**
-	 * Schedule the migration.
-	 *
-	 * @param int $when Optional timestamp to run the next migration batch. Defaults to now.
-	 *
-	 * @return string The action ID
-	 */
-	public function schedule_migration( $when = 0 ) {
-		$next = as_next_scheduled_action( self::HOOK );
-
-		if ( ! empty( $next ) ) {
-			return $next;
-		}
-
-		if ( empty( $when ) ) {
-			$when = time();
-		}
-
-		return as_schedule_single_action( $when, self::HOOK, array(), self::GROUP );
-	}
-
-	/**
-	 * Remove the scheduled migration action.
-	 */
-	public function unschedule_migration() {
-		as_unschedule_action( self::HOOK, null, self::GROUP );
-	}
-
-	/**
-	 * Get migration batch schedule interval.
-	 *
-	 * @return int Seconds between migration runs. Defaults to 0 seconds to allow chaining migration via Async Runners.
-	 */
-	private function get_schedule_interval() {
-		return (int) apply_filters( 'action_scheduler/migration_interval', 0 );
-	}
-
-	/**
-	 * Get migration batch size.
-	 *
-	 * @return int Number of actions to migrate in each batch. Defaults to 250.
-	 */
-	private function get_batch_size() {
-		return (int) apply_filters( 'action_scheduler/migration_batch_size', 250 );
-	}
-
-	/**
-	 * Get migration runner object.
-	 *
-	 * @return Runner
-	 */
-	private function get_migration_runner() {
-		$config = Controller::instance()->get_migration_config_object();
-
-		return new Runner( $config );
-	}
+    /** Migration action hook. */
+    const HOOK            = 'action_scheduler/migration_hook';
+
+    /** Migration action group. */
+    const GROUP           = 'action-scheduler-migration';
+
+    /**
+     * Set up the callback for the scheduled job.
+     */
+    public function hook() {
+        add_action( self::HOOK, array( $this, 'run_migration' ), 10, 0 );
+    }
+
+    /**
+     * Remove the callback for the scheduled job.
+     */
+    public function unhook() {
+        remove_action( self::HOOK, array( $this, 'run_migration' ), 10 );
+    }
+
+    /**
+     * The migration callback.
+     */
+    public function run_migration() {
+        $migration_runner = $this->get_migration_runner();
+        $count            = $migration_runner->run( $this->get_batch_size() );
+
+        if ( $count === 0 ) {
+            $this->mark_complete();
+        } else {
+            $this->schedule_migration( time() + $this->get_schedule_interval() );
+        }
+    }
+
+    /**
+     * Mark the migration complete.
+     */
+    public function mark_complete() {
+        $this->unschedule_migration();
+
+        \ActionScheduler_DataController::mark_migration_complete();
+        do_action( 'action_scheduler/migration_complete' );
+    }
+
+    /**
+     * Get a flag indicating whether the migration is scheduled.
+     *
+     * @return bool Whether there is a pending action in the store to handle the migration
+     */
+    public function is_migration_scheduled() {
+        $next = as_next_scheduled_action( self::HOOK );
+
+        return ! empty( $next );
+    }
+
+    /**
+     * Schedule the migration.
+     *
+     * @param int $when Optional timestamp to run the next migration batch. Defaults to now.
+     *
+     * @return string The action ID
+     */
+    public function schedule_migration( $when = 0 ) {
+        $next = as_next_scheduled_action( self::HOOK );
+
+        if ( ! empty( $next ) ) {
+            return $next;
+        }
+
+        if ( empty( $when ) ) {
+            $when = time();
+        }
+
+        return as_schedule_single_action( $when, self::HOOK, array(), self::GROUP );
+    }
+
+    /**
+     * Remove the scheduled migration action.
+     */
+    public function unschedule_migration() {
+        as_unschedule_action( self::HOOK, null, self::GROUP );
+    }
+
+    /**
+     * Get migration batch schedule interval.
+     *
+     * @return int Seconds between migration runs. Defaults to 0 seconds to allow chaining migration via Async Runners.
+     */
+    private function get_schedule_interval() {
+        return (int) apply_filters( 'action_scheduler/migration_interval', 0 );
+    }
+
+    /**
+     * Get migration batch size.
+     *
+     * @return int Number of actions to migrate in each batch. Defaults to 250.
+     */
+    private function get_batch_size() {
+        return (int) apply_filters( 'action_scheduler/migration_batch_size', 250 );
+    }
+
+    /**
+     * Get migration runner object.
+     *
+     * @return Runner
+     */
+    private function get_migration_runner() {
+        $config = Controller::instance()->get_migration_config_object();
+
+        return new Runner( $config );
+    }
 
 }

includes/libraries/action-scheduler/classes/migration/DryRun_ActionMigrator.php

Indentation +11 added lines, -11 removed lines

@@ -13,16 +13,16 @@
  * @codeCoverageIgnore
  */
 class DryRun_ActionMigrator extends ActionMigrator {
-	/**
-	 * Simulate migrating an action.
-	 *
-	 * @param int $source_action_id Action ID.
-	 *
-	 * @return int
-	 */
-	public function migrate( $source_action_id ) {
-		do_action( 'action_scheduler/migrate_action_dry_run', $source_action_id );
+    /**
+     * Simulate migrating an action.
+     *
+     * @param int $source_action_id Action ID.
+     *
+     * @return int
+     */
+    public function migrate( $source_action_id ) {
+        do_action( 'action_scheduler/migrate_action_dry_run', $source_action_id );
 
-		return 0;
-	}
+        return 0;
+    }
 }