insideout10 / wordlift-plugin

src/libraries/action-scheduler/classes/abstracts/ActionScheduler_Lock.php

Indentation +52 added lines, -52 removed lines

@@ -7,56 +7,56 @@
  */
 abstract class ActionScheduler_Lock {
 
-	/** @var ActionScheduler_Lock */
-	private static $locker = null;
-
-	/** @var int */
-	protected static $lock_duration = MINUTE_IN_SECONDS;
-
-	/**
-	 * Check if a lock is set for a given lock type.
-	 *
-	 * @param string $lock_type A string to identify different lock types.
-	 * @return bool
-	 */
-	public function is_locked( $lock_type ) {
-		return ( $this->get_expiration( $lock_type ) >= time() );
-	}
-
-	/**
-	 * Set a lock.
-	 *
-	 * @param string $lock_type A string to identify different lock types.
-	 * @return bool
-	 */
-	abstract public function set( $lock_type );
-
-	/**
-	 * If a lock is set, return the timestamp it was set to expiry.
-	 *
-	 * @param string $lock_type A string to identify different lock types.
-	 * @return bool|int False if no lock is set, otherwise the timestamp for when the lock is set to expire.
-	 */
-	abstract public function get_expiration( $lock_type );
-
-	/**
-	 * Get the amount of time to set for a given lock. 60 seconds by default.
-	 *
-	 * @param string $lock_type A string to identify different lock types.
-	 * @return int
-	 */
-	protected function get_duration( $lock_type ) {
-		return apply_filters( 'action_scheduler_lock_duration', self::$lock_duration, $lock_type );
-	}
-
-	/**
-	 * @return ActionScheduler_Lock
-	 */
-	public static function instance() {
-		if ( empty( self::$locker ) ) {
-			$class        = apply_filters( 'action_scheduler_lock_class', 'ActionScheduler_OptionLock' );
-			self::$locker = new $class();
-		}
-		return self::$locker;
-	}
+    /** @var ActionScheduler_Lock */
+    private static $locker = null;
+
+    /** @var int */
+    protected static $lock_duration = MINUTE_IN_SECONDS;
+
+    /**
+     * Check if a lock is set for a given lock type.
+     *
+     * @param string $lock_type A string to identify different lock types.
+     * @return bool
+     */
+    public function is_locked( $lock_type ) {
+        return ( $this->get_expiration( $lock_type ) >= time() );
+    }
+
+    /**
+     * Set a lock.
+     *
+     * @param string $lock_type A string to identify different lock types.
+     * @return bool
+     */
+    abstract public function set( $lock_type );
+
+    /**
+     * If a lock is set, return the timestamp it was set to expiry.
+     *
+     * @param string $lock_type A string to identify different lock types.
+     * @return bool|int False if no lock is set, otherwise the timestamp for when the lock is set to expire.
+     */
+    abstract public function get_expiration( $lock_type );
+
+    /**
+     * Get the amount of time to set for a given lock. 60 seconds by default.
+     *
+     * @param string $lock_type A string to identify different lock types.
+     * @return int
+     */
+    protected function get_duration( $lock_type ) {
+        return apply_filters( 'action_scheduler_lock_duration', self::$lock_duration, $lock_type );
+    }
+
+    /**
+     * @return ActionScheduler_Lock
+     */
+    public static function instance() {
+        if ( empty( self::$locker ) ) {
+            $class        = apply_filters( 'action_scheduler_lock_class', 'ActionScheduler_OptionLock' );
+            self::$locker = new $class();
+        }
+        return self::$locker;
+    }
 }

Spacing +8 added lines, -8 removed lines

@@ -19,8 +19,8 @@ 
 	 * @param string $lock_type A string to identify different lock types.
 	 * @return bool
 	 */
