- File: Tasks.php
- Full Path: /home/matthif/www/wp-content/plugins/wpforms-lite/src/Tasks/Tasks.php
- Date Modified: 02/16/2024 11:45 AM
- File size: 6.77 KB
- MIME-type: text/x-php
- Charset: utf-8
<?php
namespace WPForms\Tasks;
use ActionScheduler_Action;
use WPForms\Helpers\Transient;
use WPForms\Tasks\Actions\EntryEmailsMetaCleanupTask;
use WPForms\Tasks\Actions\EntryEmailsTask;
use WPForms\Tasks\Actions\FormsLocatorScanTask;
use WPForms\Tasks\Actions\AsyncRequestTask;
/**
* Class Tasks manages the tasks queue and provides API to work with it.
*
* @since 1.5.9
*/
class Tasks {
/**
* Group that will be assigned to all actions.
*
* @since 1.5.9
*/
const GROUP = 'wpforms';
/**
* Actions setting name.
*
* @since 1.7.3
*/
const ACTIONS = 'actions';
/**
* WPForms pending or in-progress actions.
*
* @since 1.7.3
*
* @var array
*/
private $active_actions;
/**
* Perform certain things on class init.
*
* @since 1.5.9
*/
public function init() {
// Get WPForms pending or in-progress actions.
$this->active_actions = $this->get_active_actions();
// Register WPForms tasks.
foreach ( $this->get_tasks() as $task ) {
if ( ! is_subclass_of( $task, Task::class ) ) {
continue;
}
new $task();
}
$this->hooks();
}
/**
* Hooks.
*
* @since 1.7.5
*/
public function hooks() {
add_action( 'delete_expired_transients', [ Transient::class, 'delete_all_expired' ], 11 );
add_action( 'admin_menu', [ $this, 'admin_hide_as_menu' ], PHP_INT_MAX );
/*
* By default we send emails in the same process as the form submission is done.
* That means that when many emails are set in form Notifications -
* the form submission can take a while because of all those emails that are sending in the background.
* Since WPForms 1.6.0 users can enable a new option in Settings > Emails,
* called "Optimize Email Sending", to send email in async way.
* This feature was enabled for WPForms 1.5.9, but some users were not happy.
*/
if ( ! (bool) wpforms_setting( 'email-async', false ) ) {
add_filter( 'wpforms_tasks_entry_emails_trigger_send_same_process', '__return_true' );
}
add_action( EntryEmailsTask::ACTION, [ EntryEmailsTask::class, 'process' ] );
add_action( 'action_scheduler_after_execute', [ $this, 'clear_action_meta' ], PHP_INT_MAX, 2 );
}
/**
* Get the list of WPForms default scheduled tasks.
* Tasks, that are fired under certain specific circumstances
* (like sending form submission email notifications)
* are not listed here.
*
* @since 1.5.9
*
* @return Task[] List of tasks classes.
*/
public function get_tasks() {
if ( ! $this->is_usable() ) {
return [];
}
$tasks = [
EntryEmailsMetaCleanupTask::class,
FormsLocatorScanTask::class,
AsyncRequestTask::class,
];
/**
* Filters the task class list to initialize.
*
* @since 1.5.9
*
* @param array $tasks Task class list.
*/
return apply_filters( 'wpforms_tasks_get_tasks', $tasks );
}
/**
* Hide Action Scheduler admin area when not in debug mode.
*
* @since 1.5.9
*/
public function admin_hide_as_menu() {
// Filter to redefine that WPForms hides Tools > Action Scheduler menu item.
if ( apply_filters( 'wpforms_tasks_admin_hide_as_menu', ! wpforms_debug() ) ) {
remove_submenu_page( 'tools.php', 'action-scheduler' );
}
}
/**
* Create a new task.
* Used for "inline" tasks, that require additional information
* from the plugin runtime before they can be scheduled.
*
* Example:
* wpforms()->get( 'tasks' )
* ->create( 'i_am_the_dude' )
* ->async()
* ->params( 'The Big Lebowski', 1998 )
* ->register();
*
* This `i_am_the_dude` action will be later processed as:
* add_action( 'i_am_the_dude', 'thats_what_you_call_me' );
*
* Function `thats_what_you_call_me()` will receive `$meta_id` param,
* and you will be able to receive all params from the action like this:
* $params = ( new Meta() )->get( (int) $meta_id );
* list( $name, $year ) = $params->data;
*
* @since 1.5.9
*
* @param string $action Action that will be used as a hook.
*
* @return \WPForms\Tasks\Task
*/
public function create( $action ) {
return new Task( $action );
}
/**
* Cancel all the AS actions for a group.
*
* @since 1.5.9
*
* @param string $group Group to cancel all actions for.
*/
public function cancel_all( $group = '' ) {
if ( empty( $group ) ) {
$group = self::GROUP;
} else {
$group = sanitize_key( $group );
}
if ( class_exists( 'ActionScheduler_DBStore' ) ) {
\ActionScheduler_DBStore::instance()->cancel_actions_by_group( $group );
$this->active_actions = $this->get_active_actions();
}
}
/**
* Whether ActionScheduler thinks that it has migrated or not.
*
* @since 1.5.9.3
*
* @return bool
*/
public function is_usable() {
// No tasks if ActionScheduler wasn't loaded.
if ( ! class_exists( 'ActionScheduler_DataController' ) ) {
return false;
}
return \ActionScheduler_DataController::is_migration_complete();
}
/**
* Whether task has been scheduled and is pending or in-progress.
*
* @since 1.6.0
*
* @param string $hook Hook to check for.
*
* @return bool|null
*/
public function is_scheduled( $hook ) {
if ( ! function_exists( 'as_has_scheduled_action' ) ) {
return null;
}
if ( in_array( $hook, $this->active_actions, true ) ) {
return true;
}
// Action is not in the array, so it is not scheduled or belongs to another group.
return as_has_scheduled_action( $hook );
}
/**
* Get all WPForms pending or in-progress actions.
*
* @since 1.7.3
*/
private function get_active_actions() {
global $wpdb;
$group = self::GROUP;
$sql = "SELECT a.hook FROM {$wpdb->prefix}actionscheduler_actions a
JOIN {$wpdb->prefix}actionscheduler_groups g ON g.group_id = a.group_id
WHERE g.slug = '$group' AND a.status IN ( 'in-progress', 'pending' )";
// phpcs:disable WordPress.DB.DirectDatabaseQuery.NoCaching
// phpcs:disable WordPress.DB.PreparedSQL.NotPrepared
$results = $wpdb->get_results( $sql, 'ARRAY_N' );
// phpcs:enable WordPress.DB.DirectDatabaseQuery.NoCaching
// phpcs:enable WordPress.DB.PreparedSQL.NotPrepared
return $results ? array_merge( ...$results ) : [];
}
/**
* Clear the meta after action complete.
* Fired before an action is marked as completed.
*
* @since 1.7.5
*
* @param integer $action_id Action ID.
* @param ActionScheduler_Action $action Action name.
*/
public function clear_action_meta( $action_id, $action ) {
$action_schedule = $action->get_schedule();
if ( $action_schedule === null || $action_schedule->is_recurring() ) {
return;
}
$hook_name = $action->get_hook();
if ( ! $this->is_scheduled( $hook_name ) ) {
return;
}
$hook_args = $action->get_args();
if ( ! isset( $hook_args['tasks_meta_id'] ) ) {
return;
}
$meta = new Meta();
$meta->delete( $hook_args['tasks_meta_id'] );
}
}