File Content: class-controller.php <?php /** * Scheduled event for Editing links. * A single scheduled event that is used for editing/unlinking links" * * @link https://wordpress.org/plugins/broken-link-checker/ * @since 2.0.0 * * @author WPMUDEV (https://wpmudev.com) * @package WPMUDEV_BLC\App\Schedule_Events\Scan * * @copyright (c) 2022, Incsub (http://incsub.com) */ namespace WPMUDEV_BLC\App\Scheduled_Events\Edit_Links; // Abort if called directly. defined( 'WPINC' ) || die; use WPMUDEV_BLC\App\Broken_Links_Actions\Link; use WPMUDEV_BLC\App\Options\Links_Queue\Model as Queue; use WPMUDEV_BLC\App\Options\Settings\Model as Settings; use WPMUDEV_BLC\App\Scheduled_Events\Edit_Links\Controller as Schedule; use WPMUDEV_BLC\App\Http_Requests\Edit_Complete\Controller as HTTP_Request; use WPMUDEV_BLC\Core\Utils\Abstracts\Base; use WPMUDEV_BLC\Core\Traits\Cron; /** * Class Controller * * @package WPMUDEV_BLC\App\Schedule_Events\Edit_Links */ class Controller extends Base { use Cron; /** * WP Cron hook to execute when event is run. * * @var string */ public $cron_hook_name = 'blc_schedule_edit_links'; /** * BLC settings from options table. * * @var array */ private $settings = null; /** * Init Schedule * * @since 2.0.0 * * @return void */ public function init() { if ( wp_doing_ajax() ) { return; } add_action( 'wpmudev_blc_plugin_deactivated', array( $this, 'deactivate_cron' ) ); } /** * Returns the scheduled event's hook name. * Overriding Trait's method. */ public function get_hook_name() { return $this->cron_hook_name; } /** * Starts the scheduled scan. */ public function process_scheduled_event() { if ( boolval( Settings::instance()->get( 'use_legacy_blc_version' ) ) ) { return false; } $queue = Queue::instance()->get_queue_data(); $current_task = Queue::instance()->get_current_task(); $limit = Queue::instance()->get( 'forced_limit' ); $page_links = $queue['page_links'] ?? array(); $full_site_links = $queue['full_site_links'] ?? array(); $result = array(); $props = array(); // 1. Starting with previously unfinished links. // 2.Then continue with page links which are faster. // 3.Finally, run full site links. if ( ! empty( $current_task['link'] ) ) { $current_link_url = $current_task['link']; $current_link_mode = ! empty( $current_task['link_mode'] ) ? $current_task['link_mode'] : null; if ( empty( $current_link_url ) || empty( $current_link_mode ) ) { // Remove current task from db since it is corrupt. Queue::instance()->set( array( 'current_task' => array(), ) ); } $link_index = array_search( untrailingslashit( $current_link_url ), array_map( 'untrailingslashit', wp_list_pluck( $queue[ $current_link_mode ], 'link' ) ) ); $props = $queue[ $current_link_mode ][ $link_index ]; // We need to use the $authors_completed flag too. $props['offset'] = $current_task['offset']; } elseif ( ! empty( $page_links ) ) { $props = $page_links[0]; } elseif ( ! empty( $full_site_links ) ) { $props = $full_site_links[0]; } if ( ! empty( $limit ) ) { $props['limit'] = intval( $limit ); } $link = new Link( $props ); if ( $link instanceof Link ) { $result = $link->execute_action(); } Queue::instance()->set( array( 'batch_end_timestamp' => current_time( 'U' ) ) ); // Set queue offsets and current link. if ( ! empty( $result ) && ! is_wp_error( $result ) ) { // What to do when link action has been completed. if ( ! empty( $result['completed'] ) ) { // Removing link. Queue::instance()->pull( array( 'link' => $link->__get( 'link' ), 'new_link' => $link->__get( 'new_link' ), 'full_site' => $link->__get( 'full_site' ), ) ); Queue::instance()->reset_totals( true ); // Send an update to HUB API after each link task is completed. HTTP_Request::instance()->send_report( $link ); } else { $current_task = Queue::instance()->get_current_task(); Queue::instance()->set( array( 'current_task' => array( 'link' => $link->get_link(), 'offset' => $result['offset'] ?? $link->get_offset(), 'rows' => ! empty( $result['row_count'] ) ? intval( $result['row_count'] ) : intval( $current_task['rows'] ), 'link_mode' => $result['link_mode'], 'target_tables' => ! empty( $result['target_tables'] ) ? $result['target_tables'] : array( 'posts' => ! empty( $current_task['target_tables']['posts'] ) ? boolval( $current_task['target_tables']['posts'] ) : false, 'postmeta' => ! empty( $current_task['target_tables']['postmeta'] ) ? boolval( $current_task['target_tables']['postmeta'] ) : false, 'comments' => ! empty( $current_task['target_tables']['comments'] ) ? boolval( $current_task['target_tables']['comments'] ) : false, 'authors' => ! empty( $current_task['target_tables']['authors'] ) ? boolval( $current_task['target_tables']['authors'] ) : false, ), ) ) ); } Queue::instance()->save(); // If there is a forced limit, it means that previous batch did not spend whole LIMIT. // Using remaining LIMIT for next batch. if ( ! empty( $result['force_limit'] ) && is_numeric( $result['force_limit'] ) ) { Queue::instance()->set( array( 'force_limit' => intval( $result['force_limit'] ) ) ); Queue::instance()->save(); } } if ( Queue::instance()->queue_is_empty() ) { Queue::instance()->clear(); } else { Schedule::instance()->setup( intval( apply_filters( 'wpmudev_blc_link_action_schedule_cooldown_seconds', 15 ) ) ); } return $result; } /** * Sets up the schedule. * * @param int $seconds * * @return bool */ public function setup( int $seconds = null ) { // Deactivate cron if is already created, so we will replace it later on. $this->deactivate_cron(); // As a single event it will be possible to set custom timestamps to run. $this->is_single_event = true; // Set the timestamp for single event's next run. $this->timestamp = intval( $this->get_timestamp( $seconds ) ); return $this->activate_cron(); } /** * Returns the timestamp of next scheduled scan. * * @param array $schedule * * @return false|int|null */ public function get_timestamp( int $seconds = null ) { if ( empty( $seconds ) ) { $seconds = intval( apply_filters( 'wpmudev_blc_edit_links_cron_seconds', 30 ) ); } return strtotime( "+ $seconds seconds" ); } /** * Sets the scan flag to true. Useful when API sends the SET request, an email about the current schedule should * be sent to schedule receivers. */ public function set_scan_schedule_flag( bool $flag = true ) { } } Submit