-	public function is_locked( $lock_type ) {
-		return ( $this->get_expiration( $lock_type ) >= time() );
+	public function is_locked($lock_type) {
+		return ($this->get_expiration($lock_type) >= time());
 	}
 
 	/**
@@ -29,7 +29,7 @@ 
 	 * @param string $lock_type A string to identify different lock types.
 	 * @return bool
 	 */
-	abstract public function set( $lock_type );
+	abstract public function set($lock_type);
 
 	/**
 	 * If a lock is set, return the timestamp it was set to expiry.
@@ -37,7 +37,7 @@ 
 	 * @param string $lock_type A string to identify different lock types.
 	 * @return bool|int False if no lock is set, otherwise the timestamp for when the lock is set to expire.
 	 */
-	abstract public function get_expiration( $lock_type );
+	abstract public function get_expiration($lock_type);
 
 	/**
 	 * Get the amount of time to set for a given lock. 60 seconds by default.
@@ -45,16 +45,16 @@ 
 	 * @param string $lock_type A string to identify different lock types.
 	 * @return int
 	 */
-	protected function get_duration( $lock_type ) {
-		return apply_filters( 'action_scheduler_lock_duration', self::$lock_duration, $lock_type );
+	protected function get_duration($lock_type) {
+		return apply_filters('action_scheduler_lock_duration', self::$lock_duration, $lock_type);
 	}
 
 	/**
 	 * @return ActionScheduler_Lock
 	 */
 	public static function instance() {
-		if ( empty( self::$locker ) ) {
-			$class        = apply_filters( 'action_scheduler_lock_class', 'ActionScheduler_OptionLock' );
+		if (empty(self::$locker)) {
+			$class        = apply_filters('action_scheduler_lock_class', 'ActionScheduler_OptionLock');
 			self::$locker = new $class();
 		}
 		return self::$locker;

src/libraries/action-scheduler/classes/abstracts/ActionScheduler_Logger.php

Indentation +167 added lines, -167 removed lines

@@ -6,171 +6,171 @@
  * @codeCoverageIgnore
  */
 abstract class ActionScheduler_Logger {
-	private static $logger = null;
-
-	/**
-	 * @return ActionScheduler_Logger
-	 */
-	public static function instance() {
-		if ( empty( self::$logger ) ) {
-			$class        = apply_filters( 'action_scheduler_logger_class', 'ActionScheduler_wpCommentLogger' );
-			self::$logger = new $class();
-		}
-		return self::$logger;
-	}
-
-	/**
-	 * @param string   $action_id
-	 * @param string   $message
-	 * @param DateTime $date
-	 *
-	 * @return string The log entry ID
-	 */
-	abstract public function log( $action_id, $message, DateTime $date = null );
-
-	/**
-	 * @param string $entry_id
-	 *
-	 * @return ActionScheduler_LogEntry
-	 */
-	abstract public function get_entry( $entry_id );
-
-	/**
-	 * @param string $action_id
-	 *
-	 * @return ActionScheduler_LogEntry[]
-	 */
-	abstract public function get_logs( $action_id );
-
-	/**
-	 * @codeCoverageIgnore
-	 */
-	public function init() {
-		$this->hook_stored_action();
-		add_action( 'action_scheduler_canceled_action', array( $this, 'log_canceled_action' ), 10, 1 );
-		add_action( 'action_scheduler_begin_execute', array( $this, 'log_started_action' ), 10, 2 );
-		add_action( 'action_scheduler_after_execute', array( $this, 'log_completed_action' ), 10, 3 );
-		add_action( 'action_scheduler_failed_execution', array( $this, 'log_failed_action' ), 10, 3 );
-		add_action( 'action_scheduler_failed_action', array( $this, 'log_timed_out_action' ), 10, 2 );
-		add_action( 'action_scheduler_unexpected_shutdown', array( $this, 'log_unexpected_shutdown' ), 10, 2 );
-		add_action( 'action_scheduler_reset_action', array( $this, 'log_reset_action' ), 10, 1 );
-		add_action( 'action_scheduler_execution_ignored', array( $this, 'log_ignored_action' ), 10, 2 );
-		add_action( 'action_scheduler_failed_fetch_action', array( $this, 'log_failed_fetch_action' ), 10, 2 );
-		add_action( 'action_scheduler_failed_to_schedule_next_instance', array( $this, 'log_failed_schedule_next_instance' ), 10, 2 );
-		add_action( 'action_scheduler_bulk_cancel_actions', array( $this, 'bulk_log_cancel_actions' ), 10, 1 );
-	}
-
-	public function hook_stored_action() {
-		add_action( 'action_scheduler_stored_action', array( $this, 'log_stored_action' ) );
-	}
-
-	public function unhook_stored_action() {
-		remove_action( 'action_scheduler_stored_action', array( $this, 'log_stored_action' ) );
-	}
-
-	public function log_stored_action( $action_id ) {
-		$this->log( $action_id, __( 'action created', 'action-scheduler' ) );
-	}
-
-	public function log_canceled_action( $action_id ) {
-		$this->log( $action_id, __( 'action canceled', 'action-scheduler' ) );
-	}
-
-	public function log_started_action( $action_id, $context = '' ) {
-		if ( ! empty( $context ) ) {
-			/* translators: %s: context */
-			$message = sprintf( __( 'action started via %s', 'action-scheduler' ), $context );
-		} else {
-			$message = __( 'action started', 'action-scheduler' );
-		}
-		$this->log( $action_id, $message );
-	}
-
-	public function log_completed_action( $action_id, $action = null, $context = '' ) {
-		if ( ! empty( $context ) ) {
-			/* translators: %s: context */
-			$message = sprintf( __( 'action complete via %s', 'action-scheduler' ), $context );
-		} else {
-			$message = __( 'action complete', 'action-scheduler' );
-		}
-		$this->log( $action_id, $message );
-	}
-
-	public function log_failed_action( $action_id, Exception $exception, $context = '' ) {
-		if ( ! empty( $context ) ) {
-			/* translators: 1: context 2: exception message */
-			$message = sprintf( __( 'action failed via %1$s: %2$s', 'action-scheduler' ), $context, $exception->getMessage() );
-		} else {
-			/* translators: %s: exception message */
-			$message = sprintf( __( 'action failed: %s', 'action-scheduler' ), $exception->getMessage() );
-		}
-		$this->log( $action_id, $message );
-	}
-
-	public function log_timed_out_action( $action_id, $timeout ) {
-		/* translators: %s: amount of time */
-		$this->log( $action_id, sprintf( __( 'action marked as failed after %s seconds. Unknown error occurred. Check server, PHP and database error logs to diagnose cause.', 'action-scheduler' ), $timeout ) );
-	}
-
-	public function log_unexpected_shutdown( $action_id, $error ) {
-		if ( ! empty( $error ) ) {
-			/* translators: 1: error message 2: filename 3: line */
-			$this->log( $action_id, sprintf( __( 'unexpected shutdown: PHP Fatal error %1$s in %2$s on line %3$s', 'action-scheduler' ), $error['message'], $error['file'], $error['line'] ) );
-		}
-	}
-
-	public function log_reset_action( $action_id ) {
-		$this->log( $action_id, __( 'action reset', 'action-scheduler' ) );
-	}
-
-	public function log_ignored_action( $action_id, $context = '' ) {
-		if ( ! empty( $context ) ) {
-			/* translators: %s: context */
-			$message = sprintf( __( 'action ignored via %s', 'action-scheduler' ), $context );
-		} else {
-			$message = __( 'action ignored', 'action-scheduler' );
-		}
-		$this->log( $action_id, $message );
-	}
-
-	/**
-	 * @param string         $action_id
-	 * @param Exception|NULL $exception The exception which occured when fetching the action. NULL by default for backward compatibility.
-	 *
-	 * @return ActionScheduler_LogEntry[]
-	 */
-	public function log_failed_fetch_action( $action_id, Exception $exception = null ) {
-
-		if ( $exception !== null ) {
-			/* translators: %s: exception message */
-			$log_message = sprintf( __( 'There was a failure fetching this action: %s', 'action-scheduler' ), $exception->getMessage() );
-		} else {
-			$log_message = __( 'There was a failure fetching this action', 'action-scheduler' );
-		}
-
-		$this->log( $action_id, $log_message );
-	}
-
-	public function log_failed_schedule_next_instance( $action_id, Exception $exception ) {
-		/* translators: %s: exception message */
-		$this->log( $action_id, sprintf( __( 'There was a failure scheduling the next instance of this action: %s', 'action-scheduler' ), $exception->getMessage() ) );
-	}
-
-	/**
-	 * Bulk add cancel action log entries.
-	 *
-	 * Implemented here for backward compatibility. Should be implemented in parent loggers
-	 * for more performant bulk logging.
-	 *
-	 * @param array $action_ids List of action ID.
-	 */
-	public function bulk_log_cancel_actions( $action_ids ) {
-		if ( empty( $action_ids ) ) {
-			return;
-		}
-
-		foreach ( $action_ids as $action_id ) {
-			$this->log_canceled_action( $action_id );
-		}
-	}
+    private static $logger = null;
+
+    /**
+     * @return ActionScheduler_Logger
+     */
+    public static function instance() {
+        if ( empty( self::$logger ) ) {
+            $class        = apply_filters( 'action_scheduler_logger_class', 'ActionScheduler_wpCommentLogger' );
+            self::$logger = new $class();
+        }
+        return self::$logger;
+    }
+
+    /**
+     * @param string   $action_id
+     * @param string   $message
+     * @param DateTime $date
+     *
+     * @return string The log entry ID
+     */
+    abstract public function log( $action_id, $message, DateTime $date = null );
+
+    /**
+     * @param string $entry_id
+     *
+     * @return ActionScheduler_LogEntry
+     */
+    abstract public function get_entry( $entry_id );
+
+    /**
+     * @param string $action_id
+     *
+     * @return ActionScheduler_LogEntry[]
+     */
+    abstract public function get_logs( $action_id );
+
+    /**
+     * @codeCoverageIgnore
+     */
+    public function init() {
+        $this->hook_stored_action();
+        add_action( 'action_scheduler_canceled_action', array( $this, 'log_canceled_action' ), 10, 1 );
+        add_action( 'action_scheduler_begin_execute', array( $this, 'log_started_action' ), 10, 2 );
+        add_action( 'action_scheduler_after_execute', array( $this, 'log_completed_action' ), 10, 3 );
+        add_action( 'action_scheduler_failed_execution', array( $this, 'log_failed_action' ), 10, 3 );
+        add_action( 'action_scheduler_failed_action', array( $this, 'log_timed_out_action' ), 10, 2 );
+        add_action( 'action_scheduler_unexpected_shutdown', array( $this, 'log_unexpected_shutdown' ), 10, 2 );
+        add_action( 'action_scheduler_reset_action', array( $this, 'log_reset_action' ), 10, 1 );
+        add_action( 'action_scheduler_execution_ignored', array( $this, 'log_ignored_action' ), 10, 2 );
+        add_action( 'action_scheduler_failed_fetch_action', array( $this, 'log_failed_fetch_action' ), 10, 2 );
+        add_action( 'action_scheduler_failed_to_schedule_next_instance', array( $this, 'log_failed_schedule_next_instance' ), 10, 2 );
+        add_action( 'action_scheduler_bulk_cancel_actions', array( $this, 'bulk_log_cancel_actions' ), 10, 1 );
+    }
+
+    public function hook_stored_action() {
+        add_action( 'action_scheduler_stored_action', array( $this, 'log_stored_action' ) );
+    }
+
+    public function unhook_stored_action() {
+        remove_action( 'action_scheduler_stored_action', array( $this, 'log_stored_action' ) );
+    }
+
+    public function log_stored_action( $action_id ) {
+        $this->log( $action_id, __( 'action created', 'action-scheduler' ) );
+    }
+
+    public function log_canceled_action( $action_id ) {
+        $this->log( $action_id, __( 'action canceled', 'action-scheduler' ) );
+    }
+
+    public function log_started_action( $action_id, $context = '' ) {
+        if ( ! empty( $context ) ) {
+            /* translators: %s: context */
+            $message = sprintf( __( 'action started via %s', 'action-scheduler' ), $context );
+        } else {
+            $message = __( 'action started', 'action-scheduler' );
+        }
+        $this->log( $action_id, $message );
+    }
+
+    public function log_completed_action( $action_id, $action = null, $context = '' ) {
+        if ( ! empty( $context ) ) {
+            /* translators: %s: context */
+            $message = sprintf( __( 'action complete via %s', 'action-scheduler' ), $context );
+        } else {
+            $message = __( 'action complete', 'action-scheduler' );
+        }
+        $this->log( $action_id, $message );
+    }
+
+    public function log_failed_action( $action_id, Exception $exception, $context = '' ) {
+        if ( ! empty( $context ) ) {
+            /* translators: 1: context 2: exception message */
+            $message = sprintf( __( 'action failed via %1$s: %2$s', 'action-scheduler' ), $context, $exception->getMessage() );
+        } else {
+            /* translators: %s: exception message */
+            $message = sprintf( __( 'action failed: %s', 'action-scheduler' ), $exception->getMessage() );
+        }
+        $this->log( $action_id, $message );
+    }
+
+    public function log_timed_out_action( $action_id, $timeout ) {
+        /* translators: %s: amount of time */
+        $this->log( $action_id, sprintf( __( 'action marked as failed after %s seconds. Unknown error occurred. Check server, PHP and database error logs to diagnose cause.', 'action-scheduler' ), $timeout ) );
+    }
+
+    public function log_unexpected_shutdown( $action_id, $error ) {
+        if ( ! empty( $error ) ) {
+            /* translators: 1: error message 2: filename 3: line */
+            $this->log( $action_id, sprintf( __( 'unexpected shutdown: PHP Fatal error %1$s in %2$s on line %3$s', 'action-scheduler' ), $error['message'], $error['file'], $error['line'] ) );
+        }
+    }
+
+    public function log_reset_action( $action_id ) {
+        $this->log( $action_id, __( 'action reset', 'action-scheduler' ) );
+    }
+
+    public function log_ignored_action( $action_id, $context = '' ) {
+        if ( ! empty( $context ) ) {
+            /* translators: %s: context */
+            $message = sprintf( __( 'action ignored via %s', 'action-scheduler' ), $context );
+        } else {
+            $message = __( 'action ignored', 'action-scheduler' );
+        }
+        $this->log( $action_id, $message );
+    }
+
+    /**
+     * @param string         $action_id
+     * @param Exception|NULL $exception The exception which occured when fetching the action. NULL by default for backward compatibility.
+     *
+     * @return ActionScheduler_LogEntry[]
+     */
+    public function log_failed_fetch_action( $action_id, Exception $exception = null ) {
+
+        if ( $exception !== null ) {
+            /* translators: %s: exception message */
+            $log_message = sprintf( __( 'There was a failure fetching this action: %s', 'action-scheduler' ), $exception->getMessage() );
+        } else {
+            $log_message = __( 'There was a failure fetching this action', 'action-scheduler' );
+        }
+
+        $this->log( $action_id, $log_message );
+    }
+
+    public function log_failed_schedule_next_instance( $action_id, Exception $exception ) {
+        /* translators: %s: exception message */
+        $this->log( $action_id, sprintf( __( 'There was a failure scheduling the next instance of this action: %s', 'action-scheduler' ), $exception->getMessage() ) );
+    }
+
+    /**
+     * Bulk add cancel action log entries.
+     *
+     * Implemented here for backward compatibility. Should be implemented in parent loggers
+     * for more performant bulk logging.
+     *
+     * @param array $action_ids List of action ID.
+     */
+    public function bulk_log_cancel_actions( $action_ids ) {
+        if ( empty( $action_ids ) ) {
+            return;
+        }
+
+        foreach ( $action_ids as $action_id ) {
+            $this->log_canceled_action( $action_id );
+        }
+    }
 }

Spacing +60 added lines, -60 removed lines

@@ -12,8 +12,8 @@ 
 	 * @return ActionScheduler_Logger
 	 */
 	public static function instance() {
-		if ( empty( self::$logger ) ) {
-			$class        = apply_filters( 'action_scheduler_logger_class', 'ActionScheduler_wpCommentLogger' );
+		if (empty(self::$logger)) {
+			$class        = apply_filters('action_scheduler_logger_class', 'ActionScheduler_wpCommentLogger');
 			self::$logger = new $class();
 		}
 		return self::$logger;
@@ -26,111 +26,111 @@ 
 	 *
 	 * @return string The log entry ID
 	 */
-	abstract public function log( $action_id, $message, DateTime $date = null );
+	abstract public function log($action_id, $message, DateTime $date = null);
 
 	/**
 	 * @param string $entry_id
 	 *
 	 * @return ActionScheduler_LogEntry
 	 */
-	abstract public function get_entry( $entry_id );
+	abstract public function get_entry($entry_id);
 
 	/**
 	 * @param string $action_id
 	 *
 	 * @return ActionScheduler_LogEntry[]
 	 */
-	abstract public function get_logs( $action_id );
+	abstract public function get_logs($action_id);
 
 	/**
 	 * @codeCoverageIgnore
 	 */
 	public function init() {
 		$this->hook_stored_action();
-		add_action( 'action_scheduler_canceled_action', array( $this, 'log_canceled_action' ), 10, 1 );
-		add_action( 'action_scheduler_begin_execute', array( $this, 'log_started_action' ), 10, 2 );
-		add_action( 'action_scheduler_after_execute', array( $this, 'log_completed_action' ), 10, 3 );
-		add_action( 'action_scheduler_failed_execution', array( $this, 'log_failed_action' ), 10, 3 );
-		add_action( 'action_scheduler_failed_action', array( $this, 'log_timed_out_action' ), 10, 2 );
-		add_action( 'action_scheduler_unexpected_shutdown', array( $this, 'log_unexpected_shutdown' ), 10, 2 );
-		add_action( 'action_scheduler_reset_action', array( $this, 'log_reset_action' ), 10, 1 );
-		add_action( 'action_scheduler_execution_ignored', array( $this, 'log_ignored_action' ), 10, 2 );
-		add_action( 'action_scheduler_failed_fetch_action', array( $this, 'log_failed_fetch_action' ), 10, 2 );
-		add_action( 'action_scheduler_failed_to_schedule_next_instance', array( $this, 'log_failed_schedule_next_instance' ), 10, 2 );
-		add_action( 'action_scheduler_bulk_cancel_actions', array( $this, 'bulk_log_cancel_actions' ), 10, 1 );
+		add_action('action_scheduler_canceled_action', array($this, 'log_canceled_action'), 10, 1);
+		add_action('action_scheduler_begin_execute', array($this, 'log_started_action'), 10, 2);
+		add_action('action_scheduler_after_execute', array($this, 'log_completed_action'), 10, 3);
+		add_action('action_scheduler_failed_execution', array($this, 'log_failed_action'), 10, 3);
+		add_action('action_scheduler_failed_action', array($this, 'log_timed_out_action'), 10, 2);
+		add_action('action_scheduler_unexpected_shutdown', array($this, 'log_unexpected_shutdown'), 10, 2);
+		add_action('action_scheduler_reset_action', array($this, 'log_reset_action'), 10, 1);
+		add_action('action_scheduler_execution_ignored', array($this, 'log_ignored_action'), 10, 2);
+		add_action('action_scheduler_failed_fetch_action', array($this, 'log_failed_fetch_action'), 10, 2);
+		add_action('action_scheduler_failed_to_schedule_next_instance', array($this, 'log_failed_schedule_next_instance'), 10, 2);
+		add_action('action_scheduler_bulk_cancel_actions', array($this, 'bulk_log_cancel_actions'), 10, 1);
 	}
 
 	public function hook_stored_action() {
-		add_action( 'action_scheduler_stored_action', array( $this, 'log_stored_action' ) );
+		add_action('action_scheduler_stored_action', array($this, 'log_stored_action'));
 	}
 
 	public function unhook_stored_action() {
-		remove_action( 'action_scheduler_stored_action', array( $this, 'log_stored_action' ) );
+		remove_action('action_scheduler_stored_action', array($this, 'log_stored_action'));
 	}
 
-	public function log_stored_action( $action_id ) {
-		$this->log( $action_id, __( 'action created', 'action-scheduler' ) );
+	public function log_stored_action($action_id) {
+		$this->log($action_id, __('action created', 'action-scheduler'));
 	}
 
-	public function log_canceled_action( $action_id ) {
-		$this->log( $action_id, __( 'action canceled', 'action-scheduler' ) );
+	public function log_canceled_action($action_id) {
+		$this->log($action_id, __('action canceled', 'action-scheduler'));
 	}
 
-	public function log_started_action( $action_id, $context = '' ) {
-		if ( ! empty( $context ) ) {
+	public function log_started_action($action_id, $context = '') {
+		if ( ! empty($context)) {
 			/* translators: %s: context */
-			$message = sprintf( __( 'action started via %s', 'action-scheduler' ), $context );
+			$message = sprintf(__('action started via %s', 'action-scheduler'), $context);
 		} else {
-			$message = __( 'action started', 'action-scheduler' );
+			$message = __('action started', 'action-scheduler');
 		}
-		$this->log( $action_id, $message );
+		$this->log($action_id, $message);
 	}
 
-	public function log_completed_action( $action_id, $action = null, $context = '' ) {
-		if ( ! empty( $context ) ) {
+	public function log_completed_action($action_id, $action = null, $context = '') {
+		if ( ! empty($context)) {
 			/* translators: %s: context */
-			$message = sprintf( __( 'action complete via %s', 'action-scheduler' ), $context );
+			$message = sprintf(__('action complete via %s', 'action-scheduler'), $context);
 		} else {
-			$message = __( 'action complete', 'action-scheduler' );
+			$message = __('action complete', 'action-scheduler');
 		}
-		$this->log( $action_id, $message );
+		$this->log($action_id, $message);
 	}
 
-	public function log_failed_action( $action_id, Exception $exception, $context = '' ) {
-		if ( ! empty( $context ) ) {
+	public function log_failed_action($action_id, Exception $exception, $context = '') {
+		if ( ! empty($context)) {
 			/* translators: 1: context 2: exception message */
-			$message = sprintf( __( 'action failed via %1$s: %2$s', 'action-scheduler' ), $context, $exception->getMessage() );
+			$message = sprintf(__('action failed via %1$s: %2$s', 'action-scheduler'), $context, $exception->getMessage());
 		} else {
 			/* translators: %s: exception message */
-			$message = sprintf( __( 'action failed: %s', 'action-scheduler' ), $exception->getMessage() );
+			$message = sprintf(__('action failed: %s', 'action-scheduler'), $exception->getMessage());
 		}
-		$this->log( $action_id, $message );
+		$this->log($action_id, $message);
 	}
 
-	public function log_timed_out_action( $action_id, $timeout ) {
+	public function log_timed_out_action($action_id, $timeout) {
 		/* translators: %s: amount of time */
-		$this->log( $action_id, sprintf( __( 'action marked as failed after %s seconds. Unknown error occurred. Check server, PHP and database error logs to diagnose cause.', 'action-scheduler' ), $timeout ) );
+		$this->log($action_id, sprintf(__('action marked as failed after %s seconds. Unknown error occurred. Check server, PHP and database error logs to diagnose cause.', 'action-scheduler'), $timeout));
 	}
 
-	public function log_unexpected_shutdown( $action_id, $error ) {
-		if ( ! empty( $error ) ) {
+	public function log_unexpected_shutdown($action_id, $error) {
+		if ( ! empty($error)) {
 			/* translators: 1: error message 2: filename 3: line */
-			$this->log( $action_id, sprintf( __( 'unexpected shutdown: PHP Fatal error %1$s in %2$s on line %3$s', 'action-scheduler' ), $error['message'], $error['file'], $error['line'] ) );
+			$this->log($action_id, sprintf(__('unexpected shutdown: PHP Fatal error %1$s in %2$s on line %3$s', 'action-scheduler'), $error['message'], $error['file'], $error['line']));
 		}
 	}
 
-	public function log_reset_action( $action_id ) {
-		$this->log( $action_id, __( 'action reset', 'action-scheduler' ) );
+	public function log_reset_action($action_id) {
+		$this->log($action_id, __('action reset', 'action-scheduler'));
 	}
 
-	public function log_ignored_action( $action_id, $context = '' ) {
-		if ( ! empty( $context ) ) {
+	public function log_ignored_action($action_id, $context = '') {
+		if ( ! empty($context)) {
 			/* translators: %s: context */
-			$message = sprintf( __( 'action ignored via %s', 'action-scheduler' ), $context );
+			$message = sprintf(__('action ignored via %s', 'action-scheduler'), $context);
 		} else {
-			$message = __( 'action ignored', 'action-scheduler' );
+			$message = __('action ignored', 'action-scheduler');
 		}
-		$this->log( $action_id, $message );
+		$this->log($action_id, $message);
 	}
 
 	/**
@@ -139,21 +139,21 @@ 
 	 *
 	 * @return ActionScheduler_LogEntry[]
 	 */
-	public function log_failed_fetch_action( $action_id, Exception $exception = null ) {
+	public function log_failed_fetch_action($action_id, Exception $exception = null) {
 
-		if ( $exception !== null ) {
+		if ($exception !== null) {
 			/* translators: %s: exception message */
-			$log_message = sprintf( __( 'There was a failure fetching this action: %s', 'action-scheduler' ), $exception->getMessage() );
+			$log_message = sprintf(__('There was a failure fetching this action: %s', 'action-scheduler'), $exception->getMessage());
 		} else {
-			$log_message = __( 'There was a failure fetching this action', 'action-scheduler' );
+			$log_message = __('There was a failure fetching this action', 'action-scheduler');
 		}
 
-		$this->log( $action_id, $log_message );
+		$this->log($action_id, $log_message);
 	}
 
-	public function log_failed_schedule_next_instance( $action_id, Exception $exception ) {
+	public function log_failed_schedule_next_instance($action_id, Exception $exception) {
 		/* translators: %s: exception message */
-		$this->log( $action_id, sprintf( __( 'There was a failure scheduling the next instance of this action: %s', 'action-scheduler' ), $exception->getMessage() ) );
+		$this->log($action_id, sprintf(__('There was a failure scheduling the next instance of this action: %s', 'action-scheduler'), $exception->getMessage()));
 	}
 
 	/**
@@ -164,13 +164,13 @@ 
 	 *
 	 * @param array $action_ids List of action ID.
 	 */
-	public function bulk_log_cancel_actions( $action_ids ) {
-		if ( empty( $action_ids ) ) {
+	public function bulk_log_cancel_actions($action_ids) {
+		if (empty($action_ids)) {
 			return;
 		}
 
-		foreach ( $action_ids as $action_id ) {
-			$this->log_canceled_action( $action_id );
+		foreach ($action_ids as $action_id) {
+			$this->log_canceled_action($action_id);
 		}
 	}
 }

src/libraries/action-scheduler/classes/abstracts/ActionScheduler_Store.php

Indentation +446 added lines, -446 removed lines

@@ -6,450 +6,450 @@
  * @codeCoverageIgnore
  */
 abstract class ActionScheduler_Store extends ActionScheduler_Store_Deprecated {
-	const STATUS_COMPLETE = 'complete';
-	const STATUS_PENDING  = 'pending';
-	const STATUS_RUNNING  = 'in-progress';
-	const STATUS_FAILED   = 'failed';
-	const STATUS_CANCELED = 'canceled';
-	const DEFAULT_CLASS   = 'ActionScheduler_wpPostStore';
-
-	/** @var ActionScheduler_Store */
-	private static $store = null;
-
-	/** @var int */
-	protected static $max_args_length = 191;
-
-	/**
-	 * @param ActionScheduler_Action $action
-	 * @param DateTime               $scheduled_date Optional Date of the first instance
-	 *                      to store. Otherwise uses the first date of the action's
-	 *                      schedule.
-	 *
-	 * @return int The action ID
-	 */
-	abstract public function save_action( ActionScheduler_Action $action, DateTime $scheduled_date = null );
-
-	/**
-	 * @param string $action_id
-	 *
-	 * @return ActionScheduler_Action
-	 */
-	abstract public function fetch_action( $action_id );
-
-	/**
-	 * Find an action.
-	 *
-	 * Note: the query ordering changes based on the passed 'status' value.
-	 *
-	 * @param string $hook Action hook.
-	 * @param array  $params Parameters of the action to find.
-	 *
-	 * @return string|null ID of the next action matching the criteria or NULL if not found.
-	 */
-	public function find_action( $hook, $params = array() ) {
-		$params = wp_parse_args(
-			$params,
-			array(
-				'args'   => null,
-				'status' => self::STATUS_PENDING,
-				'group'  => '',
-			)
-		);
-
-		// These params are fixed for this method.
-		$params['hook']     = $hook;
-		$params['orderby']  = 'date';
-		$params['per_page'] = 1;
-
-		if ( ! empty( $params['status'] ) ) {
-			if ( self::STATUS_PENDING === $params['status'] ) {
-				$params['order'] = 'ASC'; // Find the next action that matches.
-			} else {
-				$params['order'] = 'DESC'; // Find the most recent action that matches.
-			}
-		}
-
-		$results = $this->query_actions( $params );
-
-		return empty( $results ) ? null : $results[0];
-	}
-
-	/**
-	 * Query for action count or list of action IDs.
-	 *
-	 * @since 3.3.0 $query['status'] accepts array of statuses instead of a single status.
-	 *
-	 * @param array  $query {
-	 *      Query filtering options.
-	 *
-	 *      @type string       $hook             The name of the actions. Optional.
-	 *      @type string|array $status           The status or statuses of the actions. Optional.
-	 *      @type array        $args             The args array of the actions. Optional.
-	 *      @type DateTime     $date             The scheduled date of the action. Used in UTC timezone. Optional.
-	 *      @type string       $date_compare     Operator for selecting by $date param. Accepted values are '!=', '>', '>=', '<', '<=', '='. Defaults to '<='.
-	 *      @type DateTime     $modified         The last modified date of the action. Used in UTC timezone. Optional.
-	 *      @type string       $modified_compare Operator for comparing $modified param. Accepted values are '!=', '>', '>=', '<', '<=', '='. Defaults to '<='.
-	 *      @type string       $group            The group the action belongs to. Optional.
-	 *      @type bool|int     $claimed          TRUE to find claimed actions, FALSE to find unclaimed actions, an int to find a specific claim ID. Optional.
-	 *      @type int          $per_page         Number of results to return. Defaults to 5.
-	 *      @type int          $offset           The query pagination offset. Defaults to 0.
-	 *      @type int          $orderby          Accepted values are 'hook', 'group', 'modified', 'date' or 'none'. Defaults to 'date'.
-	 *      @type string       $order            Accepted values are 'ASC' or 'DESC'. Defaults to 'ASC'.
-	 * }
-	 * @param string $query_type Whether to select or count the results. Default, select.
-	 *
-	 * @return string|array|null The IDs of actions matching the query. Null on failure.
-	 */
-	abstract public function query_actions( $query = array(), $query_type = 'select' );
-
-	/**
-	 * Run query to get a single action ID.
-	 *
-	 * @since 3.3.0
-	 *
-	 * @see ActionScheduler_Store::query_actions for $query arg usage but 'per_page' and 'offset' can't be used.
-	 *
-	 * @param array $query Query parameters.
-	 *
-	 * @return int|null
-	 */
-	public function query_action( $query ) {
-		$query['per_page'] = 1;
-		$query['offset']   = 0;
-		$results           = $this->query_actions( $query );
-
-		if ( empty( $results ) ) {
-			return null;
-		} else {
-			return (int) $results[0];
-		}
-	}
-
-	/**
-	 * Get a count of all actions in the store, grouped by status
-	 *
-	 * @return array
-	 */
-	abstract public function action_counts();
-
-	/**
-	 * Get additional action counts.
-	 *
-	 * - add past-due actions
-	 *
-	 * @return array
-	 */
-	public function extra_action_counts() {
-		$extra_actions = array();
-
-		$pastdue_action_counts = (int) $this->query_actions(
-			array(
-				'status' => self::STATUS_PENDING,
-				'date'   => as_get_datetime_object(),
-			),
-			'count'
-		);
-
-		if ( $pastdue_action_counts ) {
-			$extra_actions['past-due'] = $pastdue_action_counts;
-		}
-
-		/**
-		 * Allows 3rd party code to add extra action counts (used in filters in the list table).
-		 *
-		 * @since 3.5.0
-		 * @param $extra_actions array Array with format action_count_identifier => action count.
-		 */
-		return apply_filters( 'action_scheduler_extra_action_counts', $extra_actions );
-	}
-
-	/**
-	 * @param string $action_id
-	 */
-	abstract public function cancel_action( $action_id );
-
-	/**
-	 * @param string $action_id
-	 */
-	abstract public function delete_action( $action_id );
-
-	/**
-	 * @param string $action_id
-	 *
-	 * @return DateTime The date the action is schedule to run, or the date that it ran.
-	 */
-	abstract public function get_date( $action_id );
-
-	/**
-	 * @param int      $max_actions
-	 * @param DateTime $before_date Claim only actions schedule before the given date. Defaults to now.
-	 * @param array    $hooks       Claim only actions with a hook or hooks.
-	 * @param string   $group       Claim only actions in the given group.
-	 *
-	 * @return ActionScheduler_ActionClaim
-	 */
-	abstract public function stake_claim( $max_actions = 10, DateTime $before_date = null, $hooks = array(), $group = '' );
-
-	/**
-	 * @return int
-	 */
-	abstract public function get_claim_count();
-
-	/**
-	 * @param ActionScheduler_ActionClaim $claim
-	 */
-	abstract public function release_claim( ActionScheduler_ActionClaim $claim );
-
-	/**
-	 * @param string $action_id
-	 */
-	abstract public function unclaim_action( $action_id );
-
-	/**
-	 * @param string $action_id
-	 */
-	abstract public function mark_failure( $action_id );
-
-	/**
-	 * @param string $action_id
-	 */
-	abstract public function log_execution( $action_id );
-
-	/**
-	 * @param string $action_id
-	 */
-	abstract public function mark_complete( $action_id );
-
-	/**
-	 * @param string $action_id
-	 *
-	 * @return string
-	 */
-	abstract public function get_status( $action_id );
-
-	/**
-	 * @param string $action_id
-	 * @return mixed
-	 */
-	abstract public function get_claim_id( $action_id );
-
-	/**
-	 * @param string $claim_id
-	 * @return array
-	 */
-	abstract public function find_actions_by_claim_id( $claim_id );
-
-	/**
-	 * @param string $comparison_operator
-	 * @return string
-	 */
-	protected function validate_sql_comparator( $comparison_operator ) {
-		if ( in_array( $comparison_operator, array( '!=', '>', '>=', '<', '<=', '=' ) ) ) {
-			return $comparison_operator;
-		}
-		return '=';
-	}
-
-	/**
-	 * Get the time MySQL formated date/time string for an action's (next) scheduled date.
-	 *
-	 * @param ActionScheduler_Action $action
-	 * @param DateTime               $scheduled_date (optional)
-	 * @return string
-	 */
-	protected function get_scheduled_date_string( ActionScheduler_Action $action, DateTime $scheduled_date = null ) {
-		$next = null === $scheduled_date ? $action->get_schedule()->get_date() : $scheduled_date;
-		if ( ! $next ) {
-			return '0000-00-00 00:00:00';
-		}
-		$next->setTimezone( new DateTimeZone( 'UTC' ) );
-
-		return $next->format( 'Y-m-d H:i:s' );
-	}
-
-	/**
-	 * Get the time MySQL formated date/time string for an action's (next) scheduled date.
-	 *
-	 * @param ActionScheduler_Action $action
-	 * @param DateTime               $scheduled_date (optional)
-	 * @return string
-	 */
-	protected function get_scheduled_date_string_local( ActionScheduler_Action $action, DateTime $scheduled_date = null ) {
-		$next = null === $scheduled_date ? $action->get_schedule()->get_date() : $scheduled_date;
-		if ( ! $next ) {
-			return '0000-00-00 00:00:00';
-		}
-
-		ActionScheduler_TimezoneHelper::set_local_timezone( $next );
-		return $next->format( 'Y-m-d H:i:s' );
-	}
-
-	/**
-	 * Validate that we could decode action arguments.
-	 *
-	 * @param mixed $args      The decoded arguments.
-	 * @param int   $action_id The action ID.
-	 *
-	 * @throws ActionScheduler_InvalidActionException When the decoded arguments are invalid.
-	 */
-	protected function validate_args( $args, $action_id ) {
-		// Ensure we have an array of args.
-		if ( ! is_array( $args ) ) {
-			throw ActionScheduler_InvalidActionException::from_decoding_args( $action_id );
-		}
-
-		// Validate JSON decoding if possible.
-		if ( function_exists( 'json_last_error' ) && JSON_ERROR_NONE !== json_last_error() ) {
-			throw ActionScheduler_InvalidActionException::from_decoding_args( $action_id, $args );
-		}
-	}
-
-	/**
-	 * Validate a ActionScheduler_Schedule object.
-	 *
-	 * @param mixed $schedule  The unserialized ActionScheduler_Schedule object.
-	 * @param int   $action_id The action ID.
-	 *
-	 * @throws ActionScheduler_InvalidActionException When the schedule is invalid.
-	 */
-	protected function validate_schedule( $schedule, $action_id ) {
-		if ( empty( $schedule ) || ! is_a( $schedule, 'ActionScheduler_Schedule' ) ) {
-			throw ActionScheduler_InvalidActionException::from_schedule( $action_id, $schedule );
-		}
-	}
-
-	/**
-	 * InnoDB indexes have a maximum size of 767 bytes by default, which is only 191 characters with utf8mb4.
-	 *
-	 * Previously, AS wasn't concerned about args length, as we used the (unindex) post_content column. However,
-	 * with custom tables, we use an indexed VARCHAR column instead.
-	 *
-	 * @param  ActionScheduler_Action $action Action to be validated.
-	 * @throws InvalidArgumentException When json encoded args is too long.
-	 */
-	protected function validate_action( ActionScheduler_Action $action ) {
-		if ( strlen( json_encode( $action->get_args() ) ) > static::$max_args_length ) {
-			throw new InvalidArgumentException( sprintf( __( 'ActionScheduler_Action::$args too long. To ensure the args column can be indexed, action args should not be more than %d characters when encoded as JSON.', 'action-scheduler' ), static::$max_args_length ) );
-		}
-	}
-
-	/**
-	 * Cancel pending actions by hook.
-	 *
-	 * @since 3.0.0
-	 *
-	 * @param string $hook Hook name.
-	 *
-	 * @return void
-	 */
-	public function cancel_actions_by_hook( $hook ) {
-		$action_ids = true;
-		while ( ! empty( $action_ids ) ) {
-			$action_ids = $this->query_actions(
-				array(
-					'hook'     => $hook,
-					'status'   => self::STATUS_PENDING,
-					'per_page' => 1000,
-					'orderby'  => 'action_id',
-				)
-			);
-
-			$this->bulk_cancel_actions( $action_ids );
-		}
-	}
-
-	/**
-	 * Cancel pending actions by group.
-	 *
-	 * @since 3.0.0
-	 *
-	 * @param string $group Group slug.
-	 *
-	 * @return void
-	 */
-	public function cancel_actions_by_group( $group ) {
-		$action_ids = true;
-		while ( ! empty( $action_ids ) ) {
-			$action_ids = $this->query_actions(
-				array(
-					'group'    => $group,
-					'status'   => self::STATUS_PENDING,
-					'per_page' => 1000,
-					'orderby'  => 'action_id',
-				)
-			);
-
-			$this->bulk_cancel_actions( $action_ids );
-		}
-	}
-
-	/**
-	 * Cancel a set of action IDs.
-	 *
-	 * @since 3.0.0
-	 *
-	 * @param array $action_ids List of action IDs.
-	 *
-	 * @return void
-	 */
-	private function bulk_cancel_actions( $action_ids ) {
-		foreach ( $action_ids as $action_id ) {
-			$this->cancel_action( $action_id );
-		}
-
-		do_action( 'action_scheduler_bulk_cancel_actions', $action_ids );
-	}
-
-	/**
-	 * @return array
-	 */
-	public function get_status_labels() {
-		return array(
-			self::STATUS_COMPLETE => __( 'Complete', 'action-scheduler' ),
-			self::STATUS_PENDING  => __( 'Pending', 'action-scheduler' ),
-			self::STATUS_RUNNING  => __( 'In-progress', 'action-scheduler' ),
-			self::STATUS_FAILED   => __( 'Failed', 'action-scheduler' ),
-			self::STATUS_CANCELED => __( 'Canceled', 'action-scheduler' ),
-		);
-	}
-
-	/**
-	 * Check if there are any pending scheduled actions due to run.
-	 *
-	 * @param ActionScheduler_Action $action
-	 * @param DateTime               $scheduled_date (optional)
-	 * @return string
-	 */
-	public function has_pending_actions_due() {
-		$pending_actions = $this->query_actions(
-			array(
-				'date'    => as_get_datetime_object(),
-				'status'  => self::STATUS_PENDING,
-				'orderby' => 'none',
-			)
-		);
-
-		return ! empty( $pending_actions );
-	}
-
-	/**
-	 * Callable initialization function optionally overridden in derived classes.
-	 */
-	public function init() {}
-
-	/**
-	 * Callable function to mark an action as migrated optionally overridden in derived classes.
-	 */
-	public function mark_migrated( $action_id ) {}
-
-	/**
-	 * @return ActionScheduler_Store
-	 */
-	public static function instance() {
-		if ( empty( self::$store ) ) {
-			$class       = apply_filters( 'action_scheduler_store_class', self::DEFAULT_CLASS );
-			self::$store = new $class();
-		}
-		return self::$store;
-	}
+    const STATUS_COMPLETE = 'complete';
+    const STATUS_PENDING  = 'pending';
+    const STATUS_RUNNING  = 'in-progress';
+    const STATUS_FAILED   = 'failed';
+    const STATUS_CANCELED = 'canceled';
+    const DEFAULT_CLASS   = 'ActionScheduler_wpPostStore';
+
+    /** @var ActionScheduler_Store */
+    private static $store = null;
+
+    /** @var int */
+    protected static $max_args_length = 191;
+
+    /**
+     * @param ActionScheduler_Action $action
+     * @param DateTime               $scheduled_date Optional Date of the first instance
+     *                      to store. Otherwise uses the first date of the action's
+     *                      schedule.
+     *
+     * @return int The action ID
+     */
+    abstract public function save_action( ActionScheduler_Action $action, DateTime $scheduled_date = null );
+
+    /**
+     * @param string $action_id
+     *
+     * @return ActionScheduler_Action
+     */
+    abstract public function fetch_action( $action_id );
+
+    /**
+     * Find an action.
+     *
+     * Note: the query ordering changes based on the passed 'status' value.
+     *
+     * @param string $hook Action hook.
+     * @param array  $params Parameters of the action to find.
+     *
+     * @return string|null ID of the next action matching the criteria or NULL if not found.
+     */
+    public function find_action( $hook, $params = array() ) {
+        $params = wp_parse_args(
+            $params,
+            array(
+                'args'   => null,
+                'status' => self::STATUS_PENDING,
+                'group'  => '',
+            )
+        );
+
+        // These params are fixed for this method.
+        $params['hook']     = $hook;
+        $params['orderby']  = 'date';
+        $params['per_page'] = 1;
+
+        if ( ! empty( $params['status'] ) ) {
+            if ( self::STATUS_PENDING === $params['status'] ) {
+                $params['order'] = 'ASC'; // Find the next action that matches.
+            } else {
+                $params['order'] = 'DESC'; // Find the most recent action that matches.
+            }
+        }
+
+        $results = $this->query_actions( $params );
+
+        return empty( $results ) ? null : $results[0];
+    }
+
+    /**
+     * Query for action count or list of action IDs.
+     *
+     * @since 3.3.0 $query['status'] accepts array of statuses instead of a single status.
+     *
+     * @param array  $query {
+     *      Query filtering options.
+     *
+     *      @type string       $hook             The name of the actions. Optional.
+     *      @type string|array $status           The status or statuses of the actions. Optional.
+     *      @type array        $args             The args array of the actions. Optional.
+     *      @type DateTime     $date             The scheduled date of the action. Used in UTC timezone. Optional.
+     *      @type string       $date_compare     Operator for selecting by $date param. Accepted values are '!=', '>', '>=', '<', '<=', '='. Defaults to '<='.
+     *      @type DateTime     $modified         The last modified date of the action. Used in UTC timezone. Optional.
+     *      @type string       $modified_compare Operator for comparing $modified param. Accepted values are '!=', '>', '>=', '<', '<=', '='. Defaults to '<='.
+     *      @type string       $group            The group the action belongs to. Optional.
+     *      @type bool|int     $claimed          TRUE to find claimed actions, FALSE to find unclaimed actions, an int to find a specific claim ID. Optional.
+     *      @type int          $per_page         Number of results to return. Defaults to 5.
+     *      @type int          $offset           The query pagination offset. Defaults to 0.
+     *      @type int          $orderby          Accepted values are 'hook', 'group', 'modified', 'date' or 'none'. Defaults to 'date'.
+     *      @type string       $order            Accepted values are 'ASC' or 'DESC'. Defaults to 'ASC'.
+     * }
+     * @param string $query_type Whether to select or count the results. Default, select.
+     *
+     * @return string|array|null The IDs of actions matching the query. Null on failure.
+     */
+    abstract public function query_actions( $query = array(), $query_type = 'select' );
+
+    /**
+     * Run query to get a single action ID.
+     *
+     * @since 3.3.0
+     *
+     * @see ActionScheduler_Store::query_actions for $query arg usage but 'per_page' and 'offset' can't be used.
+     *
+     * @param array $query Query parameters.
+     *
+     * @return int|null
+     */
+    public function query_action( $query ) {
+        $query['per_page'] = 1;
+        $query['offset']   = 0;
+        $results           = $this->query_actions( $query );
+
+        if ( empty( $results ) ) {
+            return null;
+        } else {
+            return (int) $results[0];
+        }
+    }
+
+    /**
+     * Get a count of all actions in the store, grouped by status
+     *
+     * @return array
+     */
+    abstract public function action_counts();
+
+    /**
+     * Get additional action counts.
+     *
+     * - add past-due actions
+     *
+     * @return array
+     */
+    public function extra_action_counts() {
+        $extra_actions = array();
+
+        $pastdue_action_counts = (int) $this->query_actions(
+            array(
+                'status' => self::STATUS_PENDING,
+                'date'   => as_get_datetime_object(),
+            ),
+            'count'
+        );
+
+        if ( $pastdue_action_counts ) {
+            $extra_actions['past-due'] = $pastdue_action_counts;
+        }
+
+        /**
+         * Allows 3rd party code to add extra action counts (used in filters in the list table).
+         *
+         * @since 3.5.0
+         * @param $extra_actions array Array with format action_count_identifier => action count.
+         */
+        return apply_filters( 'action_scheduler_extra_action_counts', $extra_actions );
+    }
+
+    /**
+     * @param string $action_id
+     */
+    abstract public function cancel_action( $action_id );
+
+    /**
+     * @param string $action_id
+     */
+    abstract public function delete_action( $action_id );
+
+    /**
+     * @param string $action_id
+     *
+     * @return DateTime The date the action is schedule to run, or the date that it ran.
+     */
+    abstract public function get_date( $action_id );
+
+    /**
+     * @param int      $max_actions
+     * @param DateTime $before_date Claim only actions schedule before the given date. Defaults to now.
+     * @param array    $hooks       Claim only actions with a hook or hooks.
+     * @param string   $group       Claim only actions in the given group.
+     *
+     * @return ActionScheduler_ActionClaim
+     */
+    abstract public function stake_claim( $max_actions = 10, DateTime $before_date = null, $hooks = array(), $group = '' );
+
+    /**
+     * @return int
+     */
+    abstract public function get_claim_count();
+
+    /**
+     * @param ActionScheduler_ActionClaim $claim
+     */
+    abstract public function release_claim( ActionScheduler_ActionClaim $claim );
+
+    /**
+     * @param string $action_id
+     */
+    abstract public function unclaim_action( $action_id );
+
+    /**
+     * @param string $action_id
+     */
+    abstract public function mark_failure( $action_id );
+
+    /**
+     * @param string $action_id
+     */
+    abstract public function log_execution( $action_id );
+
+    /**
+     * @param string $action_id
+     */
+    abstract public function mark_complete( $action_id );
+
+    /**
+     * @param string $action_id
+     *
+     * @return string
+     */
+    abstract public function get_status( $action_id );
+
+    /**
+     * @param string $action_id
+     * @return mixed
+     */
+    abstract public function get_claim_id( $action_id );
+
+    /**
+     * @param string $claim_id
+     * @return array
+     */
+    abstract public function find_actions_by_claim_id( $claim_id );
+
+    /**
+     * @param string $comparison_operator
+     * @return string
+     */
+    protected function validate_sql_comparator( $comparison_operator ) {
+        if ( in_array( $comparison_operator, array( '!=', '>', '>=', '<', '<=', '=' ) ) ) {
+            return $comparison_operator;
+        }
+        return '=';
+    }
+
+    /**
+     * Get the time MySQL formated date/time string for an action's (next) scheduled date.
+     *
+     * @param ActionScheduler_Action $action
+     * @param DateTime               $scheduled_date (optional)
+     * @return string
+     */
+    protected function get_scheduled_date_string( ActionScheduler_Action $action, DateTime $scheduled_date = null ) {
+        $next = null === $scheduled_date ? $action->get_schedule()->get_date() : $scheduled_date;
+        if ( ! $next ) {
+            return '0000-00-00 00:00:00';
+        }
+        $next->setTimezone( new DateTimeZone( 'UTC' ) );
+
+        return $next->format( 'Y-m-d H:i:s' );
+    }
+
+    /**
+     * Get the time MySQL formated date/time string for an action's (next) scheduled date.
+     *
+     * @param ActionScheduler_Action $action
+     * @param DateTime               $scheduled_date (optional)
+     * @return string
+     */
+    protected function get_scheduled_date_string_local( ActionScheduler_Action $action, DateTime $scheduled_date = null ) {
+        $next = null === $scheduled_date ? $action->get_schedule()->get_date() : $scheduled_date;
+        if ( ! $next ) {
+            return '0000-00-00 00:00:00';
+        }
+
+        ActionScheduler_TimezoneHelper::set_local_timezone( $next );
+        return $next->format( 'Y-m-d H:i:s' );
+    }
+
+    /**
+     * Validate that we could decode action arguments.
+     *
+     * @param mixed $args      The decoded arguments.
+     * @param int   $action_id The action ID.
+     *
+     * @throws ActionScheduler_InvalidActionException When the decoded arguments are invalid.
+     */
+    protected function validate_args( $args, $action_id ) {
+        // Ensure we have an array of args.
+        if ( ! is_array( $args ) ) {
+            throw ActionScheduler_InvalidActionException::from_decoding_args( $action_id );
+        }
+
+        // Validate JSON decoding if possible.
+        if ( function_exists( 'json_last_error' ) && JSON_ERROR_NONE !== json_last_error() ) {
+            throw ActionScheduler_InvalidActionException::from_decoding_args( $action_id, $args );
+        }
+    }
+
+    /**
+     * Validate a ActionScheduler_Schedule object.
+     *
+     * @param mixed $schedule  The unserialized ActionScheduler_Schedule object.
+     * @param int   $action_id The action ID.
+     *
+     * @throws ActionScheduler_InvalidActionException When the schedule is invalid.
+     */
+    protected function validate_schedule( $schedule, $action_id ) {
+        if ( empty( $schedule ) || ! is_a( $schedule, 'ActionScheduler_Schedule' ) ) {
+            throw ActionScheduler_InvalidActionException::from_schedule( $action_id, $schedule );
+        }
+    }
+
+    /**
+     * InnoDB indexes have a maximum size of 767 bytes by default, which is only 191 characters with utf8mb4.
+     *
+     * Previously, AS wasn't concerned about args length, as we used the (unindex) post_content column. However,
+     * with custom tables, we use an indexed VARCHAR column instead.
+     *
+     * @param  ActionScheduler_Action $action Action to be validated.
+     * @throws InvalidArgumentException When json encoded args is too long.
+     */
+    protected function validate_action( ActionScheduler_Action $action ) {
+        if ( strlen( json_encode( $action->get_args() ) ) > static::$max_args_length ) {
+            throw new InvalidArgumentException( sprintf( __( 'ActionScheduler_Action::$args too long. To ensure the args column can be indexed, action args should not be more than %d characters when encoded as JSON.', 'action-scheduler' ), static::$max_args_length ) );
+        }
+    }
+
+    /**
+     * Cancel pending actions by hook.
+     *
+     * @since 3.0.0
+     *
+     * @param string $hook Hook name.
+     *
+     * @return void
+     */
+    public function cancel_actions_by_hook( $hook ) {
+        $action_ids = true;
+        while ( ! empty( $action_ids ) ) {
+            $action_ids = $this->query_actions(
+                array(
+                    'hook'     => $hook,
+                    'status'   => self::STATUS_PENDING,
+                    'per_page' => 1000,
+                    'orderby'  => 'action_id',
+                )
+            );
+
+            $this->bulk_cancel_actions( $action_ids );
+        }
+    }
+
+    /**
+     * Cancel pending actions by group.
+     *
+     * @since 3.0.0
+     *
+     * @param string $group Group slug.
+     *
+     * @return void
+     */
+    public function cancel_actions_by_group( $group ) {
+        $action_ids = true;
+        while ( ! empty( $action_ids ) ) {
+            $action_ids = $this->query_actions(
+                array(
+                    'group'    => $group,
+                    'status'   => self::STATUS_PENDING,
+                    'per_page' => 1000,
+                    'orderby'  => 'action_id',
+                )
+            );
+
+            $this->bulk_cancel_actions( $action_ids );
+        }
+    }
+
+    /**
+     * Cancel a set of action IDs.
+     *
+     * @since 3.0.0
+     *
+     * @param array $action_ids List of action IDs.
+     *
+     * @return void
+     */
+    private function bulk_cancel_actions( $action_ids ) {
+        foreach ( $action_ids as $action_id ) {
+            $this->cancel_action( $action_id );
+        }
+
+        do_action( 'action_scheduler_bulk_cancel_actions', $action_ids );
+    }
+
+    /**
+     * @return array
+     */
+    public function get_status_labels() {
+        return array(
+            self::STATUS_COMPLETE => __( 'Complete', 'action-scheduler' ),
+            self::STATUS_PENDING  => __( 'Pending', 'action-scheduler' ),
+            self::STATUS_RUNNING  => __( 'In-progress', 'action-scheduler' ),
+            self::STATUS_FAILED   => __( 'Failed', 'action-scheduler' ),
+            self::STATUS_CANCELED => __( 'Canceled', 'action-scheduler' ),
+        );
+    }
+
+    /**
+     * Check if there are any pending scheduled actions due to run.
+     *
+     * @param ActionScheduler_Action $action
+     * @param DateTime               $scheduled_date (optional)
+     * @return string
+     */
+    public function has_pending_actions_due() {
+        $pending_actions = $this->query_actions(
+            array(
+                'date'    => as_get_datetime_object(),
+                'status'  => self::STATUS_PENDING,
+                'orderby' => 'none',
+            )
+        );
+
+        return ! empty( $pending_actions );
+    }
+
+    /**
+     * Callable initialization function optionally overridden in derived classes.
+     */
+    public function init() {}
+
+    /**
+     * Callable function to mark an action as migrated optionally overridden in derived classes.
+     */
+    public function mark_migrated( $action_id ) {}
+
+    /**
+     * @return ActionScheduler_Store
+     */
+    public static function instance() {
+        if ( empty( self::$store ) ) {
+            $class       = apply_filters( 'action_scheduler_store_class', self::DEFAULT_CLASS );
+            self::$store = new $class();
+        }
+        return self::$store;
+    }
 }

Spacing +65 added lines, -65 removed lines

@@ -27,14 +27,14 @@ 
 	 *
 	 * @return int The action ID
 	 */
-	abstract public function save_action( ActionScheduler_Action $action, DateTime $scheduled_date = null );
+	abstract public function save_action(ActionScheduler_Action $action, DateTime $scheduled_date = null);
 
 	/**
 	 * @param string $action_id
 	 *
 	 * @return ActionScheduler_Action
 	 */
-	abstract public function fetch_action( $action_id );
+	abstract public function fetch_action($action_id);
 
 	/**
 	 * Find an action.
@@ -46,7 +46,7 @@ 
 	 *
 	 * @return string|null ID of the next action matching the criteria or NULL if not found.
 	 */
-	public function find_action( $hook, $params = array() ) {
+	public function find_action($hook, $params = array()) {
 		$params = wp_parse_args(
 			$params,
 			array(
@@ -61,17 +61,17 @@ 
 		$params['orderby']  = 'date';
 		$params['per_page'] = 1;
 
-		if ( ! empty( $params['status'] ) ) {
-			if ( self::STATUS_PENDING === $params['status'] ) {
+		if ( ! empty($params['status'])) {
+			if (self::STATUS_PENDING === $params['status']) {
 				$params['order'] = 'ASC'; // Find the next action that matches.
 			} else {
 				$params['order'] = 'DESC'; // Find the most recent action that matches.
 			}
 		}
 
-		$results = $this->query_actions( $params );
+		$results = $this->query_actions($params);
 
-		return empty( $results ) ? null : $results[0];
+		return empty($results) ? null : $results[0];
 	}
 
 	/**
@@ -100,7 +100,7 @@ 
 	 *
 	 * @return string|array|null The IDs of actions matching the query. Null on failure.
 	 */
-	abstract public function query_actions( $query = array(), $query_type = 'select' );
+	abstract public function query_actions($query = array(), $query_type = 'select');
 
 	/**
 	 * Run query to get a single action ID.
@@ -113,12 +113,12 @@ 
 	 *
 	 * @return int|null
 	 */
-	public function query_action( $query ) {
+	public function query_action($query) {
 		$query['per_page'] = 1;
 		$query['offset']   = 0;
-		$results           = $this->query_actions( $query );
+		$results           = $this->query_actions($query);
 
-		if ( empty( $results ) ) {
+		if (empty($results)) {
 			return null;
 		} else {
 			return (int) $results[0];
@@ -150,7 +150,7 @@ 
 			'count'
 		);
 
-		if ( $pastdue_action_counts ) {
+		if ($pastdue_action_counts) {
 			$extra_actions['past-due'] = $pastdue_action_counts;
 		}
 
@@ -160,25 +160,25 @@ 
 		 * @since 3.5.0
 		 * @param $extra_actions array Array with format action_count_identifier => action count.
 		 */
-		return apply_filters( 'action_scheduler_extra_action_counts', $extra_actions );
+		return apply_filters('action_scheduler_extra_action_counts', $extra_actions);
 	}
 
 	/**
 	 * @param string $action_id
 	 */
-	abstract public function cancel_action( $action_id );
+	abstract public function cancel_action($action_id);
 
 	/**
 	 * @param string $action_id
 	 */
-	abstract public function delete_action( $action_id );
+	abstract public function delete_action($action_id);
 
 	/**
 	 * @param string $action_id
 	 *
 	 * @return DateTime The date the action is schedule to run, or the date that it ran.
 	 */
-	abstract public function get_date( $action_id );
+	abstract public function get_date($action_id);
 
 	/**
 	 * @param int      $max_actions
@@ -188,7 +188,7 @@ 
 	 *
 	 * @return ActionScheduler_ActionClaim
 	 */
-	abstract public function stake_claim( $max_actions = 10, DateTime $before_date = null, $hooks = array(), $group = '' );
+	abstract public function stake_claim($max_actions = 10, DateTime $before_date = null, $hooks = array(), $group = '');
 
 	/**
 	 * @return int
@@ -198,53 +198,53 @@ 
 	/**
 	 * @param ActionScheduler_ActionClaim $claim
 	 */
-	abstract public function release_claim( ActionScheduler_ActionClaim $claim );
+	abstract public function release_claim(ActionScheduler_ActionClaim $claim);
 
 	/**
 	 * @param string $action_id
 	 */
-	abstract public function unclaim_action( $action_id );
+	abstract public function unclaim_action($action_id);
 
 	/**
 	 * @param string $action_id
 	 */
-	abstract public function mark_failure( $action_id );
+	abstract public function mark_failure($action_id);
 
 	/**
 	 * @param string $action_id
 	 */
-	abstract public function log_execution( $action_id );
+	abstract public function log_execution($action_id);
 
 	/**
 	 * @param string $action_id
 	 */
-	abstract public function mark_complete( $action_id );
+	abstract public function mark_complete($action_id);
 
 	/**
 	 * @param string $action_id
 	 *
 	 * @return string
 	 */
-	abstract public function get_status( $action_id );
+	abstract public function get_status($action_id);
 
 	/**
 	 * @param string $action_id
 	 * @return mixed
 	 */
-	abstract public function get_claim_id( $action_id );
+	abstract public function get_claim_id($action_id);
 
 	/**
 	 * @param string $claim_id
 	 * @return array
 	 */
-	abstract public function find_actions_by_claim_id( $claim_id );
+	abstract public function find_actions_by_claim_id($claim_id);
 
 	/**
 	 * @param string $comparison_operator
 	 * @return string
 	 */
-	protected function validate_sql_comparator( $comparison_operator ) {
-		if ( in_array( $comparison_operator, array( '!=', '>', '>=', '<', '<=', '=' ) ) ) {
+	protected function validate_sql_comparator($comparison_operator) {
+		if (in_array($comparison_operator, array('!=', '>', '>=', '<', '<=', '='))) {
 			return $comparison_operator;
 		}
 		return '=';
@@ -257,14 +257,14 @@ 
 	 * @param DateTime               $scheduled_date (optional)
 	 * @return string
 	 */
-	protected function get_scheduled_date_string( ActionScheduler_Action $action, DateTime $scheduled_date = null ) {
+	protected function get_scheduled_date_string(ActionScheduler_Action $action, DateTime $scheduled_date = null) {
 		$next = null === $scheduled_date ? $action->get_schedule()->get_date() : $scheduled_date;
-		if ( ! $next ) {
+		if ( ! $next) {
 			return '0000-00-00 00:00:00';
 		}
-		$next->setTimezone( new DateTimeZone( 'UTC' ) );
+		$next->setTimezone(new DateTimeZone('UTC'));
 
-		return $next->format( 'Y-m-d H:i:s' );
+		return $next->format('Y-m-d H:i:s');
 	}
 
 	/**
@@ -274,14 +274,14 @@ 
 	 * @param DateTime               $scheduled_date (optional)
 	 * @return string
 	 */
-	protected function get_scheduled_date_string_local( ActionScheduler_Action $action, DateTime $scheduled_date = null ) {
+	protected function get_scheduled_date_string_local(ActionScheduler_Action $action, DateTime $scheduled_date = null) {
 		$next = null === $scheduled_date ? $action->get_schedule()->get_date() : $scheduled_date;
-		if ( ! $next ) {
+		if ( ! $next) {
 			return '0000-00-00 00:00:00';
 		}
 
-		ActionScheduler_TimezoneHelper::set_local_timezone( $next );
-		return $next->format( 'Y-m-d H:i:s' );
+		ActionScheduler_TimezoneHelper::set_local_timezone($next);
+		return $next->format('Y-m-d H:i:s');
 	}
 
 	/**
@@ -292,15 +292,15 @@ 
 	 *
 	 * @throws ActionScheduler_InvalidActionException When the decoded arguments are invalid.
 	 */
-	protected function validate_args( $args, $action_id ) {
+	protected function validate_args($args, $action_id) {
 		// Ensure we have an array of args.
-		if ( ! is_array( $args ) ) {
-			throw ActionScheduler_InvalidActionException::from_decoding_args( $action_id );
+		if ( ! is_array($args)) {
+			throw ActionScheduler_InvalidActionException::from_decoding_args($action_id);
 		}
 
 		// Validate JSON decoding if possible.
-		if ( function_exists( 'json_last_error' ) && JSON_ERROR_NONE !== json_last_error() ) {
-			throw ActionScheduler_InvalidActionException::from_decoding_args( $action_id, $args );
+		if (function_exists('json_last_error') && JSON_ERROR_NONE !== json_last_error()) {
+			throw ActionScheduler_InvalidActionException::from_decoding_args($action_id, $args);
 		}
 	}
 
@@ -312,9 +312,9 @@ 
 	 *
 	 * @throws ActionScheduler_InvalidActionException When the schedule is invalid.
 	 */
-	protected function validate_schedule( $schedule, $action_id ) {
-		if ( empty( $schedule ) || ! is_a( $schedule, 'ActionScheduler_Schedule' ) ) {
-			throw ActionScheduler_InvalidActionException::from_schedule( $action_id, $schedule );
+	protected function validate_schedule($schedule, $action_id) {
+		if (empty($schedule) || ! is_a($schedule, 'ActionScheduler_Schedule')) {
+			throw ActionScheduler_InvalidActionException::from_schedule($action_id, $schedule);
 		}
 	}
 
@@ -327,9 +327,9 @@ 
 	 * @param  ActionScheduler_Action $action Action to be validated.
 	 * @throws InvalidArgumentException When json encoded args is too long.
 	 */
-	protected function validate_action( ActionScheduler_Action $action ) {
-		if ( strlen( json_encode( $action->get_args() ) ) > static::$max_args_length ) {
-			throw new InvalidArgumentException( sprintf( __( 'ActionScheduler_Action::$args too long. To ensure the args column can be indexed, action args should not be more than %d characters when encoded as JSON.', 'action-scheduler' ), static::$max_args_length ) );
+	protected function validate_action(ActionScheduler_Action $action) {
+		if (strlen(json_encode($action->get_args())) > static::$max_args_length) {
+			throw new InvalidArgumentException(sprintf(__('ActionScheduler_Action::$args too long. To ensure the args column can be indexed, action args should not be more than %d characters when encoded as JSON.', 'action-scheduler'), static::$max_args_length));
 		}
 	}
 
@@ -342,9 +342,9 @@ 
 	 *
 	 * @return void
 	 */
-	public function cancel_actions_by_hook( $hook ) {
+	public function cancel_actions_by_hook($hook) {
 		$action_ids = true;
-		while ( ! empty( $action_ids ) ) {
+		while ( ! empty($action_ids)) {
 			$action_ids = $this->query_actions(
 				array(
 					'hook'     => $hook,
@@ -354,7 +354,7 @@ 
 				)
 			);
 
-			$this->bulk_cancel_actions( $action_ids );
+			$this->bulk_cancel_actions($action_ids);
 		}
 	}
 
@@ -367,9 +367,9 @@ 
 	 *
 	 * @return void
 	 */
-	public function cancel_actions_by_group( $group ) {
+	public function cancel_actions_by_group($group) {
 		$action_ids = true;
-		while ( ! empty( $action_ids ) ) {
+		while ( ! empty($action_ids)) {
 			$action_ids = $this->query_actions(
 				array(
 					'group'    => $group,
@@ -379,7 +379,7 @@ 
 				)
 			);
 
-			$this->bulk_cancel_actions( $action_ids );
+			$this->bulk_cancel_actions($action_ids);
 		}
 	}
 
@@ -392,12 +392,12 @@ 
 	 *
 	 * @return void
 	 */
-	private function bulk_cancel_actions( $action_ids ) {
-		foreach ( $action_ids as $action_id ) {
-			$this->cancel_action( $action_id );
+	private function bulk_cancel_actions($action_ids) {
+		foreach ($action_ids as $action_id) {
+			$this->cancel_action($action_id);
 		}
 
-		do_action( 'action_scheduler_bulk_cancel_actions', $action_ids );
+		do_action('action_scheduler_bulk_cancel_actions', $action_ids);
 	}
 
 	/**
@@ -405,11 +405,11 @@ 
 	 */
 	public function get_status_labels() {
 		return array(
-			self::STATUS_COMPLETE => __( 'Complete', 'action-scheduler' ),
-			self::STATUS_PENDING  => __( 'Pending', 'action-scheduler' ),
-			self::STATUS_RUNNING  => __( 'In-progress', 'action-scheduler' ),
-			self::STATUS_FAILED   => __( 'Failed', 'action-scheduler' ),
-			self::STATUS_CANCELED => __( 'Canceled', 'action-scheduler' ),
+			self::STATUS_COMPLETE => __('Complete', 'action-scheduler'),
+			self::STATUS_PENDING  => __('Pending', 'action-scheduler'),
+			self::STATUS_RUNNING  => __('In-progress', 'action-scheduler'),
+			self::STATUS_FAILED   => __('Failed', 'action-scheduler'),
+			self::STATUS_CANCELED => __('Canceled', 'action-scheduler'),
 		);
 	}
 
@@ -429,7 +429,7 @@ 
 			)
 		);
 
-		return ! empty( $pending_actions );
+		return ! empty($pending_actions);
 	}
 
 	/**
@@ -440,14 +440,14 @@ 
 	/**
 	 * Callable function to mark an action as migrated optionally overridden in derived classes.
 	 */
-	public function mark_migrated( $action_id ) {}
+	public function mark_migrated($action_id) {}
 
 	/**
 	 * @return ActionScheduler_Store
 	 */
 	public static function instance() {
-		if ( empty( self::$store ) ) {
-			$class       = apply_filters( 'action_scheduler_store_class', self::DEFAULT_CLASS );
+		if (empty(self::$store)) {
+			$class       = apply_filters('action_scheduler_store_class', self::DEFAULT_CLASS);
 			self::$store = new $class();
 		}
 		return self::$store;

src/libraries/action-scheduler/classes/ActionScheduler_ListTable.php

Indentation +650 added lines, -650 removed lines

@@ -7,654 +7,654 @@
  */
 class ActionScheduler_ListTable extends ActionScheduler_Abstract_ListTable {
 
-	/**
-	 * The package name.
-	 *
-	 * @var string
-	 */
-	protected $package = 'action-scheduler';
-
-	/**
-	 * Columns to show (name => label).
-	 *
-	 * @var array
-	 */
-	protected $columns = array();
-
-	/**
-	 * Actions (name => label).
-	 *
-	 * @var array
-	 */
-	protected $row_actions = array();
-
-	/**
-	 * The active data stores
-	 *
-	 * @var ActionScheduler_Store
-	 */
-	protected $store;
-
-	/**
-	 * A logger to use for getting action logs to display
-	 *
-	 * @var ActionScheduler_Logger
-	 */
-	protected $logger;
-
-	/**
-	 * A ActionScheduler_QueueRunner runner instance (or child class)
-	 *
-	 * @var ActionScheduler_QueueRunner
-	 */
-	protected $runner;
-
-	/**
-	 * Bulk actions. The key of the array is the method name of the implementation:
-	 *
-	 *     bulk_<key>(array $ids, string $sql_in).
-	 *
-	 * See the comments in the parent class for further details
-	 *
-	 * @var array
-	 */
-	protected $bulk_actions = array();
-
-	/**
-	 * Flag variable to render our notifications, if any, once.
-	 *
-	 * @var bool
-	 */
-	protected static $did_notification = false;
-
-	/**
-	 * Array of seconds for common time periods, like week or month, alongside an internationalised string representation, i.e. "Day" or "Days"
-	 *
-	 * @var array
-	 */
-	private static $time_periods;
-
-	/**
-	 * Sets the current data store object into `store->action` and initialises the object.
-	 *
-	 * @param ActionScheduler_Store       $store
-	 * @param ActionScheduler_Logger      $logger
-	 * @param ActionScheduler_QueueRunner $runner
-	 */
-	public function __construct( ActionScheduler_Store $store, ActionScheduler_Logger $logger, ActionScheduler_QueueRunner $runner ) {
-
-		$this->store  = $store;
-		$this->logger = $logger;
-		$this->runner = $runner;
-
-		$this->table_header = __( 'Scheduled Actions', 'action-scheduler' );
-
-		$this->bulk_actions = array(
-			'delete' => __( 'Delete', 'action-scheduler' ),
-		);
-
-		$this->columns = array(
-			'hook'        => __( 'Hook', 'action-scheduler' ),
-			'status'      => __( 'Status', 'action-scheduler' ),
-			'args'        => __( 'Arguments', 'action-scheduler' ),
-			'group'       => __( 'Group', 'action-scheduler' ),
-			'recurrence'  => __( 'Recurrence', 'action-scheduler' ),
-			'schedule'    => __( 'Scheduled Date', 'action-scheduler' ),
-			'log_entries' => __( 'Log', 'action-scheduler' ),
-		);
-
-		$this->sort_by = array(
-			'schedule',
-			'hook',
-			'group',
-		);
-
-		$this->search_by = array(
-			'hook',
-			'args',
-			'claim_id',
-		);
-
-		$request_status = $this->get_request_status();
-
-		if ( empty( $request_status ) ) {
-			$this->sort_by[] = 'status';
-		} elseif ( in_array( $request_status, array( 'in-progress', 'failed' ) ) ) {
-			$this->columns  += array( 'claim_id' => __( 'Claim ID', 'action-scheduler' ) );
-			$this->sort_by[] = 'claim_id';
-		}
-
-		$this->row_actions = array(
-			'hook' => array(
-				'run'    => array(
-					'name' => __( 'Run', 'action-scheduler' ),
-					'desc' => __( 'Process the action now as if it were run as part of a queue', 'action-scheduler' ),
-				),
-				'cancel' => array(
-					'name'  => __( 'Cancel', 'action-scheduler' ),
-					'desc'  => __( 'Cancel the action now to avoid it being run in future', 'action-scheduler' ),
-					'class' => 'cancel trash',
-				),
-			),
-		);
-
-		self::$time_periods = array(
-			array(
-				'seconds' => YEAR_IN_SECONDS,
-				/* translators: %s: amount of time */
-				'names'   => _n_noop( '%s year', '%s years', 'action-scheduler' ),
-			),
-			array(
-				'seconds' => MONTH_IN_SECONDS,
-				/* translators: %s: amount of time */
-				'names'   => _n_noop( '%s month', '%s months', 'action-scheduler' ),
-			),
-			array(
-				'seconds' => WEEK_IN_SECONDS,
-				/* translators: %s: amount of time */
-				'names'   => _n_noop( '%s week', '%s weeks', 'action-scheduler' ),
-			),
-			array(
-				'seconds' => DAY_IN_SECONDS,
-				/* translators: %s: amount of time */
-				'names'   => _n_noop( '%s day', '%s days', 'action-scheduler' ),
-			),
-			array(
-				'seconds' => HOUR_IN_SECONDS,
-				/* translators: %s: amount of time */
-				'names'   => _n_noop( '%s hour', '%s hours', 'action-scheduler' ),
-			),
-			array(
-				'seconds' => MINUTE_IN_SECONDS,
-				/* translators: %s: amount of time */
-				'names'   => _n_noop( '%s minute', '%s minutes', 'action-scheduler' ),
-			),
-			array(
-				'seconds' => 1,
-				/* translators: %s: amount of time */
-				'names'   => _n_noop( '%s second', '%s seconds', 'action-scheduler' ),
-			),
-		);
-
-		parent::__construct(
-			array(
-				'singular' => 'action-scheduler',
-				'plural'   => 'action-scheduler',
-				'ajax'     => false,
-			)
-		);
-
-		add_screen_option(
-			'per_page',
-			array(
-				'default' => $this->items_per_page,
-			)
-		);
-
-		add_filter( 'set_screen_option_' . $this->get_per_page_option_name(), array( $this, 'set_items_per_page_option' ), 10, 3 );
-		set_screen_options();
-	}
-
-	/**
-	 * Handles setting the items_per_page option for this screen.
-	 *
-	 * @param mixed  $status Default false (to skip saving the current option).
-	 * @param string $option Screen option name.
-	 * @param int    $value  Screen option value.
-	 * @return int
-	 */
-	public function set_items_per_page_option( $status, $option, $value ) {
-		return $value;
-	}
-	/**
-	 * Convert an interval of seconds into a two part human friendly string.
-	 *
-	 * The WordPress human_time_diff() function only calculates the time difference to one degree, meaning
-	 * even if an action is 1 day and 11 hours away, it will display "1 day". This function goes one step
-	 * further to display two degrees of accuracy.
-	 *
-	 * Inspired by the Crontrol::interval() function by Edward Dale: https://wordpress.org/plugins/wp-crontrol/
-	 *
-	 * @param int $interval A interval in seconds.
-	 * @param int $periods_to_include Depth of time periods to include, e.g. for an interval of 70, and $periods_to_include of 2, both minutes and seconds would be included. With a value of 1, only minutes would be included.
-	 * @return string A human friendly string representation of the interval.
-	 */
-	private static function human_interval( $interval, $periods_to_include = 2 ) {
-
-		if ( $interval <= 0 ) {
-			return __( 'Now!', 'action-scheduler' );
-		}
-
-		$output = '';
-
-		for ( $time_period_index = 0, $periods_included = 0, $seconds_remaining = $interval; $time_period_index < count( self::$time_periods ) && $seconds_remaining > 0 && $periods_included < $periods_to_include; $time_period_index++ ) {
-
-			$periods_in_interval = floor( $seconds_remaining / self::$time_periods[ $time_period_index ]['seconds'] );
-
-			if ( $periods_in_interval > 0 ) {
-				if ( ! empty( $output ) ) {
-					$output .= ' ';
-				}
-				$output            .= sprintf( _n( self::$time_periods[ $time_period_index ]['names'][0], self::$time_periods[ $time_period_index ]['names'][1], $periods_in_interval, 'action-scheduler' ), $periods_in_interval );
-				$seconds_remaining -= $periods_in_interval * self::$time_periods[ $time_period_index ]['seconds'];
-				$periods_included++;
-			}
-		}
-
-		return $output;
-	}
-
-	/**
-	 * Returns the recurrence of an action or 'Non-repeating'. The output is human readable.
-	 *
-	 * @param ActionScheduler_Action $action
-	 *
-	 * @return string
-	 */
-	protected function get_recurrence( $action ) {
-		$schedule = $action->get_schedule();
-		if ( $schedule->is_recurring() ) {
-			$recurrence = $schedule->get_recurrence();
-
-			if ( is_numeric( $recurrence ) ) {
-				/* translators: %s: time interval */
-				return sprintf( __( 'Every %s', 'action-scheduler' ), self::human_interval( $recurrence ) );
-			} else {
-				return $recurrence;
-			}
-		}
-
-		return __( 'Non-repeating', 'action-scheduler' );
-	}
-
-	/**
-	 * Serializes the argument of an action to render it in a human friendly format.
-	 *
-	 * @param array $row The array representation of the current row of the table
-	 *
-	 * @return string
-	 */
-	public function column_args( array $row ) {
-		if ( empty( $row['args'] ) ) {
-			return apply_filters( 'action_scheduler_list_table_column_args', '', $row );
-		}
-
-		$row_html = '<ul>';
-		foreach ( $row['args'] as $key => $value ) {
-			$row_html .= sprintf( '<li><code>%s => %s</code></li>', esc_html( var_export( $key, true ) ), esc_html( var_export( $value, true ) ) );
-		}
-		$row_html .= '</ul>';
-
-		return apply_filters( 'action_scheduler_list_table_column_args', $row_html, $row );
-	}
-
-	/**
-	 * Prints the logs entries inline. We do so to avoid loading Javascript and other hacks to show it in a modal.
-	 *
-	 * @param array $row Action array.
-	 * @return string
-	 */
-	public function column_log_entries( array $row ) {
-
-		$log_entries_html = '<ol>';
-
-		$timezone = new DateTimezone( 'UTC' );
-
-		foreach ( $row['log_entries'] as $log_entry ) {
-			$log_entries_html .= $this->get_log_entry_html( $log_entry, $timezone );
-		}
-
-		$log_entries_html .= '</ol>';
-
-		return $log_entries_html;
-	}
-
-	/**
-	 * Prints the logs entries inline. We do so to avoid loading Javascript and other hacks to show it in a modal.
-	 *
-	 * @param ActionScheduler_LogEntry $log_entry
-	 * @param DateTimezone             $timezone
-	 * @return string
-	 */
-	protected function get_log_entry_html( ActionScheduler_LogEntry $log_entry, DateTimezone $timezone ) {
-		$date = $log_entry->get_date();
-		$date->setTimezone( $timezone );
-		return sprintf( '<li><strong>%s</strong><br/>%s</li>', esc_html( $date->format( 'Y-m-d H:i:s O' ) ), esc_html( $log_entry->get_message() ) );
-	}
-
-	/**
-	 * Only display row actions for pending actions.
-	 *
-	 * @param array  $row         Row to render
-	 * @param string $column_name Current row
-	 *
-	 * @return string
-	 */
-	protected function maybe_render_actions( $row, $column_name ) {
-		if ( 'pending' === strtolower( $row['status_name'] ) ) {
-			return parent::maybe_render_actions( $row, $column_name );
-		}
-
-		return '';
-	}
-
-	/**
-	 * Renders admin notifications
-	 *
-	 * Notifications:
-	 *  1. When the maximum number of tasks are being executed simultaneously.
-	 *  2. Notifications when a task is manually executed.
-	 *  3. Tables are missing.
-	 */
-	public function display_admin_notices() {
-		global $wpdb;
-
-		if ( ( is_a( $this->store, 'ActionScheduler_HybridStore' ) || is_a( $this->store, 'ActionScheduler_DBStore' ) ) && apply_filters( 'action_scheduler_enable_recreate_data_store', true ) ) {
-			$table_list = array(
-				'actionscheduler_actions',
-				'actionscheduler_logs',
-				'actionscheduler_groups',
-				'actionscheduler_claims',
-			);
-
-			$found_tables = $wpdb->get_col( "SHOW TABLES LIKE '{$wpdb->prefix}actionscheduler%'" ); // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-			foreach ( $table_list as $table_name ) {
-				if ( ! in_array( $wpdb->prefix . $table_name, $found_tables ) ) {
-					$this->admin_notices[] = array(
-						'class'   => 'error',
-						'message' => __( 'It appears one or more database tables were missing. Attempting to re-create the missing table(s).', 'action-scheduler' ),
-					);
-					$this->recreate_tables();
-					parent::display_admin_notices();
-
-					return;
-				}
-			}
-		}
-
-		if ( $this->runner->has_maximum_concurrent_batches() ) {
-			$claim_count           = $this->store->get_claim_count();
-			$this->admin_notices[] = array(
-				'class'   => 'updated',
-				'message' => sprintf(
-					/* translators: %s: amount of claims */
-					_n(
-						'Maximum simultaneous queues already in progress (%s queue). No additional queues will begin processing until the current queues are complete.',
-						'Maximum simultaneous queues already in progress (%s queues). No additional queues will begin processing until the current queues are complete.',
-						$claim_count,
-						'action-scheduler'
-					),
-					$claim_count
-				),
-			);
-		} elseif ( $this->store->has_pending_actions_due() ) {
-
-			$async_request_lock_expiration = ActionScheduler::lock()->get_expiration( 'async-request-runner' );
-
-			// No lock set or lock expired
-			if ( false === $async_request_lock_expiration || $async_request_lock_expiration < time() ) {
-				$in_progress_url = add_query_arg( 'status', 'in-progress', remove_query_arg( 'status' ) );
-				/* translators: %s: process URL */
-				$async_request_message = sprintf( __( 'A new queue has begun processing. <a href="%s">View actions in-progress &raquo;</a>', 'action-scheduler' ), esc_url( $in_progress_url ) );
-			} else {
-				/* translators: %d: seconds */
-				$async_request_message = sprintf( __( 'The next queue will begin processing in approximately %d seconds.', 'action-scheduler' ), $async_request_lock_expiration - time() );
-			}
-
-			$this->admin_notices[] = array(
-				'class'   => 'notice notice-info',
-				'message' => $async_request_message,
-			);
-		}
-
-		$notification = get_transient( 'action_scheduler_admin_notice' );
-
-		if ( is_array( $notification ) ) {
-			delete_transient( 'action_scheduler_admin_notice' );
-
-			$action           = $this->store->fetch_action( $notification['action_id'] );
-			$action_hook_html = '<strong><code>' . $action->get_hook() . '</code></strong>';
-			if ( 1 == $notification['success'] ) {
-				$class = 'updated';
-				switch ( $notification['row_action_type'] ) {
-					case 'run':
-						/* translators: %s: action HTML */
-						$action_message_html = sprintf( __( 'Successfully executed action: %s', 'action-scheduler' ), $action_hook_html );
-						break;
-					case 'cancel':
-						/* translators: %s: action HTML */
-						$action_message_html = sprintf( __( 'Successfully canceled action: %s', 'action-scheduler' ), $action_hook_html );
-						break;
-					default:
-						/* translators: %s: action HTML */
-						$action_message_html = sprintf( __( 'Successfully processed change for action: %s', 'action-scheduler' ), $action_hook_html );
-						break;
-				}
-			} else {
-				$class = 'error';
-				/* translators: 1: action HTML 2: action ID 3: error message */
-				$action_message_html = sprintf( __( 'Could not process change for action: "%1$s" (ID: %2$d). Error: %3$s', 'action-scheduler' ), $action_hook_html, esc_html( $notification['action_id'] ), esc_html( $notification['error_message'] ) );
-			}
-
-			$action_message_html = apply_filters( 'action_scheduler_admin_notice_html', $action_message_html, $action, $notification );
-
-			$this->admin_notices[] = array(
-				'class'   => $class,
-				'message' => $action_message_html,
-			);
-		}
-
-		parent::display_admin_notices();
-	}
-
-	/**
-	 * Prints the scheduled date in a human friendly format.
-	 *
-	 * @param array $row The array representation of the current row of the table
-	 *
-	 * @return string
-	 */
-	public function column_schedule( $row ) {
-		return $this->get_schedule_display_string( $row['schedule'] );
-	}
-
-	/**
-	 * Get the scheduled date in a human friendly format.
-	 *
-	 * @param ActionScheduler_Schedule $schedule
-	 * @return string
-	 */
-	protected function get_schedule_display_string( ActionScheduler_Schedule $schedule ) {
-
-		$schedule_display_string = '';
-
-		if ( is_a( $schedule, 'ActionScheduler_NullSchedule' ) ) {
-			return __( 'async', 'action-scheduler' );
-		}
-
-		if ( ! $schedule->get_date() ) {
-			return '0000-00-00 00:00:00';
-		}
-
-		$next_timestamp = $schedule->get_date()->getTimestamp();
-
-		$schedule_display_string .= $schedule->get_date()->format( 'Y-m-d H:i:s O' );
-		$schedule_display_string .= '<br/>';
-
-		if ( gmdate( 'U' ) > $next_timestamp ) {
-			/* translators: %s: date interval */
-			$schedule_display_string .= sprintf( __( ' (%s ago)', 'action-scheduler' ), self::human_interval( gmdate( 'U' ) - $next_timestamp ) );
-		} else {
-			/* translators: %s: date interval */
-			$schedule_display_string .= sprintf( __( ' (%s)', 'action-scheduler' ), self::human_interval( $next_timestamp - gmdate( 'U' ) ) );
-		}
-
-		return $schedule_display_string;
-	}
-
-	/**
-	 * Bulk delete
-	 *
-	 * Deletes actions based on their ID. This is the handler for the bulk delete. It assumes the data
-	 * properly validated by the callee and it will delete the actions without any extra validation.
-	 *
-	 * @param array  $ids
-	 * @param string $ids_sql Inherited and unused
-	 */
-	protected function bulk_delete( array $ids, $ids_sql ) {
-		foreach ( $ids as $id ) {
-			$this->store->delete_action( $id );
-		}
-	}
-
-	/**
-	 * Implements the logic behind running an action. ActionScheduler_Abstract_ListTable validates the request and their
-	 * parameters are valid.
-	 *
-	 * @param int $action_id
-	 */
-	protected function row_action_cancel( $action_id ) {
-		$this->process_row_action( $action_id, 'cancel' );
-	}
-
-	/**
-	 * Implements the logic behind running an action. ActionScheduler_Abstract_ListTable validates the request and their
-	 * parameters are valid.
-	 *
-	 * @param int $action_id
-	 */
-	protected function row_action_run( $action_id ) {
-		$this->process_row_action( $action_id, 'run' );
-	}
-
-	/**
-	 * Force the data store schema updates.
-	 */
-	protected function recreate_tables() {
-		if ( is_a( $this->store, 'ActionScheduler_HybridStore' ) ) {
-			$store = $this->store;
-		} else {
-			$store = new ActionScheduler_HybridStore();
-		}
-		add_action( 'action_scheduler/created_table', array( $store, 'set_autoincrement' ), 10, 2 );
-
-		$store_schema  = new ActionScheduler_StoreSchema();
-		$logger_schema = new ActionScheduler_LoggerSchema();
-		$store_schema->register_tables( true );
-		$logger_schema->register_tables( true );
-
-		remove_action( 'action_scheduler/created_table', array( $store, 'set_autoincrement' ), 10 );
-	}
-	/**
-	 * Implements the logic behind processing an action once an action link is clicked on the list table.
-	 *
-	 * @param int    $action_id
-	 * @param string $row_action_type The type of action to perform on the action.
-	 */
-	protected function process_row_action( $action_id, $row_action_type ) {
-		try {
-			switch ( $row_action_type ) {
-				case 'run':
-					$this->runner->process_action( $action_id, 'Admin List Table' );
-					break;
-				case 'cancel':
-					$this->store->cancel_action( $action_id );
-					break;
-			}
-			$success       = 1;
-			$error_message = '';
-		} catch ( Exception $e ) {
-			$success       = 0;
-			$error_message = $e->getMessage();
-		}
-
-		set_transient( 'action_scheduler_admin_notice', compact( 'action_id', 'success', 'error_message', 'row_action_type' ), 30 );
-	}
-
-	/**
-	 * {@inheritDoc}
-	 */
-	public function prepare_items() {
-		$this->prepare_column_headers();
-
-		$per_page = $this->get_items_per_page( $this->get_per_page_option_name(), $this->items_per_page );
-
-		$query = array(
-			'per_page' => $per_page,
-			'offset'   => $this->get_items_offset(),
-			'status'   => $this->get_request_status(),
-			'orderby'  => $this->get_request_orderby(),
-			'order'    => $this->get_request_order(),
-			'search'   => $this->get_request_search_query(),
-		);
-
-		/**
-		 * Change query arguments to query for past-due actions.
-		 * Past-due actions have the 'pending' status and are in the past.
-		 * This is needed because registering 'past-due' as a status is overkill.
-		 */
-		if ( 'past-due' === $this->get_request_status() ) {
-			$query['status'] = ActionScheduler_Store::STATUS_PENDING;
-			$query['date']   = as_get_datetime_object();
-		}
-
-		$this->items = array();
-
-		$total_items = $this->store->query_actions( $query, 'count' );
-
-		$status_labels = $this->store->get_status_labels();
-
-		foreach ( $this->store->query_actions( $query ) as $action_id ) {
-			try {
-				$action = $this->store->fetch_action( $action_id );
-			} catch ( Exception $e ) {
-				continue;
-			}
-			if ( is_a( $action, 'ActionScheduler_NullAction' ) ) {
-				continue;
-			}
-			$this->items[ $action_id ] = array(
-				'ID'          => $action_id,
-				'hook'        => $action->get_hook(),
-				'status_name' => $this->store->get_status( $action_id ),
-				'status'      => $status_labels[ $this->store->get_status( $action_id ) ],
-				'args'        => $action->get_args(),
-				'group'       => $action->get_group(),
-				'log_entries' => $this->logger->get_logs( $action_id ),
-				'claim_id'    => $this->store->get_claim_id( $action_id ),
-				'recurrence'  => $this->get_recurrence( $action ),
-				'schedule'    => $action->get_schedule(),
-			);
-		}
-
-		$this->set_pagination_args(
-			array(
-				'total_items' => $total_items,
-				'per_page'    => $per_page,
-				'total_pages' => ceil( $total_items / $per_page ),
-			)
-		);
-	}
-
-	/**
-	 * Prints the available statuses so the user can click to filter.
-	 */
-	protected function display_filter_by_status() {
-		$this->status_counts = $this->store->action_counts() + $this->store->extra_action_counts();
-		parent::display_filter_by_status();
-	}
-
-	/**
-	 * Get the text to display in the search box on the list table.
-	 */
-	protected function get_search_box_button_text() {
-		return __( 'Search hook, args and claim ID', 'action-scheduler' );
-	}
-
-	/**
-	 * {@inheritDoc}
-	 */
-	protected function get_per_page_option_name() {
-		return str_replace( '-', '_', $this->screen->id ) . '_per_page';
-	}
+    /**
+     * The package name.
+     *
+     * @var string
+     */
+    protected $package = 'action-scheduler';
+
+    /**
+     * Columns to show (name => label).
+     *
+     * @var array
+     */
+    protected $columns = array();
+
+    /**
+     * Actions (name => label).
+     *
+     * @var array
+     */
+    protected $row_actions = array();
+
+    /**
+     * The active data stores
+     *
+     * @var ActionScheduler_Store
+     */
+    protected $store;
+
+    /**
+     * A logger to use for getting action logs to display
+     *
+     * @var ActionScheduler_Logger
+     */
+    protected $logger;
+
+    /**
+     * A ActionScheduler_QueueRunner runner instance (or child class)
+     *
+     * @var ActionScheduler_QueueRunner
+     */
+    protected $runner;
+
+    /**
+     * Bulk actions. The key of the array is the method name of the implementation:
+     *
+     *     bulk_<key>(array $ids, string $sql_in).
+     *
+     * See the comments in the parent class for further details
+     *
+     * @var array
+     */
+    protected $bulk_actions = array();
+
+    /**
+     * Flag variable to render our notifications, if any, once.
+     *
+     * @var bool
+     */
+    protected static $did_notification = false;
+
+    /**
+     * Array of seconds for common time periods, like week or month, alongside an internationalised string representation, i.e. "Day" or "Days"
+     *
+     * @var array
+     */
+    private static $time_periods;
+
+    /**
+     * Sets the current data store object into `store->action` and initialises the object.
+     *
+     * @param ActionScheduler_Store       $store
+     * @param ActionScheduler_Logger      $logger
+     * @param ActionScheduler_QueueRunner $runner
+     */
+    public function __construct( ActionScheduler_Store $store, ActionScheduler_Logger $logger, ActionScheduler_QueueRunner $runner ) {
+
+        $this->store  = $store;
+        $this->logger = $logger;
+        $this->runner = $runner;
+
+        $this->table_header = __( 'Scheduled Actions', 'action-scheduler' );
+
+        $this->bulk_actions = array(
+            'delete' => __( 'Delete', 'action-scheduler' ),
+        );
+
+        $this->columns = array(
+            'hook'        => __( 'Hook', 'action-scheduler' ),
+            'status'      => __( 'Status', 'action-scheduler' ),
+            'args'        => __( 'Arguments', 'action-scheduler' ),
+            'group'       => __( 'Group', 'action-scheduler' ),
+            'recurrence'  => __( 'Recurrence', 'action-scheduler' ),
+            'schedule'    => __( 'Scheduled Date', 'action-scheduler' ),
+            'log_entries' => __( 'Log', 'action-scheduler' ),
+        );
+
+        $this->sort_by = array(
+            'schedule',
+            'hook',
+            'group',
+        );
+
+        $this->search_by = array(
+            'hook',
+            'args',
+            'claim_id',
+        );
+
+        $request_status = $this->get_request_status();
+
+        if ( empty( $request_status ) ) {
+            $this->sort_by[] = 'status';
+        } elseif ( in_array( $request_status, array( 'in-progress', 'failed' ) ) ) {
+            $this->columns  += array( 'claim_id' => __( 'Claim ID', 'action-scheduler' ) );
+            $this->sort_by[] = 'claim_id';
+        }
+
+        $this->row_actions = array(
+            'hook' => array(
+                'run'    => array(
+                    'name' => __( 'Run', 'action-scheduler' ),
+                    'desc' => __( 'Process the action now as if it were run as part of a queue', 'action-scheduler' ),
+                ),
+                'cancel' => array(
+                    'name'  => __( 'Cancel', 'action-scheduler' ),
+                    'desc'  => __( 'Cancel the action now to avoid it being run in future', 'action-scheduler' ),
+                    'class' => 'cancel trash',
+                ),
+            ),
+        );
+
+        self::$time_periods = array(
+            array(
+                'seconds' => YEAR_IN_SECONDS,
+                /* translators: %s: amount of time */
+                'names'   => _n_noop( '%s year', '%s years', 'action-scheduler' ),
+            ),
+            array(
+                'seconds' => MONTH_IN_SECONDS,
+                /* translators: %s: amount of time */
+                'names'   => _n_noop( '%s month', '%s months', 'action-scheduler' ),
+            ),
+            array(
+                'seconds' => WEEK_IN_SECONDS,
+                /* translators: %s: amount of time */
+                'names'   => _n_noop( '%s week', '%s weeks', 'action-scheduler' ),
+            ),
+            array(
+                'seconds' => DAY_IN_SECONDS,
+                /* translators: %s: amount of time */
+                'names'   => _n_noop( '%s day', '%s days', 'action-scheduler' ),
+            ),
+            array(
+                'seconds' => HOUR_IN_SECONDS,
+                /* translators: %s: amount of time */
+                'names'   => _n_noop( '%s hour', '%s hours', 'action-scheduler' ),
+            ),
+            array(
+                'seconds' => MINUTE_IN_SECONDS,
+                /* translators: %s: amount of time */
+                'names'   => _n_noop( '%s minute', '%s minutes', 'action-scheduler' ),
+            ),
+            array(
+                'seconds' => 1,
+                /* translators: %s: amount of time */
+                'names'   => _n_noop( '%s second', '%s seconds', 'action-scheduler' ),
+            ),
+        );
+
+        parent::__construct(
+            array(
+                'singular' => 'action-scheduler',
+                'plural'   => 'action-scheduler',
+                'ajax'     => false,
+            )
+        );
+
+        add_screen_option(
+            'per_page',
+            array(
+                'default' => $this->items_per_page,
+            )
+        );
+
+        add_filter( 'set_screen_option_' . $this->get_per_page_option_name(), array( $this, 'set_items_per_page_option' ), 10, 3 );
+        set_screen_options();
+    }
+
+    /**
+     * Handles setting the items_per_page option for this screen.
+     *
+     * @param mixed  $status Default false (to skip saving the current option).
+     * @param string $option Screen option name.
+     * @param int    $value  Screen option value.
+     * @return int
+     */
+    public function set_items_per_page_option( $status, $option, $value ) {
+        return $value;
+    }
+    /**
+     * Convert an interval of seconds into a two part human friendly string.
+     *
+     * The WordPress human_time_diff() function only calculates the time difference to one degree, meaning
+     * even if an action is 1 day and 11 hours away, it will display "1 day". This function goes one step
+     * further to display two degrees of accuracy.
+     *
+     * Inspired by the Crontrol::interval() function by Edward Dale: https://wordpress.org/plugins/wp-crontrol/
+     *
+     * @param int $interval A interval in seconds.
+     * @param int $periods_to_include Depth of time periods to include, e.g. for an interval of 70, and $periods_to_include of 2, both minutes and seconds would be included. With a value of 1, only minutes would be included.
+     * @return string A human friendly string representation of the interval.
+     */
+    private static function human_interval( $interval, $periods_to_include = 2 ) {
+
+        if ( $interval <= 0 ) {
+            return __( 'Now!', 'action-scheduler' );
+        }
+
+        $output = '';
+
+        for ( $time_period_index = 0, $periods_included = 0, $seconds_remaining = $interval; $time_period_index < count( self::$time_periods ) && $seconds_remaining > 0 && $periods_included < $periods_to_include; $time_period_index++ ) {
+
+            $periods_in_interval = floor( $seconds_remaining / self::$time_periods[ $time_period_index ]['seconds'] );
+
+            if ( $periods_in_interval > 0 ) {
+                if ( ! empty( $output ) ) {
+                    $output .= ' ';
+                }
+                $output            .= sprintf( _n( self::$time_periods[ $time_period_index ]['names'][0], self::$time_periods[ $time_period_index ]['names'][1], $periods_in_interval, 'action-scheduler' ), $periods_in_interval );
+                $seconds_remaining -= $periods_in_interval * self::$time_periods[ $time_period_index ]['seconds'];
+                $periods_included++;
+            }
+        }
+
+        return $output;
+    }
+
+    /**
+     * Returns the recurrence of an action or 'Non-repeating'. The output is human readable.
+     *
+     * @param ActionScheduler_Action $action
+     *
+     * @return string
+     */
+    protected function get_recurrence( $action ) {
+        $schedule = $action->get_schedule();
+        if ( $schedule->is_recurring() ) {
+            $recurrence = $schedule->get_recurrence();
+
+            if ( is_numeric( $recurrence ) ) {
+                /* translators: %s: time interval */
+                return sprintf( __( 'Every %s', 'action-scheduler' ), self::human_interval( $recurrence ) );
+            } else {
+                return $recurrence;
+            }
+        }
+
+        return __( 'Non-repeating', 'action-scheduler' );
+    }
+
+    /**
+     * Serializes the argument of an action to render it in a human friendly format.
+     *
+     * @param array $row The array representation of the current row of the table
+     *
+     * @return string
+     */
+    public function column_args( array $row ) {
+        if ( empty( $row['args'] ) ) {
+            return apply_filters( 'action_scheduler_list_table_column_args', '', $row );
+        }
+
+        $row_html = '<ul>';
+        foreach ( $row['args'] as $key => $value ) {
+            $row_html .= sprintf( '<li><code>%s => %s</code></li>', esc_html( var_export( $key, true ) ), esc_html( var_export( $value, true ) ) );
+        }
+        $row_html .= '</ul>';
+
+        return apply_filters( 'action_scheduler_list_table_column_args', $row_html, $row );
+    }
+
+    /**
+     * Prints the logs entries inline. We do so to avoid loading Javascript and other hacks to show it in a modal.
+     *
+     * @param array $row Action array.
+     * @return string
+     */
+    public function column_log_entries( array $row ) {
+
+        $log_entries_html = '<ol>';
+
+        $timezone = new DateTimezone( 'UTC' );
+
+        foreach ( $row['log_entries'] as $log_entry ) {
+            $log_entries_html .= $this->get_log_entry_html( $log_entry, $timezone );
+        }
+
+        $log_entries_html .= '</ol>';
+
+        return $log_entries_html;
+    }
+
+    /**
+     * Prints the logs entries inline. We do so to avoid loading Javascript and other hacks to show it in a modal.
+     *
+     * @param ActionScheduler_LogEntry $log_entry
+     * @param DateTimezone             $timezone
+     * @return string
+     */
+    protected function get_log_entry_html( ActionScheduler_LogEntry $log_entry, DateTimezone $timezone ) {
+        $date = $log_entry->get_date();
+        $date->setTimezone( $timezone );
+        return sprintf( '<li><strong>%s</strong><br/>%s</li>', esc_html( $date->format( 'Y-m-d H:i:s O' ) ), esc_html( $log_entry->get_message() ) );
+    }
+
+    /**
+     * Only display row actions for pending actions.
+     *
+     * @param array  $row         Row to render
+     * @param string $column_name Current row
+     *
+     * @return string
+     */
+    protected function maybe_render_actions( $row, $column_name ) {
+        if ( 'pending' === strtolower( $row['status_name'] ) ) {
+            return parent::maybe_render_actions( $row, $column_name );
+        }
+
+        return '';
+    }
+
+    /**
+     * Renders admin notifications
+     *
+     * Notifications:
+     *  1. When the maximum number of tasks are being executed simultaneously.
+     *  2. Notifications when a task is manually executed.
+     *  3. Tables are missing.
+     */
+    public function display_admin_notices() {
+        global $wpdb;
+
+        if ( ( is_a( $this->store, 'ActionScheduler_HybridStore' ) || is_a( $this->store, 'ActionScheduler_DBStore' ) ) && apply_filters( 'action_scheduler_enable_recreate_data_store', true ) ) {
+            $table_list = array(
+                'actionscheduler_actions',
+                'actionscheduler_logs',
+                'actionscheduler_groups',
+                'actionscheduler_claims',
+            );
+
+            $found_tables = $wpdb->get_col( "SHOW TABLES LIKE '{$wpdb->prefix}actionscheduler%'" ); // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
+            foreach ( $table_list as $table_name ) {
+                if ( ! in_array( $wpdb->prefix . $table_name, $found_tables ) ) {
+                    $this->admin_notices[] = array(
+                        'class'   => 'error',
+                        'message' => __( 'It appears one or more database tables were missing. Attempting to re-create the missing table(s).', 'action-scheduler' ),
+                    );
+                    $this->recreate_tables();
+                    parent::display_admin_notices();
+
+                    return;
+                }
+            }
+        }
+
+        if ( $this->runner->has_maximum_concurrent_batches() ) {
+            $claim_count           = $this->store->get_claim_count();
+            $this->admin_notices[] = array(
+                'class'   => 'updated',
+                'message' => sprintf(
+                    /* translators: %s: amount of claims */
+                    _n(
+                        'Maximum simultaneous queues already in progress (%s queue). No additional queues will begin processing until the current queues are complete.',
+                        'Maximum simultaneous queues already in progress (%s queues). No additional queues will begin processing until the current queues are complete.',
+                        $claim_count,
+                        'action-scheduler'
+                    ),
+                    $claim_count
+                ),
+            );
+        } elseif ( $this->store->has_pending_actions_due() ) {
+
+            $async_request_lock_expiration = ActionScheduler::lock()->get_expiration( 'async-request-runner' );
+
+            // No lock set or lock expired
+            if ( false === $async_request_lock_expiration || $async_request_lock_expiration < time() ) {
+                $in_progress_url = add_query_arg( 'status', 'in-progress', remove_query_arg( 'status' ) );
+                /* translators: %s: process URL */
+                $async_request_message = sprintf( __( 'A new queue has begun processing. <a href="%s">View actions in-progress &raquo;</a>', 'action-scheduler' ), esc_url( $in_progress_url ) );
+            } else {
+                /* translators: %d: seconds */
+                $async_request_message = sprintf( __( 'The next queue will begin processing in approximately %d seconds.', 'action-scheduler' ), $async_request_lock_expiration - time() );
+            }
+
+            $this->admin_notices[] = array(
+                'class'   => 'notice notice-info',
+                'message' => $async_request_message,
+            );
+        }
+
+        $notification = get_transient( 'action_scheduler_admin_notice' );
+
+        if ( is_array( $notification ) ) {
+            delete_transient( 'action_scheduler_admin_notice' );
+
+            $action           = $this->store->fetch_action( $notification['action_id'] );
+            $action_hook_html = '<strong><code>' . $action->get_hook() . '</code></strong>';
+            if ( 1 == $notification['success'] ) {
+                $class = 'updated';
+                switch ( $notification['row_action_type'] ) {
+                    case 'run':
+                        /* translators: %s: action HTML */
+                        $action_message_html = sprintf( __( 'Successfully executed action: %s', 'action-scheduler' ), $action_hook_html );
+                        break;
+                    case 'cancel':
+                        /* translators: %s: action HTML */
+                        $action_message_html = sprintf( __( 'Successfully canceled action: %s', 'action-scheduler' ), $action_hook_html );
+                        break;
+                    default:
+                        /* translators: %s: action HTML */
+                        $action_message_html = sprintf( __( 'Successfully processed change for action: %s', 'action-scheduler' ), $action_hook_html );
+                        break;
+                }
+            } else {
+                $class = 'error';
+                /* translators: 1: action HTML 2: action ID 3: error message */
+                $action_message_html = sprintf( __( 'Could not process change for action: "%1$s" (ID: %2$d). Error: %3$s', 'action-scheduler' ), $action_hook_html, esc_html( $notification['action_id'] ), esc_html( $notification['error_message'] ) );
+            }
+
+            $action_message_html = apply_filters( 'action_scheduler_admin_notice_html', $action_message_html, $action, $notification );
+
+            $this->admin_notices[] = array(
+                'class'   => $class,
+                'message' => $action_message_html,
+            );
+        }
+
+        parent::display_admin_notices();
+    }
+
+    /**
+     * Prints the scheduled date in a human friendly format.
+     *
+     * @param array $row The array representation of the current row of the table
+     *
+     * @return string
+     */
+    public function column_schedule( $row ) {
+        return $this->get_schedule_display_string( $row['schedule'] );
+    }
+
+    /**
+     * Get the scheduled date in a human friendly format.
+     *
+     * @param ActionScheduler_Schedule $schedule
+     * @return string
+     */
+    protected function get_schedule_display_string( ActionScheduler_Schedule $schedule ) {
+
+        $schedule_display_string = '';
+
+        if ( is_a( $schedule, 'ActionScheduler_NullSchedule' ) ) {
+            return __( 'async', 'action-scheduler' );
+        }
+
+        if ( ! $schedule->get_date() ) {
+            return '0000-00-00 00:00:00';
+        }
+
+        $next_timestamp = $schedule->get_date()->getTimestamp();
+
+        $schedule_display_string .= $schedule->get_date()->format( 'Y-m-d H:i:s O' );
+        $schedule_display_string .= '<br/>';
+
+        if ( gmdate( 'U' ) > $next_timestamp ) {
+            /* translators: %s: date interval */
+            $schedule_display_string .= sprintf( __( ' (%s ago)', 'action-scheduler' ), self::human_interval( gmdate( 'U' ) - $next_timestamp ) );
+        } else {
+            /* translators: %s: date interval */
+            $schedule_display_string .= sprintf( __( ' (%s)', 'action-scheduler' ), self::human_interval( $next_timestamp - gmdate( 'U' ) ) );
+        }
+
+        return $schedule_display_string;
+    }
+
+    /**
+     * Bulk delete
+     *
+     * Deletes actions based on their ID. This is the handler for the bulk delete. It assumes the data
+     * properly validated by the callee and it will delete the actions without any extra validation.
+     *
+     * @param array  $ids
+     * @param string $ids_sql Inherited and unused
+     */
+    protected function bulk_delete( array $ids, $ids_sql ) {
+        foreach ( $ids as $id ) {
+            $this->store->delete_action( $id );
+        }
+    }
+
+    /**
+     * Implements the logic behind running an action. ActionScheduler_Abstract_ListTable validates the request and their
+     * parameters are valid.
+     *
+     * @param int $action_id
+     */
+    protected function row_action_cancel( $action_id ) {
+        $this->process_row_action( $action_id, 'cancel' );
+    }
+
+    /**
+     * Implements the logic behind running an action. ActionScheduler_Abstract_ListTable validates the request and their
+     * parameters are valid.
+     *
+     * @param int $action_id
+     */
+    protected function row_action_run( $action_id ) {
+        $this->process_row_action( $action_id, 'run' );
+    }
+
+    /**
+     * Force the data store schema updates.
+     */
+    protected function recreate_tables() {
+        if ( is_a( $this->store, 'ActionScheduler_HybridStore' ) ) {
+            $store = $this->store;
+        } else {
+            $store = new ActionScheduler_HybridStore();
+        }
+        add_action( 'action_scheduler/created_table', array( $store, 'set_autoincrement' ), 10, 2 );
+
+        $store_schema  = new ActionScheduler_StoreSchema();
+        $logger_schema = new ActionScheduler_LoggerSchema();
+        $store_schema->register_tables( true );
+        $logger_schema->register_tables( true );
+
+        remove_action( 'action_scheduler/created_table', array( $store, 'set_autoincrement' ), 10 );
+    }
+    /**
+     * Implements the logic behind processing an action once an action link is clicked on the list table.
+     *
+     * @param int    $action_id
+     * @param string $row_action_type The type of action to perform on the action.
+     */
+    protected function process_row_action( $action_id, $row_action_type ) {
+        try {
+            switch ( $row_action_type ) {
+                case 'run':
+                    $this->runner->process_action( $action_id, 'Admin List Table' );
+                    break;
+                case 'cancel':
+                    $this->store->cancel_action( $action_id );
+                    break;
+            }
+            $success       = 1;
+            $error_message = '';
+        } catch ( Exception $e ) {
+            $success       = 0;
+            $error_message = $e->getMessage();
+        }
+
+        set_transient( 'action_scheduler_admin_notice', compact( 'action_id', 'success', 'error_message', 'row_action_type' ), 30 );
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    public function prepare_items() {
+        $this->prepare_column_headers();
+
+        $per_page = $this->get_items_per_page( $this->get_per_page_option_name(), $this->items_per_page );
+
+        $query = array(
+            'per_page' => $per_page,
+            'offset'   => $this->get_items_offset(),
+            'status'   => $this->get_request_status(),
+            'orderby'  => $this->get_request_orderby(),
+            'order'    => $this->get_request_order(),
+            'search'   => $this->get_request_search_query(),
+        );
+
+        /**
+         * Change query arguments to query for past-due actions.
+         * Past-due actions have the 'pending' status and are in the past.
+         * This is needed because registering 'past-due' as a status is overkill.
+         */
+        if ( 'past-due' === $this->get_request_status() ) {
+            $query['status'] = ActionScheduler_Store::STATUS_PENDING;
+            $query['date']   = as_get_datetime_object();
+        }
+
+        $this->items = array();
+
+        $total_items = $this->store->query_actions( $query, 'count' );
+
+        $status_labels = $this->store->get_status_labels();
+
+        foreach ( $this->store->query_actions( $query ) as $action_id ) {
+            try {
+                $action = $this->store->fetch_action( $action_id );
+            } catch ( Exception $e ) {
+                continue;
+            }
+            if ( is_a( $action, 'ActionScheduler_NullAction' ) ) {
+                continue;
+            }
+            $this->items[ $action_id ] = array(
+                'ID'          => $action_id,
+                'hook'        => $action->get_hook(),
+                'status_name' => $this->store->get_status( $action_id ),
+                'status'      => $status_labels[ $this->store->get_status( $action_id ) ],
+                'args'        => $action->get_args(),
+                'group'       => $action->get_group(),
+                'log_entries' => $this->logger->get_logs( $action_id ),
+                'claim_id'    => $this->store->get_claim_id( $action_id ),
+                'recurrence'  => $this->get_recurrence( $action ),
+                'schedule'    => $action->get_schedule(),
+            );
+        }
+
+        $this->set_pagination_args(
+            array(
+                'total_items' => $total_items,
+                'per_page'    => $per_page,
+                'total_pages' => ceil( $total_items / $per_page ),
+            )
+        );
+    }
+
+    /**
+     * Prints the available statuses so the user can click to filter.
+     */
+    protected function display_filter_by_status() {
+        $this->status_counts = $this->store->action_counts() + $this->store->extra_action_counts();
+        parent::display_filter_by_status();
+    }
+
+    /**
+     * Get the text to display in the search box on the list table.
+     */
+    protected function get_search_box_button_text() {
+        return __( 'Search hook, args and claim ID', 'action-scheduler' );
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    protected function get_per_page_option_name() {
+        return str_replace( '-', '_', $this->screen->id ) . '_per_page';
+    }
 }

Spacing +124 added lines, -124 removed lines

@@ -81,26 +81,26 @@ 
 	 * @param ActionScheduler_Logger      $logger
 	 * @param ActionScheduler_QueueRunner $runner
 	 */
-	public function __construct( ActionScheduler_Store $store, ActionScheduler_Logger $logger, ActionScheduler_QueueRunner $runner ) {
+	public function __construct(ActionScheduler_Store $store, ActionScheduler_Logger $logger, ActionScheduler_QueueRunner $runner) {
 
 		$this->store  = $store;
 		$this->logger = $logger;
 		$this->runner = $runner;
 
-		$this->table_header = __( 'Scheduled Actions', 'action-scheduler' );
+		$this->table_header = __('Scheduled Actions', 'action-scheduler');
 
 		$this->bulk_actions = array(
-			'delete' => __( 'Delete', 'action-scheduler' ),
+			'delete' => __('Delete', 'action-scheduler'),
 		);
 
 		$this->columns = array(
-			'hook'        => __( 'Hook', 'action-scheduler' ),
-			'status'      => __( 'Status', 'action-scheduler' ),
-			'args'        => __( 'Arguments', 'action-scheduler' ),
-			'group'       => __( 'Group', 'action-scheduler' ),
-			'recurrence'  => __( 'Recurrence', 'action-scheduler' ),
-			'schedule'    => __( 'Scheduled Date', 'action-scheduler' ),
-			'log_entries' => __( 'Log', 'action-scheduler' ),
+			'hook'        => __('Hook', 'action-scheduler'),
+			'status'      => __('Status', 'action-scheduler'),
+			'args'        => __('Arguments', 'action-scheduler'),
+			'group'       => __('Group', 'action-scheduler'),
+			'recurrence'  => __('Recurrence', 'action-scheduler'),
+			'schedule'    => __('Scheduled Date', 'action-scheduler'),
+			'log_entries' => __('Log', 'action-scheduler'),
 		);
 
 		$this->sort_by = array(
@@ -117,22 +117,22 @@ 
 
 		$request_status = $this->get_request_status();
 
-		if ( empty( $request_status ) ) {
+		if (empty($request_status)) {
 			$this->sort_by[] = 'status';
-		} elseif ( in_array( $request_status, array( 'in-progress', 'failed' ) ) ) {
-			$this->columns  += array( 'claim_id' => __( 'Claim ID', 'action-scheduler' ) );
+		} elseif (in_array($request_status, array('in-progress', 'failed'))) {
+			$this->columns  += array('claim_id' => __('Claim ID', 'action-scheduler'));
 			$this->sort_by[] = 'claim_id';
 		}
 
 		$this->row_actions = array(
 			'hook' => array(
 				'run'    => array(
-					'name' => __( 'Run', 'action-scheduler' ),
-					'desc' => __( 'Process the action now as if it were run as part of a queue', 'action-scheduler' ),
+					'name' => __('Run', 'action-scheduler'),
+					'desc' => __('Process the action now as if it were run as part of a queue', 'action-scheduler'),
 				),
 				'cancel' => array(
-					'name'  => __( 'Cancel', 'action-scheduler' ),
-					'desc'  => __( 'Cancel the action now to avoid it being run in future', 'action-scheduler' ),
+					'name'  => __('Cancel', 'action-scheduler'),
+					'desc'  => __('Cancel the action now to avoid it being run in future', 'action-scheduler'),
 					'class' => 'cancel trash',
 				),
 			),
@@ -142,37 +142,37 @@ 
 			array(
 				'seconds' => YEAR_IN_SECONDS,
 				/* translators: %s: amount of time */
-				'names'   => _n_noop( '%s year', '%s years', 'action-scheduler' ),
+				'names'   => _n_noop('%s year', '%s years', 'action-scheduler'),
 			),
 			array(
 				'seconds' => MONTH_IN_SECONDS,
 				/* translators: %s: amount of time */
-				'names'   => _n_noop( '%s month', '%s months', 'action-scheduler' ),
+				'names'   => _n_noop('%s month', '%s months', 'action-scheduler'),
 			),
 			array(
 				'seconds' => WEEK_IN_SECONDS,
 				/* translators: %s: amount of time */
-				'names'   => _n_noop( '%s week', '%s weeks', 'action-scheduler' ),
+				'names'   => _n_noop('%s week', '%s weeks', 'action-scheduler'),
 			),
 			array(
 				'seconds' => DAY_IN_SECONDS,
 				/* translators: %s: amount of time */
-				'names'   => _n_noop( '%s day', '%s days', 'action-scheduler' ),
+				'names'   => _n_noop('%s day', '%s days', 'action-scheduler'),
 			),
 			array(
 				'seconds' => HOUR_IN_SECONDS,
 				/* translators: %s: amount of time */
-				'names'   => _n_noop( '%s hour', '%s hours', 'action-scheduler' ),
+				'names'   => _n_noop('%s hour', '%s hours', 'action-scheduler'),
 			),
 			array(
 				'seconds' => MINUTE_IN_SECONDS,
 				/* translators: %s: amount of time */
-				'names'   => _n_noop( '%s minute', '%s minutes', 'action-scheduler' ),
+				'names'   => _n_noop('%s minute', '%s minutes', 'action-scheduler'),
 			),
 			array(
 				'seconds' => 1,
 				/* translators: %s: amount of time */
-				'names'   => _n_noop( '%s second', '%s seconds', 'action-scheduler' ),
+				'names'   => _n_noop('%s second', '%s seconds', 'action-scheduler'),
 			),
 		);
 
@@ -191,7 +191,7 @@ 
 			)
 		);
 
-		add_filter( 'set_screen_option_' . $this->get_per_page_option_name(), array( $this, 'set_items_per_page_option' ), 10, 3 );
+		add_filter('set_screen_option_'.$this->get_per_page_option_name(), array($this, 'set_items_per_page_option'), 10, 3);
 		set_screen_options();
 	}
 
@@ -203,7 +203,7 @@ 
 	 * @param int    $value  Screen option value.
 	 * @return int
 	 */
-	public function set_items_per_page_option( $status, $option, $value ) {
+	public function set_items_per_page_option($status, $option, $value) {
 		return $value;
 	}
 	/**
@@ -219,24 +219,24 @@ 
 	 * @param int $periods_to_include Depth of time periods to include, e.g. for an interval of 70, and $periods_to_include of 2, both minutes and seconds would be included. With a value of 1, only minutes would be included.
 	 * @return string A human friendly string representation of the interval.
 	 */
-	private static function human_interval( $interval, $periods_to_include = 2 ) {
+	private static function human_interval($interval, $periods_to_include = 2) {
 
-		if ( $interval <= 0 ) {
-			return __( 'Now!', 'action-scheduler' );
+		if ($interval <= 0) {
+			return __('Now!', 'action-scheduler');
 		}
 
 		$output = '';
 
-		for ( $time_period_index = 0, $periods_included = 0, $seconds_remaining = $interval; $time_period_index < count( self::$time_periods ) && $seconds_remaining > 0 && $periods_included < $periods_to_include; $time_period_index++ ) {
+		for ($time_period_index = 0, $periods_included = 0, $seconds_remaining = $interval; $time_period_index < count(self::$time_periods) && $seconds_remaining > 0 && $periods_included < $periods_to_include; $time_period_index++) {
 
-			$periods_in_interval = floor( $seconds_remaining / self::$time_periods[ $time_period_index ]['seconds'] );
+			$periods_in_interval = floor($seconds_remaining / self::$time_periods[$time_period_index]['seconds']);
 
-			if ( $periods_in_interval > 0 ) {
-				if ( ! empty( $output ) ) {
+			if ($periods_in_interval > 0) {
+				if ( ! empty($output)) {
 					$output .= ' ';
 				}
-				$output            .= sprintf( _n( self::$time_periods[ $time_period_index ]['names'][0], self::$time_periods[ $time_period_index ]['names'][1], $periods_in_interval, 'action-scheduler' ), $periods_in_interval );
-				$seconds_remaining -= $periods_in_interval * self::$time_periods[ $time_period_index ]['seconds'];
+				$output            .= sprintf(_n(self::$time_periods[$time_period_index]['names'][0], self::$time_periods[$time_period_index]['names'][1], $periods_in_interval, 'action-scheduler'), $periods_in_interval);
+				$seconds_remaining -= $periods_in_interval * self::$time_periods[$time_period_index]['seconds'];
 				$periods_included++;
 			}
 		}
@@ -251,20 +251,20 @@ 
 	 *
 	 * @return string
 	 */
-	protected function get_recurrence( $action ) {
+	protected function get_recurrence($action) {
 		$schedule = $action->get_schedule();
-		if ( $schedule->is_recurring() ) {
+		if ($schedule->is_recurring()) {
 			$recurrence = $schedule->get_recurrence();
 
-			if ( is_numeric( $recurrence ) ) {
+			if (is_numeric($recurrence)) {
 				/* translators: %s: time interval */
-				return sprintf( __( 'Every %s', 'action-scheduler' ), self::human_interval( $recurrence ) );
+				return sprintf(__('Every %s', 'action-scheduler'), self::human_interval($recurrence));
 			} else {
 				return $recurrence;
 			}
 		}
 
-		return __( 'Non-repeating', 'action-scheduler' );
+		return __('Non-repeating', 'action-scheduler');
 	}
 
 	/**
@@ -274,18 +274,18 @@ 
 	 *
 	 * @return string
 	 */
-	public function column_args( array $row ) {
-		if ( empty( $row['args'] ) ) {
-			return apply_filters( 'action_scheduler_list_table_column_args', '', $row );
+	public function column_args(array $row) {
+		if (empty($row['args'])) {
+			return apply_filters('action_scheduler_list_table_column_args', '', $row);
 		}
 
 		$row_html = '<ul>';
-		foreach ( $row['args'] as $key => $value ) {
-			$row_html .= sprintf( '<li><code>%s => %s</code></li>', esc_html( var_export( $key, true ) ), esc_html( var_export( $value, true ) ) );
+		foreach ($row['args'] as $key => $value) {
+			$row_html .= sprintf('<li><code>%s => %s</code></li>', esc_html(var_export($key, true)), esc_html(var_export($value, true)));
 		}
 		$row_html .= '</ul>';
 
-		return apply_filters( 'action_scheduler_list_table_column_args', $row_html, $row );
+		return apply_filters('action_scheduler_list_table_column_args', $row_html, $row);
 	}
 
 	/**
@@ -294,14 +294,14 @@ 
 	 * @param array $row Action array.
 	 * @return string
 	 */
-	public function column_log_entries( array $row ) {
+	public function column_log_entries(array $row) {
 
 		$log_entries_html = '<ol>';
 
-		$timezone = new DateTimezone( 'UTC' );
+		$timezone = new DateTimezone('UTC');
 
-		foreach ( $row['log_entries'] as $log_entry ) {
-			$log_entries_html .= $this->get_log_entry_html( $log_entry, $timezone );
+		foreach ($row['log_entries'] as $log_entry) {
+			$log_entries_html .= $this->get_log_entry_html($log_entry, $timezone);
 		}
 
 		$log_entries_html .= '</ol>';
@@ -316,10 +316,10 @@ 
 	 * @param DateTimezone             $timezone
 	 * @return string
 	 */
-	protected function get_log_entry_html( ActionScheduler_LogEntry $log_entry, DateTimezone $timezone ) {
+	protected function get_log_entry_html(ActionScheduler_LogEntry $log_entry, DateTimezone $timezone) {
 		$date = $log_entry->get_date();
-		$date->setTimezone( $timezone );
-		return sprintf( '<li><strong>%s</strong><br/>%s</li>', esc_html( $date->format( 'Y-m-d H:i:s O' ) ), esc_html( $log_entry->get_message() ) );
+		$date->setTimezone($timezone);
+		return sprintf('<li><strong>%s</strong><br/>%s</li>', esc_html($date->format('Y-m-d H:i:s O')), esc_html($log_entry->get_message()));
 	}
 
 	/**
@@ -330,9 +330,9 @@ 
 	 *
 	 * @return string
 	 */
-	protected function maybe_render_actions( $row, $column_name ) {
-		if ( 'pending' === strtolower( $row['status_name'] ) ) {
-			return parent::maybe_render_actions( $row, $column_name );
+	protected function maybe_render_actions($row, $column_name) {
+		if ('pending' === strtolower($row['status_name'])) {
+			return parent::maybe_render_actions($row, $column_name);
 		}
 
 		return '';
@@ -349,7 +349,7 @@ 
 	public function display_admin_notices() {
 		global $wpdb;
 
-		if ( ( is_a( $this->store, 'ActionScheduler_HybridStore' ) || is_a( $this->store, 'ActionScheduler_DBStore' ) ) && apply_filters( 'action_scheduler_enable_recreate_data_store', true ) ) {
+		if ((is_a($this->store, 'ActionScheduler_HybridStore') || is_a($this->store, 'ActionScheduler_DBStore')) && apply_filters('action_scheduler_enable_recreate_data_store', true)) {
 			$table_list = array(
 				'actionscheduler_actions',
 				'actionscheduler_logs',
@@ -357,12 +357,12 @@ 
 				'actionscheduler_claims',
 			);
 
-			$found_tables = $wpdb->get_col( "SHOW TABLES LIKE '{$wpdb->prefix}actionscheduler%'" ); // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-			foreach ( $table_list as $table_name ) {
-				if ( ! in_array( $wpdb->prefix . $table_name, $found_tables ) ) {
+			$found_tables = $wpdb->get_col("SHOW TABLES LIKE '{$wpdb->prefix}actionscheduler%'"); // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
+			foreach ($table_list as $table_name) {
+				if ( ! in_array($wpdb->prefix.$table_name, $found_tables)) {
 					$this->admin_notices[] = array(
 						'class'   => 'error',
-						'message' => __( 'It appears one or more database tables were missing. Attempting to re-create the missing table(s).', 'action-scheduler' ),
+						'message' => __('It appears one or more database tables were missing. Attempting to re-create the missing table(s).', 'action-scheduler'),
 					);
 					$this->recreate_tables();
 					parent::display_admin_notices();
@@ -372,7 +372,7 @@ 
 			}
 		}
 
-		if ( $this->runner->has_maximum_concurrent_batches() ) {
+		if ($this->runner->has_maximum_concurrent_batches()) {
 			$claim_count           = $this->store->get_claim_count();
 			$this->admin_notices[] = array(
 				'class'   => 'updated',
@@ -387,18 +387,18 @@ 
 					$claim_count
 				),
 			);
-		} elseif ( $this->store->has_pending_actions_due() ) {
+		} elseif ($this->store->has_pending_actions_due()) {
 
-			$async_request_lock_expiration = ActionScheduler::lock()->get_expiration( 'async-request-runner' );
+			$async_request_lock_expiration = ActionScheduler::lock()->get_expiration('async-request-runner');
 
 			// No lock set or lock expired
-			if ( false === $async_request_lock_expiration || $async_request_lock_expiration < time() ) {
-				$in_progress_url = add_query_arg( 'status', 'in-progress', remove_query_arg( 'status' ) );
+			if (false === $async_request_lock_expiration || $async_request_lock_expiration < time()) {
+				$in_progress_url = add_query_arg('status', 'in-progress', remove_query_arg('status'));
 				/* translators: %s: process URL */
-				$async_request_message = sprintf( __( 'A new queue has begun processing. <a href="%s">View actions in-progress &raquo;</a>', 'action-scheduler' ), esc_url( $in_progress_url ) );
+				$async_request_message = sprintf(__('A new queue has begun processing. <a href="%s">View actions in-progress &raquo;</a>', 'action-scheduler'), esc_url($in_progress_url));
 			} else {
 				/* translators: %d: seconds */
-				$async_request_message = sprintf( __( 'The next queue will begin processing in approximately %d seconds.', 'action-scheduler' ), $async_request_lock_expiration - time() );
+				$async_request_message = sprintf(__('The next queue will begin processing in approximately %d seconds.', 'action-scheduler'), $async_request_lock_expiration - time());
 			}
 
 			$this->admin_notices[] = array(
@@ -407,36 +407,36 @@ 
 			);
 		}
 
-		$notification = get_transient( 'action_scheduler_admin_notice' );
+		$notification = get_transient('action_scheduler_admin_notice');
 
-		if ( is_array( $notification ) ) {
-			delete_transient( 'action_scheduler_admin_notice' );
+		if (is_array($notification)) {
+			delete_transient('action_scheduler_admin_notice');
 
-			$action           = $this->store->fetch_action( $notification['action_id'] );
-			$action_hook_html = '<strong><code>' . $action->get_hook() . '</code></strong>';
-			if ( 1 == $notification['success'] ) {
+			$action           = $this->store->fetch_action($notification['action_id']);
+			$action_hook_html = '<strong><code>'.$action->get_hook().'</code></strong>';
+			if (1 == $notification['success']) {
 				$class = 'updated';
-				switch ( $notification['row_action_type'] ) {
+				switch ($notification['row_action_type']) {
 					case 'run':
 						/* translators: %s: action HTML */
-						$action_message_html = sprintf( __( 'Successfully executed action: %s', 'action-scheduler' ), $action_hook_html );
+						$action_message_html = sprintf(__('Successfully executed action: %s', 'action-scheduler'), $action_hook_html);
 						break;
 					case 'cancel':
 						/* translators: %s: action HTML */
-						$action_message_html = sprintf( __( 'Successfully canceled action: %s', 'action-scheduler' ), $action_hook_html );
+						$action_message_html = sprintf(__('Successfully canceled action: %s', 'action-scheduler'), $action_hook_html);
 						break;
 					default:
 						/* translators: %s: action HTML */
-						$action_message_html = sprintf( __( 'Successfully processed change for action: %s', 'action-scheduler' ), $action_hook_html );
+						$action_message_html = sprintf(__('Successfully processed change for action: %s', 'action-scheduler'), $action_hook_html);
 						break;
 				}
 			} else {
 				$class = 'error';
 				/* translators: 1: action HTML 2: action ID 3: error message */
-				$action_message_html = sprintf( __( 'Could not process change for action: "%1$s" (ID: %2$d). Error: %3$s', 'action-scheduler' ), $action_hook_html, esc_html( $notification['action_id'] ), esc_html( $notification['error_message'] ) );
+				$action_message_html = sprintf(__('Could not process change for action: "%1$s" (ID: %2$d). Error: %3$s', 'action-scheduler'), $action_hook_html, esc_html($notification['action_id']), esc_html($notification['error_message']));
 			}
 
-			$action_message_html = apply_filters( 'action_scheduler_admin_notice_html', $action_message_html, $action, $notification );
+			$action_message_html = apply_filters('action_scheduler_admin_notice_html', $action_message_html, $action, $notification);
 
 			$this->admin_notices[] = array(
 				'class'   => $class,
@@ -454,8 +454,8 @@ 
 	 *
 	 * @return string
 	 */
-	public function column_schedule( $row ) {
-		return $this->get_schedule_display_string( $row['schedule'] );
+	public function column_schedule($row) {
+		return $this->get_schedule_display_string($row['schedule']);
 	}
 
 	/**
@@ -464,29 +464,29 @@ 
 	 * @param ActionScheduler_Schedule $schedule
 	 * @return string
 	 */
-	protected function get_schedule_display_string( ActionScheduler_Schedule $schedule ) {
+	protected function get_schedule_display_string(ActionScheduler_Schedule $schedule) {
 
 		$schedule_display_string = '';
 
-		if ( is_a( $schedule, 'ActionScheduler_NullSchedule' ) ) {
-			return __( 'async', 'action-scheduler' );
+		if (is_a($schedule, 'ActionScheduler_NullSchedule')) {
+			return __('async', 'action-scheduler');
 		}
 
-		if ( ! $schedule->get_date() ) {
+		if ( ! $schedule->get_date()) {
 			return '0000-00-00 00:00:00';
 		}
 
 		$next_timestamp = $schedule->get_date()->getTimestamp();
 
-		$schedule_display_string .= $schedule->get_date()->format( 'Y-m-d H:i:s O' );
+		$schedule_display_string .= $schedule->get_date()->format('Y-m-d H:i:s O');
 		$schedule_display_string .= '<br/>';
 
-		if ( gmdate( 'U' ) > $next_timestamp ) {
+		if (gmdate('U') > $next_timestamp) {
 			/* translators: %s: date interval */
-			$schedule_display_string .= sprintf( __( ' (%s ago)', 'action-scheduler' ), self::human_interval( gmdate( 'U' ) - $next_timestamp ) );
+			$schedule_display_string .= sprintf(__(' (%s ago)', 'action-scheduler'), self::human_interval(gmdate('U') - $next_timestamp));
 		} else {
 			/* translators: %s: date interval */
-			$schedule_display_string .= sprintf( __( ' (%s)', 'action-scheduler' ), self::human_interval( $next_timestamp - gmdate( 'U' ) ) );
+			$schedule_display_string .= sprintf(__(' (%s)', 'action-scheduler'), self::human_interval($next_timestamp - gmdate('U')));
 		}
 
 		return $schedule_display_string;
@@ -501,9 +501,9 @@ 
 	 * @param array  $ids
 	 * @param string $ids_sql Inherited and unused
 	 */
-	protected function bulk_delete( array $ids, $ids_sql ) {
-		foreach ( $ids as $id ) {
-			$this->store->delete_action( $id );
+	protected function bulk_delete(array $ids, $ids_sql) {
+		foreach ($ids as $id) {
+			$this->store->delete_action($id);
 		}
 	}
 
@@ -513,8 +513,8 @@ 
 	 *
 	 * @param int $action_id
 	 */
-	protected function row_action_cancel( $action_id ) {
-		$this->process_row_action( $action_id, 'cancel' );
+	protected function row_action_cancel($action_id) {
+		$this->process_row_action($action_id, 'cancel');
 	}
 
 	/**
@@ -523,27 +523,27 @@ 
 	 *
 	 * @param int $action_id
 	 */
-	protected function row_action_run( $action_id ) {
-		$this->process_row_action( $action_id, 'run' );
+	protected function row_action_run($action_id) {
+		$this->process_row_action($action_id, 'run');
 	}
 
 	/**
 	 * Force the data store schema updates.
 	 */
 	protected function recreate_tables() {
-		if ( is_a( $this->store, 'ActionScheduler_HybridStore' ) ) {
+		if (is_a($this->store, 'ActionScheduler_HybridStore')) {
 			$store = $this->store;
 		} else {
 			$store = new ActionScheduler_HybridStore();
 		}
-		add_action( 'action_scheduler/created_table', array( $store, 'set_autoincrement' ), 10, 2 );
+		add_action('action_scheduler/created_table', array($store, 'set_autoincrement'), 10, 2);
 
 		$store_schema  = new ActionScheduler_StoreSchema();
 		$logger_schema = new ActionScheduler_LoggerSchema();
-		$store_schema->register_tables( true );
-		$logger_schema->register_tables( true );
+		$store_schema->register_tables(true);
+		$logger_schema->register_tables(true);
 
-		remove_action( 'action_scheduler/created_table', array( $store, 'set_autoincrement' ), 10 );
+		remove_action('action_scheduler/created_table', array($store, 'set_autoincrement'), 10);
 	}
 	/**
 	 * Implements the logic behind processing an action once an action link is clicked on the list table.
@@ -551,24 +551,24 @@ 
 	 * @param int    $action_id
 	 * @param string $row_action_type The type of action to perform on the action.
 	 */
-	protected function process_row_action( $action_id, $row_action_type ) {
+	protected function process_row_action($action_id, $row_action_type) {
 		try {
-			switch ( $row_action_type ) {
+			switch ($row_action_type) {
 				case 'run':
-					$this->runner->process_action( $action_id, 'Admin List Table' );
+					$this->runner->process_action($action_id, 'Admin List Table');
 					break;
 				case 'cancel':
-					$this->store->cancel_action( $action_id );
+					$this->store->cancel_action($action_id);
 					break;
 			}
 			$success       = 1;
 			$error_message = '';
-		} catch ( Exception $e ) {
+		} catch (Exception $e) {
 			$success       = 0;
 			$error_message = $e->getMessage();
 		}
 
-		set_transient( 'action_scheduler_admin_notice', compact( 'action_id', 'success', 'error_message', 'row_action_type' ), 30 );
+		set_transient('action_scheduler_admin_notice', compact('action_id', 'success', 'error_message', 'row_action_type'), 30);
 	}
 
 	/**
@@ -577,7 +577,7 @@ 
 	public function prepare_items() {
 		$this->prepare_column_headers();
 
-		$per_page = $this->get_items_per_page( $this->get_per_page_option_name(), $this->items_per_page );
+		$per_page = $this->get_items_per_page($this->get_per_page_option_name(), $this->items_per_page);
 
 		$query = array(
 			'per_page' => $per_page,
@@ -593,36 +593,36 @@ 
 		 * Past-due actions have the 'pending' status and are in the past.
 		 * This is needed because registering 'past-due' as a status is overkill.
 		 */
-		if ( 'past-due' === $this->get_request_status() ) {
+		if ('past-due' === $this->get_request_status()) {
 			$query['status'] = ActionScheduler_Store::STATUS_PENDING;
 			$query['date']   = as_get_datetime_object();
 		}
 
 		$this->items = array();
 
-		$total_items = $this->store->query_actions( $query, 'count' );
+		$total_items = $this->store->query_actions($query, 'count');
 
 		$status_labels = $this->store->get_status_labels();
 
-		foreach ( $this->store->query_actions( $query ) as $action_id ) {
+		foreach ($this->store->query_actions($query) as $action_id) {
 			try {
-				$action = $this->store->fetch_action( $action_id );
-			} catch ( Exception $e ) {
+				$action = $this->store->fetch_action($action_id);
+			} catch (Exception $e) {
 				continue;
 			}
-			if ( is_a( $action, 'ActionScheduler_NullAction' ) ) {
+			if (is_a($action, 'ActionScheduler_NullAction')) {
 				continue;
 			}
-			$this->items[ $action_id ] = array(
+			$this->items[$action_id] = array(
 				'ID'          => $action_id,
 				'hook'        => $action->get_hook(),
-				'status_name' => $this->store->get_status( $action_id ),
-				'status'      => $status_labels[ $this->store->get_status( $action_id ) ],
+				'status_name' => $this->store->get_status($action_id),
+				'status'      => $status_labels[$this->store->get_status($action_id)],
 				'args'        => $action->get_args(),
 				'group'       => $action->get_group(),
-				'log_entries' => $this->logger->get_logs( $action_id ),
-				'claim_id'    => $this->store->get_claim_id( $action_id ),
-				'recurrence'  => $this->get_recurrence( $action ),
+				'log_entries' => $this->logger->get_logs($action_id),
+				'claim_id'    => $this->store->get_claim_id($action_id),
+				'recurrence'  => $this->get_recurrence($action),
 				'schedule'    => $action->get_schedule(),
 			);
 		}
@@ -631,7 +631,7 @@ 
 			array(
 				'total_items' => $total_items,
 				'per_page'    => $per_page,
-				'total_pages' => ceil( $total_items / $per_page ),
+				'total_pages' => ceil($total_items / $per_page),
 			)
 		);
 	}
@@ -648,13 +648,13 @@ 
 	 * Get the text to display in the search box on the list table.
 	 */
 	protected function get_search_box_button_text() {
-		return __( 'Search hook, args and claim ID', 'action-scheduler' );
+		return __('Search hook, args and claim ID', 'action-scheduler');
 	}
 
 	/**
 	 * {@inheritDoc}
 	 */
 	protected function get_per_page_option_name() {
-		return str_replace( '-', '_', $this->screen->id ) . '_per_page';
+		return str_replace('-', '_', $this->screen->id).'_per_page';
 	}
 }

src/libraries/action-scheduler/classes/ActionScheduler_Versions.php

Indentation +54 added lines, -54 removed lines

@@ -4,59 +4,59 @@
  * Class ActionScheduler_Versions
  */
 class ActionScheduler_Versions {
-	/**
-	 * @var ActionScheduler_Versions
-	 */
-	private static $instance = null;
-
-	private $versions = array();
-
-	public function register( $version_string, $initialization_callback ) {
-		if ( isset( $this->versions[ $version_string ] ) ) {
-			return false;
-		}
-		$this->versions[ $version_string ] = $initialization_callback;
-		return true;
-	}
-
-	public function get_versions() {
-		return $this->versions;
-	}
-
-	public function latest_version() {
-		$keys = array_keys( $this->versions );
-		if ( empty( $keys ) ) {
-			return false;
-		}
-		uasort( $keys, 'version_compare' );
-		return end( $keys );
-	}
-
-	public function latest_version_callback() {
-		$latest = $this->latest_version();
-		if ( empty( $latest ) || ! isset( $this->versions[ $latest ] ) ) {
-			return '__return_null';
-		}
-		return $this->versions[ $latest ];
-	}
-
-	/**
-	 * @return ActionScheduler_Versions
-	 * @codeCoverageIgnore
-	 */
-	public static function instance() {
-		if ( empty( self::$instance ) ) {
-			self::$instance = new self();
-		}
-		return self::$instance;
-	}
-
-	/**
-	 * @codeCoverageIgnore
-	 */
-	public static function initialize_latest_version() {
-		$self = self::instance();
-		call_user_func( $self->latest_version_callback() );
-	}
+    /**
+     * @var ActionScheduler_Versions
+     */
+    private static $instance = null;
+
+    private $versions = array();
+
+    public function register( $version_string, $initialization_callback ) {
+        if ( isset( $this->versions[ $version_string ] ) ) {
+            return false;
+        }
+        $this->versions[ $version_string ] = $initialization_callback;
+        return true;
+    }
+
+    public function get_versions() {
+        return $this->versions;
+    }
+
+    public function latest_version() {
+        $keys = array_keys( $this->versions );
+        if ( empty( $keys ) ) {
+            return false;
+        }
+        uasort( $keys, 'version_compare' );
+        return end( $keys );
+    }
+
+    public function latest_version_callback() {
+        $latest = $this->latest_version();
+        if ( empty( $latest ) || ! isset( $this->versions[ $latest ] ) ) {
+            return '__return_null';
+        }
+        return $this->versions[ $latest ];
+    }
+
+    /**
+     * @return ActionScheduler_Versions
+     * @codeCoverageIgnore
+     */
+    public static function instance() {
+        if ( empty( self::$instance ) ) {
+            self::$instance = new self();
+        }
+        return self::$instance;
+    }
+
+    /**
+     * @codeCoverageIgnore
+     */
+    public static function initialize_latest_version() {
+        $self = self::instance();
+        call_user_func( $self->latest_version_callback() );
+    }
 }
 

Spacing +11 added lines, -11 removed lines

@@ -11,11 +11,11 @@ 
 
 	private $versions = array();
 
-	public function register( $version_string, $initialization_callback ) {
-		if ( isset( $this->versions[ $version_string ] ) ) {
+	public function register($version_string, $initialization_callback) {
+		if (isset($this->versions[$version_string])) {
 			return false;
 		}
-		$this->versions[ $version_string ] = $initialization_callback;
+		$this->versions[$version_string] = $initialization_callback;
 		return true;
 	}
 
@@ -24,20 +24,20 @@ 
 	}
 
 	public function latest_version() {
-		$keys = array_keys( $this->versions );
-		if ( empty( $keys ) ) {
+		$keys = array_keys($this->versions);
+		if (empty($keys)) {
 			return false;
 		}
-		uasort( $keys, 'version_compare' );
-		return end( $keys );
+		uasort($keys, 'version_compare');
+		return end($keys);
 	}
 
 	public function latest_version_callback() {
 		$latest = $this->latest_version();
-		if ( empty( $latest ) || ! isset( $this->versions[ $latest ] ) ) {
+		if (empty($latest) || ! isset($this->versions[$latest])) {
 			return '__return_null';
 		}
-		return $this->versions[ $latest ];
+		return $this->versions[$latest];
 	}
 
 	/**
@@ -45,7 +45,7 @@ 
 	 * @codeCoverageIgnore
 	 */
 	public static function instance() {
-		if ( empty( self::$instance ) ) {
+		if (empty(self::$instance)) {
 			self::$instance = new self();
 		}
 		return self::$instance;
@@ -56,7 +56,7 @@ 
 	 */
 	public static function initialize_latest_version() {
 		$self = self::instance();
-		call_user_func( $self->latest_version_callback() );
+		call_user_func($self->latest_version_callback());
 	}
 }
 

src/libraries/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.', 'action-scheduler' ), __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.', 'action-scheduler' ), __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.', 'action-scheduler' ), __CLASS__ ) );
+			throw new \Exception(sprintf(__('The %s class can only be run within WP CLI.', 'action-scheduler'), __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();
 	}

src/libraries/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.', 'action-scheduler' ), __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.', 'action-scheduler' ) );
-			} else {
-				WP_CLI::error( __( 'There are too many concurrent batches.', 'action-scheduler' ) );
-			}
-		}
-
-		// 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, 'action-scheduler' ), 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.', 'action-scheduler' ) );
-				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', 'action-scheduler' ), $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', 'action-scheduler' ), $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', 'action-scheduler' ), $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.', 'action-scheduler' ), __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.', 'action-scheduler' ) );
+            } else {
+                WP_CLI::error( __( 'There are too many concurrent batches.', 'action-scheduler' ) );
+            }
+        }
+
+        // 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, 'action-scheduler' ), 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.', 'action-scheduler' ) );
+                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', 'action-scheduler' ), $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', 'action-scheduler' ), $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', 'action-scheduler' ), $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.', 'action-scheduler' ), __CLASS__ ) );
+			throw new Exception(sprintf(__('The %s class can only be run within WP CLI.', 'action-scheduler'), __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.', 'action-scheduler' ) );
+		if ($this->has_maximum_concurrent_batches()) {
+			if ($force) {
+				WP_CLI::warning(__('There are too many concurrent batches, but the run is forced to continue.', 'action-scheduler'));
 			} else {
-				WP_CLI::error( __( 'There are too many concurrent batches.', 'action-scheduler' ) );
+				WP_CLI::error(__('There are too many concurrent batches.', 'action-scheduler'));
 			}
 		}
 
 		// 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, 'action-scheduler' ), number_format_i18n( $count ) ),
+			sprintf(_n('Running %d action', 'Running %d actions', $count, 'action-scheduler'), 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.', 'action-scheduler' ) );
+			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.', 'action-scheduler'));
 				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', 'action-scheduler' ), $action_id ) );
+		WP_CLI::log(sprintf(__('Started processing action %s', 'action-scheduler'), $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', 'action-scheduler' ), $action_id, $action->get_hook() ) );
+		WP_CLI::log(sprintf(__('Completed processing action %1$s with hook: %2$s', 'action-scheduler'), $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', 'action-scheduler' ), $action_id, $exception->getMessage() ),
+			sprintf(__('Error processing action %1$s: %2$s', 'action-scheduler'), $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();
 		}
 	}

src/libraries/action-scheduler/classes/WP_CLI/Migration_Command.php

Indentation +166 added lines, -166 removed lines

@@ -19,170 +19,170 @@
  */
 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',
-			array( $this, 'migrate' ),
-			array(
-				'shortdesc' => 'Migrates actions to the DB tables store',
-				'synopsis'  => array(
-					array(
-						'type'        => 'assoc',
-						'name'        => 'batch-size',
-						'optional'    => true,
-						'default'     => 100,
-						'description' => 'The number of actions to process in each batch',
-					),
-					array(
-						'type'        => 'assoc',
-						'name'        => 'free-memory-on',
-						'optional'    => true,
-						'default'     => 50,
-						'description' => 'The number of actions to process between freeing memory. 0 disables freeing memory',
-					),
-					array(
-						'type'        => 'assoc',
-						'name'        => 'pause',
-						'optional'    => true,
-						'default'     => 0,
-						'description' => 'The number of seconds to pause when freeing memory',
-					),
-					array(
-						'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,
-			array(
-				'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',
+            array( $this, 'migrate' ),
+            array(
+                'shortdesc' => 'Migrates actions to the DB tables store',
+                'synopsis'  => array(
+                    array(
+                        'type'        => 'assoc',
+                        'name'        => 'batch-size',
+                        'optional'    => true,
+                        'default'     => 100,
+                        'description' => 'The number of actions to process in each batch',
+                    ),
+                    array(
+                        'type'        => 'assoc',
+                        'name'        => 'free-memory-on',
+                        'optional'    => true,
+                        'default'     => 50,
+                        'description' => 'The number of actions to process between freeing memory. 0 disables freeing memory',
+                    ),
+                    array(
+                        'type'        => 'assoc',
+                        'name'        => 'pause',
+                        'optional'    => true,
+                        'default'     => 0,
+                        'description' => 'The number of seconds to pause when freeing memory',
+                    ),
+                    array(
+                        '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,
+            array(
+                '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 +30 added lines, -30 removed lines

@@ -26,13 +26,13 @@ 
 	 * 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',
-			array( $this, 'migrate' ),
+			array($this, 'migrate'),
 			array(
 				'shortdesc' => 'Migrates actions to the DB tables store',
 				'synopsis'  => array(
@@ -76,31 +76,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));
 	}
 
 	/**
@@ -110,7 +110,7 @@ 
 	 *
 	 * @return ActionScheduler\Migration\Config
 	 */
-	private function get_migration_config( $args ) {
+	private function get_migration_config($args) {
 		$args = wp_parse_args(
 			$args,
 			array(
@@ -119,7 +119,7 @@ 
 		);
 
 		$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;
 	}
@@ -130,56 +130,56 @@ 
 	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 ) );
+			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 ) );
+			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 ) );
+			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 ) );
+			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 ) );
+			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 ) );
+			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 ) ) );
+			function($batch) {
+				WP_CLI::log(sprintf('Completed migration of %d actions', count($batch)));
 			},
 			10,
 			1

src/libraries/action-scheduler/classes/migration/DryRun_LogMigrator.php

Indentation +9 added lines, -9 removed lines

@@ -10,13 +10,13 @@
  * @codeCoverageIgnore
  */
 class DryRun_LogMigrator extends LogMigrator {
-	/**
-	 * Simulate migrating 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 ) {
-		// no-op
-	}
+    /**
+     * Simulate migrating 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 ) {
+        // no-op
+    }
 }

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
 	 * @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 ) {
+	public function migrate($source_action_id, $destination_action_id) {
 		// no-op
 	}
 }