Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory : /home/corals/www/wp-content/plugins/wp-rocket/inc/Engine/Common/JobManager/Cron/ |
<?php
declare(strict_types=1);
namespace WP_Rocket\Engine\Common\JobManager\Cron;
use WP_Rocket\Event_Management\Subscriber_Interface;
use WP_Rocket\Engine\Common\Queue\RUCSSQueueRunner;
use WP_Rocket\Engine\Common\JobManager\JobProcessor;
class Subscriber implements Subscriber_Interface {
/**
* JobProcessor instance
*
* @var JobProcessor
*/
private $job_processor;
/**
* Array of Factories.
*
* @var array
*/
private $factories;
/**
* Instantiate the class
*
* @param JobProcessor $job_processor JobProcessor instance.
* @param array $factories Array of factories.
*/
public function __construct(
JobProcessor $job_processor,
array $factories
) {
$this->job_processor = $job_processor;
$this->factories = $factories;
}
/**
* Return an array of events that this subscriber listens to.
*
* @return array
*/
public static function get_subscribed_events(): array {
return [
'rocket_saas_pending_jobs' => 'process_pending_jobs',
'rocket_saas_on_submit_jobs' => 'process_on_submit_jobs',
'rocket_saas_job_check_status' => [ 'check_job_status', 10, 3 ],
'rocket_saas_clean_rows_time_event' => 'cron_clean_rows',
'cron_schedules' => 'add_interval',
'rocket_deactivation' => 'on_deactivation',
'rocket_remove_saas_failed_jobs' => 'cron_remove_failed_jobs',
'init' => [
[ 'schedule_clean_not_commonly_used_rows' ],
[ 'schedule_pending_jobs' ],
[ 'initialize_rucss_queue_runner' ],
[ 'schedule_removing_failed_jobs' ],
[ 'schedule_on_submit_jobs' ],
],
'wp_rocket_upgrade' => [ 'unschedule_rucss_cron', 13, 2 ],
];
}
/**
* Schedules cron to clean not commonly used rows.
*
* @since 3.9
*
* @return void
*/
public function schedule_clean_not_commonly_used_rows() {
if ( ! $this->job_processor->is_allowed() ) {
return;
}
if ( wp_next_scheduled( 'rocket_saas_clean_rows_time_event' ) ) {
return;
}
wp_schedule_event( time(), 'weekly', 'rocket_saas_clean_rows_time_event' );
}
/**
* Initialize the queue runner for our SaaS.
*
* @return void
*/
public function initialize_rucss_queue_runner() {
if ( ! $this->job_processor->is_allowed() ) {
return;
}
RUCSSQueueRunner::instance()->init();
}
/**
* Process pending jobs with Cron iteration.
*
* @return void
*/
public function process_pending_jobs() {
$this->job_processor->process_pending_jobs();
}
/**
* Process on submit jobs with Cron iteration.
*
* @return void
*/
public function process_on_submit_jobs() {
$this->job_processor->process_on_submit_jobs();
}
/**
* Cron callback for deleting old rows in both table databases.
*
* @since 3.9
*
* @return void
*/
public function cron_clean_rows() {
if ( ! $this->is_deletion_enabled() ) {
return;
}
foreach ( $this->factories as $factory ) {
if ( $factory->manager()->is_allowed() ) {
$factory->table()->delete_old_rows();
}
}
}
/**
* Cron callback for removing failed jobs.
*
* @return void
*/
public function cron_remove_failed_jobs() {
$this->job_processor->clear_failed_urls();
}
/**
* Handle job status by DB url and is_mobile.
*
* @param string $url Url from DB row.
* @param boolean $is_mobile Is mobile from DB row.
* @param string $optimization_type The type of optimization request to send.
*
* @return void
*/
public function check_job_status( string $url, bool $is_mobile, string $optimization_type ) {
$this->job_processor->check_job_status( $url, $is_mobile, $optimization_type );
}
/**
* Adds new interval for SaaS pending jobs cron
*
* @since 3.11.3
*
* @param array[] $schedules An array of non-default cron schedule arrays.
*
* @return array
*/
public function add_interval( $schedules ) {
if ( ! $this->job_processor->is_allowed() ) {
return $schedules;
}
/**
* Filters the cron interval.
*
* @since 3.11
*
* @param int $interval Interval in seconds.
*/
$interval = rocket_apply_filter_and_deprecated(
'rocket_saas_pending_jobs_cron_interval',
[ 1 * rocket_get_constant( 'MINUTE_IN_SECONDS', 60 ) ],
'3.16',
'rocket_rucss_pending_jobs_cron_interval'
);
$schedules['rocket_saas_pending_jobs'] = [
'interval' => $interval,
'display' => esc_html__( 'WP Rocket process pending jobs', 'rocket' ),
];
$default_interval = 3 * rocket_get_constant( 'DAY_IN_SECONDS', 86400 );
/**
* Filters the cron interval for clearing failed jobs.
*
* @param int $interval Interval in seconds.
*/
$interval = rocket_apply_filter_and_deprecated(
'rocket_remove_saas_failed_jobs_cron_interval',
[ $default_interval ],
'3.16',
'rocket_remove_rucss_failed_jobs_cron_interval'
);
$interval = (bool) $interval ? $interval : $default_interval;
$schedules['rocket_remove_saas_failed_jobs'] = [
'interval' => $interval,
'display' => esc_html__( 'WP Rocket clear failed jobs', 'rocket' ),
];
/**
* Filters the cron interval for processing on submit jobs.
*
* @param int $interval Interval in seconds.
*/
$interval = (int) rocket_apply_filter_and_deprecated(
'rocket_remove_saas_on_submit_jobs_cron_interval',
[ 1 * rocket_get_constant( 'MINUTE_IN_SECONDS', 60 ) ],
'3.16',
'rocket_remove_rucss_on_submit_jobs_cron_interval'
);
$schedules['rocket_saas_on_submit_jobs'] = [
'interval' => $interval,
'display' => esc_html__( 'WP Rocket process on submit jobs', 'rocket' ),
];
return $schedules;
}
/**
* Schedule on submit jobs.
*
* @return void
*/
public function schedule_on_submit_jobs() {
if (
! $this->job_processor->is_allowed()
&&
wp_next_scheduled( 'rocket_saas_on_submit_jobs' )
) {
wp_clear_scheduled_hook( 'rocket_saas_on_submit_jobs' );
return;
}
if ( ! $this->job_processor->is_allowed() ) {
return;
}
if ( wp_next_scheduled( 'rocket_saas_on_submit_jobs' ) ) {
return;
}
wp_schedule_event( time(), 'rocket_saas_on_submit_jobs', 'rocket_saas_on_submit_jobs' );
}
/**
* Schedules cron to get SaaS pendings jobs.
*
* @since 3.11.3
*
* @return void
*/
public function schedule_pending_jobs() {
if (
! $this->job_processor->is_allowed()
&&
wp_next_scheduled( 'rocket_saas_pending_jobs' )
) {
wp_clear_scheduled_hook( 'rocket_saas_pending_jobs' );
return;
}
if ( ! $this->job_processor->is_allowed() ) {
return;
}
if ( wp_next_scheduled( 'rocket_saas_pending_jobs' ) ) {
return;
}
wp_schedule_event( time(), 'rocket_saas_pending_jobs', 'rocket_saas_pending_jobs' );
}
/**
* Schedules cron to remove failed jobs.
*
* @return void
*/
public function schedule_removing_failed_jobs() {
if (
! $this->job_processor->is_allowed()
&&
wp_next_scheduled( 'rocket_remove_saas_failed_jobs' )
) {
wp_clear_scheduled_hook( 'rocket_remove_saas_failed_jobs' );
return;
}
if ( ! $this->job_processor->is_allowed() ) {
return;
}
if ( wp_next_scheduled( 'rocket_remove_saas_failed_jobs' ) ) {
return;
}
wp_schedule_event( time(), 'rocket_remove_saas_failed_jobs', 'rocket_remove_saas_failed_jobs' );
}
/**
* Clear schedule of SaaS CRONs on deactivation.
*
* @return void
*/
public function on_deactivation() {
wp_clear_scheduled_hook( 'action_scheduler_run_queue_rucss', [ 'WP Cron' ] );
}
/**
* Checks if the SaaS deletion is enabled.
*
* @return bool
*/
protected function is_deletion_enabled(): bool {
/**
* Filters the enable SaaS job deletion value
*
* @param bool $delete_saas_jobs True to enable deletion, false otherwise.
*/
return (bool) rocket_apply_filter_and_deprecated(
'rocket_saas_deletion_enabled',
[ true ],
'3.16',
'rocket_rucss_deletion_enabled'
);
}
/**
* Unschedule old rucss crons.
*
* @since 3.16
*
* @param string $new_version New plugin version.
* @param string $old_version Previous plugin version.
*
* @return void
*/
public function unschedule_rucss_cron( $new_version, $old_version ) {
if ( version_compare( $old_version, '3.16', '>=' ) ) {
return;
}
wp_clear_scheduled_hook( 'rocket_rucss_on_submit_jobs' );
wp_clear_scheduled_hook( 'rocket_rucss_pending_jobs' );
wp_clear_scheduled_hook( 'rocket_remove_rucss_failed_jobs' );
wp_clear_scheduled_hook( 'rocket_rucss_clean_rows_time_event' );
}
}