insideout10 / wordlift-plugin

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

Indentation +93 added lines, -93 removed lines

@@ -12,97 +12,97 @@
  * @codeCoverageIgnore
  */
 class ActionMigrator {
-	/** var ActionScheduler_Store */
-	private $source;
-
-	/** var ActionScheduler_Store */
-	private $destination;
-
-	/** var LogMigrator */
-	private $log_migrator;
-
-	/**
-	 * ActionMigrator constructor.
-	 *
-	 * @param ActionScheduler_Store $source_store Source store object.
-	 * @param ActionScheduler_Store $destination_store Destination store object.
-	 * @param LogMigrator           $log_migrator Log migrator object.
-	 */
-	public function __construct( \ActionScheduler_Store $source_store, \ActionScheduler_Store $destination_store, LogMigrator $log_migrator ) {
-		$this->source       = $source_store;
-		$this->destination  = $destination_store;
-		$this->log_migrator = $log_migrator;
-	}
-
-	/**
-	 * Migrate an action.
-	 *
-	 * @param int $source_action_id Action ID.
-	 *
-	 * @return int 0|new action ID
-	 */
-	public function migrate( $source_action_id ) {
-		try {
-			$action = $this->source->fetch_action( $source_action_id );
-			$status = $this->source->get_status( $source_action_id );
-		} catch ( \Exception $e ) {
-			$action = null;
-			$status = '';
-		}
-
-		if ( $action === null || empty( $status ) || ! $action->get_schedule()->get_date() ) {
-			// null action or empty status means the fetch operation failed or the action didn't exist
-			// null schedule means it's missing vital data
-			// delete it and move on
-			try {
-				$this->source->delete_action( $source_action_id );
-			} catch ( \Exception $e ) {
-				// nothing to do, it didn't exist in the first place
-			}
-			do_action( 'action_scheduler/no_action_to_migrate', $source_action_id, $this->source, $this->destination );
-
-			return 0;
-		}
-
-		try {
-
-			// Make sure the last attempt date is set correctly for completed and failed actions
-			$last_attempt_date = ( $status !== \ActionScheduler_Store::STATUS_PENDING ) ? $this->source->get_date( $source_action_id ) : null;
-
-			$destination_action_id = $this->destination->save_action( $action, null, $last_attempt_date );
-		} catch ( \Exception $e ) {
-			do_action( 'action_scheduler/migrate_action_failed', $source_action_id, $this->source, $this->destination );
-
-			return 0; // could not save the action in the new store
-		}
-
-		try {
-			switch ( $status ) {
-				case \ActionScheduler_Store::STATUS_FAILED:
-					$this->destination->mark_failure( $destination_action_id );
-					break;
-				case \ActionScheduler_Store::STATUS_CANCELED:
-					$this->destination->cancel_action( $destination_action_id );
-					break;
-			}
-
-			$this->log_migrator->migrate( $source_action_id, $destination_action_id );
-			$this->source->delete_action( $source_action_id );
-
-			$test_action = $this->source->fetch_action( $source_action_id );
-			if ( ! is_a( $test_action, 'ActionScheduler_NullAction' ) ) {
-				throw new \RuntimeException( sprintf( __( 'Unable to remove source migrated action %s', 'action-scheduler' ), $source_action_id ) );
-			}
-			do_action( 'action_scheduler/migrated_action', $source_action_id, $destination_action_id, $this->source, $this->destination );
-
-			return $destination_action_id;
-		} catch ( \Exception $e ) {
-			// could not delete from the old store
-			$this->source->mark_migrated( $source_action_id );
-			do_action( 'action_scheduler/migrate_action_incomplete', $source_action_id, $destination_action_id, $this->source, $this->destination );
-			do_action( 'action_scheduler/migrated_action', $source_action_id, $destination_action_id, $this->source, $this->destination );
-
-			return $destination_action_id;
-		}
-	}
+    /** var ActionScheduler_Store */
+    private $source;
+
+    /** var ActionScheduler_Store */
+    private $destination;
+
+    /** var LogMigrator */
+    private $log_migrator;
+
+    /**
+     * ActionMigrator constructor.
+     *
+     * @param ActionScheduler_Store $source_store Source store object.
+     * @param ActionScheduler_Store $destination_store Destination store object.
+     * @param LogMigrator           $log_migrator Log migrator object.
+     */
+    public function __construct( \ActionScheduler_Store $source_store, \ActionScheduler_Store $destination_store, LogMigrator $log_migrator ) {
+        $this->source       = $source_store;
+        $this->destination  = $destination_store;
+        $this->log_migrator = $log_migrator;
+    }
+
+    /**
+     * Migrate an action.
+     *
+     * @param int $source_action_id Action ID.
+     *
+     * @return int 0|new action ID
+     */
+    public function migrate( $source_action_id ) {
+        try {
+            $action = $this->source->fetch_action( $source_action_id );
+            $status = $this->source->get_status( $source_action_id );
+        } catch ( \Exception $e ) {
+            $action = null;
+            $status = '';
+        }
+
+        if ( $action === null || empty( $status ) || ! $action->get_schedule()->get_date() ) {
+            // null action or empty status means the fetch operation failed or the action didn't exist
+            // null schedule means it's missing vital data
+            // delete it and move on
+            try {
+                $this->source->delete_action( $source_action_id );
+            } catch ( \Exception $e ) {
+                // nothing to do, it didn't exist in the first place
+            }
+            do_action( 'action_scheduler/no_action_to_migrate', $source_action_id, $this->source, $this->destination );
+
+            return 0;
+        }
+
+        try {
+
+            // Make sure the last attempt date is set correctly for completed and failed actions
+            $last_attempt_date = ( $status !== \ActionScheduler_Store::STATUS_PENDING ) ? $this->source->get_date( $source_action_id ) : null;
+
+            $destination_action_id = $this->destination->save_action( $action, null, $last_attempt_date );
+        } catch ( \Exception $e ) {
+            do_action( 'action_scheduler/migrate_action_failed', $source_action_id, $this->source, $this->destination );
+
+            return 0; // could not save the action in the new store
+        }
+
+        try {
+            switch ( $status ) {
+                case \ActionScheduler_Store::STATUS_FAILED:
+                    $this->destination->mark_failure( $destination_action_id );
+                    break;
+                case \ActionScheduler_Store::STATUS_CANCELED:
+                    $this->destination->cancel_action( $destination_action_id );
+                    break;
+            }
+
+            $this->log_migrator->migrate( $source_action_id, $destination_action_id );
+            $this->source->delete_action( $source_action_id );
+
+            $test_action = $this->source->fetch_action( $source_action_id );
+            if ( ! is_a( $test_action, 'ActionScheduler_NullAction' ) ) {
+                throw new \RuntimeException( sprintf( __( 'Unable to remove source migrated action %s', 'action-scheduler' ), $source_action_id ) );
+            }
+            do_action( 'action_scheduler/migrated_action', $source_action_id, $destination_action_id, $this->source, $this->destination );
+
+            return $destination_action_id;
+        } catch ( \Exception $e ) {
+            // could not delete from the old store
+            $this->source->mark_migrated( $source_action_id );
+            do_action( 'action_scheduler/migrate_action_incomplete', $source_action_id, $destination_action_id, $this->source, $this->destination );
+            do_action( 'action_scheduler/migrated_action', $source_action_id, $destination_action_id, $this->source, $this->destination );
+
+            return $destination_action_id;
+        }
+    }
 }

Spacing +26 added lines, -26 removed lines

@@ -28,7 +28,7 @@ 
 	 * @param ActionScheduler_Store $destination_store Destination store object.
 	 * @param LogMigrator           $log_migrator Log migrator object.
 	 */
