| | |
|---|
| | | use WP_Error; |
|---|
| | | use WP_REST_Response; |
|---|
| | | use WP_REST_Request; |
|---|
| | | use wpdb; |
|---|
| | | |
|---|
| | | if (!defined('ABSPATH')) { |
|---|
| | | exit; // Exit if accessed directly |
|---|
| | |
|---|
| | | protected string $table = BASE.'_operation_queue'; |
|---|
| | | protected string $metricsTable = BASE.'stats__operation_queue'; |
|---|
| | | protected int $max_attempts = 3; |
|---|
| | | protected \wpdb $wpdb; |
|---|
| | | protected wpdb $wpdb; |
|---|
| | | |
|---|
| | | // System load thresholds |
|---|
| | | protected array $load_thresholds = [ |
|---|
| | |
|---|
| | | { |
|---|
| | | global $wpdb; |
|---|
| | | $this->wpdb = $wpdb; |
|---|
| | | $this->cache = Cache::for('queue', DAY_IN_SECONDS)->connect('user')->user(); |
|---|
| | | $this->cache = Cache::for('queue', 'user',DAY_IN_SECONDS)->user(); |
|---|
| | | add_action('jvb_process_queue', [ $this, 'checkQueue' ]); |
|---|
| | | add_action('jvb_queue_maintenance', [$this, 'hourlyMaintenance']); |
|---|
| | | add_action('jvbEmailDailyMetricsReport', [$this, 'emailDailyMetricsReport']); |
|---|
| | |
|---|
| | | * |
|---|
| | | * @param object $operation The current operation |
|---|
| | | * |
|---|
| | | * @return bool|array false if not batched, the extracted data to process if batchable |
|---|
| | | * @return array false if not batched, the extracted data to process if batchable |
|---|
| | | */ |
|---|
| | | protected function getNextChunk(object $operation): array |
|---|
| | | { |
|---|
