|
Server : Apache System : Linux srv.rainic.com 4.18.0-553.47.1.el8_10.x86_64 #1 SMP Wed Apr 2 05:45:37 EDT 2025 x86_64 User : rainic ( 1014) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory : /home/rainic/public_html/oldTZh/wp-content/plugins/wp-rocket/inc/Engine/Preload/Cron/ |
Upload File : |
<?php
namespace WP_Rocket\Engine\Preload\Cron;
use WP_Rocket\Engine\Common\Queue\Cleaner;
use WP_Rocket\Engine\Preload\Admin\Settings;
use WP_Rocket\Engine\Preload\Controller\PreloadUrl;
use WP_Rocket\Engine\Preload\Database\Queries\Cache;
use WP_Rocket\Event_Management\Subscriber_Interface;
class Subscriber implements Subscriber_Interface {
/**
* Preload settings.
*
* @var Settings
*/
protected $settings;
/**
* Db query.
*
* @var Cache
*/
protected $query;
/**
* Preload url controller.
*
* @var PreloadUrl
*/
protected $preload_controller;
/**
* Creates an instance of the class.
*
* @param Settings $settings Preload settings.
* @param Cache $query Db query.
* @param PreloadUrl $preload_controller Preload url controller.
*/
public function __construct( Settings $settings, Cache $query, PreloadUrl $preload_controller ) {
$this->settings = $settings;
$this->query = $query;
$this->preload_controller = $preload_controller;
}
/**
* Return an array of events that this subscriber listens to.
*
* @return array
*/
public static function get_subscribed_events() {
return [
'rocket_preload_clean_rows_time_event' => 'remove_old_rows',
'rocket_preload_process_pending' => [
[ 'process_pending_urls' ],
[ 'clean_preload_jobs' ],
],
'rocket_preload_revert_old_failed_rows' => 'revert_old_failed_rows',
'cron_schedules' => [
[ 'add_interval' ],
[ 'add_revert_old_failed_interval' ],
],
'init' => [
[ 'schedule_clean_not_commonly_used_rows' ],
[ 'schedule_pending_jobs' ],
[ 'schedule_revert_old_failed_rows' ],
],
];
}
/**
* Schedule clean from removing of old urls.
*
* @return void
*/
public function schedule_clean_not_commonly_used_rows() {
/**
* Delay before the not accessed row is deleted.
*
* @param string $delay delay before the not accessed row is deleted.
*/
$delay = (string) apply_filters( 'rocket_preload_delay_delete_non_accessed', '1 month' );
if ( '' === $delay || wp_next_scheduled( 'rocket_preload_clean_rows_time_event' ) ) {
return;
}
wp_schedule_event( time() + 10 * MINUTE_IN_SECONDS, 'weekly', 'rocket_preload_clean_rows_time_event' );
}
/**
* Preload Url jobs.
*
* @return void
*/
public function process_pending_urls() {
if ( ! $this->settings->is_enabled() ) {
return;
}
$this->preload_controller->process_pending_jobs();
}
/**
* Clean Action Scheduler jobs for preload.
*
* @return void
*/
public function clean_preload_jobs() {
$clean_batch_size = (int) apply_filters( 'rocket_action_scheduler_clean_batch_size', 100, 'rocket-preload' );
$cleaner = new Cleaner( null, $clean_batch_size, 'rocket-preload' );
$cleaner->clean();
}
/**
* Add the interval for the cron.
*
* @param array $schedules Cron schedules.
* @return mixed
*/
public function add_interval( $schedules ) {
if ( ! $this->settings->is_enabled() ) {
return $schedules;
}
/**
* Filters the cron interval.
*
* @since 3.11
*
* @param int $interval Interval in seconds.
*/
$interval = apply_filters( 'rocket_preload_pending_jobs_cron_interval', 1 * rocket_get_constant( 'MINUTE_IN_SECONDS', 60 ) );
$schedules['rocket_preload_process_pending'] = [
'interval' => $interval,
'display' => esc_html__( 'WP Rocket Preload pending jobs', 'rocket' ),
];
return $schedules;
}
/**
* Add the interval for the cron.
*
* @param array $schedules Cron schedules.
* @return mixed
*/
public function add_revert_old_failed_interval( $schedules ) {
if ( ! $this->settings->is_enabled() ) {
return $schedules;
}
/**
* Filters the cron interval.
*
* @since 3.11
*
* @param int $interval Interval in seconds.
*/
$interval = apply_filters( 'rocket_preload_revert_old_failed_rows_cron_interval', 12 * rocket_get_constant( 'HOUR_IN_SECONDS', 60 * 60 ) );
$schedules['rocket_revert_old_failed_rows'] = [
'interval' => $interval,
'display' => esc_html__( 'WP Rocket Preload revert stuck failed jobs', 'rocket' ),
];
return $schedules;
}
/**
* Schedule pending preload urls.
*
* @return void
*/
public function schedule_pending_jobs() {
if (
! $this->settings->is_enabled()
&&
wp_next_scheduled( 'rocket_preload_process_pending' )
) {
wp_clear_scheduled_hook( 'rocket_preload_process_pending' );
return;
}
if ( ! $this->settings->is_enabled() ) {
return;
}
if ( wp_next_scheduled( 'rocket_preload_process_pending' ) ) {
return;
}
wp_schedule_event( time() + MINUTE_IN_SECONDS, 'rocket_preload_process_pending', 'rocket_preload_process_pending' );
}
/**
* Schedule revert stuck failed row cron.
*
* @return void
*/
public function schedule_revert_old_failed_rows() {
if (
! $this->settings->is_enabled()
&&
wp_next_scheduled( 'rocket_preload_revert_old_failed_rows' )
) {
wp_clear_scheduled_hook( 'rocket_preload_revert_old_failed_rows' );
return;
}
if ( ! $this->settings->is_enabled() ) {
return;
}
if ( wp_next_scheduled( 'rocket_preload_revert_old_failed_rows' ) ) {
return;
}
wp_schedule_event( time() + MINUTE_IN_SECONDS, 'rocket_revert_old_failed_rows', 'rocket_preload_revert_old_failed_rows' );
}
/**
* Remove old urls.
*
* @return void
*/
public function remove_old_rows() {
/**
* Delay before the not accessed row is deleted.
*
* @param string $delay delay before the not accessed row is deleted.
*/
$delay = (string) apply_filters( 'rocket_preload_delay_delete_non_accessed', '1 month' );
$parts = explode( ' ', $delay );
if ( '' === $delay || '0' === $delay ) {
return;
}
$value = 1;
$unit = 'month';
if ( count( $parts ) === 2 && $parts[0] >= 0 ) {
$value = $parts[0];
$unit = $parts[1];
}
$this->query->remove_all_not_accessed_rows( $value, $unit );
}
/**
* Remove old failed urls.
*
* @return void
*/
public function revert_old_failed_rows() {
$this->query->revert_old_failed();
}
}