REDROOM

Edit File Size: 2.44 KB

/home/certprox/template.certproxywizard.com/wp-content/plugins/hostinger-reach/src/Jobs/AbstractBatchedJob.php

Text Base64

<?php

namespace Hostinger\Reach\Jobs;

defined( 'ABSPATH' ) || exit;

abstract class AbstractBatchedJob extends AbstractJob {

public const BATCH_LIMIT_PER_JOB = 15;

public function init(): void {
        add_action( $this->get_create_batch_hook(), array( $this, 'handle_create_batch_action' ), 10, 2 );
        parent::init();
    }

protected function get_create_batch_hook(): string {
        return "{$this->get_hook_base_name()}/create_batch";
    }

public function schedule( array $args = array() ): void {
        $this->schedule_create_batch_action( 1, $args );
    }

public function handle_create_batch_action( int $batch_number, array $args ): void {
        $items = $this->get_batch( $batch_number, $args );

if ( empty( $items ) || $batch_number > self::BATCH_LIMIT_PER_JOB ) {
            $this->handle_complete( $batch_number, $args );
        } else {
            $this->set_items_as_processing( $items );
            $this->schedule_process_action( $items, $args );
            $this->schedule_create_batch_action( $batch_number + 1, $args );
        }
    }

protected function get_batch_size(): int {
        return apply_filters( 'hostinger_reach_batch_item_limit', 1 );
    }

protected function schedule_create_batch_action( int $batch_number, array $args ): void {
        if ( $this->can_schedule( array( $batch_number ) ) ) {
            $this->action_scheduler->schedule_immediate(
                $this->get_create_batch_hook(),
                array(
                    $batch_number,
                    $args,
                )
            );
        }
    }

protected function schedule_process_action( array $items = array(), array $args = array() ): void {
        $job_data = array(
            'items' => $items,
            'args'  => $args,
        );
        if ( ! $this->is_processing( $job_data ) ) {
            $this->action_scheduler->schedule_immediate( $this->get_process_item_hook(), array( $job_data ) );
        }
    }

protected function is_processing( array $args = array() ): bool {
        return $this->action_scheduler->has_scheduled_action( $this->get_process_item_hook(), array( $args ) );
    }

protected function handle_complete( int $final_batch_number, array $args ): void {
        return;
    }

protected function set_items_as_processing( array $items ): void {
        return;
    }

abstract protected function get_batch( int $batch_number, array $args ): array;
}

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Name	Size	Perms	Modified	Actions
AbandonedCartsJob.php	2.59 KB	lrw-r--r--	2026-06-10 16:30:29	Edit Download recursive recursive
AbstractBatchedJob.php	2.44 KB	lrw-r--r--	2026-06-10 16:30:29	Edit Download recursive recursive
AbstractJob.php	2.32 KB	lrw-r--r--	2026-06-10 16:30:29	Edit Download recursive recursive
ActionScheduler.php	1.56 KB	lrw-r--r--	2026-06-10 16:30:29	Edit Download recursive recursive
CleanupCartsJob.php	1.58 KB	lrw-r--r--	2026-06-10 16:30:29	Edit Download recursive recursive
ImportJob.php	1.58 KB	lrw-r--r--	2026-06-10 16:30:29	Edit Download recursive recursive
JobInterface.php	397 B	lrw-r--r--	2026-06-10 16:30:29	Edit Download recursive recursive
RecurringJobInterface.php	148 B	lrw-r--r--	2026-06-10 16:30:29	Edit Download recursive recursive

Directory Contents