-	public function __construct( \ActionScheduler_Store $source_store, \ActionScheduler_Store $destination_store, LogMigrator $log_migrator ) {
+	public function __construct(\ActionScheduler_Store $source_store, \ActionScheduler_Store $destination_store, LogMigrator $log_migrator) {
 		$this->source       = $source_store;
 		$this->destination  = $destination_store;
 		$this->log_migrator = $log_migrator;
@@ -41,25 +41,25 @@ 
 	 *
 	 * @return int 0|new action ID
 	 */
-	public function migrate( $source_action_id ) {
+	public function migrate($source_action_id) {
 		try {
-			$action = $this->source->fetch_action( $source_action_id );
-			$status = $this->source->get_status( $source_action_id );
-		} catch ( \Exception $e ) {
+			$action = $this->source->fetch_action($source_action_id);
+			$status = $this->source->get_status($source_action_id);
+		} catch (\Exception $e) {
 			$action = null;
 			$status = '';
 		}
 
-		if ( $action === null || empty( $status ) || ! $action->get_schedule()->get_date() ) {
+		if ($action === null || empty($status) || ! $action->get_schedule()->get_date()) {
 			// null action or empty status means the fetch operation failed or the action didn't exist
 			// null schedule means it's missing vital data
 			// delete it and move on
 			try {
-				$this->source->delete_action( $source_action_id );
-			} catch ( \Exception $e ) {
+				$this->source->delete_action($source_action_id);
+			} catch (\Exception $e) {
 				// nothing to do, it didn't exist in the first place
 			}
-			do_action( 'action_scheduler/no_action_to_migrate', $source_action_id, $this->source, $this->destination );
+			do_action('action_scheduler/no_action_to_migrate', $source_action_id, $this->source, $this->destination);
 
 			return 0;
 		}
@@ -67,40 +67,40 @@ 
 		try {
 
 			// Make sure the last attempt date is set correctly for completed and failed actions
-			$last_attempt_date = ( $status !== \ActionScheduler_Store::STATUS_PENDING ) ? $this->source->get_date( $source_action_id ) : null;
+			$last_attempt_date = ($status !== \ActionScheduler_Store::STATUS_PENDING) ? $this->source->get_date($source_action_id) : null;
 
-			$destination_action_id = $this->destination->save_action( $action, null, $last_attempt_date );
-		} catch ( \Exception $e ) {
-			do_action( 'action_scheduler/migrate_action_failed', $source_action_id, $this->source, $this->destination );
+			$destination_action_id = $this->destination->save_action($action, null, $last_attempt_date);
+		} catch (\Exception $e) {
+			do_action('action_scheduler/migrate_action_failed', $source_action_id, $this->source, $this->destination);
 
 			return 0; // could not save the action in the new store
 		}
 
 		try {
-			switch ( $status ) {
+			switch ($status) {
 				case \ActionScheduler_Store::STATUS_FAILED:
-					$this->destination->mark_failure( $destination_action_id );
+					$this->destination->mark_failure($destination_action_id);
 					break;
 				case \ActionScheduler_Store::STATUS_CANCELED:
-					$this->destination->cancel_action( $destination_action_id );
+					$this->destination->cancel_action($destination_action_id);
 					break;
 			}
 
-			$this->log_migrator->migrate( $source_action_id, $destination_action_id );
-			$this->source->delete_action( $source_action_id );
+			$this->log_migrator->migrate($source_action_id, $destination_action_id);
+			$this->source->delete_action($source_action_id);
 
-			$test_action = $this->source->fetch_action( $source_action_id );
-			if ( ! is_a( $test_action, 'ActionScheduler_NullAction' ) ) {
-				throw new \RuntimeException( sprintf( __( 'Unable to remove source migrated action %s', 'action-scheduler' ), $source_action_id ) );
+			$test_action = $this->source->fetch_action($source_action_id);
+			if ( ! is_a($test_action, 'ActionScheduler_NullAction')) {
+				throw new \RuntimeException(sprintf(__('Unable to remove source migrated action %s', 'action-scheduler'), $source_action_id));
 			}
-			do_action( 'action_scheduler/migrated_action', $source_action_id, $destination_action_id, $this->source, $this->destination );
+			do_action('action_scheduler/migrated_action', $source_action_id, $destination_action_id, $this->source, $this->destination);
 
 			return $destination_action_id;
-		} catch ( \Exception $e ) {
+		} catch (\Exception $e) {
 			// could not delete from the old store
-			$this->source->mark_migrated( $source_action_id );
-			do_action( 'action_scheduler/migrate_action_incomplete', $source_action_id, $destination_action_id, $this->source, $this->destination );
-			do_action( 'action_scheduler/migrated_action', $source_action_id, $destination_action_id, $this->source, $this->destination );
+			$this->source->mark_migrated($source_action_id);
+			do_action('action_scheduler/migrate_action_incomplete', $source_action_id, $destination_action_id, $this->source, $this->destination);
+			do_action('action_scheduler/migrated_action', $source_action_id, $destination_action_id, $this->source, $this->destination);
 
 			return $destination_action_id;
 		}

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

Indentation +123 added lines, -123 removed lines

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

Spacing +27 added lines, -27 removed lines

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

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

Indentation +31 added lines, -31 removed lines

@@ -9,39 +9,39 @@
  */
 class ActionScheduler_DBStoreMigrator extends ActionScheduler_DBStore {
 
-	/**
-	 * Save an action with optional last attempt date.
-	 *
-	 * Normally, saving an action sets its attempted date to 0000-00-00 00:00:00 because when an action is first saved,
-	 * it can't have been attempted yet, but migrated completed actions will have an attempted date, so we need to save
-	 * that when first saving the action.
-	 *
-	 * @param ActionScheduler_Action $action
-	 * @param \DateTime              $scheduled_date Optional date of the first instance to store.
-	 * @param \DateTime              $last_attempt_date Optional date the action was last attempted.
-	 *
-	 * @return string The action ID
-	 * @throws \RuntimeException When the action is not saved.
-	 */
-	public function save_action( ActionScheduler_Action $action, \DateTime $scheduled_date = null, \DateTime $last_attempt_date = null ) {
-		try {
-			/** @var \wpdb $wpdb */
-			global $wpdb;
+    /**
+     * Save an action with optional last attempt date.
+     *
+     * Normally, saving an action sets its attempted date to 0000-00-00 00:00:00 because when an action is first saved,
+     * it can't have been attempted yet, but migrated completed actions will have an attempted date, so we need to save
+     * that when first saving the action.
+     *
+     * @param ActionScheduler_Action $action
+     * @param \DateTime              $scheduled_date Optional date of the first instance to store.
+     * @param \DateTime              $last_attempt_date Optional date the action was last attempted.
+     *
+     * @return string The action ID
+     * @throws \RuntimeException When the action is not saved.
+     */
+    public function save_action( ActionScheduler_Action $action, \DateTime $scheduled_date = null, \DateTime $last_attempt_date = null ) {
+        try {
+            /** @var \wpdb $wpdb */
+            global $wpdb;
 
-			$action_id = parent::save_action( $action, $scheduled_date );
+            $action_id = parent::save_action( $action, $scheduled_date );
 
-			if ( null !== $last_attempt_date ) {
-				$data = array(
-					'last_attempt_gmt'   => $this->get_scheduled_date_string( $action, $last_attempt_date ),
-					'last_attempt_local' => $this->get_scheduled_date_string_local( $action, $last_attempt_date ),
-				);
+            if ( null !== $last_attempt_date ) {
+                $data = array(
+                    'last_attempt_gmt'   => $this->get_scheduled_date_string( $action, $last_attempt_date ),
+                    'last_attempt_local' => $this->get_scheduled_date_string_local( $action, $last_attempt_date ),
+                );
 
-				$wpdb->update( $wpdb->actionscheduler_actions, $data, array( 'action_id' => $action_id ), array( '%s', '%s' ), array( '%d' ) );
-			}
+                $wpdb->update( $wpdb->actionscheduler_actions, $data, array( 'action_id' => $action_id ), array( '%s', '%s' ), array( '%d' ) );
+            }
 
-			return $action_id;
-		} catch ( \Exception $e ) {
-			throw new \RuntimeException( sprintf( __( 'Error saving action: %s', 'action-scheduler' ), $e->getMessage() ), 0 );
-		}
-	}
+            return $action_id;
+        } catch ( \Exception $e ) {
+            throw new \RuntimeException( sprintf( __( 'Error saving action: %s', 'action-scheduler' ), $e->getMessage() ), 0 );
+        }
+    }
 }

Spacing +8 added lines, -8 removed lines

@@ -23,25 +23,25 @@
 	 * @return string The action ID
 	 * @throws \RuntimeException When the action is not saved.
 	 */
-	public function save_action( ActionScheduler_Action $action, \DateTime $scheduled_date = null, \DateTime $last_attempt_date = null ) {
+	public function save_action(ActionScheduler_Action $action, \DateTime $scheduled_date = null, \DateTime $last_attempt_date = null) {
 		try {
 			/** @var \wpdb $wpdb */
 			global $wpdb;
 
-			$action_id = parent::save_action( $action, $scheduled_date );
+			$action_id = parent::save_action($action, $scheduled_date);
 
-			if ( null !== $last_attempt_date ) {
+			if (null !== $last_attempt_date) {
 				$data = array(
-					'last_attempt_gmt'   => $this->get_scheduled_date_string( $action, $last_attempt_date ),
-					'last_attempt_local' => $this->get_scheduled_date_string_local( $action, $last_attempt_date ),
+					'last_attempt_gmt'   => $this->get_scheduled_date_string($action, $last_attempt_date),
+					'last_attempt_local' => $this->get_scheduled_date_string_local($action, $last_attempt_date),
 				);
 
-				$wpdb->update( $wpdb->actionscheduler_actions, $data, array( 'action_id' => $action_id ), array( '%s', '%s' ), array( '%d' ) );
+				$wpdb->update($wpdb->actionscheduler_actions, $data, array('action_id' => $action_id), array('%s', '%s'), array('%d'));
 			}
 
 			return $action_id;
-		} catch ( \Exception $e ) {
-			throw new \RuntimeException( sprintf( __( 'Error saving action: %s', 'action-scheduler' ), $e->getMessage() ), 0 );
+		} catch (\Exception $e) {
+			throw new \RuntimeException(sprintf(__('Error saving action: %s', 'action-scheduler'), $e->getMessage()), 0);
 		}
 	}
 }

src/libraries/action-scheduler/classes/schema/ActionScheduler_LoggerSchema.php

Indentation +55 added lines, -55 removed lines

@@ -8,35 +8,35 @@ 
  * Creates a custom table for storing action logs
  */
 class ActionScheduler_LoggerSchema extends ActionScheduler_Abstract_Schema {
-	const LOG_TABLE = 'actionscheduler_logs';
+    const LOG_TABLE = 'actionscheduler_logs';
 
-	/**
-	 * @var int Increment this value to trigger a schema update.
-	 */
-	protected $schema_version = 3;
+    /**
+     * @var int Increment this value to trigger a schema update.
+     */
+    protected $schema_version = 3;
 
-	public function __construct() {
-		$this->tables = array(
-			self::LOG_TABLE,
-		);
-	}
+    public function __construct() {
+        $this->tables = array(
+            self::LOG_TABLE,
+        );
+    }
 
-	/**
-	 * Performs additional setup work required to support this schema.
-	 */
-	public function init() {
-		add_action( 'action_scheduler_before_schema_update', array( $this, 'update_schema_3_0' ), 10, 2 );
-	}
+    /**
+     * Performs additional setup work required to support this schema.
+     */
+    public function init() {
+        add_action( 'action_scheduler_before_schema_update', array( $this, 'update_schema_3_0' ), 10, 2 );
+    }
 
-	protected function get_table_definition( $table ) {
-		global $wpdb;
-		$table_name      = $wpdb->$table;
-		$charset_collate = $wpdb->get_charset_collate();
-		switch ( $table ) {
+    protected function get_table_definition( $table ) {
+        global $wpdb;
+        $table_name      = $wpdb->$table;
+        $charset_collate = $wpdb->get_charset_collate();
+        switch ( $table ) {
 
-			case self::LOG_TABLE:
-				$default_date = ActionScheduler_StoreSchema::DEFAULT_DATE;
-				return "CREATE TABLE $table_name (
+            case self::LOG_TABLE:
+                $default_date = ActionScheduler_StoreSchema::DEFAULT_DATE;
+                return "CREATE TABLE $table_name (
 				        log_id bigint(20) unsigned NOT NULL auto_increment,
 				        action_id bigint(20) unsigned NOT NULL,
 				        message text NOT NULL,
@@ -47,43 +47,43 @@ 
 				        KEY log_date_gmt (log_date_gmt)
 				        ) $charset_collate";
 
-			default:
-				return '';
-		}
-	}
+            default:
+                return '';
+        }
+    }
 
-	/**
-	 * Update the logs table schema, allowing datetime fields to be NULL.
-	 *
-	 * This is needed because the NOT NULL constraint causes a conflict with some versions of MySQL
-	 * configured with sql_mode=NO_ZERO_DATE, which can for instance lead to tables not being created.
-	 *
-	 * Most other schema updates happen via ActionScheduler_Abstract_Schema::update_table(), however
-	 * that method relies on dbDelta() and this change is not possible when using that function.
-	 *
-	 * @param string $table Name of table being updated.
-	 * @param string $db_version The existing schema version of the table.
-	 */
-	public function update_schema_3_0( $table, $db_version ) {
-		global $wpdb;
+    /**
+     * Update the logs table schema, allowing datetime fields to be NULL.
+     *
+     * This is needed because the NOT NULL constraint causes a conflict with some versions of MySQL
+     * configured with sql_mode=NO_ZERO_DATE, which can for instance lead to tables not being created.
+     *
+     * Most other schema updates happen via ActionScheduler_Abstract_Schema::update_table(), however
+     * that method relies on dbDelta() and this change is not possible when using that function.
+     *
+     * @param string $table Name of table being updated.
+     * @param string $db_version The existing schema version of the table.
+     */
+    public function update_schema_3_0( $table, $db_version ) {
+        global $wpdb;
 
-		if ( 'actionscheduler_logs' !== $table || version_compare( $db_version, '3', '>=' ) ) {
-			return;
-		}
+        if ( 'actionscheduler_logs' !== $table || version_compare( $db_version, '3', '>=' ) ) {
+            return;
+        }
 
-		// phpcs:disable WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-		$table_name   = $wpdb->prefix . 'actionscheduler_logs';
-		$table_list   = $wpdb->get_col( "SHOW TABLES LIKE '{$table_name}'" );
-		$default_date = ActionScheduler_StoreSchema::DEFAULT_DATE;
+        // phpcs:disable WordPress.DB.PreparedSQL.InterpolatedNotPrepared
+        $table_name   = $wpdb->prefix . 'actionscheduler_logs';
+        $table_list   = $wpdb->get_col( "SHOW TABLES LIKE '{$table_name}'" );
+        $default_date = ActionScheduler_StoreSchema::DEFAULT_DATE;
 
-		if ( ! empty( $table_list ) ) {
-			$query = "
+        if ( ! empty( $table_list ) ) {
+            $query = "
 				ALTER TABLE {$table_name}
 				MODIFY COLUMN log_date_gmt datetime NULL default '{$default_date}',
 				MODIFY COLUMN log_date_local datetime NULL default '{$default_date}'
 			";
-			$wpdb->query( $query ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-		}
-		// phpcs:enable WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-	}
+            $wpdb->query( $query ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+        }
+        // phpcs:enable WordPress.DB.PreparedSQL.InterpolatedNotPrepared
+    }
 }

Spacing +9 added lines, -9 removed lines

@@ -25,14 +25,14 @@ 
 	 * Performs additional setup work required to support this schema.
 	 */
 	public function init() {
-		add_action( 'action_scheduler_before_schema_update', array( $this, 'update_schema_3_0' ), 10, 2 );
+		add_action('action_scheduler_before_schema_update', array($this, 'update_schema_3_0'), 10, 2);
 	}
 
-	protected function get_table_definition( $table ) {
+	protected function get_table_definition($table) {
 		global $wpdb;
 		$table_name      = $wpdb->$table;
 		$charset_collate = $wpdb->get_charset_collate();
-		switch ( $table ) {
+		switch ($table) {
 
 			case self::LOG_TABLE:
 				$default_date = ActionScheduler_StoreSchema::DEFAULT_DATE;
@@ -64,25 +64,25 @@ 
 	 * @param string $table Name of table being updated.
 	 * @param string $db_version The existing schema version of the table.
 	 */
-	public function update_schema_3_0( $table, $db_version ) {
+	public function update_schema_3_0($table, $db_version) {
 		global $wpdb;
 
-		if ( 'actionscheduler_logs' !== $table || version_compare( $db_version, '3', '>=' ) ) {
+		if ('actionscheduler_logs' !== $table || version_compare($db_version, '3', '>=')) {
 			return;
 		}
 
 		// phpcs:disable WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-		$table_name   = $wpdb->prefix . 'actionscheduler_logs';
-		$table_list   = $wpdb->get_col( "SHOW TABLES LIKE '{$table_name}'" );
+		$table_name   = $wpdb->prefix.'actionscheduler_logs';
+		$table_list   = $wpdb->get_col("SHOW TABLES LIKE '{$table_name}'");
 		$default_date = ActionScheduler_StoreSchema::DEFAULT_DATE;
 
-		if ( ! empty( $table_list ) ) {
+		if ( ! empty($table_list)) {
 			$query = "
 				ALTER TABLE {$table_name}
 				MODIFY COLUMN log_date_gmt datetime NULL default '{$default_date}',
 				MODIFY COLUMN log_date_local datetime NULL default '{$default_date}'
 			";
-			$wpdb->query( $query ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+			$wpdb->query($query); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
 		}
 		// phpcs:enable WordPress.DB.PreparedSQL.InterpolatedNotPrepared
 	}

src/libraries/action-scheduler/classes/schema/ActionScheduler_StoreSchema.php

Indentation +65 added lines, -65 removed lines

@@ -8,41 +8,41 @@ 
  * Creates custom tables for storing scheduled actions
  */
 class ActionScheduler_StoreSchema extends ActionScheduler_Abstract_Schema {
-	const ACTIONS_TABLE = 'actionscheduler_actions';
-	const CLAIMS_TABLE  = 'actionscheduler_claims';
-	const GROUPS_TABLE  = 'actionscheduler_groups';
-	const DEFAULT_DATE  = '0000-00-00 00:00:00';
+    const ACTIONS_TABLE = 'actionscheduler_actions';
+    const CLAIMS_TABLE  = 'actionscheduler_claims';
+    const GROUPS_TABLE  = 'actionscheduler_groups';
+    const DEFAULT_DATE  = '0000-00-00 00:00:00';
 
-	/**
-	 * @var int Increment this value to trigger a schema update.
-	 */
-	protected $schema_version = 6;
+    /**
+     * @var int Increment this value to trigger a schema update.
+     */
+    protected $schema_version = 6;
 
-	public function __construct() {
-		$this->tables = array(
-			self::ACTIONS_TABLE,
-			self::CLAIMS_TABLE,
-			self::GROUPS_TABLE,
-		);
-	}
+    public function __construct() {
+        $this->tables = array(
+            self::ACTIONS_TABLE,
+            self::CLAIMS_TABLE,
+            self::GROUPS_TABLE,
+        );
+    }
 
-	/**
-	 * Performs additional setup work required to support this schema.
-	 */
-	public function init() {
-		add_action( 'action_scheduler_before_schema_update', array( $this, 'update_schema_5_0' ), 10, 2 );
-	}
+    /**
+     * Performs additional setup work required to support this schema.
+     */
+    public function init() {
+        add_action( 'action_scheduler_before_schema_update', array( $this, 'update_schema_5_0' ), 10, 2 );
+    }
 
-	protected function get_table_definition( $table ) {
-		global $wpdb;
-		$table_name       = $wpdb->$table;
-		$charset_collate  = $wpdb->get_charset_collate();
-		$max_index_length = 191; // @see wp_get_db_schema()
-		$default_date     = self::DEFAULT_DATE;
-		switch ( $table ) {
+    protected function get_table_definition( $table ) {
+        global $wpdb;
+        $table_name       = $wpdb->$table;
+        $charset_collate  = $wpdb->get_charset_collate();
+        $max_index_length = 191; // @see wp_get_db_schema()
+        $default_date     = self::DEFAULT_DATE;
+        switch ( $table ) {
 
-			case self::ACTIONS_TABLE:
-				return "CREATE TABLE {$table_name} (
+            case self::ACTIONS_TABLE:
+                return "CREATE TABLE {$table_name} (
 				        action_id bigint(20) unsigned NOT NULL auto_increment,
 				        hook varchar(191) NOT NULL,
 				        status varchar(20) NOT NULL,
@@ -66,61 +66,61 @@ 
 				        KEY `claim_id_status_scheduled_date_gmt` (`claim_id`, `status`, `scheduled_date_gmt`)
 				        ) $charset_collate";
 
-			case self::CLAIMS_TABLE:
-				return "CREATE TABLE {$table_name} (
+            case self::CLAIMS_TABLE:
+                return "CREATE TABLE {$table_name} (
 				        claim_id bigint(20) unsigned NOT NULL auto_increment,
 				        date_created_gmt datetime NULL default '${default_date}',
 				        PRIMARY KEY  (claim_id),
 				        KEY date_created_gmt (date_created_gmt)
 				        ) $charset_collate";
 
-			case self::GROUPS_TABLE:
-				return "CREATE TABLE {$table_name} (
+            case self::GROUPS_TABLE:
+                return "CREATE TABLE {$table_name} (
 				        group_id bigint(20) unsigned NOT NULL auto_increment,
 				        slug varchar(255) NOT NULL,
 				        PRIMARY KEY  (group_id),
 				        KEY slug (slug($max_index_length))
 				        ) $charset_collate";
 
-			default:
-				return '';
-		}
-	}
+            default:
+                return '';
+        }
+    }
 
-	/**
-	 * Update the actions table schema, allowing datetime fields to be NULL.
-	 *
-	 * This is needed because the NOT NULL constraint causes a conflict with some versions of MySQL
-	 * configured with sql_mode=NO_ZERO_DATE, which can for instance lead to tables not being created.
-	 *
-	 * Most other schema updates happen via ActionScheduler_Abstract_Schema::update_table(), however
-	 * that method relies on dbDelta() and this change is not possible when using that function.
-	 *
-	 * @param string $table Name of table being updated.
-	 * @param string $db_version The existing schema version of the table.
-	 */
-	public function update_schema_5_0( $table, $db_version ) {
-		global $wpdb;
+    /**
+     * Update the actions table schema, allowing datetime fields to be NULL.
+     *
+     * This is needed because the NOT NULL constraint causes a conflict with some versions of MySQL
+     * configured with sql_mode=NO_ZERO_DATE, which can for instance lead to tables not being created.
+     *
+     * Most other schema updates happen via ActionScheduler_Abstract_Schema::update_table(), however
+     * that method relies on dbDelta() and this change is not possible when using that function.
+     *
+     * @param string $table Name of table being updated.
+     * @param string $db_version The existing schema version of the table.
+     */
+    public function update_schema_5_0( $table, $db_version ) {
+        global $wpdb;
 
-		if ( 'actionscheduler_actions' !== $table || version_compare( $db_version, '5', '>=' ) ) {
-			return;
-		}
+        if ( 'actionscheduler_actions' !== $table || version_compare( $db_version, '5', '>=' ) ) {
+            return;
+        }
 
-		// phpcs:disable WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-		$table_name   = $wpdb->prefix . 'actionscheduler_actions';
-		$table_list   = $wpdb->get_col( "SHOW TABLES LIKE '${table_name}'" );
-		$default_date = self::DEFAULT_DATE;
+        // phpcs:disable WordPress.DB.PreparedSQL.InterpolatedNotPrepared
+        $table_name   = $wpdb->prefix . 'actionscheduler_actions';
+        $table_list   = $wpdb->get_col( "SHOW TABLES LIKE '${table_name}'" );
+        $default_date = self::DEFAULT_DATE;
 
-		if ( ! empty( $table_list ) ) {
-			$query = "
+        if ( ! empty( $table_list ) ) {
+            $query = "
 				ALTER TABLE ${table_name}
 				MODIFY COLUMN scheduled_date_gmt datetime NULL default '${default_date}',
 				MODIFY COLUMN scheduled_date_local datetime NULL default '${default_date}',
 				MODIFY COLUMN last_attempt_gmt datetime NULL default '${default_date}',
 				MODIFY COLUMN last_attempt_local datetime NULL default '${default_date}'
 		";
-			$wpdb->query( $query ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-		}
-		// phpcs:enable WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-	}
+            $wpdb->query( $query ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+        }
+        // phpcs:enable WordPress.DB.PreparedSQL.InterpolatedNotPrepared
+    }
 }

Spacing +9 added lines, -9 removed lines

@@ -30,16 +30,16 @@ 
 	 * Performs additional setup work required to support this schema.
 	 */
 	public function init() {
-		add_action( 'action_scheduler_before_schema_update', array( $this, 'update_schema_5_0' ), 10, 2 );
+		add_action('action_scheduler_before_schema_update', array($this, 'update_schema_5_0'), 10, 2);
 	}
 
-	protected function get_table_definition( $table ) {
+	protected function get_table_definition($table) {
 		global $wpdb;
 		$table_name       = $wpdb->$table;
 		$charset_collate  = $wpdb->get_charset_collate();
 		$max_index_length = 191; // @see wp_get_db_schema()
 		$default_date     = self::DEFAULT_DATE;
-		switch ( $table ) {
+		switch ($table) {
 
 			case self::ACTIONS_TABLE:
 				return "CREATE TABLE {$table_name} (
@@ -99,19 +99,19 @@ 
 	 * @param string $table Name of table being updated.
 	 * @param string $db_version The existing schema version of the table.
 	 */
-	public function update_schema_5_0( $table, $db_version ) {
+	public function update_schema_5_0($table, $db_version) {
 		global $wpdb;
 
-		if ( 'actionscheduler_actions' !== $table || version_compare( $db_version, '5', '>=' ) ) {
+		if ('actionscheduler_actions' !== $table || version_compare($db_version, '5', '>=')) {
 			return;
 		}
 
 		// phpcs:disable WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-		$table_name   = $wpdb->prefix . 'actionscheduler_actions';
-		$table_list   = $wpdb->get_col( "SHOW TABLES LIKE '${table_name}'" );
+		$table_name   = $wpdb->prefix.'actionscheduler_actions';
+		$table_list   = $wpdb->get_col("SHOW TABLES LIKE '${table_name}'");
 		$default_date = self::DEFAULT_DATE;
 
-		if ( ! empty( $table_list ) ) {
+		if ( ! empty($table_list)) {
 			$query = "
 				ALTER TABLE ${table_name}
 				MODIFY COLUMN scheduled_date_gmt datetime NULL default '${default_date}',
@@ -119,7 +119,7 @@ 
 				MODIFY COLUMN last_attempt_gmt datetime NULL default '${default_date}',
 				MODIFY COLUMN last_attempt_local datetime NULL default '${default_date}'
 		";
-			$wpdb->query( $query ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+			$wpdb->query($query); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
 		}
 		// phpcs:enable WordPress.DB.PreparedSQL.InterpolatedNotPrepared
 	}

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

Indentation +87 added lines, -87 removed lines

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

Spacing +25 added lines, -25 removed lines

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

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

Indentation +207 added lines, -207 removed lines

@@ -4,214 +4,214 @@
  * Class ActionScheduler_QueueRunner
  */
 class ActionScheduler_QueueRunner extends ActionScheduler_Abstract_QueueRunner {
-	const WP_CRON_HOOK = 'action_scheduler_run_queue';
-
-	const WP_CRON_SCHEDULE = 'every_minute';
-
-	/** @var ActionScheduler_AsyncRequest_QueueRunner */
-	protected $async_request;
-
-	/** @var ActionScheduler_QueueRunner  */
-	private static $runner = null;
-
-	/**
-	 * @return ActionScheduler_QueueRunner
-	 * @codeCoverageIgnore
-	 */
-	public static function instance() {
-		if ( empty( self::$runner ) ) {
-			$class        = apply_filters( 'action_scheduler_queue_runner_class', 'ActionScheduler_QueueRunner' );
-			self::$runner = new $class();
-		}
-		return self::$runner;
-	}
-
-	/**
-	 * ActionScheduler_QueueRunner constructor.
-	 *
-	 * @param ActionScheduler_Store             $store
-	 * @param ActionScheduler_FatalErrorMonitor $monitor
-	 * @param ActionScheduler_QueueCleaner      $cleaner
-	 */
-	public function __construct( ActionScheduler_Store $store = null, ActionScheduler_FatalErrorMonitor $monitor = null, ActionScheduler_QueueCleaner $cleaner = null, ActionScheduler_AsyncRequest_QueueRunner $async_request = null ) {
-		parent::__construct( $store, $monitor, $cleaner );
-
-		if ( $async_request === null ) {
-			$async_request = new ActionScheduler_AsyncRequest_QueueRunner( $this->store );
-		}
-
-		$this->async_request = $async_request;
-	}
-
-	/**
-	 * @codeCoverageIgnore
-	 */
-	public function init() {
-
-		add_filter( 'cron_schedules', array( self::instance(), 'add_wp_cron_schedule' ) );
-
-		// Check for and remove any WP Cron hook scheduled by Action Scheduler < 3.0.0, which didn't include the $context param
-		$next_timestamp = wp_next_scheduled( self::WP_CRON_HOOK );
-		if ( $next_timestamp ) {
-			wp_unschedule_event( $next_timestamp, self::WP_CRON_HOOK );
-		}
-
-		$cron_context = array( 'WP Cron' );
-
-		if ( ! wp_next_scheduled( self::WP_CRON_HOOK, $cron_context ) ) {
-			$schedule = apply_filters( 'action_scheduler_run_schedule', self::WP_CRON_SCHEDULE );
-			wp_schedule_event( time(), $schedule, self::WP_CRON_HOOK, $cron_context );
-		}
-
-		add_action( self::WP_CRON_HOOK, array( self::instance(), 'run' ) );
-		$this->hook_dispatch_async_request();
-	}
-
-	/**
-	 * Hook check for dispatching an async request.
-	 */
-	public function hook_dispatch_async_request() {
-		add_action( 'shutdown', array( $this, 'maybe_dispatch_async_request' ) );
-	}
-
-	/**
-	 * Unhook check for dispatching an async request.
-	 */
-	public function unhook_dispatch_async_request() {
-		remove_action( 'shutdown', array( $this, 'maybe_dispatch_async_request' ) );
-	}
-
-	/**
-	 * Check if we should dispatch an async request to process actions.
-	 *
-	 * This method is attached to 'shutdown', so is called frequently. To avoid slowing down
-	 * the site, it mitigates the work performed in each request by:
-	 * 1. checking if it's in the admin context and then
-	 * 2. haven't run on the 'shutdown' hook within the lock time (60 seconds by default)
-	 * 3. haven't exceeded the number of allowed batches.
-	 *
-	 * The order of these checks is important, because they run from a check on a value:
-	 * 1. in memory - is_admin() maps to $GLOBALS or the WP_ADMIN constant
-	 * 2. in memory - transients use autoloaded options by default
-	 * 3. from a database query - has_maximum_concurrent_batches() run the query
-	 *    $this->store->get_claim_count() to find the current number of claims in the DB.
-	 *
-	 * If all of these conditions are met, then we request an async runner check whether it
-	 * should dispatch a request to process pending actions.
-	 */
-	public function maybe_dispatch_async_request() {
-		if ( is_admin() && ! ActionScheduler::lock()->is_locked( 'async-request-runner' ) ) {
-			// Only start an async queue at most once every 60 seconds
-			ActionScheduler::lock()->set( 'async-request-runner' );
-			$this->async_request->maybe_dispatch();
-		}
-	}
-
-	/**
-	 * Process actions in the queue. Attached to self::WP_CRON_HOOK i.e. 'action_scheduler_run_queue'
-	 *
-	 * The $context param of this method defaults to 'WP Cron', because prior to Action Scheduler 3.0.0
-	 * that was the only context in which this method was run, and the self::WP_CRON_HOOK hook had no context
-	 * passed along with it. New code calling this method directly, or by triggering the self::WP_CRON_HOOK,
-	 * should set a context as the first parameter. For an example of this, refer to the code seen in
-	 *
-	 * @see ActionScheduler_AsyncRequest_QueueRunner::handle()
-	 *
-	 * @param string $context Optional identifer for the context in which this action is being processed, e.g. 'WP CLI' or 'WP Cron'
-	 *        Generally, this should be capitalised and not localised as it's a proper noun.
-	 * @return int The number of actions processed.
-	 */
-	public function run( $context = 'WP Cron' ) {
-		ActionScheduler_Compatibility::raise_memory_limit();
-		ActionScheduler_Compatibility::raise_time_limit( $this->get_time_limit() );
-		do_action( 'action_scheduler_before_process_queue' );
-		$this->run_cleanup();
-		$processed_actions = 0;
-		if ( false === $this->has_maximum_concurrent_batches() ) {
-			$batch_size = apply_filters( 'action_scheduler_queue_runner_batch_size', 25 );
-			do {
-				$processed_actions_in_batch = $this->do_batch( $batch_size, $context );
-				$processed_actions         += $processed_actions_in_batch;
-			} while ( $processed_actions_in_batch > 0 && ! $this->batch_limits_exceeded( $processed_actions ) ); // keep going until we run out of actions, time, or memory
-		}
-
-		do_action( 'action_scheduler_after_process_queue' );
-		return $processed_actions;
-	}
-
-	/**
-	 * Process a batch of actions pending in the queue.
-	 *
-	 * Actions are processed by claiming a set of pending actions then processing each one until either the batch
-	 * size is completed, or memory or time limits are reached, defined by @see $this->batch_limits_exceeded().
-	 *
-	 * @param int    $size The maximum number of actions to process in the batch.
-	 * @param string $context Optional identifer for the context in which this action is being processed, e.g. 'WP CLI' or 'WP Cron'
-	 *        Generally, this should be capitalised and not localised as it's a proper noun.
-	 * @return int The number of actions processed.
-	 */
-	protected function do_batch( $size = 100, $context = '' ) {
-		$claim = $this->store->stake_claim( $size );
-		$this->monitor->attach( $claim );
-		$processed_actions = 0;
-
-		foreach ( $claim->get_actions() as $action_id ) {
-			// bail if we lost the claim
-			if ( ! in_array( $action_id, $this->store->find_actions_by_claim_id( $claim->get_id() ) ) ) {
-				break;
-			}
-			$this->process_action( $action_id, $context );
-			$processed_actions++;
-
-			if ( $this->batch_limits_exceeded( $processed_actions ) ) {
-				break;
-			}
-		}
-		$this->store->release_claim( $claim );
-		$this->monitor->detach();
-		$this->clear_caches();
-		return $processed_actions;
-	}
-
-	/**
-	 * Flush the cache if possible (intended for use after a batch of actions has been processed).
-	 *
-	 * This is useful because running large batches can eat up memory and because invalid data can accrue in the
-	 * runtime cache, which may lead to unexpected results.
-	 */
-	protected function clear_caches() {
-		/*
+    const WP_CRON_HOOK = 'action_scheduler_run_queue';
+
+    const WP_CRON_SCHEDULE = 'every_minute';
+
+    /** @var ActionScheduler_AsyncRequest_QueueRunner */
+    protected $async_request;
+
+    /** @var ActionScheduler_QueueRunner  */
+    private static $runner = null;
+
+    /**
+     * @return ActionScheduler_QueueRunner
+     * @codeCoverageIgnore
+     */
+    public static function instance() {
+        if ( empty( self::$runner ) ) {
+            $class        = apply_filters( 'action_scheduler_queue_runner_class', 'ActionScheduler_QueueRunner' );
+            self::$runner = new $class();
+        }
+        return self::$runner;
+    }
+
+    /**
+     * ActionScheduler_QueueRunner constructor.
+     *
+     * @param ActionScheduler_Store             $store
+     * @param ActionScheduler_FatalErrorMonitor $monitor
+     * @param ActionScheduler_QueueCleaner      $cleaner
+     */
+    public function __construct( ActionScheduler_Store $store = null, ActionScheduler_FatalErrorMonitor $monitor = null, ActionScheduler_QueueCleaner $cleaner = null, ActionScheduler_AsyncRequest_QueueRunner $async_request = null ) {
+        parent::__construct( $store, $monitor, $cleaner );
+
+        if ( $async_request === null ) {
+            $async_request = new ActionScheduler_AsyncRequest_QueueRunner( $this->store );
+        }
+
+        $this->async_request = $async_request;
+    }
+
+    /**
+     * @codeCoverageIgnore
+     */
+    public function init() {
+
+        add_filter( 'cron_schedules', array( self::instance(), 'add_wp_cron_schedule' ) );
+
+        // Check for and remove any WP Cron hook scheduled by Action Scheduler < 3.0.0, which didn't include the $context param
+        $next_timestamp = wp_next_scheduled( self::WP_CRON_HOOK );
+        if ( $next_timestamp ) {
+            wp_unschedule_event( $next_timestamp, self::WP_CRON_HOOK );
+        }
+
+        $cron_context = array( 'WP Cron' );
+
+        if ( ! wp_next_scheduled( self::WP_CRON_HOOK, $cron_context ) ) {
+            $schedule = apply_filters( 'action_scheduler_run_schedule', self::WP_CRON_SCHEDULE );
+            wp_schedule_event( time(), $schedule, self::WP_CRON_HOOK, $cron_context );
+        }
+
+        add_action( self::WP_CRON_HOOK, array( self::instance(), 'run' ) );
+        $this->hook_dispatch_async_request();
+    }
+
+    /**
+     * Hook check for dispatching an async request.
+     */
+    public function hook_dispatch_async_request() {
+        add_action( 'shutdown', array( $this, 'maybe_dispatch_async_request' ) );
+    }
+
+    /**
+     * Unhook check for dispatching an async request.
+     */
+    public function unhook_dispatch_async_request() {
+        remove_action( 'shutdown', array( $this, 'maybe_dispatch_async_request' ) );
+    }
+
+    /**
+     * Check if we should dispatch an async request to process actions.
+     *
+     * This method is attached to 'shutdown', so is called frequently. To avoid slowing down
+     * the site, it mitigates the work performed in each request by:
+     * 1. checking if it's in the admin context and then
+     * 2. haven't run on the 'shutdown' hook within the lock time (60 seconds by default)
+     * 3. haven't exceeded the number of allowed batches.
+     *
+     * The order of these checks is important, because they run from a check on a value:
+     * 1. in memory - is_admin() maps to $GLOBALS or the WP_ADMIN constant
+     * 2. in memory - transients use autoloaded options by default
+     * 3. from a database query - has_maximum_concurrent_batches() run the query
+     *    $this->store->get_claim_count() to find the current number of claims in the DB.
+     *
+     * If all of these conditions are met, then we request an async runner check whether it
+     * should dispatch a request to process pending actions.
+     */
+    public function maybe_dispatch_async_request() {
+        if ( is_admin() && ! ActionScheduler::lock()->is_locked( 'async-request-runner' ) ) {
+            // Only start an async queue at most once every 60 seconds
+            ActionScheduler::lock()->set( 'async-request-runner' );
+            $this->async_request->maybe_dispatch();
+        }
+    }
+
+    /**
+     * Process actions in the queue. Attached to self::WP_CRON_HOOK i.e. 'action_scheduler_run_queue'
+     *
+     * The $context param of this method defaults to 'WP Cron', because prior to Action Scheduler 3.0.0
+     * that was the only context in which this method was run, and the self::WP_CRON_HOOK hook had no context
+     * passed along with it. New code calling this method directly, or by triggering the self::WP_CRON_HOOK,
+     * should set a context as the first parameter. For an example of this, refer to the code seen in
+     *
+     * @see ActionScheduler_AsyncRequest_QueueRunner::handle()
+     *
+     * @param string $context Optional identifer for the context in which this action is being processed, e.g. 'WP CLI' or 'WP Cron'
+     *        Generally, this should be capitalised and not localised as it's a proper noun.
+     * @return int The number of actions processed.
+     */
+    public function run( $context = 'WP Cron' ) {
+        ActionScheduler_Compatibility::raise_memory_limit();
+        ActionScheduler_Compatibility::raise_time_limit( $this->get_time_limit() );
+        do_action( 'action_scheduler_before_process_queue' );
+        $this->run_cleanup();
+        $processed_actions = 0;
+        if ( false === $this->has_maximum_concurrent_batches() ) {
+            $batch_size = apply_filters( 'action_scheduler_queue_runner_batch_size', 25 );
+            do {
+                $processed_actions_in_batch = $this->do_batch( $batch_size, $context );
+                $processed_actions         += $processed_actions_in_batch;
+            } while ( $processed_actions_in_batch > 0 && ! $this->batch_limits_exceeded( $processed_actions ) ); // keep going until we run out of actions, time, or memory
+        }
+
+        do_action( 'action_scheduler_after_process_queue' );
+        return $processed_actions;
+    }
+
+    /**
+     * Process a batch of actions pending in the queue.
+     *
+     * Actions are processed by claiming a set of pending actions then processing each one until either the batch
+     * size is completed, or memory or time limits are reached, defined by @see $this->batch_limits_exceeded().
+     *
+     * @param int    $size The maximum number of actions to process in the batch.
+     * @param string $context Optional identifer for the context in which this action is being processed, e.g. 'WP CLI' or 'WP Cron'
+     *        Generally, this should be capitalised and not localised as it's a proper noun.
+     * @return int The number of actions processed.
+     */
+    protected function do_batch( $size = 100, $context = '' ) {
+        $claim = $this->store->stake_claim( $size );
+        $this->monitor->attach( $claim );
+        $processed_actions = 0;
+
+        foreach ( $claim->get_actions() as $action_id ) {
+            // bail if we lost the claim
+            if ( ! in_array( $action_id, $this->store->find_actions_by_claim_id( $claim->get_id() ) ) ) {
+                break;
+            }
+            $this->process_action( $action_id, $context );
+            $processed_actions++;
+
+            if ( $this->batch_limits_exceeded( $processed_actions ) ) {
+                break;
+            }
+        }
+        $this->store->release_claim( $claim );
+        $this->monitor->detach();
+        $this->clear_caches();
+        return $processed_actions;
+    }
+
+    /**
+     * Flush the cache if possible (intended for use after a batch of actions has been processed).
+     *
+     * This is useful because running large batches can eat up memory and because invalid data can accrue in the
+     * runtime cache, which may lead to unexpected results.
+     */
+    protected function clear_caches() {
+        /*
 		 * Calling wp_cache_flush_runtime() lets us clear the runtime cache without invalidating the external object
 		 * cache, so we will always prefer this when it is available (but it was only introduced in WordPress 6.0).
 		 */
-		if ( function_exists( 'wp_cache_flush_runtime' ) ) {
-			wp_cache_flush_runtime();
-		} elseif (
-			! wp_using_ext_object_cache()
-			/**
-			 * When an external object cache is in use, and when wp_cache_flush_runtime() is not available, then
-			 * normally the cache will not be flushed after processing a batch of actions (to avoid a performance
-			 * penalty for other processes).
-			 *
-			 * This filter makes it possible to override this behavior and always flush the cache, even if an external
-			 * object cache is in use.
-			 *
-			 * @since 1.0
-			 *
-			 * @param bool $flush_cache If the cache should be flushed.
-			 */
-			|| apply_filters( 'action_scheduler_queue_runner_flush_cache', false )
-		) {
-			wp_cache_flush();
-		}
-	}
-
-	public function add_wp_cron_schedule( $schedules ) {
-		$schedules['every_minute'] = array(
-			'interval' => 60, // in seconds
-			'display'  => __( 'Every minute', 'action-scheduler' ),
-		);
-
-		return $schedules;
-	}
+        if ( function_exists( 'wp_cache_flush_runtime' ) ) {
+            wp_cache_flush_runtime();
+        } elseif (
+            ! wp_using_ext_object_cache()
+            /**
+             * When an external object cache is in use, and when wp_cache_flush_runtime() is not available, then
+             * normally the cache will not be flushed after processing a batch of actions (to avoid a performance
+             * penalty for other processes).
+             *
+             * This filter makes it possible to override this behavior and always flush the cache, even if an external
+             * object cache is in use.
+             *
+             * @since 1.0
+             *
+             * @param bool $flush_cache If the cache should be flushed.
+             */
+            || apply_filters( 'action_scheduler_queue_runner_flush_cache', false )
+        ) {
+            wp_cache_flush();
+        }
+    }
+
+    public function add_wp_cron_schedule( $schedules ) {
+        $schedules['every_minute'] = array(
+            'interval' => 60, // in seconds
+            'display'  => __( 'Every minute', 'action-scheduler' ),
+        );
+
+        return $schedules;
+    }
 }

Spacing +39 added lines, -39 removed lines

@@ -19,8 +19,8 @@ 
 	 * @codeCoverageIgnore
 	 */
 	public static function instance() {
-		if ( empty( self::$runner ) ) {
-			$class        = apply_filters( 'action_scheduler_queue_runner_class', 'ActionScheduler_QueueRunner' );
+		if (empty(self::$runner)) {
+			$class        = apply_filters('action_scheduler_queue_runner_class', 'ActionScheduler_QueueRunner');
 			self::$runner = new $class();
 		}
 		return self::$runner;
@@ -33,11 +33,11 @@ 
 	 * @param ActionScheduler_FatalErrorMonitor $monitor
 	 * @param ActionScheduler_QueueCleaner      $cleaner
 	 */
-	public function __construct( ActionScheduler_Store $store = null, ActionScheduler_FatalErrorMonitor $monitor = null, ActionScheduler_QueueCleaner $cleaner = null, ActionScheduler_AsyncRequest_QueueRunner $async_request = null ) {
-		parent::__construct( $store, $monitor, $cleaner );
+	public function __construct(ActionScheduler_Store $store = null, ActionScheduler_FatalErrorMonitor $monitor = null, ActionScheduler_QueueCleaner $cleaner = null, ActionScheduler_AsyncRequest_QueueRunner $async_request = null) {
+		parent::__construct($store, $monitor, $cleaner);
 
-		if ( $async_request === null ) {
-			$async_request = new ActionScheduler_AsyncRequest_QueueRunner( $this->store );
+		if ($async_request === null) {
+			$async_request = new ActionScheduler_AsyncRequest_QueueRunner($this->store);
 		}
 
 		$this->async_request = $async_request;
@@ -48,22 +48,22 @@ 
 	 */
 	public function init() {
 
-		add_filter( 'cron_schedules', array( self::instance(), 'add_wp_cron_schedule' ) );
+		add_filter('cron_schedules', array(self::instance(), 'add_wp_cron_schedule'));
 
 		// Check for and remove any WP Cron hook scheduled by Action Scheduler < 3.0.0, which didn't include the $context param
-		$next_timestamp = wp_next_scheduled( self::WP_CRON_HOOK );
-		if ( $next_timestamp ) {
-			wp_unschedule_event( $next_timestamp, self::WP_CRON_HOOK );
+		$next_timestamp = wp_next_scheduled(self::WP_CRON_HOOK);
+		if ($next_timestamp) {
+			wp_unschedule_event($next_timestamp, self::WP_CRON_HOOK);
 		}
 
-		$cron_context = array( 'WP Cron' );
+		$cron_context = array('WP Cron');
 
-		if ( ! wp_next_scheduled( self::WP_CRON_HOOK, $cron_context ) ) {
-			$schedule = apply_filters( 'action_scheduler_run_schedule', self::WP_CRON_SCHEDULE );
-			wp_schedule_event( time(), $schedule, self::WP_CRON_HOOK, $cron_context );
+		if ( ! wp_next_scheduled(self::WP_CRON_HOOK, $cron_context)) {
+			$schedule = apply_filters('action_scheduler_run_schedule', self::WP_CRON_SCHEDULE);
+			wp_schedule_event(time(), $schedule, self::WP_CRON_HOOK, $cron_context);
 		}
 
-		add_action( self::WP_CRON_HOOK, array( self::instance(), 'run' ) );
+		add_action(self::WP_CRON_HOOK, array(self::instance(), 'run'));
 		$this->hook_dispatch_async_request();
 	}
 
@@ -71,14 +71,14 @@ 
 	 * Hook check for dispatching an async request.
 	 */
 	public function hook_dispatch_async_request() {
-		add_action( 'shutdown', array( $this, 'maybe_dispatch_async_request' ) );
+		add_action('shutdown', array($this, 'maybe_dispatch_async_request'));
 	}
 
 	/**
 	 * Unhook check for dispatching an async request.
 	 */
 	public function unhook_dispatch_async_request() {
-		remove_action( 'shutdown', array( $this, 'maybe_dispatch_async_request' ) );
+		remove_action('shutdown', array($this, 'maybe_dispatch_async_request'));
 	}
 
 	/**
@@ -100,9 +100,9 @@ 
 	 * should dispatch a request to process pending actions.
 	 */
 	public function maybe_dispatch_async_request() {
-		if ( is_admin() && ! ActionScheduler::lock()->is_locked( 'async-request-runner' ) ) {
+		if (is_admin() && ! ActionScheduler::lock()->is_locked('async-request-runner')) {
 			// Only start an async queue at most once every 60 seconds
-			ActionScheduler::lock()->set( 'async-request-runner' );
+			ActionScheduler::lock()->set('async-request-runner');
 			$this->async_request->maybe_dispatch();
 		}
 	}
@@ -121,21 +121,21 @@ 
 	 *        Generally, this should be capitalised and not localised as it's a proper noun.
 	 * @return int The number of actions processed.
 	 */
-	public function run( $context = 'WP Cron' ) {
+	public function run($context = 'WP Cron') {
 		ActionScheduler_Compatibility::raise_memory_limit();
-		ActionScheduler_Compatibility::raise_time_limit( $this->get_time_limit() );
-		do_action( 'action_scheduler_before_process_queue' );
+		ActionScheduler_Compatibility::raise_time_limit($this->get_time_limit());
+		do_action('action_scheduler_before_process_queue');
 		$this->run_cleanup();
 		$processed_actions = 0;
-		if ( false === $this->has_maximum_concurrent_batches() ) {
-			$batch_size = apply_filters( 'action_scheduler_queue_runner_batch_size', 25 );
+		if (false === $this->has_maximum_concurrent_batches()) {
+			$batch_size = apply_filters('action_scheduler_queue_runner_batch_size', 25);
 			do {
-				$processed_actions_in_batch = $this->do_batch( $batch_size, $context );
+				$processed_actions_in_batch = $this->do_batch($batch_size, $context);
 				$processed_actions         += $processed_actions_in_batch;
-			} while ( $processed_actions_in_batch > 0 && ! $this->batch_limits_exceeded( $processed_actions ) ); // keep going until we run out of actions, time, or memory
+			} while ($processed_actions_in_batch > 0 && ! $this->batch_limits_exceeded($processed_actions)); // keep going until we run out of actions, time, or memory
 		}
 
-		do_action( 'action_scheduler_after_process_queue' );
+		do_action('action_scheduler_after_process_queue');
 		return $processed_actions;
 	}
 
@@ -150,24 +150,24 @@ 
 	 *        Generally, this should be capitalised and not localised as it's a proper noun.
 	 * @return int The number of actions processed.
 	 */
-	protected function do_batch( $size = 100, $context = '' ) {
-		$claim = $this->store->stake_claim( $size );
-		$this->monitor->attach( $claim );
+	protected function do_batch($size = 100, $context = '') {
+		$claim = $this->store->stake_claim($size);
+		$this->monitor->attach($claim);
 		$processed_actions = 0;
 
-		foreach ( $claim->get_actions() as $action_id ) {
+		foreach ($claim->get_actions() as $action_id) {
 			// bail if we lost the claim
-			if ( ! in_array( $action_id, $this->store->find_actions_by_claim_id( $claim->get_id() ) ) ) {
+			if ( ! in_array($action_id, $this->store->find_actions_by_claim_id($claim->get_id()))) {
 				break;
 			}
-			$this->process_action( $action_id, $context );
+			$this->process_action($action_id, $context);
 			$processed_actions++;
 
-			if ( $this->batch_limits_exceeded( $processed_actions ) ) {
+			if ($this->batch_limits_exceeded($processed_actions)) {
 				break;
 			}
 		}
-		$this->store->release_claim( $claim );
+		$this->store->release_claim($claim);
 		$this->monitor->detach();
 		$this->clear_caches();
 		return $processed_actions;
@@ -184,7 +184,7 @@ 
 		 * Calling wp_cache_flush_runtime() lets us clear the runtime cache without invalidating the external object
 		 * cache, so we will always prefer this when it is available (but it was only introduced in WordPress 6.0).
 		 */
-		if ( function_exists( 'wp_cache_flush_runtime' ) ) {
+		if (function_exists('wp_cache_flush_runtime')) {
 			wp_cache_flush_runtime();
 		} elseif (
 			! wp_using_ext_object_cache()
@@ -200,16 +200,16 @@ 
 			 *
 			 * @param bool $flush_cache If the cache should be flushed.
 			 */
-			|| apply_filters( 'action_scheduler_queue_runner_flush_cache', false )
+			|| apply_filters('action_scheduler_queue_runner_flush_cache', false)
 		) {
 			wp_cache_flush();
 		}
 	}
 
-	public function add_wp_cron_schedule( $schedules ) {
+	public function add_wp_cron_schedule($schedules) {
 		$schedules['every_minute'] = array(
 			'interval' => 60, // in seconds
-			'display'  => __( 'Every minute', 'action-scheduler' ),
+			'display'  => __('Every minute', 'action-scheduler'),
 		);
 
 		return $schedules;

src/libraries/action-scheduler/classes/data-stores/ActionScheduler_DBStore.php

Indentation +1043 added lines, -1043 removed lines

@@ -9,1055 +9,1055 @@
  */
 class ActionScheduler_DBStore extends ActionScheduler_Store {
 
-	/**
-	 * Used to share information about the before_date property of claims internally.
-	 *
-	 * This is used in preference to passing the same information as a method param
-	 * for backwards-compatibility reasons.
-	 *
-	 * @var DateTime|null
-	 */
-	private $claim_before_date = null;
-
-	/** @var int */
-	protected static $max_args_length = 8000;
-
-	/** @var int */
-	protected static $max_index_length = 191;
-
-	/**
-	 * Initialize the data store
-	 *
-	 * @codeCoverageIgnore
-	 */
-	public function init() {
-		$table_maker = new ActionScheduler_StoreSchema();
-		$table_maker->init();
-		$table_maker->register_tables();
-	}
-
-	/**
-	 * Save an action, checks if this is a unique action before actually saving.
-	 *
-	 * @param ActionScheduler_Action $action         Action object.
-	 * @param \DateTime              $scheduled_date Optional schedule date. Default null.
-	 *
-	 * @return int                  Action ID.
-	 * @throws RuntimeException     Throws exception when saving the action fails.
-	 */
-	public function save_unique_action( ActionScheduler_Action $action, \DateTime $scheduled_date = null ) {
-		return $this->save_action_to_db( $action, $scheduled_date, true );
-	}
-
-	/**
-	 * Save an action. Can save duplicate action as well, prefer using `save_unique_action` instead.
-	 *
-	 * @param ActionScheduler_Action $action Action object.
-	 * @param \DateTime              $scheduled_date Optional schedule date. Default null.
-	 *
-	 * @return int Action ID.
-	 * @throws RuntimeException     Throws exception when saving the action fails.
-	 */
-	public function save_action( ActionScheduler_Action $action, \DateTime $scheduled_date = null ) {
-		return $this->save_action_to_db( $action, $scheduled_date, false );
-	}
-
-	/**
-	 * Save an action.
-	 *
-	 * @param ActionScheduler_Action $action Action object.
-	 * @param ?DateTime              $date Optional schedule date. Default null.
-	 * @param bool                   $unique Whether the action should be unique.
-	 *
-	 * @return int Action ID.
-	 * @throws RuntimeException     Throws exception when saving the action fails.
-	 */
-	private function save_action_to_db( ActionScheduler_Action $action, DateTime $date = null, $unique = false ) {
-		global $wpdb;
-
-		try {
-			$this->validate_action( $action );
-
-			$data = array(
-				'hook'                 => $action->get_hook(),
-				'status'               => ( $action->is_finished() ? self::STATUS_COMPLETE : self::STATUS_PENDING ),
-				'scheduled_date_gmt'   => $this->get_scheduled_date_string( $action, $date ),
-				'scheduled_date_local' => $this->get_scheduled_date_string_local( $action, $date ),
-				'schedule'             => serialize( $action->get_schedule() ), // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_serialize
-				'group_id'             => $this->get_group_id( $action->get_group() ),
-			);
-
-			$args = wp_json_encode( $action->get_args() );
-			if ( strlen( $args ) <= static::$max_index_length ) {
-				$data['args'] = $args;
-			} else {
-				$data['args']          = $this->hash_args( $args );
-				$data['extended_args'] = $args;
-			}
-
-			$insert_sql = $this->build_insert_sql( $data, $unique );
-
-			// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared -- $insert_sql should be already prepared.
-			$wpdb->query( $insert_sql );
-			$action_id = $wpdb->insert_id;
-
-			if ( is_wp_error( $action_id ) ) {
-				throw new \RuntimeException( $action_id->get_error_message() );
-			} elseif ( empty( $action_id ) ) {
-				if ( $unique ) {
-					return 0;
-				}
-				throw new \RuntimeException( $wpdb->last_error ? $wpdb->last_error : __( 'Database error.', 'action-scheduler' ) );
-			}
-
-			do_action( 'action_scheduler_stored_action', $action_id );
-
-			return $action_id;
-		} catch ( \Exception $e ) {
-			/* translators: %s: error message */
-			throw new \RuntimeException( sprintf( __( 'Error saving action: %s', 'action-scheduler' ), $e->getMessage() ), 0 );
-		}
-	}
-
-	/**
-	 * Helper function to build insert query.
-	 *
-	 * @param array $data Row data for action.
-	 * @param bool  $unique Whether the action should be unique.
-	 *
-	 * @return string Insert query.
-	 */
-	private function build_insert_sql( array $data, $unique ) {
-		global $wpdb;
-		$columns      = array_keys( $data );
-		$values       = array_values( $data );
-		$placeholders = array_map( array( $this, 'get_placeholder_for_column' ), $columns );
-
-		$table_name = ! empty( $wpdb->actionscheduler_actions ) ? $wpdb->actionscheduler_actions : $wpdb->prefix . 'actionscheduler_actions';
-
-		$column_sql      = '`' . implode( '`, `', $columns ) . '`';
-		$placeholder_sql = implode( ', ', $placeholders );
-		$where_clause    = $this->build_where_clause_for_insert( $data, $table_name, $unique );
-		// phpcs:disable WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.PreparedSQL.InterpolatedNotPrepared -- $column_sql and $where_clause are already prepared. $placeholder_sql is hardcoded.
-		$insert_query = $wpdb->prepare(
-			"
+    /**
+     * Used to share information about the before_date property of claims internally.
+     *
+     * This is used in preference to passing the same information as a method param
+     * for backwards-compatibility reasons.
+     *
+     * @var DateTime|null
+     */
+    private $claim_before_date = null;
+
+    /** @var int */
+    protected static $max_args_length = 8000;
+
+    /** @var int */
+    protected static $max_index_length = 191;
+
+    /**
+     * Initialize the data store
+     *
+     * @codeCoverageIgnore
+     */
+    public function init() {
+        $table_maker = new ActionScheduler_StoreSchema();
+        $table_maker->init();
+        $table_maker->register_tables();
+    }
+
+    /**
+     * Save an action, checks if this is a unique action before actually saving.
+     *
+     * @param ActionScheduler_Action $action         Action object.
+     * @param \DateTime              $scheduled_date Optional schedule date. Default null.
+     *
+     * @return int                  Action ID.
+     * @throws RuntimeException     Throws exception when saving the action fails.
+     */
+    public function save_unique_action( ActionScheduler_Action $action, \DateTime $scheduled_date = null ) {
+        return $this->save_action_to_db( $action, $scheduled_date, true );
+    }
+
+    /**
+     * Save an action. Can save duplicate action as well, prefer using `save_unique_action` instead.
+     *
+     * @param ActionScheduler_Action $action Action object.
+     * @param \DateTime              $scheduled_date Optional schedule date. Default null.
+     *
+     * @return int Action ID.
+     * @throws RuntimeException     Throws exception when saving the action fails.
+     */
+    public function save_action( ActionScheduler_Action $action, \DateTime $scheduled_date = null ) {
+        return $this->save_action_to_db( $action, $scheduled_date, false );
+    }
+
+    /**
+     * Save an action.
+     *
+     * @param ActionScheduler_Action $action Action object.
+     * @param ?DateTime              $date Optional schedule date. Default null.
+     * @param bool                   $unique Whether the action should be unique.
+     *
+     * @return int Action ID.
+     * @throws RuntimeException     Throws exception when saving the action fails.
+     */
+    private function save_action_to_db( ActionScheduler_Action $action, DateTime $date = null, $unique = false ) {
+        global $wpdb;
+
+        try {
+            $this->validate_action( $action );
+
+            $data = array(
+                'hook'                 => $action->get_hook(),
+                'status'               => ( $action->is_finished() ? self::STATUS_COMPLETE : self::STATUS_PENDING ),
+                'scheduled_date_gmt'   => $this->get_scheduled_date_string( $action, $date ),
+                'scheduled_date_local' => $this->get_scheduled_date_string_local( $action, $date ),
+                'schedule'             => serialize( $action->get_schedule() ), // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_serialize
+                'group_id'             => $this->get_group_id( $action->get_group() ),
+            );
+
+            $args = wp_json_encode( $action->get_args() );
+            if ( strlen( $args ) <= static::$max_index_length ) {
+                $data['args'] = $args;
+            } else {
+                $data['args']          = $this->hash_args( $args );
+                $data['extended_args'] = $args;
+            }
+
+            $insert_sql = $this->build_insert_sql( $data, $unique );
+
+            // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared -- $insert_sql should be already prepared.
+            $wpdb->query( $insert_sql );
+            $action_id = $wpdb->insert_id;
+
+            if ( is_wp_error( $action_id ) ) {
+                throw new \RuntimeException( $action_id->get_error_message() );
+            } elseif ( empty( $action_id ) ) {
+                if ( $unique ) {
+                    return 0;
+                }
+                throw new \RuntimeException( $wpdb->last_error ? $wpdb->last_error : __( 'Database error.', 'action-scheduler' ) );
+            }
+
+            do_action( 'action_scheduler_stored_action', $action_id );
+
+            return $action_id;
+        } catch ( \Exception $e ) {
+            /* translators: %s: error message */
+            throw new \RuntimeException( sprintf( __( 'Error saving action: %s', 'action-scheduler' ), $e->getMessage() ), 0 );
+        }
+    }
+
+    /**
+     * Helper function to build insert query.
+     *
+     * @param array $data Row data for action.
+     * @param bool  $unique Whether the action should be unique.
+     *
+     * @return string Insert query.
+     */
+    private function build_insert_sql( array $data, $unique ) {
+        global $wpdb;
+        $columns      = array_keys( $data );
+        $values       = array_values( $data );
+        $placeholders = array_map( array( $this, 'get_placeholder_for_column' ), $columns );
+
+        $table_name = ! empty( $wpdb->actionscheduler_actions ) ? $wpdb->actionscheduler_actions : $wpdb->prefix . 'actionscheduler_actions';
+
+        $column_sql      = '`' . implode( '`, `', $columns ) . '`';
+        $placeholder_sql = implode( ', ', $placeholders );
+        $where_clause    = $this->build_where_clause_for_insert( $data, $table_name, $unique );
+        // phpcs:disable WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.PreparedSQL.InterpolatedNotPrepared -- $column_sql and $where_clause are already prepared. $placeholder_sql is hardcoded.
+        $insert_query = $wpdb->prepare(
+            "
 INSERT INTO $table_name ( $column_sql )
 SELECT $placeholder_sql FROM DUAL
 WHERE ( $where_clause ) IS NULL",
-			$values
-		);
-		// phpcs:enable
-
-		return $insert_query;
-	}
-
-	/**
-	 * Helper method to build where clause for action insert statement.
-	 *
-	 * @param array  $data Row data for action.
-	 * @param string $table_name Action table name.
-	 * @param bool   $unique Where action should be unique.
-	 *
-	 * @return string Where clause to be used with insert.
-	 */
-	private function build_where_clause_for_insert( $data, $table_name, $unique ) {
-		global $wpdb;
-
-		if ( ! $unique ) {
-			return 'SELECT NULL FROM DUAL';
-		}
-
-		$pending_statuses            = array(
-			ActionScheduler_Store::STATUS_PENDING,
-			ActionScheduler_Store::STATUS_RUNNING,
-		);
-		$pending_status_placeholders = implode( ', ', array_fill( 0, count( $pending_statuses ), '%s' ) );
-		// phpcs:disable WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.PreparedSQL.InterpolatedNotPrepared -- $pending_status_placeholders is hardcoded.
-		$where_clause = $wpdb->prepare(
-			"
+            $values
+        );
+        // phpcs:enable
+
+        return $insert_query;
+    }
+
+    /**
+     * Helper method to build where clause for action insert statement.
+     *
+     * @param array  $data Row data for action.
+     * @param string $table_name Action table name.
+     * @param bool   $unique Where action should be unique.
+     *
+     * @return string Where clause to be used with insert.
+     */
+    private function build_where_clause_for_insert( $data, $table_name, $unique ) {
+        global $wpdb;
+
+        if ( ! $unique ) {
+            return 'SELECT NULL FROM DUAL';
+        }
+
+        $pending_statuses            = array(
+            ActionScheduler_Store::STATUS_PENDING,
+            ActionScheduler_Store::STATUS_RUNNING,
+        );
+        $pending_status_placeholders = implode( ', ', array_fill( 0, count( $pending_statuses ), '%s' ) );
+        // phpcs:disable WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.PreparedSQL.InterpolatedNotPrepared -- $pending_status_placeholders is hardcoded.
+        $where_clause = $wpdb->prepare(
+            "
 SELECT action_id FROM $table_name
 WHERE status IN ( $pending_status_placeholders )
 AND hook = %s
 AND `group_id` = %d
 ",
-			array_merge(
-				$pending_statuses,
-				array(
-					$data['hook'],
-					$data['group_id'],
-				)
-			)
-		);
-		// phpcs:enable
-
-		return "$where_clause" . ' LIMIT 1';
-	}
-
-	/**
-	 * Helper method to get $wpdb->prepare placeholder for a given column name.
-	 *
-	 * @param string $column_name Name of column in actions table.
-	 *
-	 * @return string Placeholder to use for given column.
-	 */
-	private function get_placeholder_for_column( $column_name ) {
-		$string_columns = array(
-			'hook',
-			'status',
-			'scheduled_date_gmt',
-			'scheduled_date_local',
-			'args',
-			'schedule',
-			'last_attempt_gmt',
-			'last_attempt_local',
-			'extended_args',
-		);
-
-		return in_array( $column_name, $string_columns ) ? '%s' : '%d';
-	}
-
-	/**
-	 * Generate a hash from json_encoded $args using MD5 as this isn't for security.
-	 *
-	 * @param string $args JSON encoded action args.
-	 * @return string
-	 */
-	protected function hash_args( $args ) {
-		return md5( $args );
-	}
-
-	/**
-	 * Get action args query param value from action args.
-	 *
-	 * @param array $args Action args.
-	 * @return string
-	 */
-	protected function get_args_for_query( $args ) {
-		$encoded = wp_json_encode( $args );
-		if ( strlen( $encoded ) <= static::$max_index_length ) {
-			return $encoded;
-		}
-		return $this->hash_args( $encoded );
-	}
-	/**
-	 * Get a group's ID based on its name/slug.
-	 *
-	 * @param string $slug The string name of a group.
-	 * @param bool   $create_if_not_exists Whether to create the group if it does not already exist. Default, true - create the group.
-	 *
-	 * @return int The group's ID, if it exists or is created, or 0 if it does not exist and is not created.
-	 */
-	protected function get_group_id( $slug, $create_if_not_exists = true ) {
-		if ( empty( $slug ) ) {
-			return 0;
-		}
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-		$group_id = (int) $wpdb->get_var( $wpdb->prepare( "SELECT group_id FROM {$wpdb->actionscheduler_groups} WHERE slug=%s", $slug ) );
-		if ( empty( $group_id ) && $create_if_not_exists ) {
-			$group_id = $this->create_group( $slug );
-		}
-
-		return $group_id;
-	}
-
-	/**
-	 * Create an action group.
-	 *
-	 * @param string $slug Group slug.
-	 *
-	 * @return int Group ID.
-	 */
-	protected function create_group( $slug ) {
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-		$wpdb->insert( $wpdb->actionscheduler_groups, array( 'slug' => $slug ) );
-
-		return (int) $wpdb->insert_id;
-	}
-
-	/**
-	 * Retrieve an action.
-	 *
-	 * @param int $action_id Action ID.
-	 *
-	 * @return ActionScheduler_Action
-	 */
-	public function fetch_action( $action_id ) {
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-		$data = $wpdb->get_row(
-			$wpdb->prepare(
-				"SELECT a.*, g.slug AS `group` FROM {$wpdb->actionscheduler_actions} a LEFT JOIN {$wpdb->actionscheduler_groups} g ON a.group_id=g.group_id WHERE a.action_id=%d",
-				$action_id
-			)
-		);
-
-		if ( empty( $data ) ) {
-			return $this->get_null_action();
-		}
-
-		if ( ! empty( $data->extended_args ) ) {
-			$data->args = $data->extended_args;
-			unset( $data->extended_args );
-		}
-
-		// Convert NULL dates to zero dates.
-		$date_fields = array(
-			'scheduled_date_gmt',
-			'scheduled_date_local',
-			'last_attempt_gmt',
-			'last_attempt_gmt',
-		);
-		foreach ( $date_fields as $date_field ) {
-			if ( $data->$date_field === null ) {
-				$data->$date_field = ActionScheduler_StoreSchema::DEFAULT_DATE;
-			}
-		}
-
-		try {
-			$action = $this->make_action_from_db_record( $data );
-		} catch ( ActionScheduler_InvalidActionException $exception ) {
-			do_action( 'action_scheduler_failed_fetch_action', $action_id, $exception );
-			return $this->get_null_action();
-		}
-
-		return $action;
-	}
-
-	/**
-	 * Create a null action.
-	 *
-	 * @return ActionScheduler_NullAction
-	 */
-	protected function get_null_action() {
-		return new ActionScheduler_NullAction();
-	}
-
-	/**
-	 * Create an action from a database record.
-	 *
-	 * @param object $data Action database record.
-	 *
-	 * @return ActionScheduler_Action|ActionScheduler_CanceledAction|ActionScheduler_FinishedAction
-	 */
-	protected function make_action_from_db_record( $data ) {
-
-		$hook     = $data->hook;
-		$args     = json_decode( $data->args, true );
-		$schedule = unserialize( $data->schedule ); // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_unserialize
-
-		$this->validate_args( $args, $data->action_id );
-		$this->validate_schedule( $schedule, $data->action_id );
-
-		if ( empty( $schedule ) ) {
-			$schedule = new ActionScheduler_NullSchedule();
-		}
-		$group = $data->group ? $data->group : '';
-
-		return ActionScheduler::factory()->get_stored_action( $data->status, $data->hook, $args, $schedule, $group );
-	}
-
-	/**
-	 * Returns the SQL statement to query (or count) actions.
-	 *
-	 * @since 3.3.0 $query['status'] accepts array of statuses instead of a single status.
-	 *
-	 * @param array  $query Filtering options.
-	 * @param string $select_or_count  Whether the SQL should select and return the IDs or just the row count.
-	 *
-	 * @return string SQL statement already properly escaped.
-	 * @throws InvalidArgumentException If the query is invalid.
-	 */
-	protected function get_query_actions_sql( array $query, $select_or_count = 'select' ) {
-
-		if ( ! in_array( $select_or_count, array( 'select', 'count' ), true ) ) {
-			throw new InvalidArgumentException( __( 'Invalid value for select or count parameter. Cannot query actions.', 'action-scheduler' ) );
-		}
-
-		$query = wp_parse_args(
-			$query,
-			array(
-				'hook'                  => '',
-				'args'                  => null,
-				'partial_args_matching' => 'off', // can be 'like' or 'json'
-				'date'                  => null,
-				'date_compare'          => '<=',
-				'modified'              => null,
-				'modified_compare'      => '<=',
-				'group'                 => '',
-				'status'                => '',
-				'claimed'               => null,
-				'per_page'              => 5,
-				'offset'                => 0,
-				'orderby'               => 'date',
-				'order'                 => 'ASC',
-			)
-		);
-
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-
-		$db_server_info = is_callable( array( $wpdb, 'db_server_info' ) ) ? $wpdb->db_server_info() : $wpdb->db_version();
-		if ( false !== strpos( $db_server_info, 'MariaDB' ) ) {
-			$supports_json = version_compare(
-				PHP_VERSION_ID >= 80016 ? $wpdb->db_version() : preg_replace( '/[^0-9.].*/', '', str_replace( '5.5.5-', '', $db_server_info ) ),
-				'10.2',
-				'>='
-			);
-		} else {
-			$supports_json = version_compare( $wpdb->db_version(), '5.7', '>=' );
-		}
-
-		$sql        = ( 'count' === $select_or_count ) ? 'SELECT count(a.action_id)' : 'SELECT a.action_id';
-		$sql       .= " FROM {$wpdb->actionscheduler_actions} a";
-		$sql_params = array();
-
-		if ( ! empty( $query['group'] ) || 'group' === $query['orderby'] ) {
-			$sql .= " LEFT JOIN {$wpdb->actionscheduler_groups} g ON g.group_id=a.group_id";
-		}
-
-		$sql .= ' WHERE 1=1';
-
-		if ( ! empty( $query['group'] ) ) {
-			$sql         .= ' AND g.slug=%s';
-			$sql_params[] = $query['group'];
-		}
-
-		if ( ! empty( $query['hook'] ) ) {
-			$sql         .= ' AND a.hook=%s';
-			$sql_params[] = $query['hook'];
-		}
-
-		if ( $query['args'] !== null ) {
-			switch ( $query['partial_args_matching'] ) {
-				case 'json':
-					if ( ! $supports_json ) {
-						throw new \RuntimeException( __( 'JSON partial matching not supported in your environment. Please check your MySQL/MariaDB version.', 'action-scheduler' ) );
-					}
-					$supported_types = array(
-						'integer' => '%d',
-						'boolean' => '%s',
-						'double'  => '%f',
-						'string'  => '%s',
-					);
-					foreach ( $query['args'] as $key => $value ) {
-						$value_type = gettype( $value );
-						if ( 'boolean' === $value_type ) {
-							$value = $value ? 'true' : 'false';
-						}
-						$placeholder = isset( $supported_types[ $value_type ] ) ? $supported_types[ $value_type ] : false;
-						if ( ! $placeholder ) {
-							throw new \RuntimeException(
-								sprintf(
-								/* translators: %s: provided value type */
-									__( 'The value type for the JSON partial matching is not supported. Must be either integer, boolean, double or string. %s type provided.', 'action-scheduler' ),
-									$value_type
-								)
-							);
-						}
-						$sql         .= ' AND JSON_EXTRACT(a.args, %s)=' . $placeholder;
-						$sql_params[] = '$.' . $key;
-						$sql_params[] = $value;
-					}
-					break;
-				case 'like':
-					foreach ( $query['args'] as $key => $value ) {
-						$sql         .= ' AND a.args LIKE %s';
-						$json_partial = $wpdb->esc_like( trim( json_encode( array( $key => $value ) ), '{}' ) );
-						$sql_params[] = "%{$json_partial}%";
-					}
-					break;
-				case 'off':
-					$sql         .= ' AND a.args=%s';
-					$sql_params[] = $this->get_args_for_query( $query['args'] );
-					break;
-				default:
-					throw new \RuntimeException( __( 'Unknown partial args matching value.', 'action-scheduler' ) );
-			}
-		}
-
-		if ( $query['status'] ) {
-			$statuses     = (array) $query['status'];
-			$placeholders = array_fill( 0, count( $statuses ), '%s' );
-			$sql         .= ' AND a.status IN (' . join( ', ', $placeholders ) . ')';
-			$sql_params   = array_merge( $sql_params, array_values( $statuses ) );
-		}
-
-		if ( $query['date'] instanceof \DateTime ) {
-			$date = clone $query['date'];
-			$date->setTimezone( new \DateTimeZone( 'UTC' ) );
-			$date_string  = $date->format( 'Y-m-d H:i:s' );
-			$comparator   = $this->validate_sql_comparator( $query['date_compare'] );
-			$sql         .= " AND a.scheduled_date_gmt $comparator %s";
-			$sql_params[] = $date_string;
-		}
-
-		if ( $query['modified'] instanceof \DateTime ) {
-			$modified = clone $query['modified'];
-			$modified->setTimezone( new \DateTimeZone( 'UTC' ) );
-			$date_string  = $modified->format( 'Y-m-d H:i:s' );
-			$comparator   = $this->validate_sql_comparator( $query['modified_compare'] );
-			$sql         .= " AND a.last_attempt_gmt $comparator %s";
-			$sql_params[] = $date_string;
-		}
-
-		if ( true === $query['claimed'] ) {
-			$sql .= ' AND a.claim_id != 0';
-		} elseif ( false === $query['claimed'] ) {
-			$sql .= ' AND a.claim_id = 0';
-		} elseif ( $query['claimed'] !== null ) {
-			$sql         .= ' AND a.claim_id = %d';
-			$sql_params[] = $query['claimed'];
-		}
-
-		if ( ! empty( $query['search'] ) ) {
-			$sql .= ' AND (a.hook LIKE %s OR (a.extended_args IS NULL AND a.args LIKE %s) OR a.extended_args LIKE %s';
-			for ( $i = 0; $i < 3; $i++ ) {
-				$sql_params[] = sprintf( '%%%s%%', $query['search'] );
-			}
-
-			$search_claim_id = (int) $query['search'];
-			if ( $search_claim_id ) {
-				$sql         .= ' OR a.claim_id = %d';
-				$sql_params[] = $search_claim_id;
-			}
-
-			$sql .= ')';
-		}
-
-		if ( 'select' === $select_or_count ) {
-			if ( 'ASC' === strtoupper( $query['order'] ) ) {
-				$order = 'ASC';
-			} else {
-				$order = 'DESC';
-			}
-			switch ( $query['orderby'] ) {
-				case 'hook':
-					$sql .= " ORDER BY a.hook $order";
-					break;
-				case 'group':
-					$sql .= " ORDER BY g.slug $order";
-					break;
-				case 'modified':
-					$sql .= " ORDER BY a.last_attempt_gmt $order";
-					break;
-				case 'none':
-					break;
-				case 'action_id':
-					$sql .= " ORDER BY a.action_id $order";
-					break;
-				case 'date':
-				default:
-					$sql .= " ORDER BY a.scheduled_date_gmt $order";
-					break;
-			}
-
-			if ( $query['per_page'] > 0 ) {
-				$sql         .= ' LIMIT %d, %d';
-				$sql_params[] = $query['offset'];
-				$sql_params[] = $query['per_page'];
-			}
-		}
-
-		if ( ! empty( $sql_params ) ) {
-			$sql = $wpdb->prepare( $sql, $sql_params ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-		}
-
-		return $sql;
-	}
-
-	/**
-	 * Query for action count or list of action IDs.
-	 *
-	 * @since 3.3.0 $query['status'] accepts array of statuses instead of a single status.
-	 *
-	 * @see ActionScheduler_Store::query_actions for $query arg usage.
-	 *
-	 * @param array  $query      Query filtering options.
-	 * @param string $query_type Whether to select or count the results. Defaults to select.
-	 *
-	 * @return string|array|null The IDs of actions matching the query. Null on failure.
-	 */
-	public function query_actions( $query = array(), $query_type = 'select' ) {
-		/** @var wpdb $wpdb */
-		global $wpdb;
-
-		$sql = $this->get_query_actions_sql( $query, $query_type );
-
-		return ( 'count' === $query_type ) ? $wpdb->get_var( $sql ) : $wpdb->get_col( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.DirectDatabaseQuery.NoSql, WordPress.DB.DirectDatabaseQuery.NoCaching
-	}
-
-	/**
-	 * Get a count of all actions in the store, grouped by status.
-	 *
-	 * @return array Set of 'status' => int $count pairs for statuses with 1 or more actions of that status.
-	 */
-	public function action_counts() {
-		global $wpdb;
-
-		$sql  = "SELECT a.status, count(a.status) as 'count'";
-		$sql .= " FROM {$wpdb->actionscheduler_actions} a";
-		$sql .= ' GROUP BY a.status';
-
-		$actions_count_by_status = array();
-		$action_stati_and_labels = $this->get_status_labels();
-
-		foreach ( $wpdb->get_results( $sql ) as $action_data ) { // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-			// Ignore any actions with invalid status.
-			if ( array_key_exists( $action_data->status, $action_stati_and_labels ) ) {
-				$actions_count_by_status[ $action_data->status ] = $action_data->count;
-			}
-		}
-
-		return $actions_count_by_status;
-	}
-
-	/**
-	 * Cancel an action.
-	 *
-	 * @param int $action_id Action ID.
-	 *
-	 * @return void
-	 * @throws \InvalidArgumentException If the action update failed.
-	 */
-	public function cancel_action( $action_id ) {
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-
-		$updated = $wpdb->update(
-			$wpdb->actionscheduler_actions,
-			array( 'status' => self::STATUS_CANCELED ),
-			array( 'action_id' => $action_id ),
-			array( '%s' ),
-			array( '%d' )
-		);
-		if ( false === $updated ) {
-			/* translators: %s: action ID */
-			throw new \InvalidArgumentException( sprintf( __( 'Unidentified action %s', 'action-scheduler' ), $action_id ) );
-		}
-		do_action( 'action_scheduler_canceled_action', $action_id );
-	}
-
-	/**
-	 * Cancel pending actions by hook.
-	 *
-	 * @since 3.0.0
-	 *
-	 * @param string $hook Hook name.
-	 *
-	 * @return void
-	 */
-	public function cancel_actions_by_hook( $hook ) {
-		$this->bulk_cancel_actions( array( 'hook' => $hook ) );
-	}
-
-	/**
-	 * Cancel pending actions by group.
-	 *
-	 * @param string $group Group slug.
-	 *
-	 * @return void
-	 */
-	public function cancel_actions_by_group( $group ) {
-		$this->bulk_cancel_actions( array( 'group' => $group ) );
-	}
-
-	/**
-	 * Bulk cancel actions.
-	 *
-	 * @since 3.0.0
-	 *
-	 * @param array $query_args Query parameters.
-	 */
-	protected function bulk_cancel_actions( $query_args ) {
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-
-		if ( ! is_array( $query_args ) ) {
-			return;
-		}
-
-		// Don't cancel actions that are already canceled.
-		if ( isset( $query_args['status'] ) && self::STATUS_CANCELED === $query_args['status'] ) {
-			return;
-		}
-
-		$action_ids = true;
-		$query_args = wp_parse_args(
-			$query_args,
-			array(
-				'per_page' => 1000,
-				'status'   => self::STATUS_PENDING,
-				'orderby'  => 'action_id',
-			)
-		);
-
-		while ( $action_ids ) {
-			$action_ids = $this->query_actions( $query_args );
-			if ( empty( $action_ids ) ) {
-				break;
-			}
-
-			$format     = array_fill( 0, count( $action_ids ), '%d' );
-			$query_in   = '(' . implode( ',', $format ) . ')';
-			$parameters = $action_ids;
-			array_unshift( $parameters, self::STATUS_CANCELED );
-
-			$wpdb->query(
-				$wpdb->prepare(
-					"UPDATE {$wpdb->actionscheduler_actions} SET status = %s WHERE action_id IN {$query_in}", // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
-					$parameters
-				)
-			);
-
-			do_action( 'action_scheduler_bulk_cancel_actions', $action_ids );
-		}
-	}
-
-	/**
-	 * Delete an action.
-	 *
-	 * @param int $action_id Action ID.
-	 * @throws \InvalidArgumentException If the action deletion failed.
-	 */
-	public function delete_action( $action_id ) {
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-		$deleted = $wpdb->delete( $wpdb->actionscheduler_actions, array( 'action_id' => $action_id ), array( '%d' ) );
-		if ( empty( $deleted ) ) {
-			throw new \InvalidArgumentException( sprintf( __( 'Unidentified action %s', 'action-scheduler' ), $action_id ) ); //phpcs:ignore WordPress.WP.I18n.MissingTranslatorsComment
-		}
-		do_action( 'action_scheduler_deleted_action', $action_id );
-	}
-
-	/**
-	 * Get the schedule date for an action.
-	 *
-	 * @param string $action_id Action ID.
-	 *
-	 * @return \DateTime The local date the action is scheduled to run, or the date that it ran.
-	 */
-	public function get_date( $action_id ) {
-		$date = $this->get_date_gmt( $action_id );
-		ActionScheduler_TimezoneHelper::set_local_timezone( $date );
-		return $date;
-	}
-
-	/**
-	 * Get the GMT schedule date for an action.
-	 *
-	 * @param int $action_id Action ID.
-	 *
-	 * @throws \InvalidArgumentException If action cannot be identified.
-	 * @return \DateTime The GMT date the action is scheduled to run, or the date that it ran.
-	 */
-	protected function get_date_gmt( $action_id ) {
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-		$record = $wpdb->get_row( $wpdb->prepare( "SELECT * FROM {$wpdb->actionscheduler_actions} WHERE action_id=%d", $action_id ) );
-		if ( empty( $record ) ) {
-			throw new \InvalidArgumentException( sprintf( __( 'Unidentified action %s', 'action-scheduler' ), $action_id ) ); //phpcs:ignore WordPress.WP.I18n.MissingTranslatorsComment
-		}
-		if ( self::STATUS_PENDING === $record->status ) {
-			return as_get_datetime_object( $record->scheduled_date_gmt );
-		} else {
-			return as_get_datetime_object( $record->last_attempt_gmt );
-		}
-	}
-
-	/**
-	 * Stake a claim on actions.
-	 *
-	 * @param int       $max_actions Maximum number of action to include in claim.
-	 * @param \DateTime $before_date Jobs must be schedule before this date. Defaults to now.
-	 * @param array     $hooks Hooks to filter for.
-	 * @param string    $group Group to filter for.
-	 *
-	 * @return ActionScheduler_ActionClaim
-	 */
-	public function stake_claim( $max_actions = 10, \DateTime $before_date = null, $hooks = array(), $group = '' ) {
-		$claim_id = $this->generate_claim_id();
-
-		$this->claim_before_date = $before_date;
-		$this->claim_actions( $claim_id, $max_actions, $before_date, $hooks, $group );
-		$action_ids              = $this->find_actions_by_claim_id( $claim_id );
-		$this->claim_before_date = null;
-
-		return new ActionScheduler_ActionClaim( $claim_id, $action_ids );
-	}
-
-	/**
-	 * Generate a new action claim.
-	 *
-	 * @return int Claim ID.
-	 */
-	protected function generate_claim_id() {
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-		$now = as_get_datetime_object();
-		$wpdb->insert( $wpdb->actionscheduler_claims, array( 'date_created_gmt' => $now->format( 'Y-m-d H:i:s' ) ) );
-
-		return $wpdb->insert_id;
-	}
-
-	/**
-	 * Mark actions claimed.
-	 *
-	 * @param string    $claim_id Claim Id.
-	 * @param int       $limit Number of action to include in claim.
-	 * @param \DateTime $before_date Should use UTC timezone.
-	 * @param array     $hooks Hooks to filter for.
-	 * @param string    $group Group to filter for.
-	 *
-	 * @return int The number of actions that were claimed.
-	 * @throws \InvalidArgumentException Throws InvalidArgumentException if group doesn't exist.
-	 * @throws \RuntimeException Throws RuntimeException if unable to claim action.
-	 */
-	protected function claim_actions( $claim_id, $limit, \DateTime $before_date = null, $hooks = array(), $group = '' ) {
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-
-		$now  = as_get_datetime_object();
-		$date = $before_date === null ? $now : clone $before_date;
-
-		// can't use $wpdb->update() because of the <= condition.
-		$update = "UPDATE {$wpdb->actionscheduler_actions} SET claim_id=%d, last_attempt_gmt=%s, last_attempt_local=%s";
-		$params = array(
-			$claim_id,
-			$now->format( 'Y-m-d H:i:s' ),
-			current_time( 'mysql' ),
-		);
-
-		$where    = 'WHERE claim_id = 0 AND scheduled_date_gmt <= %s AND status=%s';
-		$params[] = $date->format( 'Y-m-d H:i:s' );
-		$params[] = self::STATUS_PENDING;
-
-		if ( ! empty( $hooks ) ) {
-			$placeholders = array_fill( 0, count( $hooks ), '%s' );
-			$where       .= ' AND hook IN (' . join( ', ', $placeholders ) . ')';
-			$params       = array_merge( $params, array_values( $hooks ) );
-		}
-
-		if ( ! empty( $group ) ) {
-
-			$group_id = $this->get_group_id( $group, false );
-
-			// throw exception if no matching group found, this matches ActionScheduler_wpPostStore's behaviour.
-			if ( empty( $group_id ) ) {
-				/* translators: %s: group name */
-				throw new InvalidArgumentException( sprintf( __( 'The group "%s" does not exist.', 'action-scheduler' ), $group ) );
-			}
-
-			$where   .= ' AND group_id = %d';
-			$params[] = $group_id;
-		}
-
-		/**
-		 * Sets the order-by clause used in the action claim query.
-		 *
-		 * @since 3.4.0
-		 *
-		 * @param string $order_by_sql
-		 */
-		$order    = apply_filters( 'action_scheduler_claim_actions_order_by', 'ORDER BY attempts ASC, scheduled_date_gmt ASC, action_id ASC' );
-		$params[] = $limit;
-
-		$sql           = $wpdb->prepare( "{$update} {$where} {$order} LIMIT %d", $params ); // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared, WordPress.DB.PreparedSQLPlaceholders
-		$rows_affected = $wpdb->query( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching
-		if ( false === $rows_affected ) {
-			throw new \RuntimeException( __( 'Unable to claim actions. Database error.', 'action-scheduler' ) );
-		}
-
-		return (int) $rows_affected;
-	}
-
-	/**
-	 * Get the number of active claims.
-	 *
-	 * @return int
-	 */
-	public function get_claim_count() {
-		global $wpdb;
-
-		$sql = "SELECT COUNT(DISTINCT claim_id) FROM {$wpdb->actionscheduler_actions} WHERE claim_id != 0 AND status IN ( %s, %s)";
-		$sql = $wpdb->prepare( $sql, array( self::STATUS_PENDING, self::STATUS_RUNNING ) ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-
-		return (int) $wpdb->get_var( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-	}
-
-	/**
-	 * Return an action's claim ID, as stored in the claim_id column.
-	 *
-	 * @param string $action_id Action ID.
-	 * @return mixed
-	 */
-	public function get_claim_id( $action_id ) {
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-
-		$sql = "SELECT claim_id FROM {$wpdb->actionscheduler_actions} WHERE action_id=%d";
-		$sql = $wpdb->prepare( $sql, $action_id ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-
-		return (int) $wpdb->get_var( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-	}
-
-	/**
-	 * Retrieve the action IDs of action in a claim.
-	 *
-	 * @param  int $claim_id Claim ID.
-	 * @return int[]
-	 */
-	public function find_actions_by_claim_id( $claim_id ) {
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-
-		$action_ids  = array();
-		$before_date = isset( $this->claim_before_date ) ? $this->claim_before_date : as_get_datetime_object();
-		$cut_off     = $before_date->format( 'Y-m-d H:i:s' );
-
-		$sql = $wpdb->prepare(
-			"SELECT action_id, scheduled_date_gmt FROM {$wpdb->actionscheduler_actions} WHERE claim_id = %d",
-			$claim_id
-		);
-
-		// Verify that the scheduled date for each action is within the expected bounds (in some unusual
-		// cases, we cannot depend on MySQL to honor all of the WHERE conditions we specify).
-		foreach ( $wpdb->get_results( $sql ) as $claimed_action ) { // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-			if ( $claimed_action->scheduled_date_gmt <= $cut_off ) {
-				$action_ids[] = absint( $claimed_action->action_id );
-			}
-		}
-
-		return $action_ids;
-	}
-
-	/**
-	 * Release actions from a claim and delete the claim.
-	 *
-	 * @param ActionScheduler_ActionClaim $claim Claim object.
-	 */
-	public function release_claim( ActionScheduler_ActionClaim $claim ) {
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-		$wpdb->update( $wpdb->actionscheduler_actions, array( 'claim_id' => 0 ), array( 'claim_id' => $claim->get_id() ), array( '%d' ), array( '%d' ) );
-		$wpdb->delete( $wpdb->actionscheduler_claims, array( 'claim_id' => $claim->get_id() ), array( '%d' ) );
-	}
-
-	/**
-	 * Remove the claim from an action.
-	 *
-	 * @param int $action_id Action ID.
-	 *
-	 * @return void
-	 */
-	public function unclaim_action( $action_id ) {
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-		$wpdb->update(
-			$wpdb->actionscheduler_actions,
-			array( 'claim_id' => 0 ),
-			array( 'action_id' => $action_id ),
-			array( '%s' ),
-			array( '%d' )
-		);
-	}
-
-	/**
-	 * Mark an action as failed.
-	 *
-	 * @param int $action_id Action ID.
-	 * @throws \InvalidArgumentException Throw an exception if action was not updated.
-	 */
-	public function mark_failure( $action_id ) {
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-		$updated = $wpdb->update(
-			$wpdb->actionscheduler_actions,
-			array( 'status' => self::STATUS_FAILED ),
-			array( 'action_id' => $action_id ),
-			array( '%s' ),
-			array( '%d' )
-		);
-		if ( empty( $updated ) ) {
-			throw new \InvalidArgumentException( sprintf( __( 'Unidentified action %s', 'action-scheduler' ), $action_id ) ); //phpcs:ignore WordPress.WP.I18n.MissingTranslatorsComment
-		}
-	}
-
-	/**
-	 * Add execution message to action log.
-	 *
-	 * @param int $action_id Action ID.
-	 *
-	 * @return void
-	 */
-	public function log_execution( $action_id ) {
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-
-		$sql = "UPDATE {$wpdb->actionscheduler_actions} SET attempts = attempts+1, status=%s, last_attempt_gmt = %s, last_attempt_local = %s WHERE action_id = %d";
-		$sql = $wpdb->prepare( $sql, self::STATUS_RUNNING, current_time( 'mysql', true ), current_time( 'mysql' ), $action_id ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-		$wpdb->query( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-	}
-
-	/**
-	 * Mark an action as complete.
-	 *
-	 * @param int $action_id Action ID.
-	 *
-	 * @return void
-	 * @throws \InvalidArgumentException Throw an exception if action was not updated.
-	 */
-	public function mark_complete( $action_id ) {
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-		$updated = $wpdb->update(
-			$wpdb->actionscheduler_actions,
-			array(
-				'status'             => self::STATUS_COMPLETE,
-				'last_attempt_gmt'   => current_time( 'mysql', true ),
-				'last_attempt_local' => current_time( 'mysql' ),
-			),
-			array( 'action_id' => $action_id ),
-			array( '%s' ),
-			array( '%d' )
-		);
-		if ( empty( $updated ) ) {
-			throw new \InvalidArgumentException( sprintf( __( 'Unidentified action %s', 'action-scheduler' ), $action_id ) ); //phpcs:ignore WordPress.WP.I18n.MissingTranslatorsComment
-		}
-
-		/**
-		 * Fires after a scheduled action has been completed.
-		 *
-		 * @since 3.4.2
-		 *
-		 * @param int $action_id Action ID.
-		 */
-		do_action( 'action_scheduler_completed_action', $action_id );
-	}
-
-	/**
-	 * Get an action's status.
-	 *
-	 * @param int $action_id Action ID.
-	 *
-	 * @return string
-	 * @throws \InvalidArgumentException Throw an exception if not status was found for action_id.
-	 * @throws \RuntimeException Throw an exception if action status could not be retrieved.
-	 */
-	public function get_status( $action_id ) {
-		/** @var \wpdb $wpdb */
-		global $wpdb;
-		$sql    = "SELECT status FROM {$wpdb->actionscheduler_actions} WHERE action_id=%d";
-		$sql    = $wpdb->prepare( $sql, $action_id ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-		$status = $wpdb->get_var( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-
-		if ( null === $status ) {
-			throw new \InvalidArgumentException( __( 'Invalid action ID. No status found.', 'action-scheduler' ) );
-		} elseif ( empty( $status ) ) {
-			throw new \RuntimeException( __( 'Unknown status found for action.', 'action-scheduler' ) );
-		} else {
-			return $status;
-		}
-	}
+            array_merge(
+                $pending_statuses,
+                array(
+                    $data['hook'],
+                    $data['group_id'],
+                )
+            )
+        );
+        // phpcs:enable
+
+        return "$where_clause" . ' LIMIT 1';
+    }
+
+    /**
+     * Helper method to get $wpdb->prepare placeholder for a given column name.
+     *
+     * @param string $column_name Name of column in actions table.
+     *
+     * @return string Placeholder to use for given column.
+     */
+    private function get_placeholder_for_column( $column_name ) {
+        $string_columns = array(
+            'hook',
+            'status',
+            'scheduled_date_gmt',
+            'scheduled_date_local',
+            'args',
+            'schedule',
+            'last_attempt_gmt',
+            'last_attempt_local',
+            'extended_args',
+        );
+
+        return in_array( $column_name, $string_columns ) ? '%s' : '%d';
+    }
+
+    /**
+     * Generate a hash from json_encoded $args using MD5 as this isn't for security.
+     *
+     * @param string $args JSON encoded action args.
+     * @return string
+     */
+    protected function hash_args( $args ) {
+        return md5( $args );
+    }
+
+    /**
+     * Get action args query param value from action args.
+     *
+     * @param array $args Action args.
+     * @return string
+     */
+    protected function get_args_for_query( $args ) {
+        $encoded = wp_json_encode( $args );
+        if ( strlen( $encoded ) <= static::$max_index_length ) {
+            return $encoded;
+        }
+        return $this->hash_args( $encoded );
+    }
+    /**
+     * Get a group's ID based on its name/slug.
+     *
+     * @param string $slug The string name of a group.
+     * @param bool   $create_if_not_exists Whether to create the group if it does not already exist. Default, true - create the group.
+     *
+     * @return int The group's ID, if it exists or is created, or 0 if it does not exist and is not created.
+     */
+    protected function get_group_id( $slug, $create_if_not_exists = true ) {
+        if ( empty( $slug ) ) {
+            return 0;
+        }
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+        $group_id = (int) $wpdb->get_var( $wpdb->prepare( "SELECT group_id FROM {$wpdb->actionscheduler_groups} WHERE slug=%s", $slug ) );
+        if ( empty( $group_id ) && $create_if_not_exists ) {
+            $group_id = $this->create_group( $slug );
+        }
+
+        return $group_id;
+    }
+
+    /**
+     * Create an action group.
+     *
+     * @param string $slug Group slug.
+     *
+     * @return int Group ID.
+     */
+    protected function create_group( $slug ) {
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+        $wpdb->insert( $wpdb->actionscheduler_groups, array( 'slug' => $slug ) );
+
+        return (int) $wpdb->insert_id;
+    }
+
+    /**
+     * Retrieve an action.
+     *
+     * @param int $action_id Action ID.
+     *
+     * @return ActionScheduler_Action
+     */
+    public function fetch_action( $action_id ) {
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+        $data = $wpdb->get_row(
+            $wpdb->prepare(
+                "SELECT a.*, g.slug AS `group` FROM {$wpdb->actionscheduler_actions} a LEFT JOIN {$wpdb->actionscheduler_groups} g ON a.group_id=g.group_id WHERE a.action_id=%d",
+                $action_id
+            )
+        );
+
+        if ( empty( $data ) ) {
+            return $this->get_null_action();
+        }
+
+        if ( ! empty( $data->extended_args ) ) {
+            $data->args = $data->extended_args;
+            unset( $data->extended_args );
+        }
+
+        // Convert NULL dates to zero dates.
+        $date_fields = array(
+            'scheduled_date_gmt',
+            'scheduled_date_local',
+            'last_attempt_gmt',
+            'last_attempt_gmt',
+        );
+        foreach ( $date_fields as $date_field ) {
+            if ( $data->$date_field === null ) {
+                $data->$date_field = ActionScheduler_StoreSchema::DEFAULT_DATE;
+            }
+        }
+
+        try {
+            $action = $this->make_action_from_db_record( $data );
+        } catch ( ActionScheduler_InvalidActionException $exception ) {
+            do_action( 'action_scheduler_failed_fetch_action', $action_id, $exception );
+            return $this->get_null_action();
+        }
+
+        return $action;
+    }
+
+    /**
+     * Create a null action.
+     *
+     * @return ActionScheduler_NullAction
+     */
+    protected function get_null_action() {
+        return new ActionScheduler_NullAction();
+    }
+
+    /**
+     * Create an action from a database record.
+     *
+     * @param object $data Action database record.
+     *
+     * @return ActionScheduler_Action|ActionScheduler_CanceledAction|ActionScheduler_FinishedAction
+     */
+    protected function make_action_from_db_record( $data ) {
+
+        $hook     = $data->hook;
+        $args     = json_decode( $data->args, true );
+        $schedule = unserialize( $data->schedule ); // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_unserialize
+
+        $this->validate_args( $args, $data->action_id );
+        $this->validate_schedule( $schedule, $data->action_id );
+
+        if ( empty( $schedule ) ) {
+            $schedule = new ActionScheduler_NullSchedule();
+        }
+        $group = $data->group ? $data->group : '';
+
+        return ActionScheduler::factory()->get_stored_action( $data->status, $data->hook, $args, $schedule, $group );
+    }
+
+    /**
+     * Returns the SQL statement to query (or count) actions.
+     *
+     * @since 3.3.0 $query['status'] accepts array of statuses instead of a single status.
+     *
+     * @param array  $query Filtering options.
+     * @param string $select_or_count  Whether the SQL should select and return the IDs or just the row count.
+     *
+     * @return string SQL statement already properly escaped.
+     * @throws InvalidArgumentException If the query is invalid.
+     */
+    protected function get_query_actions_sql( array $query, $select_or_count = 'select' ) {
+
+        if ( ! in_array( $select_or_count, array( 'select', 'count' ), true ) ) {
+            throw new InvalidArgumentException( __( 'Invalid value for select or count parameter. Cannot query actions.', 'action-scheduler' ) );
+        }
+
+        $query = wp_parse_args(
+            $query,
+            array(
+                'hook'                  => '',
+                'args'                  => null,
+                'partial_args_matching' => 'off', // can be 'like' or 'json'
+                'date'                  => null,
+                'date_compare'          => '<=',
+                'modified'              => null,
+                'modified_compare'      => '<=',
+                'group'                 => '',
+                'status'                => '',
+                'claimed'               => null,
+                'per_page'              => 5,
+                'offset'                => 0,
+                'orderby'               => 'date',
+                'order'                 => 'ASC',
+            )
+        );
+
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+
+        $db_server_info = is_callable( array( $wpdb, 'db_server_info' ) ) ? $wpdb->db_server_info() : $wpdb->db_version();
+        if ( false !== strpos( $db_server_info, 'MariaDB' ) ) {
+            $supports_json = version_compare(
+                PHP_VERSION_ID >= 80016 ? $wpdb->db_version() : preg_replace( '/[^0-9.].*/', '', str_replace( '5.5.5-', '', $db_server_info ) ),
+                '10.2',
+                '>='
+            );
+        } else {
+            $supports_json = version_compare( $wpdb->db_version(), '5.7', '>=' );
+        }
+
+        $sql        = ( 'count' === $select_or_count ) ? 'SELECT count(a.action_id)' : 'SELECT a.action_id';
+        $sql       .= " FROM {$wpdb->actionscheduler_actions} a";
+        $sql_params = array();
+
+        if ( ! empty( $query['group'] ) || 'group' === $query['orderby'] ) {
+            $sql .= " LEFT JOIN {$wpdb->actionscheduler_groups} g ON g.group_id=a.group_id";
+        }
+
+        $sql .= ' WHERE 1=1';
+
+        if ( ! empty( $query['group'] ) ) {
+            $sql         .= ' AND g.slug=%s';
+            $sql_params[] = $query['group'];
+        }
+
+        if ( ! empty( $query['hook'] ) ) {
+            $sql         .= ' AND a.hook=%s';
+            $sql_params[] = $query['hook'];
+        }
+
+        if ( $query['args'] !== null ) {
+            switch ( $query['partial_args_matching'] ) {
+                case 'json':
+                    if ( ! $supports_json ) {
+                        throw new \RuntimeException( __( 'JSON partial matching not supported in your environment. Please check your MySQL/MariaDB version.', 'action-scheduler' ) );
+                    }
+                    $supported_types = array(
+                        'integer' => '%d',
+                        'boolean' => '%s',
+                        'double'  => '%f',
+                        'string'  => '%s',
+                    );
+                    foreach ( $query['args'] as $key => $value ) {
+                        $value_type = gettype( $value );
+                        if ( 'boolean' === $value_type ) {
+                            $value = $value ? 'true' : 'false';
+                        }
+                        $placeholder = isset( $supported_types[ $value_type ] ) ? $supported_types[ $value_type ] : false;
+                        if ( ! $placeholder ) {
+                            throw new \RuntimeException(
+                                sprintf(
+                                /* translators: %s: provided value type */
+                                    __( 'The value type for the JSON partial matching is not supported. Must be either integer, boolean, double or string. %s type provided.', 'action-scheduler' ),
+                                    $value_type
+                                )
+                            );
+                        }
+                        $sql         .= ' AND JSON_EXTRACT(a.args, %s)=' . $placeholder;
+                        $sql_params[] = '$.' . $key;
+                        $sql_params[] = $value;
+                    }
+                    break;
+                case 'like':
+                    foreach ( $query['args'] as $key => $value ) {
+                        $sql         .= ' AND a.args LIKE %s';
+                        $json_partial = $wpdb->esc_like( trim( json_encode( array( $key => $value ) ), '{}' ) );
+                        $sql_params[] = "%{$json_partial}%";
+                    }
+                    break;
+                case 'off':
+                    $sql         .= ' AND a.args=%s';
+                    $sql_params[] = $this->get_args_for_query( $query['args'] );
+                    break;
+                default:
+                    throw new \RuntimeException( __( 'Unknown partial args matching value.', 'action-scheduler' ) );
+            }
+        }
+
+        if ( $query['status'] ) {
+            $statuses     = (array) $query['status'];
+            $placeholders = array_fill( 0, count( $statuses ), '%s' );
+            $sql         .= ' AND a.status IN (' . join( ', ', $placeholders ) . ')';
+            $sql_params   = array_merge( $sql_params, array_values( $statuses ) );
+        }
+
+        if ( $query['date'] instanceof \DateTime ) {
+            $date = clone $query['date'];
+            $date->setTimezone( new \DateTimeZone( 'UTC' ) );
+            $date_string  = $date->format( 'Y-m-d H:i:s' );
+            $comparator   = $this->validate_sql_comparator( $query['date_compare'] );
+            $sql         .= " AND a.scheduled_date_gmt $comparator %s";
+            $sql_params[] = $date_string;
+        }
+
+        if ( $query['modified'] instanceof \DateTime ) {
+            $modified = clone $query['modified'];
+            $modified->setTimezone( new \DateTimeZone( 'UTC' ) );
+            $date_string  = $modified->format( 'Y-m-d H:i:s' );
+            $comparator   = $this->validate_sql_comparator( $query['modified_compare'] );
+            $sql         .= " AND a.last_attempt_gmt $comparator %s";
+            $sql_params[] = $date_string;
+        }
+
+        if ( true === $query['claimed'] ) {
+            $sql .= ' AND a.claim_id != 0';
+        } elseif ( false === $query['claimed'] ) {
+            $sql .= ' AND a.claim_id = 0';
+        } elseif ( $query['claimed'] !== null ) {
+            $sql         .= ' AND a.claim_id = %d';
+            $sql_params[] = $query['claimed'];
+        }
+
+        if ( ! empty( $query['search'] ) ) {
+            $sql .= ' AND (a.hook LIKE %s OR (a.extended_args IS NULL AND a.args LIKE %s) OR a.extended_args LIKE %s';
+            for ( $i = 0; $i < 3; $i++ ) {
+                $sql_params[] = sprintf( '%%%s%%', $query['search'] );
+            }
+
+            $search_claim_id = (int) $query['search'];
+            if ( $search_claim_id ) {
+                $sql         .= ' OR a.claim_id = %d';
+                $sql_params[] = $search_claim_id;
+            }
+
+            $sql .= ')';
+        }
+
+        if ( 'select' === $select_or_count ) {
+            if ( 'ASC' === strtoupper( $query['order'] ) ) {
+                $order = 'ASC';
+            } else {
+                $order = 'DESC';
+            }
+            switch ( $query['orderby'] ) {
+                case 'hook':
+                    $sql .= " ORDER BY a.hook $order";
+                    break;
+                case 'group':
+                    $sql .= " ORDER BY g.slug $order";
+                    break;
+                case 'modified':
+                    $sql .= " ORDER BY a.last_attempt_gmt $order";
+                    break;
+                case 'none':
+                    break;
+                case 'action_id':
+                    $sql .= " ORDER BY a.action_id $order";
+                    break;
+                case 'date':
+                default:
+                    $sql .= " ORDER BY a.scheduled_date_gmt $order";
+                    break;
+            }
+
+            if ( $query['per_page'] > 0 ) {
+                $sql         .= ' LIMIT %d, %d';
+                $sql_params[] = $query['offset'];
+                $sql_params[] = $query['per_page'];
+            }
+        }
+
+        if ( ! empty( $sql_params ) ) {
+            $sql = $wpdb->prepare( $sql, $sql_params ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+        }
+
+        return $sql;
+    }
+
+    /**
+     * Query for action count or list of action IDs.
+     *
+     * @since 3.3.0 $query['status'] accepts array of statuses instead of a single status.
+     *
+     * @see ActionScheduler_Store::query_actions for $query arg usage.
+     *
+     * @param array  $query      Query filtering options.
+     * @param string $query_type Whether to select or count the results. Defaults to select.
+     *
+     * @return string|array|null The IDs of actions matching the query. Null on failure.
+     */
+    public function query_actions( $query = array(), $query_type = 'select' ) {
+        /** @var wpdb $wpdb */
+        global $wpdb;
+
+        $sql = $this->get_query_actions_sql( $query, $query_type );
+
+        return ( 'count' === $query_type ) ? $wpdb->get_var( $sql ) : $wpdb->get_col( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.DirectDatabaseQuery.NoSql, WordPress.DB.DirectDatabaseQuery.NoCaching
+    }
+
+    /**
+     * Get a count of all actions in the store, grouped by status.
+     *
+     * @return array Set of 'status' => int $count pairs for statuses with 1 or more actions of that status.
+     */
+    public function action_counts() {
+        global $wpdb;
+
+        $sql  = "SELECT a.status, count(a.status) as 'count'";
+        $sql .= " FROM {$wpdb->actionscheduler_actions} a";
+        $sql .= ' GROUP BY a.status';
+
+        $actions_count_by_status = array();
+        $action_stati_and_labels = $this->get_status_labels();
+
+        foreach ( $wpdb->get_results( $sql ) as $action_data ) { // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+            // Ignore any actions with invalid status.
+            if ( array_key_exists( $action_data->status, $action_stati_and_labels ) ) {
+                $actions_count_by_status[ $action_data->status ] = $action_data->count;
+            }
+        }
+
+        return $actions_count_by_status;
+    }
+
+    /**
+     * Cancel an action.
+     *
+     * @param int $action_id Action ID.
+     *
+     * @return void
+     * @throws \InvalidArgumentException If the action update failed.
+     */
+    public function cancel_action( $action_id ) {
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+
+        $updated = $wpdb->update(
+            $wpdb->actionscheduler_actions,
+            array( 'status' => self::STATUS_CANCELED ),
+            array( 'action_id' => $action_id ),
+            array( '%s' ),
+            array( '%d' )
+        );
+        if ( false === $updated ) {
+            /* translators: %s: action ID */
+            throw new \InvalidArgumentException( sprintf( __( 'Unidentified action %s', 'action-scheduler' ), $action_id ) );
+        }
+        do_action( 'action_scheduler_canceled_action', $action_id );
+    }
+
+    /**
+     * Cancel pending actions by hook.
+     *
+     * @since 3.0.0
+     *
+     * @param string $hook Hook name.
+     *
+     * @return void
+     */
+    public function cancel_actions_by_hook( $hook ) {
+        $this->bulk_cancel_actions( array( 'hook' => $hook ) );
+    }
+
+    /**
+     * Cancel pending actions by group.
+     *
+     * @param string $group Group slug.
+     *
+     * @return void
+     */
+    public function cancel_actions_by_group( $group ) {
+        $this->bulk_cancel_actions( array( 'group' => $group ) );
+    }
+
+    /**
+     * Bulk cancel actions.
+     *
+     * @since 3.0.0
+     *
+     * @param array $query_args Query parameters.
+     */
+    protected function bulk_cancel_actions( $query_args ) {
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+
+        if ( ! is_array( $query_args ) ) {
+            return;
+        }
+
+        // Don't cancel actions that are already canceled.
+        if ( isset( $query_args['status'] ) && self::STATUS_CANCELED === $query_args['status'] ) {
+            return;
+        }
+
+        $action_ids = true;
+        $query_args = wp_parse_args(
+            $query_args,
+            array(
+                'per_page' => 1000,
+                'status'   => self::STATUS_PENDING,
+                'orderby'  => 'action_id',
+            )
+        );
+
+        while ( $action_ids ) {
+            $action_ids = $this->query_actions( $query_args );
+            if ( empty( $action_ids ) ) {
+                break;
+            }
+
+            $format     = array_fill( 0, count( $action_ids ), '%d' );
+            $query_in   = '(' . implode( ',', $format ) . ')';
+            $parameters = $action_ids;
+            array_unshift( $parameters, self::STATUS_CANCELED );
+
+            $wpdb->query(
+                $wpdb->prepare(
+                    "UPDATE {$wpdb->actionscheduler_actions} SET status = %s WHERE action_id IN {$query_in}", // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared
+                    $parameters
+                )
+            );
+
+            do_action( 'action_scheduler_bulk_cancel_actions', $action_ids );
+        }
+    }
+
+    /**
+     * Delete an action.
+     *
+     * @param int $action_id Action ID.
+     * @throws \InvalidArgumentException If the action deletion failed.
+     */
+    public function delete_action( $action_id ) {
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+        $deleted = $wpdb->delete( $wpdb->actionscheduler_actions, array( 'action_id' => $action_id ), array( '%d' ) );
+        if ( empty( $deleted ) ) {
+            throw new \InvalidArgumentException( sprintf( __( 'Unidentified action %s', 'action-scheduler' ), $action_id ) ); //phpcs:ignore WordPress.WP.I18n.MissingTranslatorsComment
+        }
+        do_action( 'action_scheduler_deleted_action', $action_id );
+    }
+
+    /**
+     * Get the schedule date for an action.
+     *
+     * @param string $action_id Action ID.
+     *
+     * @return \DateTime The local date the action is scheduled to run, or the date that it ran.
+     */
+    public function get_date( $action_id ) {
+        $date = $this->get_date_gmt( $action_id );
+        ActionScheduler_TimezoneHelper::set_local_timezone( $date );
+        return $date;
+    }
+
+    /**
+     * Get the GMT schedule date for an action.
+     *
+     * @param int $action_id Action ID.
+     *
+     * @throws \InvalidArgumentException If action cannot be identified.
+     * @return \DateTime The GMT date the action is scheduled to run, or the date that it ran.
+     */
+    protected function get_date_gmt( $action_id ) {
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+        $record = $wpdb->get_row( $wpdb->prepare( "SELECT * FROM {$wpdb->actionscheduler_actions} WHERE action_id=%d", $action_id ) );
+        if ( empty( $record ) ) {
+            throw new \InvalidArgumentException( sprintf( __( 'Unidentified action %s', 'action-scheduler' ), $action_id ) ); //phpcs:ignore WordPress.WP.I18n.MissingTranslatorsComment
+        }
+        if ( self::STATUS_PENDING === $record->status ) {
+            return as_get_datetime_object( $record->scheduled_date_gmt );
+        } else {
+            return as_get_datetime_object( $record->last_attempt_gmt );
+        }
+    }
+
+    /**
+     * Stake a claim on actions.
+     *
+     * @param int       $max_actions Maximum number of action to include in claim.
+     * @param \DateTime $before_date Jobs must be schedule before this date. Defaults to now.
+     * @param array     $hooks Hooks to filter for.
+     * @param string    $group Group to filter for.
+     *
+     * @return ActionScheduler_ActionClaim
+     */
+    public function stake_claim( $max_actions = 10, \DateTime $before_date = null, $hooks = array(), $group = '' ) {
+        $claim_id = $this->generate_claim_id();
+
+        $this->claim_before_date = $before_date;
+        $this->claim_actions( $claim_id, $max_actions, $before_date, $hooks, $group );
+        $action_ids              = $this->find_actions_by_claim_id( $claim_id );
+        $this->claim_before_date = null;
+
+        return new ActionScheduler_ActionClaim( $claim_id, $action_ids );
+    }
+
+    /**
+     * Generate a new action claim.
+     *
+     * @return int Claim ID.
+     */
+    protected function generate_claim_id() {
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+        $now = as_get_datetime_object();
+        $wpdb->insert( $wpdb->actionscheduler_claims, array( 'date_created_gmt' => $now->format( 'Y-m-d H:i:s' ) ) );
+
+        return $wpdb->insert_id;
+    }
+
+    /**
+     * Mark actions claimed.
+     *
+     * @param string    $claim_id Claim Id.
+     * @param int       $limit Number of action to include in claim.
+     * @param \DateTime $before_date Should use UTC timezone.
+     * @param array     $hooks Hooks to filter for.
+     * @param string    $group Group to filter for.
+     *
+     * @return int The number of actions that were claimed.
+     * @throws \InvalidArgumentException Throws InvalidArgumentException if group doesn't exist.
+     * @throws \RuntimeException Throws RuntimeException if unable to claim action.
+     */
+    protected function claim_actions( $claim_id, $limit, \DateTime $before_date = null, $hooks = array(), $group = '' ) {
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+
+        $now  = as_get_datetime_object();
+        $date = $before_date === null ? $now : clone $before_date;
+
+        // can't use $wpdb->update() because of the <= condition.
+        $update = "UPDATE {$wpdb->actionscheduler_actions} SET claim_id=%d, last_attempt_gmt=%s, last_attempt_local=%s";
+        $params = array(
+            $claim_id,
+            $now->format( 'Y-m-d H:i:s' ),
+            current_time( 'mysql' ),
+        );
+
+        $where    = 'WHERE claim_id = 0 AND scheduled_date_gmt <= %s AND status=%s';
+        $params[] = $date->format( 'Y-m-d H:i:s' );
+        $params[] = self::STATUS_PENDING;
+
+        if ( ! empty( $hooks ) ) {
+            $placeholders = array_fill( 0, count( $hooks ), '%s' );
+            $where       .= ' AND hook IN (' . join( ', ', $placeholders ) . ')';
+            $params       = array_merge( $params, array_values( $hooks ) );
+        }
+
+        if ( ! empty( $group ) ) {
+
+            $group_id = $this->get_group_id( $group, false );
+
+            // throw exception if no matching group found, this matches ActionScheduler_wpPostStore's behaviour.
+            if ( empty( $group_id ) ) {
+                /* translators: %s: group name */
+                throw new InvalidArgumentException( sprintf( __( 'The group "%s" does not exist.', 'action-scheduler' ), $group ) );
+            }
+
+            $where   .= ' AND group_id = %d';
+            $params[] = $group_id;
+        }
+
+        /**
+         * Sets the order-by clause used in the action claim query.
+         *
+         * @since 3.4.0
+         *
+         * @param string $order_by_sql
+         */
+        $order    = apply_filters( 'action_scheduler_claim_actions_order_by', 'ORDER BY attempts ASC, scheduled_date_gmt ASC, action_id ASC' );
+        $params[] = $limit;
+
+        $sql           = $wpdb->prepare( "{$update} {$where} {$order} LIMIT %d", $params ); // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared, WordPress.DB.PreparedSQLPlaceholders
+        $rows_affected = $wpdb->query( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching
+        if ( false === $rows_affected ) {
+            throw new \RuntimeException( __( 'Unable to claim actions. Database error.', 'action-scheduler' ) );
+        }
+
+        return (int) $rows_affected;
+    }
+
+    /**
+     * Get the number of active claims.
+     *
+     * @return int
+     */
+    public function get_claim_count() {
+        global $wpdb;
+
+        $sql = "SELECT COUNT(DISTINCT claim_id) FROM {$wpdb->actionscheduler_actions} WHERE claim_id != 0 AND status IN ( %s, %s)";
+        $sql = $wpdb->prepare( $sql, array( self::STATUS_PENDING, self::STATUS_RUNNING ) ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+
+        return (int) $wpdb->get_var( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+    }
+
+    /**
+     * Return an action's claim ID, as stored in the claim_id column.
+     *
+     * @param string $action_id Action ID.
+     * @return mixed
+     */
+    public function get_claim_id( $action_id ) {
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+
+        $sql = "SELECT claim_id FROM {$wpdb->actionscheduler_actions} WHERE action_id=%d";
+        $sql = $wpdb->prepare( $sql, $action_id ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+
+        return (int) $wpdb->get_var( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+    }
+
+    /**
+     * Retrieve the action IDs of action in a claim.
+     *
+     * @param  int $claim_id Claim ID.
+     * @return int[]
+     */
+    public function find_actions_by_claim_id( $claim_id ) {
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+
+        $action_ids  = array();
+        $before_date = isset( $this->claim_before_date ) ? $this->claim_before_date : as_get_datetime_object();
+        $cut_off     = $before_date->format( 'Y-m-d H:i:s' );
+
+        $sql = $wpdb->prepare(
+            "SELECT action_id, scheduled_date_gmt FROM {$wpdb->actionscheduler_actions} WHERE claim_id = %d",
+            $claim_id
+        );
+
+        // Verify that the scheduled date for each action is within the expected bounds (in some unusual
+        // cases, we cannot depend on MySQL to honor all of the WHERE conditions we specify).
+        foreach ( $wpdb->get_results( $sql ) as $claimed_action ) { // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+            if ( $claimed_action->scheduled_date_gmt <= $cut_off ) {
+                $action_ids[] = absint( $claimed_action->action_id );
+            }
+        }
+
+        return $action_ids;
+    }
+
+    /**
+     * Release actions from a claim and delete the claim.
+     *
+     * @param ActionScheduler_ActionClaim $claim Claim object.
+     */
+    public function release_claim( ActionScheduler_ActionClaim $claim ) {
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+        $wpdb->update( $wpdb->actionscheduler_actions, array( 'claim_id' => 0 ), array( 'claim_id' => $claim->get_id() ), array( '%d' ), array( '%d' ) );
+        $wpdb->delete( $wpdb->actionscheduler_claims, array( 'claim_id' => $claim->get_id() ), array( '%d' ) );
+    }
+
+    /**
+     * Remove the claim from an action.
+     *
+     * @param int $action_id Action ID.
+     *
+     * @return void
+     */
+    public function unclaim_action( $action_id ) {
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+        $wpdb->update(
+            $wpdb->actionscheduler_actions,
+            array( 'claim_id' => 0 ),
+            array( 'action_id' => $action_id ),
+            array( '%s' ),
+            array( '%d' )
+        );
+    }
+
+    /**
+     * Mark an action as failed.
+     *
+     * @param int $action_id Action ID.
+     * @throws \InvalidArgumentException Throw an exception if action was not updated.
+     */
+    public function mark_failure( $action_id ) {
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+        $updated = $wpdb->update(
+            $wpdb->actionscheduler_actions,
+            array( 'status' => self::STATUS_FAILED ),
+            array( 'action_id' => $action_id ),
+            array( '%s' ),
+            array( '%d' )
+        );
+        if ( empty( $updated ) ) {
+            throw new \InvalidArgumentException( sprintf( __( 'Unidentified action %s', 'action-scheduler' ), $action_id ) ); //phpcs:ignore WordPress.WP.I18n.MissingTranslatorsComment
+        }
+    }
+
+    /**
+     * Add execution message to action log.
+     *
+     * @param int $action_id Action ID.
+     *
+     * @return void
+     */
+    public function log_execution( $action_id ) {
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+
+        $sql = "UPDATE {$wpdb->actionscheduler_actions} SET attempts = attempts+1, status=%s, last_attempt_gmt = %s, last_attempt_local = %s WHERE action_id = %d";
+        $sql = $wpdb->prepare( $sql, self::STATUS_RUNNING, current_time( 'mysql', true ), current_time( 'mysql' ), $action_id ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+        $wpdb->query( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+    }
+
+    /**
+     * Mark an action as complete.
+     *
+     * @param int $action_id Action ID.
+     *
+     * @return void
+     * @throws \InvalidArgumentException Throw an exception if action was not updated.
+     */
+    public function mark_complete( $action_id ) {
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+        $updated = $wpdb->update(
+            $wpdb->actionscheduler_actions,
+            array(
+                'status'             => self::STATUS_COMPLETE,
+                'last_attempt_gmt'   => current_time( 'mysql', true ),
+                'last_attempt_local' => current_time( 'mysql' ),
+            ),
+            array( 'action_id' => $action_id ),
+            array( '%s' ),
+            array( '%d' )
+        );
+        if ( empty( $updated ) ) {
+            throw new \InvalidArgumentException( sprintf( __( 'Unidentified action %s', 'action-scheduler' ), $action_id ) ); //phpcs:ignore WordPress.WP.I18n.MissingTranslatorsComment
+        }
+
+        /**
+         * Fires after a scheduled action has been completed.
+         *
+         * @since 3.4.2
+         *
+         * @param int $action_id Action ID.
+         */
+        do_action( 'action_scheduler_completed_action', $action_id );
+    }
+
+    /**
+     * Get an action's status.
+     *
+     * @param int $action_id Action ID.
+     *
+     * @return string
+     * @throws \InvalidArgumentException Throw an exception if not status was found for action_id.
+     * @throws \RuntimeException Throw an exception if action status could not be retrieved.
+     */
+    public function get_status( $action_id ) {
+        /** @var \wpdb $wpdb */
+        global $wpdb;
+        $sql    = "SELECT status FROM {$wpdb->actionscheduler_actions} WHERE action_id=%d";
+        $sql    = $wpdb->prepare( $sql, $action_id ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+        $status = $wpdb->get_var( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+
+        if ( null === $status ) {
+            throw new \InvalidArgumentException( __( 'Invalid action ID. No status found.', 'action-scheduler' ) );
+        } elseif ( empty( $status ) ) {
+            throw new \RuntimeException( __( 'Unknown status found for action.', 'action-scheduler' ) );
+        } else {
+            return $status;
+        }
+    }
 }

Spacing +230 added lines, -230 removed lines

@@ -45,8 +45,8 @@ 
 	 * @return int                  Action ID.
 	 * @throws RuntimeException     Throws exception when saving the action fails.
 	 */
-	public function save_unique_action( ActionScheduler_Action $action, \DateTime $scheduled_date = null ) {
-		return $this->save_action_to_db( $action, $scheduled_date, true );
+	public function save_unique_action(ActionScheduler_Action $action, \DateTime $scheduled_date = null) {
+		return $this->save_action_to_db($action, $scheduled_date, true);
 	}
 
 	/**
@@ -58,8 +58,8 @@ 
 	 * @return int Action ID.
 	 * @throws RuntimeException     Throws exception when saving the action fails.
 	 */
-	public function save_action( ActionScheduler_Action $action, \DateTime $scheduled_date = null ) {
-		return $this->save_action_to_db( $action, $scheduled_date, false );
+	public function save_action(ActionScheduler_Action $action, \DateTime $scheduled_date = null) {
+		return $this->save_action_to_db($action, $scheduled_date, false);
 	}
 
 	/**
@@ -72,50 +72,50 @@ 
 	 * @return int Action ID.
 	 * @throws RuntimeException     Throws exception when saving the action fails.
 	 */
-	private function save_action_to_db( ActionScheduler_Action $action, DateTime $date = null, $unique = false ) {
+	private function save_action_to_db(ActionScheduler_Action $action, DateTime $date = null, $unique = false) {
 		global $wpdb;
 
 		try {
-			$this->validate_action( $action );
+			$this->validate_action($action);
 
 			$data = array(
 				'hook'                 => $action->get_hook(),
-				'status'               => ( $action->is_finished() ? self::STATUS_COMPLETE : self::STATUS_PENDING ),
-				'scheduled_date_gmt'   => $this->get_scheduled_date_string( $action, $date ),
-				'scheduled_date_local' => $this->get_scheduled_date_string_local( $action, $date ),
-				'schedule'             => serialize( $action->get_schedule() ), // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_serialize
-				'group_id'             => $this->get_group_id( $action->get_group() ),
+				'status'               => ($action->is_finished() ? self::STATUS_COMPLETE : self::STATUS_PENDING),
+				'scheduled_date_gmt'   => $this->get_scheduled_date_string($action, $date),
+				'scheduled_date_local' => $this->get_scheduled_date_string_local($action, $date),
+				'schedule'             => serialize($action->get_schedule()), // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_serialize
+				'group_id'             => $this->get_group_id($action->get_group()),
 			);
 
-			$args = wp_json_encode( $action->get_args() );
-			if ( strlen( $args ) <= static::$max_index_length ) {
+			$args = wp_json_encode($action->get_args());
+			if (strlen($args) <= static::$max_index_length) {
 				$data['args'] = $args;
 			} else {
-				$data['args']          = $this->hash_args( $args );
+				$data['args']          = $this->hash_args($args);
 				$data['extended_args'] = $args;
 			}
 
-			$insert_sql = $this->build_insert_sql( $data, $unique );
+			$insert_sql = $this->build_insert_sql($data, $unique);
 
 			// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared -- $insert_sql should be already prepared.
-			$wpdb->query( $insert_sql );
+			$wpdb->query($insert_sql);
 			$action_id = $wpdb->insert_id;
 
-			if ( is_wp_error( $action_id ) ) {
-				throw new \RuntimeException( $action_id->get_error_message() );
-			} elseif ( empty( $action_id ) ) {
-				if ( $unique ) {
+			if (is_wp_error($action_id)) {
+				throw new \RuntimeException($action_id->get_error_message());
+			} elseif (empty($action_id)) {
+				if ($unique) {
 					return 0;
 				}
-				throw new \RuntimeException( $wpdb->last_error ? $wpdb->last_error : __( 'Database error.', 'action-scheduler' ) );
+				throw new \RuntimeException($wpdb->last_error ? $wpdb->last_error : __('Database error.', 'action-scheduler'));
 			}
 
-			do_action( 'action_scheduler_stored_action', $action_id );
+			do_action('action_scheduler_stored_action', $action_id);
 
 			return $action_id;
-		} catch ( \Exception $e ) {
+		} catch (\Exception $e) {
 			/* translators: %s: error message */
-			throw new \RuntimeException( sprintf( __( 'Error saving action: %s', 'action-scheduler' ), $e->getMessage() ), 0 );
+			throw new \RuntimeException(sprintf(__('Error saving action: %s', 'action-scheduler'), $e->getMessage()), 0);
 		}
 	}
 
@@ -127,17 +127,17 @@ 
 	 *
 	 * @return string Insert query.
 	 */
-	private function build_insert_sql( array $data, $unique ) {
+	private function build_insert_sql(array $data, $unique) {
 		global $wpdb;
-		$columns      = array_keys( $data );
-		$values       = array_values( $data );
-		$placeholders = array_map( array( $this, 'get_placeholder_for_column' ), $columns );
+		$columns      = array_keys($data);
+		$values       = array_values($data);
+		$placeholders = array_map(array($this, 'get_placeholder_for_column'), $columns);
 
-		$table_name = ! empty( $wpdb->actionscheduler_actions ) ? $wpdb->actionscheduler_actions : $wpdb->prefix . 'actionscheduler_actions';
+		$table_name = ! empty($wpdb->actionscheduler_actions) ? $wpdb->actionscheduler_actions : $wpdb->prefix.'actionscheduler_actions';
 
-		$column_sql      = '`' . implode( '`, `', $columns ) . '`';
-		$placeholder_sql = implode( ', ', $placeholders );
-		$where_clause    = $this->build_where_clause_for_insert( $data, $table_name, $unique );
+		$column_sql      = '`'.implode('`, `', $columns).'`';
+		$placeholder_sql = implode(', ', $placeholders);
+		$where_clause    = $this->build_where_clause_for_insert($data, $table_name, $unique);
 		// phpcs:disable WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.PreparedSQL.InterpolatedNotPrepared -- $column_sql and $where_clause are already prepared. $placeholder_sql is hardcoded.
 		$insert_query = $wpdb->prepare(
 			"
@@ -160,18 +160,18 @@ 
 	 *
 	 * @return string Where clause to be used with insert.
 	 */
-	private function build_where_clause_for_insert( $data, $table_name, $unique ) {
+	private function build_where_clause_for_insert($data, $table_name, $unique) {
 		global $wpdb;
 
-		if ( ! $unique ) {
+		if ( ! $unique) {
 			return 'SELECT NULL FROM DUAL';
 		}
 
-		$pending_statuses            = array(
+		$pending_statuses = array(
 			ActionScheduler_Store::STATUS_PENDING,
 			ActionScheduler_Store::STATUS_RUNNING,
 		);
-		$pending_status_placeholders = implode( ', ', array_fill( 0, count( $pending_statuses ), '%s' ) );
+		$pending_status_placeholders = implode(', ', array_fill(0, count($pending_statuses), '%s'));
 		// phpcs:disable WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.PreparedSQL.InterpolatedNotPrepared -- $pending_status_placeholders is hardcoded.
 		$where_clause = $wpdb->prepare(
 			"
@@ -190,7 +190,7 @@ 
 		);
 		// phpcs:enable
 
-		return "$where_clause" . ' LIMIT 1';
+		return "$where_clause".' LIMIT 1';
 	}
 
 	/**
@@ -200,7 +200,7 @@ 
 	 *
 	 * @return string Placeholder to use for given column.
 	 */
-	private function get_placeholder_for_column( $column_name ) {
+	private function get_placeholder_for_column($column_name) {
 		$string_columns = array(
 			'hook',
 			'status',
@@ -213,7 +213,7 @@ 
 			'extended_args',
 		);
 
-		return in_array( $column_name, $string_columns ) ? '%s' : '%d';
+		return in_array($column_name, $string_columns) ? '%s' : '%d';
 	}
 
 	/**
@@ -222,8 +222,8 @@ 
 	 * @param string $args JSON encoded action args.
 	 * @return string
 	 */
-	protected function hash_args( $args ) {
-		return md5( $args );
+	protected function hash_args($args) {
+		return md5($args);
 	}
 
 	/**
@@ -232,12 +232,12 @@ 
 	 * @param array $args Action args.
 	 * @return string
 	 */
-	protected function get_args_for_query( $args ) {
-		$encoded = wp_json_encode( $args );
-		if ( strlen( $encoded ) <= static::$max_index_length ) {
+	protected function get_args_for_query($args) {
+		$encoded = wp_json_encode($args);
+		if (strlen($encoded) <= static::$max_index_length) {
 			return $encoded;
 		}
-		return $this->hash_args( $encoded );
+		return $this->hash_args($encoded);
 	}
 	/**
 	 * Get a group's ID based on its name/slug.
@@ -247,15 +247,15 @@ 
 	 *
 	 * @return int The group's ID, if it exists or is created, or 0 if it does not exist and is not created.
 	 */
-	protected function get_group_id( $slug, $create_if_not_exists = true ) {
-		if ( empty( $slug ) ) {
+	protected function get_group_id($slug, $create_if_not_exists = true) {
+		if (empty($slug)) {
 			return 0;
 		}
 		/** @var \wpdb $wpdb */
 		global $wpdb;
-		$group_id = (int) $wpdb->get_var( $wpdb->prepare( "SELECT group_id FROM {$wpdb->actionscheduler_groups} WHERE slug=%s", $slug ) );
-		if ( empty( $group_id ) && $create_if_not_exists ) {
-			$group_id = $this->create_group( $slug );
+		$group_id = (int) $wpdb->get_var($wpdb->prepare("SELECT group_id FROM {$wpdb->actionscheduler_groups} WHERE slug=%s", $slug));
+		if (empty($group_id) && $create_if_not_exists) {
+			$group_id = $this->create_group($slug);
 		}
 
 		return $group_id;
@@ -268,10 +268,10 @@ 
 	 *
 	 * @return int Group ID.
 	 */
-	protected function create_group( $slug ) {
+	protected function create_group($slug) {
 		/** @var \wpdb $wpdb */
 		global $wpdb;
-		$wpdb->insert( $wpdb->actionscheduler_groups, array( 'slug' => $slug ) );
+		$wpdb->insert($wpdb->actionscheduler_groups, array('slug' => $slug));
 
 		return (int) $wpdb->insert_id;
 	}
@@ -283,7 +283,7 @@ 
 	 *
 	 * @return ActionScheduler_Action
 	 */
-	public function fetch_action( $action_id ) {
+	public function fetch_action($action_id) {
 		/** @var \wpdb $wpdb */
 		global $wpdb;
 		$data = $wpdb->get_row(
@@ -293,13 +293,13 @@ 
 			)
 		);
 
-		if ( empty( $data ) ) {
+		if (empty($data)) {
 			return $this->get_null_action();
 		}
 
-		if ( ! empty( $data->extended_args ) ) {
+		if ( ! empty($data->extended_args)) {
 			$data->args = $data->extended_args;
-			unset( $data->extended_args );
+			unset($data->extended_args);
 		}
 
 		// Convert NULL dates to zero dates.
@@ -309,16 +309,16 @@ 
 			'last_attempt_gmt',
 			'last_attempt_gmt',
 		);
-		foreach ( $date_fields as $date_field ) {
-			if ( $data->$date_field === null ) {
+		foreach ($date_fields as $date_field) {
+			if ($data->$date_field === null) {
 				$data->$date_field = ActionScheduler_StoreSchema::DEFAULT_DATE;
 			}
 		}
 
 		try {
-			$action = $this->make_action_from_db_record( $data );
-		} catch ( ActionScheduler_InvalidActionException $exception ) {
-			do_action( 'action_scheduler_failed_fetch_action', $action_id, $exception );
+			$action = $this->make_action_from_db_record($data);
+		} catch (ActionScheduler_InvalidActionException $exception) {
+			do_action('action_scheduler_failed_fetch_action', $action_id, $exception);
 			return $this->get_null_action();
 		}
 
@@ -341,21 +341,21 @@ 
 	 *
 	 * @return ActionScheduler_Action|ActionScheduler_CanceledAction|ActionScheduler_FinishedAction
 	 */
-	protected function make_action_from_db_record( $data ) {
+	protected function make_action_from_db_record($data) {
 
 		$hook     = $data->hook;
-		$args     = json_decode( $data->args, true );
-		$schedule = unserialize( $data->schedule ); // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_unserialize
+		$args     = json_decode($data->args, true);
+		$schedule = unserialize($data->schedule); // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_unserialize
 
-		$this->validate_args( $args, $data->action_id );
-		$this->validate_schedule( $schedule, $data->action_id );
+		$this->validate_args($args, $data->action_id);
+		$this->validate_schedule($schedule, $data->action_id);
 
-		if ( empty( $schedule ) ) {
+		if (empty($schedule)) {
 			$schedule = new ActionScheduler_NullSchedule();
 		}
 		$group = $data->group ? $data->group : '';
 
-		return ActionScheduler::factory()->get_stored_action( $data->status, $data->hook, $args, $schedule, $group );
+		return ActionScheduler::factory()->get_stored_action($data->status, $data->hook, $args, $schedule, $group);
 	}
 
 	/**
@@ -369,10 +369,10 @@ 
 	 * @return string SQL statement already properly escaped.
 	 * @throws InvalidArgumentException If the query is invalid.
 	 */
-	protected function get_query_actions_sql( array $query, $select_or_count = 'select' ) {
+	protected function get_query_actions_sql(array $query, $select_or_count = 'select') {
 
-		if ( ! in_array( $select_or_count, array( 'select', 'count' ), true ) ) {
-			throw new InvalidArgumentException( __( 'Invalid value for select or count parameter. Cannot query actions.', 'action-scheduler' ) );
+		if ( ! in_array($select_or_count, array('select', 'count'), true)) {
+			throw new InvalidArgumentException(__('Invalid value for select or count parameter. Cannot query actions.', 'action-scheduler'));
 		}
 
 		$query = wp_parse_args(
@@ -398,42 +398,42 @@ 
 		/** @var \wpdb $wpdb */
 		global $wpdb;
 
-		$db_server_info = is_callable( array( $wpdb, 'db_server_info' ) ) ? $wpdb->db_server_info() : $wpdb->db_version();
-		if ( false !== strpos( $db_server_info, 'MariaDB' ) ) {
+		$db_server_info = is_callable(array($wpdb, 'db_server_info')) ? $wpdb->db_server_info() : $wpdb->db_version();
+		if (false !== strpos($db_server_info, 'MariaDB')) {
 			$supports_json = version_compare(
-				PHP_VERSION_ID >= 80016 ? $wpdb->db_version() : preg_replace( '/[^0-9.].*/', '', str_replace( '5.5.5-', '', $db_server_info ) ),
+				PHP_VERSION_ID >= 80016 ? $wpdb->db_version() : preg_replace('/[^0-9.].*/', '', str_replace('5.5.5-', '', $db_server_info)),
 				'10.2',
 				'>='
 			);
 		} else {
-			$supports_json = version_compare( $wpdb->db_version(), '5.7', '>=' );
+			$supports_json = version_compare($wpdb->db_version(), '5.7', '>=');
 		}
 
-		$sql        = ( 'count' === $select_or_count ) ? 'SELECT count(a.action_id)' : 'SELECT a.action_id';
+		$sql        = ('count' === $select_or_count) ? 'SELECT count(a.action_id)' : 'SELECT a.action_id';
 		$sql       .= " FROM {$wpdb->actionscheduler_actions} a";
 		$sql_params = array();
 
-		if ( ! empty( $query['group'] ) || 'group' === $query['orderby'] ) {
+		if ( ! empty($query['group']) || 'group' === $query['orderby']) {
 			$sql .= " LEFT JOIN {$wpdb->actionscheduler_groups} g ON g.group_id=a.group_id";
 		}
 
 		$sql .= ' WHERE 1=1';
 
-		if ( ! empty( $query['group'] ) ) {
+		if ( ! empty($query['group'])) {
 			$sql         .= ' AND g.slug=%s';
 			$sql_params[] = $query['group'];
 		}
 
-		if ( ! empty( $query['hook'] ) ) {
+		if ( ! empty($query['hook'])) {
 			$sql         .= ' AND a.hook=%s';
 			$sql_params[] = $query['hook'];
 		}
 
-		if ( $query['args'] !== null ) {
-			switch ( $query['partial_args_matching'] ) {
+		if ($query['args'] !== null) {
+			switch ($query['partial_args_matching']) {
 				case 'json':
-					if ( ! $supports_json ) {
-						throw new \RuntimeException( __( 'JSON partial matching not supported in your environment. Please check your MySQL/MariaDB version.', 'action-scheduler' ) );
+					if ( ! $supports_json) {
+						throw new \RuntimeException(__('JSON partial matching not supported in your environment. Please check your MySQL/MariaDB version.', 'action-scheduler'));
 					}
 					$supported_types = array(
 						'integer' => '%d',
@@ -441,84 +441,84 @@ 
 						'double'  => '%f',
 						'string'  => '%s',
 					);
-					foreach ( $query['args'] as $key => $value ) {
-						$value_type = gettype( $value );
-						if ( 'boolean' === $value_type ) {
+					foreach ($query['args'] as $key => $value) {
+						$value_type = gettype($value);
+						if ('boolean' === $value_type) {
 							$value = $value ? 'true' : 'false';
 						}
-						$placeholder = isset( $supported_types[ $value_type ] ) ? $supported_types[ $value_type ] : false;
-						if ( ! $placeholder ) {
+						$placeholder = isset($supported_types[$value_type]) ? $supported_types[$value_type] : false;
+						if ( ! $placeholder) {
 							throw new \RuntimeException(
 								sprintf(
 								/* translators: %s: provided value type */
-									__( 'The value type for the JSON partial matching is not supported. Must be either integer, boolean, double or string. %s type provided.', 'action-scheduler' ),
+									__('The value type for the JSON partial matching is not supported. Must be either integer, boolean, double or string. %s type provided.', 'action-scheduler'),
 									$value_type
 								)
 							);
 						}
-						$sql         .= ' AND JSON_EXTRACT(a.args, %s)=' . $placeholder;
-						$sql_params[] = '$.' . $key;
+						$sql         .= ' AND JSON_EXTRACT(a.args, %s)='.$placeholder;
+						$sql_params[] = '$.'.$key;
 						$sql_params[] = $value;
 					}
 					break;
 				case 'like':
-					foreach ( $query['args'] as $key => $value ) {
+					foreach ($query['args'] as $key => $value) {
 						$sql         .= ' AND a.args LIKE %s';
-						$json_partial = $wpdb->esc_like( trim( json_encode( array( $key => $value ) ), '{}' ) );
+						$json_partial = $wpdb->esc_like(trim(json_encode(array($key => $value)), '{}'));
 						$sql_params[] = "%{$json_partial}%";
 					}
 					break;
 				case 'off':
 					$sql         .= ' AND a.args=%s';
-					$sql_params[] = $this->get_args_for_query( $query['args'] );
+					$sql_params[] = $this->get_args_for_query($query['args']);
 					break;
 				default:
-					throw new \RuntimeException( __( 'Unknown partial args matching value.', 'action-scheduler' ) );
+					throw new \RuntimeException(__('Unknown partial args matching value.', 'action-scheduler'));
 			}
 		}
 
-		if ( $query['status'] ) {
+		if ($query['status']) {
 			$statuses     = (array) $query['status'];
-			$placeholders = array_fill( 0, count( $statuses ), '%s' );
-			$sql         .= ' AND a.status IN (' . join( ', ', $placeholders ) . ')';
-			$sql_params   = array_merge( $sql_params, array_values( $statuses ) );
+			$placeholders = array_fill(0, count($statuses), '%s');
+			$sql         .= ' AND a.status IN ('.join(', ', $placeholders).')';
+			$sql_params   = array_merge($sql_params, array_values($statuses));
 		}
 
-		if ( $query['date'] instanceof \DateTime ) {
+		if ($query['date'] instanceof \DateTime) {
 			$date = clone $query['date'];
-			$date->setTimezone( new \DateTimeZone( 'UTC' ) );
-			$date_string  = $date->format( 'Y-m-d H:i:s' );
-			$comparator   = $this->validate_sql_comparator( $query['date_compare'] );
+			$date->setTimezone(new \DateTimeZone('UTC'));
+			$date_string  = $date->format('Y-m-d H:i:s');
+			$comparator   = $this->validate_sql_comparator($query['date_compare']);
 			$sql         .= " AND a.scheduled_date_gmt $comparator %s";
 			$sql_params[] = $date_string;
 		}
 
-		if ( $query['modified'] instanceof \DateTime ) {
+		if ($query['modified'] instanceof \DateTime) {
 			$modified = clone $query['modified'];
-			$modified->setTimezone( new \DateTimeZone( 'UTC' ) );
-			$date_string  = $modified->format( 'Y-m-d H:i:s' );
-			$comparator   = $this->validate_sql_comparator( $query['modified_compare'] );
+			$modified->setTimezone(new \DateTimeZone('UTC'));
+			$date_string  = $modified->format('Y-m-d H:i:s');
+			$comparator   = $this->validate_sql_comparator($query['modified_compare']);
 			$sql         .= " AND a.last_attempt_gmt $comparator %s";
 			$sql_params[] = $date_string;
 		}
 
-		if ( true === $query['claimed'] ) {
+		if (true === $query['claimed']) {
 			$sql .= ' AND a.claim_id != 0';
-		} elseif ( false === $query['claimed'] ) {
+		} elseif (false === $query['claimed']) {
 			$sql .= ' AND a.claim_id = 0';
-		} elseif ( $query['claimed'] !== null ) {
+		} elseif ($query['claimed'] !== null) {
 			$sql         .= ' AND a.claim_id = %d';
 			$sql_params[] = $query['claimed'];
 		}
 
-		if ( ! empty( $query['search'] ) ) {
+		if ( ! empty($query['search'])) {
 			$sql .= ' AND (a.hook LIKE %s OR (a.extended_args IS NULL AND a.args LIKE %s) OR a.extended_args LIKE %s';
-			for ( $i = 0; $i < 3; $i++ ) {
-				$sql_params[] = sprintf( '%%%s%%', $query['search'] );
+			for ($i = 0; $i < 3; $i++) {
+				$sql_params[] = sprintf('%%%s%%', $query['search']);
 			}
 
 			$search_claim_id = (int) $query['search'];
-			if ( $search_claim_id ) {
+			if ($search_claim_id) {
 				$sql         .= ' OR a.claim_id = %d';
 				$sql_params[] = $search_claim_id;
 			}
@@ -526,13 +526,13 @@ 
 			$sql .= ')';
 		}
 
-		if ( 'select' === $select_or_count ) {
-			if ( 'ASC' === strtoupper( $query['order'] ) ) {
+		if ('select' === $select_or_count) {
+			if ('ASC' === strtoupper($query['order'])) {
 				$order = 'ASC';
 			} else {
 				$order = 'DESC';
 			}
-			switch ( $query['orderby'] ) {
+			switch ($query['orderby']) {
 				case 'hook':
 					$sql .= " ORDER BY a.hook $order";
 					break;
@@ -553,15 +553,15 @@ 
 					break;
 			}
 
-			if ( $query['per_page'] > 0 ) {
+			if ($query['per_page'] > 0) {
 				$sql         .= ' LIMIT %d, %d';
 				$sql_params[] = $query['offset'];
 				$sql_params[] = $query['per_page'];
 			}
 		}
 
-		if ( ! empty( $sql_params ) ) {
-			$sql = $wpdb->prepare( $sql, $sql_params ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+		if ( ! empty($sql_params)) {
+			$sql = $wpdb->prepare($sql, $sql_params); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
 		}
 
 		return $sql;
@@ -579,13 +579,13 @@ 
 	 *
 	 * @return string|array|null The IDs of actions matching the query. Null on failure.
 	 */
-	public function query_actions( $query = array(), $query_type = 'select' ) {
+	public function query_actions($query = array(), $query_type = 'select') {
 		/** @var wpdb $wpdb */
 		global $wpdb;
 
-		$sql = $this->get_query_actions_sql( $query, $query_type );
+		$sql = $this->get_query_actions_sql($query, $query_type);
 
-		return ( 'count' === $query_type ) ? $wpdb->get_var( $sql ) : $wpdb->get_col( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.DirectDatabaseQuery.NoSql, WordPress.DB.DirectDatabaseQuery.NoCaching
+		return ('count' === $query_type) ? $wpdb->get_var($sql) : $wpdb->get_col($sql); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.DirectDatabaseQuery.NoSql, WordPress.DB.DirectDatabaseQuery.NoCaching
 	}
 
 	/**
@@ -603,10 +603,10 @@ 
 		$actions_count_by_status = array();
 		$action_stati_and_labels = $this->get_status_labels();
 
-		foreach ( $wpdb->get_results( $sql ) as $action_data ) { // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+		foreach ($wpdb->get_results($sql) as $action_data) { // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
 			// Ignore any actions with invalid status.
-			if ( array_key_exists( $action_data->status, $action_stati_and_labels ) ) {
-				$actions_count_by_status[ $action_data->status ] = $action_data->count;
+			if (array_key_exists($action_data->status, $action_stati_and_labels)) {
+				$actions_count_by_status[$action_data->status] = $action_data->count;
 			}
 		}
 
@@ -621,22 +621,22 @@ 
 	 * @return void
 	 * @throws \InvalidArgumentException If the action update failed.
 	 */
-	public function cancel_action( $action_id ) {
+	public function cancel_action($action_id) {
 		/** @var \wpdb $wpdb */
 		global $wpdb;
 
 		$updated = $wpdb->update(
 			$wpdb->actionscheduler_actions,
-			array( 'status' => self::STATUS_CANCELED ),
-			array( 'action_id' => $action_id ),
-			array( '%s' ),
-			array( '%d' )
+			array('status' => self::STATUS_CANCELED),
+			array('action_id' => $action_id),
+			array('%s'),
+			array('%d')
 		);
-		if ( false === $updated ) {
+		if (false === $updated) {
 			/* translators: %s: action ID */
-			throw new \InvalidArgumentException( sprintf( __( 'Unidentified action %s', 'action-scheduler' ), $action_id ) );
+			throw new \InvalidArgumentException(sprintf(__('Unidentified action %s', 'action-scheduler'), $action_id));
 		}
-		do_action( 'action_scheduler_canceled_action', $action_id );
+		do_action('action_scheduler_canceled_action', $action_id);
 	}
 
 	/**
@@ -648,8 +648,8 @@ 
 	 *
 	 * @return void
 	 */
-	public function cancel_actions_by_hook( $hook ) {
-		$this->bulk_cancel_actions( array( 'hook' => $hook ) );
+	public function cancel_actions_by_hook($hook) {
+		$this->bulk_cancel_actions(array('hook' => $hook));
 	}
 
 	/**
@@ -659,8 +659,8 @@ 
 	 *
 	 * @return void
 	 */
-	public function cancel_actions_by_group( $group ) {
-		$this->bulk_cancel_actions( array( 'group' => $group ) );
+	public function cancel_actions_by_group($group) {
+		$this->bulk_cancel_actions(array('group' => $group));
 	}
 
 	/**
@@ -670,16 +670,16 @@ 
 	 *
 	 * @param array $query_args Query parameters.
 	 */
-	protected function bulk_cancel_actions( $query_args ) {
+	protected function bulk_cancel_actions($query_args) {
 		/** @var \wpdb $wpdb */
 		global $wpdb;
 
-		if ( ! is_array( $query_args ) ) {
+		if ( ! is_array($query_args)) {
 			return;
 		}
 
 		// Don't cancel actions that are already canceled.
-		if ( isset( $query_args['status'] ) && self::STATUS_CANCELED === $query_args['status'] ) {
+		if (isset($query_args['status']) && self::STATUS_CANCELED === $query_args['status']) {
 			return;
 		}
 
@@ -693,16 +693,16 @@ 
 			)
 		);
 
-		while ( $action_ids ) {
-			$action_ids = $this->query_actions( $query_args );
-			if ( empty( $action_ids ) ) {
+		while ($action_ids) {
+			$action_ids = $this->query_actions($query_args);
+			if (empty($action_ids)) {
 				break;
 			}
 
-			$format     = array_fill( 0, count( $action_ids ), '%d' );
-			$query_in   = '(' . implode( ',', $format ) . ')';
+			$format     = array_fill(0, count($action_ids), '%d');
+			$query_in   = '('.implode(',', $format).')';
 			$parameters = $action_ids;
-			array_unshift( $parameters, self::STATUS_CANCELED );
+			array_unshift($parameters, self::STATUS_CANCELED);
 
 			$wpdb->query(
 				$wpdb->prepare(
@@ -711,7 +711,7 @@ 
 				)
 			);
 
-			do_action( 'action_scheduler_bulk_cancel_actions', $action_ids );
+			do_action('action_scheduler_bulk_cancel_actions', $action_ids);
 		}
 	}
 
@@ -721,14 +721,14 @@ 
 	 * @param int $action_id Action ID.
 	 * @throws \InvalidArgumentException If the action deletion failed.
 	 */
-	public function delete_action( $action_id ) {
+	public function delete_action($action_id) {
 		/** @var \wpdb $wpdb */
 		global $wpdb;
-		$deleted = $wpdb->delete( $wpdb->actionscheduler_actions, array( 'action_id' => $action_id ), array( '%d' ) );
-		if ( empty( $deleted ) ) {
-			throw new \InvalidArgumentException( sprintf( __( 'Unidentified action %s', 'action-scheduler' ), $action_id ) ); //phpcs:ignore WordPress.WP.I18n.MissingTranslatorsComment
+		$deleted = $wpdb->delete($wpdb->actionscheduler_actions, array('action_id' => $action_id), array('%d'));
+		if (empty($deleted)) {
+			throw new \InvalidArgumentException(sprintf(__('Unidentified action %s', 'action-scheduler'), $action_id)); //phpcs:ignore WordPress.WP.I18n.MissingTranslatorsComment
 		}
-		do_action( 'action_scheduler_deleted_action', $action_id );
+		do_action('action_scheduler_deleted_action', $action_id);
 	}
 
 	/**
@@ -738,9 +738,9 @@ 
 	 *
 	 * @return \DateTime The local date the action is scheduled to run, or the date that it ran.
 	 */
-	public function get_date( $action_id ) {
-		$date = $this->get_date_gmt( $action_id );
-		ActionScheduler_TimezoneHelper::set_local_timezone( $date );
+	public function get_date($action_id) {
+		$date = $this->get_date_gmt($action_id);
+		ActionScheduler_TimezoneHelper::set_local_timezone($date);
 		return $date;
 	}
 
@@ -752,17 +752,17 @@ 
 	 * @throws \InvalidArgumentException If action cannot be identified.
 	 * @return \DateTime The GMT date the action is scheduled to run, or the date that it ran.
 	 */
-	protected function get_date_gmt( $action_id ) {
+	protected function get_date_gmt($action_id) {
 		/** @var \wpdb $wpdb */
 		global $wpdb;
-		$record = $wpdb->get_row( $wpdb->prepare( "SELECT * FROM {$wpdb->actionscheduler_actions} WHERE action_id=%d", $action_id ) );
-		if ( empty( $record ) ) {
-			throw new \InvalidArgumentException( sprintf( __( 'Unidentified action %s', 'action-scheduler' ), $action_id ) ); //phpcs:ignore WordPress.WP.I18n.MissingTranslatorsComment
+		$record = $wpdb->get_row($wpdb->prepare("SELECT * FROM {$wpdb->actionscheduler_actions} WHERE action_id=%d", $action_id));
+		if (empty($record)) {
+			throw new \InvalidArgumentException(sprintf(__('Unidentified action %s', 'action-scheduler'), $action_id)); //phpcs:ignore WordPress.WP.I18n.MissingTranslatorsComment
 		}
-		if ( self::STATUS_PENDING === $record->status ) {
-			return as_get_datetime_object( $record->scheduled_date_gmt );
+		if (self::STATUS_PENDING === $record->status) {
+			return as_get_datetime_object($record->scheduled_date_gmt);
 		} else {
-			return as_get_datetime_object( $record->last_attempt_gmt );
+			return as_get_datetime_object($record->last_attempt_gmt);
 		}
 	}
 
@@ -776,15 +776,15 @@ 
 	 *
 	 * @return ActionScheduler_ActionClaim
 	 */
-	public function stake_claim( $max_actions = 10, \DateTime $before_date = null, $hooks = array(), $group = '' ) {
+	public function stake_claim($max_actions = 10, \DateTime $before_date = null, $hooks = array(), $group = '') {
 		$claim_id = $this->generate_claim_id();
 
 		$this->claim_before_date = $before_date;
-		$this->claim_actions( $claim_id, $max_actions, $before_date, $hooks, $group );
-		$action_ids              = $this->find_actions_by_claim_id( $claim_id );
+		$this->claim_actions($claim_id, $max_actions, $before_date, $hooks, $group);
+		$action_ids              = $this->find_actions_by_claim_id($claim_id);
 		$this->claim_before_date = null;
 
-		return new ActionScheduler_ActionClaim( $claim_id, $action_ids );
+		return new ActionScheduler_ActionClaim($claim_id, $action_ids);
 	}
 
 	/**
@@ -796,7 +796,7 @@ 
 		/** @var \wpdb $wpdb */
 		global $wpdb;
 		$now = as_get_datetime_object();
-		$wpdb->insert( $wpdb->actionscheduler_claims, array( 'date_created_gmt' => $now->format( 'Y-m-d H:i:s' ) ) );
+		$wpdb->insert($wpdb->actionscheduler_claims, array('date_created_gmt' => $now->format('Y-m-d H:i:s')));
 
 		return $wpdb->insert_id;
 	}
@@ -814,7 +814,7 @@ 
 	 * @throws \InvalidArgumentException Throws InvalidArgumentException if group doesn't exist.
 	 * @throws \RuntimeException Throws RuntimeException if unable to claim action.
 	 */
-	protected function claim_actions( $claim_id, $limit, \DateTime $before_date = null, $hooks = array(), $group = '' ) {
+	protected function claim_actions($claim_id, $limit, \DateTime $before_date = null, $hooks = array(), $group = '') {
 		/** @var \wpdb $wpdb */
 		global $wpdb;
 
@@ -825,28 +825,28 @@ 
 		$update = "UPDATE {$wpdb->actionscheduler_actions} SET claim_id=%d, last_attempt_gmt=%s, last_attempt_local=%s";
 		$params = array(
 			$claim_id,
-			$now->format( 'Y-m-d H:i:s' ),
-			current_time( 'mysql' ),
+			$now->format('Y-m-d H:i:s'),
+			current_time('mysql'),
 		);
 
 		$where    = 'WHERE claim_id = 0 AND scheduled_date_gmt <= %s AND status=%s';
-		$params[] = $date->format( 'Y-m-d H:i:s' );
+		$params[] = $date->format('Y-m-d H:i:s');
 		$params[] = self::STATUS_PENDING;
 
-		if ( ! empty( $hooks ) ) {
-			$placeholders = array_fill( 0, count( $hooks ), '%s' );
-			$where       .= ' AND hook IN (' . join( ', ', $placeholders ) . ')';
-			$params       = array_merge( $params, array_values( $hooks ) );
+		if ( ! empty($hooks)) {
+			$placeholders = array_fill(0, count($hooks), '%s');
+			$where       .= ' AND hook IN ('.join(', ', $placeholders).')';
+			$params       = array_merge($params, array_values($hooks));
 		}
 
-		if ( ! empty( $group ) ) {
+		if ( ! empty($group)) {
 
-			$group_id = $this->get_group_id( $group, false );
+			$group_id = $this->get_group_id($group, false);
 
 			// throw exception if no matching group found, this matches ActionScheduler_wpPostStore's behaviour.
-			if ( empty( $group_id ) ) {
+			if (empty($group_id)) {
 				/* translators: %s: group name */
-				throw new InvalidArgumentException( sprintf( __( 'The group "%s" does not exist.', 'action-scheduler' ), $group ) );
+				throw new InvalidArgumentException(sprintf(__('The group "%s" does not exist.', 'action-scheduler'), $group));
 			}
 
 			$where   .= ' AND group_id = %d';
@@ -860,13 +860,13 @@ 
 		 *
 		 * @param string $order_by_sql
 		 */
-		$order    = apply_filters( 'action_scheduler_claim_actions_order_by', 'ORDER BY attempts ASC, scheduled_date_gmt ASC, action_id ASC' );
+		$order    = apply_filters('action_scheduler_claim_actions_order_by', 'ORDER BY attempts ASC, scheduled_date_gmt ASC, action_id ASC');
 		$params[] = $limit;
 
-		$sql           = $wpdb->prepare( "{$update} {$where} {$order} LIMIT %d", $params ); // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared, WordPress.DB.PreparedSQLPlaceholders
-		$rows_affected = $wpdb->query( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching
-		if ( false === $rows_affected ) {
-			throw new \RuntimeException( __( 'Unable to claim actions. Database error.', 'action-scheduler' ) );
+		$sql           = $wpdb->prepare("{$update} {$where} {$order} LIMIT %d", $params); // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared, WordPress.DB.PreparedSQLPlaceholders
+		$rows_affected = $wpdb->query($sql); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching
+		if (false === $rows_affected) {
+			throw new \RuntimeException(__('Unable to claim actions. Database error.', 'action-scheduler'));
 		}
 
 		return (int) $rows_affected;
@@ -881,9 +881,9 @@ 
 		global $wpdb;
 
 		$sql = "SELECT COUNT(DISTINCT claim_id) FROM {$wpdb->actionscheduler_actions} WHERE claim_id != 0 AND status IN ( %s, %s)";
-		$sql = $wpdb->prepare( $sql, array( self::STATUS_PENDING, self::STATUS_RUNNING ) ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+		$sql = $wpdb->prepare($sql, array(self::STATUS_PENDING, self::STATUS_RUNNING)); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
 
-		return (int) $wpdb->get_var( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+		return (int) $wpdb->get_var($sql); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
 	}
 
 	/**
@@ -892,14 +892,14 @@ 
 	 * @param string $action_id Action ID.
 	 * @return mixed
 	 */
-	public function get_claim_id( $action_id ) {
+	public function get_claim_id($action_id) {
 		/** @var \wpdb $wpdb */
 		global $wpdb;
 
 		$sql = "SELECT claim_id FROM {$wpdb->actionscheduler_actions} WHERE action_id=%d";
-		$sql = $wpdb->prepare( $sql, $action_id ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+		$sql = $wpdb->prepare($sql, $action_id); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
 
-		return (int) $wpdb->get_var( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+		return (int) $wpdb->get_var($sql); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
 	}
 
 	/**
@@ -908,13 +908,13 @@ 
 	 * @param  int $claim_id Claim ID.
 	 * @return int[]
 	 */
-	public function find_actions_by_claim_id( $claim_id ) {
+	public function find_actions_by_claim_id($claim_id) {
 		/** @var \wpdb $wpdb */
 		global $wpdb;
 
 		$action_ids  = array();
-		$before_date = isset( $this->claim_before_date ) ? $this->claim_before_date : as_get_datetime_object();
-		$cut_off     = $before_date->format( 'Y-m-d H:i:s' );
+		$before_date = isset($this->claim_before_date) ? $this->claim_before_date : as_get_datetime_object();
+		$cut_off     = $before_date->format('Y-m-d H:i:s');
 
 		$sql = $wpdb->prepare(
 			"SELECT action_id, scheduled_date_gmt FROM {$wpdb->actionscheduler_actions} WHERE claim_id = %d",
@@ -923,9 +923,9 @@ 
 
 		// Verify that the scheduled date for each action is within the expected bounds (in some unusual
 		// cases, we cannot depend on MySQL to honor all of the WHERE conditions we specify).
-		foreach ( $wpdb->get_results( $sql ) as $claimed_action ) { // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-			if ( $claimed_action->scheduled_date_gmt <= $cut_off ) {
-				$action_ids[] = absint( $claimed_action->action_id );
+		foreach ($wpdb->get_results($sql) as $claimed_action) { // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+			if ($claimed_action->scheduled_date_gmt <= $cut_off) {
+				$action_ids[] = absint($claimed_action->action_id);
 			}
 		}
 
@@ -937,11 +937,11 @@ 
 	 *
 	 * @param ActionScheduler_ActionClaim $claim Claim object.
 	 */
-	public function release_claim( ActionScheduler_ActionClaim $claim ) {
+	public function release_claim(ActionScheduler_ActionClaim $claim) {
 		/** @var \wpdb $wpdb */
 		global $wpdb;
-		$wpdb->update( $wpdb->actionscheduler_actions, array( 'claim_id' => 0 ), array( 'claim_id' => $claim->get_id() ), array( '%d' ), array( '%d' ) );
-		$wpdb->delete( $wpdb->actionscheduler_claims, array( 'claim_id' => $claim->get_id() ), array( '%d' ) );
+		$wpdb->update($wpdb->actionscheduler_actions, array('claim_id' => 0), array('claim_id' => $claim->get_id()), array('%d'), array('%d'));
+		$wpdb->delete($wpdb->actionscheduler_claims, array('claim_id' => $claim->get_id()), array('%d'));
 	}
 
 	/**
@@ -951,15 +951,15 @@ 
 	 *
 	 * @return void
 	 */
-	public function unclaim_action( $action_id ) {
+	public function unclaim_action($action_id) {
 		/** @var \wpdb $wpdb */
 		global $wpdb;
 		$wpdb->update(
 			$wpdb->actionscheduler_actions,
-			array( 'claim_id' => 0 ),
-			array( 'action_id' => $action_id ),
-			array( '%s' ),
-			array( '%d' )
+			array('claim_id' => 0),
+			array('action_id' => $action_id),
+			array('%s'),
+			array('%d')
 		);
 	}
 
@@ -969,18 +969,18 @@ 
 	 * @param int $action_id Action ID.
 	 * @throws \InvalidArgumentException Throw an exception if action was not updated.
 	 */
-	public function mark_failure( $action_id ) {
+	public function mark_failure($action_id) {
 		/** @var \wpdb $wpdb */
 		global $wpdb;
 		$updated = $wpdb->update(
 			$wpdb->actionscheduler_actions,
-			array( 'status' => self::STATUS_FAILED ),
-			array( 'action_id' => $action_id ),
-			array( '%s' ),
-			array( '%d' )
+			array('status' => self::STATUS_FAILED),
+			array('action_id' => $action_id),
+			array('%s'),
+			array('%d')
 		);
-		if ( empty( $updated ) ) {
-			throw new \InvalidArgumentException( sprintf( __( 'Unidentified action %s', 'action-scheduler' ), $action_id ) ); //phpcs:ignore WordPress.WP.I18n.MissingTranslatorsComment
+		if (empty($updated)) {
+			throw new \InvalidArgumentException(sprintf(__('Unidentified action %s', 'action-scheduler'), $action_id)); //phpcs:ignore WordPress.WP.I18n.MissingTranslatorsComment
 		}
 	}
 
@@ -991,13 +991,13 @@ 
 	 *
 	 * @return void
 	 */
-	public function log_execution( $action_id ) {
+	public function log_execution($action_id) {
 		/** @var \wpdb $wpdb */
 		global $wpdb;
 
 		$sql = "UPDATE {$wpdb->actionscheduler_actions} SET attempts = attempts+1, status=%s, last_attempt_gmt = %s, last_attempt_local = %s WHERE action_id = %d";
-		$sql = $wpdb->prepare( $sql, self::STATUS_RUNNING, current_time( 'mysql', true ), current_time( 'mysql' ), $action_id ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-		$wpdb->query( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+		$sql = $wpdb->prepare($sql, self::STATUS_RUNNING, current_time('mysql', true), current_time('mysql'), $action_id); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+		$wpdb->query($sql); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
 	}
 
 	/**
@@ -1008,22 +1008,22 @@ 
 	 * @return void
 	 * @throws \InvalidArgumentException Throw an exception if action was not updated.
 	 */
-	public function mark_complete( $action_id ) {
+	public function mark_complete($action_id) {
 		/** @var \wpdb $wpdb */
 		global $wpdb;
 		$updated = $wpdb->update(
 			$wpdb->actionscheduler_actions,
 			array(
 				'status'             => self::STATUS_COMPLETE,
-				'last_attempt_gmt'   => current_time( 'mysql', true ),
-				'last_attempt_local' => current_time( 'mysql' ),
+				'last_attempt_gmt'   => current_time('mysql', true),
+				'last_attempt_local' => current_time('mysql'),
 			),
-			array( 'action_id' => $action_id ),
-			array( '%s' ),
-			array( '%d' )
+			array('action_id' => $action_id),
+			array('%s'),
+			array('%d')
 		);
-		if ( empty( $updated ) ) {
-			throw new \InvalidArgumentException( sprintf( __( 'Unidentified action %s', 'action-scheduler' ), $action_id ) ); //phpcs:ignore WordPress.WP.I18n.MissingTranslatorsComment
+		if (empty($updated)) {
+			throw new \InvalidArgumentException(sprintf(__('Unidentified action %s', 'action-scheduler'), $action_id)); //phpcs:ignore WordPress.WP.I18n.MissingTranslatorsComment
 		}
 
 		/**
@@ -1033,7 +1033,7 @@ 
 		 *
 		 * @param int $action_id Action ID.
 		 */
-		do_action( 'action_scheduler_completed_action', $action_id );
+		do_action('action_scheduler_completed_action', $action_id);
 	}
 
 	/**
@@ -1045,17 +1045,17 @@ 
 	 * @throws \InvalidArgumentException Throw an exception if not status was found for action_id.
 	 * @throws \RuntimeException Throw an exception if action status could not be retrieved.
 	 */
-	public function get_status( $action_id ) {
+	public function get_status($action_id) {
 		/** @var \wpdb $wpdb */
 		global $wpdb;
 		$sql    = "SELECT status FROM {$wpdb->actionscheduler_actions} WHERE action_id=%d";
-		$sql    = $wpdb->prepare( $sql, $action_id ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-		$status = $wpdb->get_var( $sql ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+		$sql    = $wpdb->prepare($sql, $action_id); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+		$status = $wpdb->get_var($sql); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
 
-		if ( null === $status ) {
-			throw new \InvalidArgumentException( __( 'Invalid action ID. No status found.', 'action-scheduler' ) );
-		} elseif ( empty( $status ) ) {
-			throw new \RuntimeException( __( 'Unknown status found for action.', 'action-scheduler' ) );
+		if (null === $status) {
+			throw new \InvalidArgumentException(__('Invalid action ID. No status found.', 'action-scheduler'));
+		} elseif (empty($status)) {
+			throw new \RuntimeException(__('Unknown status found for action.', 'action-scheduler'));
 		} else {
 			return $status;
 		}

src/libraries/action-scheduler/classes/data-stores/ActionScheduler_wpCommentLogger.php

Indentation +238 added lines, -238 removed lines

@@ -4,243 +4,243 @@
  * Class ActionScheduler_wpCommentLogger
  */
 class ActionScheduler_wpCommentLogger extends ActionScheduler_Logger {
-	const AGENT = 'ActionScheduler';
-	const TYPE  = 'action_log';
-
-	/**
-	 * @param string   $action_id
-	 * @param string   $message
-	 * @param DateTime $date
-	 *
-	 * @return string The log entry ID
-	 */
-	public function log( $action_id, $message, DateTime $date = null ) {
-		if ( empty( $date ) ) {
-			$date = as_get_datetime_object();
-		} else {
-			$date = as_get_datetime_object( clone $date );
-		}
-		$comment_id = $this->create_wp_comment( $action_id, $message, $date );
-		return $comment_id;
-	}
-
-	protected function create_wp_comment( $action_id, $message, DateTime $date ) {
-
-		$comment_date_gmt = $date->format( 'Y-m-d H:i:s' );
-		ActionScheduler_TimezoneHelper::set_local_timezone( $date );
-		$comment_data = array(
-			'comment_post_ID'  => $action_id,
-			'comment_date'     => $date->format( 'Y-m-d H:i:s' ),
-			'comment_date_gmt' => $comment_date_gmt,
-			'comment_author'   => self::AGENT,
-			'comment_content'  => $message,
-			'comment_agent'    => self::AGENT,
-			'comment_type'     => self::TYPE,
-		);
-		return wp_insert_comment( $comment_data );
-	}
-
-	/**
-	 * @param string $entry_id
-	 *
-	 * @return ActionScheduler_LogEntry
-	 */
-	public function get_entry( $entry_id ) {
-		$comment = $this->get_comment( $entry_id );
-		if ( empty( $comment ) || $comment->comment_type != self::TYPE ) {
-			return new ActionScheduler_NullLogEntry();
-		}
-
-		$date = as_get_datetime_object( $comment->comment_date_gmt );
-		ActionScheduler_TimezoneHelper::set_local_timezone( $date );
-		return new ActionScheduler_LogEntry( $comment->comment_post_ID, $comment->comment_content, $date );
-	}
-
-	/**
-	 * @param string $action_id
-	 *
-	 * @return ActionScheduler_LogEntry[]
-	 */
-	public function get_logs( $action_id ) {
-		$status = 'all';
-		if ( get_post_status( $action_id ) == 'trash' ) {
-			$status = 'post-trashed';
-		}
-		$comments = get_comments(
-			array(
-				'post_id' => $action_id,
-				'orderby' => 'comment_date_gmt',
-				'order'   => 'ASC',
-				'type'    => self::TYPE,
-				'status'  => $status,
-			)
-		);
-		$logs     = array();
-		foreach ( $comments as $c ) {
-			$entry = $this->get_entry( $c );
-			if ( ! empty( $entry ) ) {
-				$logs[] = $entry;
-			}
-		}
-		return $logs;
-	}
-
-	protected function get_comment( $comment_id ) {
-		return get_comment( $comment_id );
-	}
-
-	/**
-	 * @param WP_Comment_Query $query
-	 */
-	public function filter_comment_queries( $query ) {
-		foreach ( array( 'ID', 'parent', 'post_author', 'post_name', 'post_parent', 'type', 'post_type', 'post_id', 'post_ID' ) as $key ) {
-			if ( ! empty( $query->query_vars[ $key ] ) ) {
-				return; // don't slow down queries that wouldn't include action_log comments anyway
-			}
-		}
-		$query->query_vars['action_log_filter'] = true;
-		add_filter( 'comments_clauses', array( $this, 'filter_comment_query_clauses' ), 10, 2 );
-	}
-
-	/**
-	 * @param array            $clauses
-	 * @param WP_Comment_Query $query
-	 *
-	 * @return array
-	 */
-	public function filter_comment_query_clauses( $clauses, $query ) {
-		if ( ! empty( $query->query_vars['action_log_filter'] ) ) {
-			$clauses['where'] .= $this->get_where_clause();
-		}
-		return $clauses;
-	}
-
-	/**
-	 * Make sure Action Scheduler logs are excluded from comment feeds, which use WP_Query, not
-	 * the WP_Comment_Query class handled by @see self::filter_comment_queries().
-	 *
-	 * @param string   $where
-	 * @param WP_Query $query
-	 *
-	 * @return string
-	 */
-	public function filter_comment_feed( $where, $query ) {
-		if ( is_comment_feed() ) {
-			$where .= $this->get_where_clause();
-		}
-		return $where;
-	}
-
-	/**
-	 * Return a SQL clause to exclude Action Scheduler comments.
-	 *
-	 * @return string
-	 */
-	protected function get_where_clause() {
-		global $wpdb;
-		return sprintf( " AND {$wpdb->comments}.comment_type != '%s'", self::TYPE );
-	}
-
-	/**
-	 * Remove action log entries from wp_count_comments()
-	 *
-	 * @param array $stats
-	 * @param int   $post_id
-	 *
-	 * @return object
-	 */
-	public function filter_comment_count( $stats, $post_id ) {
-		global $wpdb;
-
-		if ( 0 === $post_id ) {
-			$stats = $this->get_comment_count();
-		}
-
-		return $stats;
-	}
-
-	/**
-	 * Retrieve the comment counts from our cache, or the database if the cached version isn't set.
-	 *
-	 * @return object
-	 */
-	protected function get_comment_count() {
-		global $wpdb;
-
-		$stats = get_transient( 'as_comment_count' );
-
-		if ( ! $stats ) {
-			$stats = array();
-
-			$count = $wpdb->get_results( "SELECT comment_approved, COUNT( * ) AS num_comments FROM {$wpdb->comments} WHERE comment_type NOT IN('order_note','action_log') GROUP BY comment_approved", ARRAY_A );
-
-			$total    = 0;
-			$stats    = array();
-			$approved = array(
-				'0'            => 'moderated',
-				'1'            => 'approved',
-				'spam'         => 'spam',
-				'trash'        => 'trash',
-				'post-trashed' => 'post-trashed',
-			);
-
-			foreach ( (array) $count as $row ) {
-				// Don't count post-trashed toward totals
-				if ( 'post-trashed' != $row['comment_approved'] && 'trash' != $row['comment_approved'] ) {
-					$total += $row['num_comments'];
-				}
-				if ( isset( $approved[ $row['comment_approved'] ] ) ) {
-					$stats[ $approved[ $row['comment_approved'] ] ] = $row['num_comments'];
-				}
-			}
-
-			$stats['total_comments'] = $total;
-			$stats['all']            = $total;
-
-			foreach ( $approved as $key ) {
-				if ( empty( $stats[ $key ] ) ) {
-					$stats[ $key ] = 0;
-				}
-			}
-
-			$stats = (object) $stats;
-			set_transient( 'as_comment_count', $stats );
-		}
-
-		return $stats;
-	}
-
-	/**
-	 * Delete comment count cache whenever there is new comment or the status of a comment changes. Cache
-	 * will be regenerated next time ActionScheduler_wpCommentLogger::filter_comment_count() is called.
-	 */
-	public function delete_comment_count_cache() {
-		delete_transient( 'as_comment_count' );
-	}
-
-	/**
-	 * @codeCoverageIgnore
-	 */
-	public function init() {
-		add_action( 'action_scheduler_before_process_queue', array( $this, 'disable_comment_counting' ), 10, 0 );
-		add_action( 'action_scheduler_after_process_queue', array( $this, 'enable_comment_counting' ), 10, 0 );
-
-		parent::init();
-
-		add_action( 'pre_get_comments', array( $this, 'filter_comment_queries' ), 10, 1 );
-		add_action( 'wp_count_comments', array( $this, 'filter_comment_count' ), 20, 2 ); // run after WC_Comments::wp_count_comments() to make sure we exclude order notes and action logs
-		add_action( 'comment_feed_where', array( $this, 'filter_comment_feed' ), 10, 2 );
-
-		// Delete comments count cache whenever there is a new comment or a comment status changes
-		add_action( 'wp_insert_comment', array( $this, 'delete_comment_count_cache' ) );
-		add_action( 'wp_set_comment_status', array( $this, 'delete_comment_count_cache' ) );
-	}
-
-	public function disable_comment_counting() {
-		wp_defer_comment_counting( true );
-	}
-	public function enable_comment_counting() {
-		wp_defer_comment_counting( false );
-	}
+    const AGENT = 'ActionScheduler';
+    const TYPE  = 'action_log';
+
+    /**
+     * @param string   $action_id
+     * @param string   $message
+     * @param DateTime $date
+     *
+     * @return string The log entry ID
+     */
+    public function log( $action_id, $message, DateTime $date = null ) {
+        if ( empty( $date ) ) {
+            $date = as_get_datetime_object();
+        } else {
+            $date = as_get_datetime_object( clone $date );
+        }
+        $comment_id = $this->create_wp_comment( $action_id, $message, $date );
+        return $comment_id;
+    }
+
+    protected function create_wp_comment( $action_id, $message, DateTime $date ) {
+
+        $comment_date_gmt = $date->format( 'Y-m-d H:i:s' );
+        ActionScheduler_TimezoneHelper::set_local_timezone( $date );
+        $comment_data = array(
+            'comment_post_ID'  => $action_id,
+            'comment_date'     => $date->format( 'Y-m-d H:i:s' ),
+            'comment_date_gmt' => $comment_date_gmt,
+            'comment_author'   => self::AGENT,
+            'comment_content'  => $message,
+            'comment_agent'    => self::AGENT,
+            'comment_type'     => self::TYPE,
+        );
+        return wp_insert_comment( $comment_data );
+    }
+
+    /**
+     * @param string $entry_id
+     *
+     * @return ActionScheduler_LogEntry
+     */
+    public function get_entry( $entry_id ) {
+        $comment = $this->get_comment( $entry_id );
+        if ( empty( $comment ) || $comment->comment_type != self::TYPE ) {
+            return new ActionScheduler_NullLogEntry();
+        }
+
+        $date = as_get_datetime_object( $comment->comment_date_gmt );
+        ActionScheduler_TimezoneHelper::set_local_timezone( $date );
+        return new ActionScheduler_LogEntry( $comment->comment_post_ID, $comment->comment_content, $date );
+    }
+
+    /**
+     * @param string $action_id
+     *
+     * @return ActionScheduler_LogEntry[]
+     */
+    public function get_logs( $action_id ) {
+        $status = 'all';
+        if ( get_post_status( $action_id ) == 'trash' ) {
+            $status = 'post-trashed';
+        }
+        $comments = get_comments(
+            array(
+                'post_id' => $action_id,
+                'orderby' => 'comment_date_gmt',
+                'order'   => 'ASC',
+                'type'    => self::TYPE,
+                'status'  => $status,
+            )
+        );
+        $logs     = array();
+        foreach ( $comments as $c ) {
+            $entry = $this->get_entry( $c );
+            if ( ! empty( $entry ) ) {
+                $logs[] = $entry;
+            }
+        }
+        return $logs;
+    }
+
+    protected function get_comment( $comment_id ) {
+        return get_comment( $comment_id );
+    }
+
+    /**
+     * @param WP_Comment_Query $query
+     */
+    public function filter_comment_queries( $query ) {
+        foreach ( array( 'ID', 'parent', 'post_author', 'post_name', 'post_parent', 'type', 'post_type', 'post_id', 'post_ID' ) as $key ) {
+            if ( ! empty( $query->query_vars[ $key ] ) ) {
+                return; // don't slow down queries that wouldn't include action_log comments anyway
+            }
+        }
+        $query->query_vars['action_log_filter'] = true;
+        add_filter( 'comments_clauses', array( $this, 'filter_comment_query_clauses' ), 10, 2 );
+    }
+
+    /**
+     * @param array            $clauses
+     * @param WP_Comment_Query $query
+     *
+     * @return array
+     */
+    public function filter_comment_query_clauses( $clauses, $query ) {
+        if ( ! empty( $query->query_vars['action_log_filter'] ) ) {
+            $clauses['where'] .= $this->get_where_clause();
+        }
+        return $clauses;
+    }
+
+    /**
+     * Make sure Action Scheduler logs are excluded from comment feeds, which use WP_Query, not
+     * the WP_Comment_Query class handled by @see self::filter_comment_queries().
+     *
+     * @param string   $where
+     * @param WP_Query $query
+     *
+     * @return string
+     */
+    public function filter_comment_feed( $where, $query ) {
+        if ( is_comment_feed() ) {
+            $where .= $this->get_where_clause();
+        }
+        return $where;
+    }
+
+    /**
+     * Return a SQL clause to exclude Action Scheduler comments.
+     *
+     * @return string
+     */
+    protected function get_where_clause() {
+        global $wpdb;
+        return sprintf( " AND {$wpdb->comments}.comment_type != '%s'", self::TYPE );
+    }
+
+    /**
+     * Remove action log entries from wp_count_comments()
+     *
+     * @param array $stats
+     * @param int   $post_id
+     *
+     * @return object
+     */
+    public function filter_comment_count( $stats, $post_id ) {
+        global $wpdb;
+
+        if ( 0 === $post_id ) {
+            $stats = $this->get_comment_count();
+        }
+
+        return $stats;
+    }
+
+    /**
+     * Retrieve the comment counts from our cache, or the database if the cached version isn't set.
+     *
+     * @return object
+     */
+    protected function get_comment_count() {
+        global $wpdb;
+
+        $stats = get_transient( 'as_comment_count' );
+
+        if ( ! $stats ) {
+            $stats = array();
+
+            $count = $wpdb->get_results( "SELECT comment_approved, COUNT( * ) AS num_comments FROM {$wpdb->comments} WHERE comment_type NOT IN('order_note','action_log') GROUP BY comment_approved", ARRAY_A );
+
+            $total    = 0;
+            $stats    = array();
+            $approved = array(
+                '0'            => 'moderated',
+                '1'            => 'approved',
+                'spam'         => 'spam',
+                'trash'        => 'trash',
+                'post-trashed' => 'post-trashed',
+            );
+
+            foreach ( (array) $count as $row ) {
+                // Don't count post-trashed toward totals
+                if ( 'post-trashed' != $row['comment_approved'] && 'trash' != $row['comment_approved'] ) {
+                    $total += $row['num_comments'];
+                }
+                if ( isset( $approved[ $row['comment_approved'] ] ) ) {
+                    $stats[ $approved[ $row['comment_approved'] ] ] = $row['num_comments'];
+                }
+            }
+
+            $stats['total_comments'] = $total;
+            $stats['all']            = $total;
+
+            foreach ( $approved as $key ) {
+                if ( empty( $stats[ $key ] ) ) {
+                    $stats[ $key ] = 0;
+                }
+            }
+
+            $stats = (object) $stats;
+            set_transient( 'as_comment_count', $stats );
+        }
+
+        return $stats;
+    }
+
+    /**
+     * Delete comment count cache whenever there is new comment or the status of a comment changes. Cache
+     * will be regenerated next time ActionScheduler_wpCommentLogger::filter_comment_count() is called.
+     */
+    public function delete_comment_count_cache() {
+        delete_transient( 'as_comment_count' );
+    }
+
+    /**
+     * @codeCoverageIgnore
+     */
+    public function init() {
+        add_action( 'action_scheduler_before_process_queue', array( $this, 'disable_comment_counting' ), 10, 0 );
+        add_action( 'action_scheduler_after_process_queue', array( $this, 'enable_comment_counting' ), 10, 0 );
+
+        parent::init();
+
+        add_action( 'pre_get_comments', array( $this, 'filter_comment_queries' ), 10, 1 );
+        add_action( 'wp_count_comments', array( $this, 'filter_comment_count' ), 20, 2 ); // run after WC_Comments::wp_count_comments() to make sure we exclude order notes and action logs
+        add_action( 'comment_feed_where', array( $this, 'filter_comment_feed' ), 10, 2 );
+
+        // Delete comments count cache whenever there is a new comment or a comment status changes
+        add_action( 'wp_insert_comment', array( $this, 'delete_comment_count_cache' ) );
+        add_action( 'wp_set_comment_status', array( $this, 'delete_comment_count_cache' ) );
+    }
+
+    public function disable_comment_counting() {
+        wp_defer_comment_counting( true );
+    }
+    public function enable_comment_counting() {
+        wp_defer_comment_counting( false );
+    }
 
 }

Spacing +55 added lines, -55 removed lines

@@ -14,30 +14,30 @@ 
 	 *
 	 * @return string The log entry ID
 	 */
-	public function log( $action_id, $message, DateTime $date = null ) {
-		if ( empty( $date ) ) {
+	public function log($action_id, $message, DateTime $date = null) {
+		if (empty($date)) {
 			$date = as_get_datetime_object();
 		} else {
-			$date = as_get_datetime_object( clone $date );
+			$date = as_get_datetime_object(clone $date);
 		}
-		$comment_id = $this->create_wp_comment( $action_id, $message, $date );
+		$comment_id = $this->create_wp_comment($action_id, $message, $date);
 		return $comment_id;
 	}
 
-	protected function create_wp_comment( $action_id, $message, DateTime $date ) {
+	protected function create_wp_comment($action_id, $message, DateTime $date) {
 
-		$comment_date_gmt = $date->format( 'Y-m-d H:i:s' );
-		ActionScheduler_TimezoneHelper::set_local_timezone( $date );
+		$comment_date_gmt = $date->format('Y-m-d H:i:s');
+		ActionScheduler_TimezoneHelper::set_local_timezone($date);
 		$comment_data = array(
 			'comment_post_ID'  => $action_id,
-			'comment_date'     => $date->format( 'Y-m-d H:i:s' ),
+			'comment_date'     => $date->format('Y-m-d H:i:s'),
 			'comment_date_gmt' => $comment_date_gmt,
 			'comment_author'   => self::AGENT,
 			'comment_content'  => $message,
 			'comment_agent'    => self::AGENT,
 			'comment_type'     => self::TYPE,
 		);
-		return wp_insert_comment( $comment_data );
+		return wp_insert_comment($comment_data);
 	}
 
 	/**
@@ -45,15 +45,15 @@ 
 	 *
 	 * @return ActionScheduler_LogEntry
 	 */
-	public function get_entry( $entry_id ) {
-		$comment = $this->get_comment( $entry_id );
-		if ( empty( $comment ) || $comment->comment_type != self::TYPE ) {
+	public function get_entry($entry_id) {
+		$comment = $this->get_comment($entry_id);
+		if (empty($comment) || $comment->comment_type != self::TYPE) {
 			return new ActionScheduler_NullLogEntry();
 		}
 
-		$date = as_get_datetime_object( $comment->comment_date_gmt );
-		ActionScheduler_TimezoneHelper::set_local_timezone( $date );
-		return new ActionScheduler_LogEntry( $comment->comment_post_ID, $comment->comment_content, $date );
+		$date = as_get_datetime_object($comment->comment_date_gmt);
+		ActionScheduler_TimezoneHelper::set_local_timezone($date);
+		return new ActionScheduler_LogEntry($comment->comment_post_ID, $comment->comment_content, $date);
 	}
 
 	/**
@@ -61,9 +61,9 @@ 
 	 *
 	 * @return ActionScheduler_LogEntry[]
 	 */
-	public function get_logs( $action_id ) {
+	public function get_logs($action_id) {
 		$status = 'all';
-		if ( get_post_status( $action_id ) == 'trash' ) {
+		if (get_post_status($action_id) == 'trash') {
 			$status = 'post-trashed';
 		}
 		$comments = get_comments(
@@ -75,31 +75,31 @@ 
 				'status'  => $status,
 			)
 		);
-		$logs     = array();
-		foreach ( $comments as $c ) {
-			$entry = $this->get_entry( $c );
-			if ( ! empty( $entry ) ) {
+		$logs = array();
+		foreach ($comments as $c) {
+			$entry = $this->get_entry($c);
+			if ( ! empty($entry)) {
 				$logs[] = $entry;
 			}
 		}
 		return $logs;
 	}
 
-	protected function get_comment( $comment_id ) {
-		return get_comment( $comment_id );
+	protected function get_comment($comment_id) {
+		return get_comment($comment_id);
 	}
 
 	/**
 	 * @param WP_Comment_Query $query
 	 */
-	public function filter_comment_queries( $query ) {
-		foreach ( array( 'ID', 'parent', 'post_author', 'post_name', 'post_parent', 'type', 'post_type', 'post_id', 'post_ID' ) as $key ) {
-			if ( ! empty( $query->query_vars[ $key ] ) ) {
+	public function filter_comment_queries($query) {
+		foreach (array('ID', 'parent', 'post_author', 'post_name', 'post_parent', 'type', 'post_type', 'post_id', 'post_ID') as $key) {
+			if ( ! empty($query->query_vars[$key])) {
 				return; // don't slow down queries that wouldn't include action_log comments anyway
 			}
 		}
 		$query->query_vars['action_log_filter'] = true;
-		add_filter( 'comments_clauses', array( $this, 'filter_comment_query_clauses' ), 10, 2 );
+		add_filter('comments_clauses', array($this, 'filter_comment_query_clauses'), 10, 2);
 	}
 
 	/**
@@ -108,8 +108,8 @@ 
 	 *
 	 * @return array
 	 */
-	public function filter_comment_query_clauses( $clauses, $query ) {
-		if ( ! empty( $query->query_vars['action_log_filter'] ) ) {
+	public function filter_comment_query_clauses($clauses, $query) {
+		if ( ! empty($query->query_vars['action_log_filter'])) {
 			$clauses['where'] .= $this->get_where_clause();
 		}
 		return $clauses;
@@ -124,8 +124,8 @@ 
 	 *
 	 * @return string
 	 */
-	public function filter_comment_feed( $where, $query ) {
-		if ( is_comment_feed() ) {
+	public function filter_comment_feed($where, $query) {
+		if (is_comment_feed()) {
 			$where .= $this->get_where_clause();
 		}
 		return $where;
@@ -138,7 +138,7 @@ 
 	 */
 	protected function get_where_clause() {
 		global $wpdb;
-		return sprintf( " AND {$wpdb->comments}.comment_type != '%s'", self::TYPE );
+		return sprintf(" AND {$wpdb->comments}.comment_type != '%s'", self::TYPE);
 	}
 
 	/**
@@ -149,10 +149,10 @@ 
 	 *
 	 * @return object
 	 */
-	public function filter_comment_count( $stats, $post_id ) {
+	public function filter_comment_count($stats, $post_id) {
 		global $wpdb;
 
-		if ( 0 === $post_id ) {
+		if (0 === $post_id) {
 			$stats = $this->get_comment_count();
 		}
 
@@ -167,12 +167,12 @@ 
 	protected function get_comment_count() {
 		global $wpdb;
 
-		$stats = get_transient( 'as_comment_count' );
+		$stats = get_transient('as_comment_count');
 
-		if ( ! $stats ) {
+		if ( ! $stats) {
 			$stats = array();
 
-			$count = $wpdb->get_results( "SELECT comment_approved, COUNT( * ) AS num_comments FROM {$wpdb->comments} WHERE comment_type NOT IN('order_note','action_log') GROUP BY comment_approved", ARRAY_A );
+			$count = $wpdb->get_results("SELECT comment_approved, COUNT( * ) AS num_comments FROM {$wpdb->comments} WHERE comment_type NOT IN('order_note','action_log') GROUP BY comment_approved", ARRAY_A);
 
 			$total    = 0;
 			$stats    = array();
@@ -184,27 +184,27 @@ 
 				'post-trashed' => 'post-trashed',
 			);
 
-			foreach ( (array) $count as $row ) {
+			foreach ((array) $count as $row) {
 				// Don't count post-trashed toward totals
-				if ( 'post-trashed' != $row['comment_approved'] && 'trash' != $row['comment_approved'] ) {
+				if ('post-trashed' != $row['comment_approved'] && 'trash' != $row['comment_approved']) {
 					$total += $row['num_comments'];
 				}
-				if ( isset( $approved[ $row['comment_approved'] ] ) ) {
-					$stats[ $approved[ $row['comment_approved'] ] ] = $row['num_comments'];
+				if (isset($approved[$row['comment_approved']])) {
+					$stats[$approved[$row['comment_approved']]] = $row['num_comments'];
 				}
 			}
 
 			$stats['total_comments'] = $total;
 			$stats['all']            = $total;
 
-			foreach ( $approved as $key ) {
-				if ( empty( $stats[ $key ] ) ) {
-					$stats[ $key ] = 0;
+			foreach ($approved as $key) {
+				if (empty($stats[$key])) {
+					$stats[$key] = 0;
 				}
 			}
 
 			$stats = (object) $stats;
-			set_transient( 'as_comment_count', $stats );
+			set_transient('as_comment_count', $stats);
 		}
 
 		return $stats;
@@ -215,32 +215,32 @@ 
 	 * will be regenerated next time ActionScheduler_wpCommentLogger::filter_comment_count() is called.
 	 */
 	public function delete_comment_count_cache() {
-		delete_transient( 'as_comment_count' );
+		delete_transient('as_comment_count');
 	}
 
 	/**
 	 * @codeCoverageIgnore
 	 */
 	public function init() {
-		add_action( 'action_scheduler_before_process_queue', array( $this, 'disable_comment_counting' ), 10, 0 );
-		add_action( 'action_scheduler_after_process_queue', array( $this, 'enable_comment_counting' ), 10, 0 );
+		add_action('action_scheduler_before_process_queue', array($this, 'disable_comment_counting'), 10, 0);
+		add_action('action_scheduler_after_process_queue', array($this, 'enable_comment_counting'), 10, 0);
 
 		parent::init();
 
-		add_action( 'pre_get_comments', array( $this, 'filter_comment_queries' ), 10, 1 );
-		add_action( 'wp_count_comments', array( $this, 'filter_comment_count' ), 20, 2 ); // run after WC_Comments::wp_count_comments() to make sure we exclude order notes and action logs
-		add_action( 'comment_feed_where', array( $this, 'filter_comment_feed' ), 10, 2 );
+		add_action('pre_get_comments', array($this, 'filter_comment_queries'), 10, 1);
+		add_action('wp_count_comments', array($this, 'filter_comment_count'), 20, 2); // run after WC_Comments::wp_count_comments() to make sure we exclude order notes and action logs
+		add_action('comment_feed_where', array($this, 'filter_comment_feed'), 10, 2);
 
 		// Delete comments count cache whenever there is a new comment or a comment status changes
-		add_action( 'wp_insert_comment', array( $this, 'delete_comment_count_cache' ) );
-		add_action( 'wp_set_comment_status', array( $this, 'delete_comment_count_cache' ) );
+		add_action('wp_insert_comment', array($this, 'delete_comment_count_cache'));
+		add_action('wp_set_comment_status', array($this, 'delete_comment_count_cache'));
 	}
 
 	public function disable_comment_counting() {
-		wp_defer_comment_counting( true );
+		wp_defer_comment_counting(true);
 	}
 	public function enable_comment_counting() {
-		wp_defer_comment_counting( false );
+		wp_defer_comment_counting(false);
 	}
 
 }