File manager

File manager - Edit - /home/carfac/.trash/wp-statistics/src/Service/Database/Migrations/BackgroundProcess/BackgroundProcessManager.php

Back
<?php namespace WP_Statistics\Service\Database\Migrations\BackgroundProcess; use WP_Statistics\Abstracts\BaseMigrationManager; use WP_STATISTICS\Admin_Assets; use WP_STATISTICS\Menus; use WP_Statistics\Service\Admin\NoticeHandler\Notice; use WP_Statistics\Service\Database\Migrations\BackgroundProcess\Jobs\CalculatePostWordsCount; use WP_Statistics\Service\Database\Migrations\BackgroundProcess\Jobs\IncompleteGeoIpUpdater; use WP_Statistics\Service\Database\Migrations\BackgroundProcess\Jobs\SourceChannelUpdater; use WP_Statistics\Service\Database\Migrations\BackgroundProcess\Jobs\SummaryTotalsDataMigration; use WP_Statistics\Service\Database\Migrations\BackgroundProcess\Jobs\VisitorColumnsMigrator; use WP_STATISTICS\User; use WP_Statistics\Utils\Request; /** * Class BackgroundProcessManager * * Manages background processes for database migrations. * * ## Extensibility * * Add-ons can register custom background processes using the `wp_statistics_register_background_jobs` filter: * * ```php * add_filter('wp_statistics_register_background_jobs', function ($jobs) { * $jobs['my_custom_job'] = \MyAddon\BackgroundJobs\MyCustomJob::class; * return $jobs; * }); * ``` * * Custom job classes must extend `WP_Statistics\Abstracts\BaseBackgroundProcess`. * * @see \WP_Statistics\Abstracts\BaseBackgroundProcess / class BackgroundProcessManager extends BaseMigrationManager { /* * Filter hook name for registering background jobs. * * @var string / public const REGISTER_JOBS_FILTER = 'wp_statistics_register_background_jobs'; /* * Filter hook name for registering data migrations. * * @var string / public const REGISTER_DATA_MIGRATIONS_FILTER = 'wp_statistics_register_data_migrations'; /* * The background process instances. * * @var array<string, object> / private $backgroundProcess = []; /* * List of background process classes to be registered. * * @var array<string, string> / private $backgroundProcesses = []; /* * Core background process classes (always registered). * * @var array<string, string> / private $coreBackgroundProcesses = [ 'visitor_columns_migrator' => VisitorColumnsMigrator::class, 'calculate_post_words_count' => CalculatePostWordsCount::class, 'update_unknown_visitor_geoip' => IncompleteGeoIpUpdater::class, 'update_visitors_source_channel' => SourceChannelUpdater::class, 'summary_totals_data_migration' => SummaryTotalsDataMigration::class, ]; /* * List of available data migration keys. * * @var array<string> Array of migration keys. / private $dataMigrations = []; /* * Core data migration keys (always registered). * * @var array<string> Array of core migration keys. / private $coreDataMigrations = [ 'visitor_columns_migrator', 'summary_totals_data_migration' ]; /* * The key of the currently running background process. * * @var string / private $currentProcess = ''; /* * Success message for the currently active background job. * * @var string / private $successNotice = ''; /* * The action slug used for manually triggering the background migration. * * @var string / public const BACKGROUND_PROCESS_ACTION = 'run_async_background_process'; /* * The nonce name used to secure the manual migration action. * * @var string / public const BACKGROUND_PROCESS_NONCE = 'run_ajax_background_process_nonce'; /* * Class constructor. * * Initializes background processes and attaches necessary WordPress hooks. / public function __construct() { $this->initializeBackgroundProcess(); add_action('admin_init', [$this, 'showProgressNotices']); add_action('admin_enqueue_scripts', [$this, 'registerScript']); add_filter('wp_statistics_ajax_list', [$this, 'addAjax']); add_action('admin_post_' . self::BACKGROUND_PROCESS_ACTION, [$this, 'handleBackgroundProcessAction']); } /* * Initialize and register background processes. * * Merges core background processes with any additional processes registered * via the `wp_statistics_register_background_jobs` filter. * * @return void / private function initializeBackgroundProcess() { if (!empty($this->backgroundProcess)) { return; } $this->backgroundProcesses = $this->getRegisteredBackgroundProcesses(); $this->dataMigrations = $this->getRegisteredDataMigrations(); if (empty($this->backgroundProcesses)) { return; } foreach ($this->backgroundProcesses as $key => $className) { $this->registerBackgroundProcess($className, $key); } } /* * Get all registered background processes (core + add-on). * * Applies the `wp_statistics_register_background_jobs` filter to allow * add-ons to register their own background processes. * * @return array<string, string> Array of process key => class name. / private function getRegisteredBackgroundProcesses() { /* * Filter to register custom background processes. * * Add-ons can use this filter to register their own background processes. * Each process must extend `WP_Statistics\Abstracts\BaseBackgroundProcess`. * * @since 14.17 * * @param array<string, string> $jobs Array of job key => fully qualified class name. * * @example * ```php * add_filter('wp_statistics_register_background_jobs', function ($jobs) { * $jobs['my_addon_sync_job'] = \Addon\Jobs\SyncDataJob::class; * return $jobs; * }); * ``` / $allJobs = apply_filters(self::REGISTER_JOBS_FILTER, $this->coreBackgroundProcesses); return $this->validateBackgroundProcesses($allJobs); } /* * Get all registered data migrations (core + add-on). * * Applies the `wp_statistics_register_data_migrations` filter to allow * add-ons to register their data migration keys. * * @return array<string> Array of data migration keys. / private function getRegisteredDataMigrations() { /* * Filter to register custom data migrations. * * Add-ons can use this filter to register their own data migration keys. * These keys should correspond to background process keys that handle data migrations. * * @since 14.17 * * @param array<string> $migrations Array of data migration keys. * * @example * ```php * add_filter('wp_statistics_register_data_migrations', function ($migrations) { * $migrations[] = 'my_addon_data_migration'; * return $migrations; * }); * ``` / $allMigrations = apply_filters(self::REGISTER_DATA_MIGRATIONS_FILTER, $this->coreDataMigrations); return array_unique(array_filter($allMigrations, 'is_string')); } /* * Validate registered background processes. * * Ensures all registered classes exist and extend BaseBackgroundProcess. * * @param array $jobs Array of job key => class name. * @return array<string, string> Validated array of jobs. / private function validateBackgroundProcesses($jobs) { if (!is_array($jobs)) { return $this->coreBackgroundProcesses; } $validated = []; foreach ($jobs as $key => $className) { if (!is_string($key) \|\| empty($key)) { continue; } if (!is_string($className) \|\| !class_exists($className)) { continue; } if (!is_subclass_of($className, \WP_Statistics\Abstracts\BaseBackgroundProcess::class)) { continue; } $validated[$key] = $className; } return $validated; } /* * Register a background process by its class name and key. * * @param string $className The class name of the background process. * @param string $processKey The key to identify the background process. * * @return void / private function registerBackgroundProcess($className, $processKey) { if (!class_exists($className) \|\| !empty($this->backgroundProcess[$processKey])) { return; } $this->backgroundProcess[$processKey] = new $className(); } /* * Get a background process instance by its key. * * @param string $processKey The key of the background process. * * @return object\|null The background process instance or null if not found. / public function getBackgroundProcess($processKey) { return $this->backgroundProcess[$processKey] ?? null; } /* * Get all registered background migration processes. * * @return array / public function getAllBackgroundProcesses() { return $this->backgroundProcesses; } /* * Get the list of available data migrations (keys). * * @return array / public function getAllDataMigrations() { if (empty($this->dataMigrations)) { $this->dataMigrations = $this->getRegisteredDataMigrations(); } return $this->dataMigrations; } /* * Get the list of available data migrations (keys). * * @deprecated 14.17 Use getAllDataMigrations() instead. * @return array / public function getAllDataMirations() { return $this->getAllDataMigrations(); } /* * Show progress notices for each registered background process. * Displays a notice like: "Calculate Post Words Count: 34% complete (34/100)." * Only shows while a process is active and has a non-zero total. * * @return void / public function showProgressNotices() { if (empty($this->backgroundProcess) \|\| !$this->isValidContext()) { return; } foreach ($this->backgroundProcess as $key => $instance) { if (!is_object($instance)) { continue; } if (method_exists($instance, 'initialNotice')) { $instance->initialNotice(); } $isActive = method_exists($instance, 'is_active') ? (bool)$instance->is_active() : false; if (!$isActive) { continue; } $this->currentProcess = $key; $total = method_exists($instance, 'getTotal') ? $instance->getTotal() : 0; $processed = method_exists($instance, 'getProcessed') ? $instance->getProcessed() : 0; if ($total <= 0 \|\| $processed >= $total) { continue; } $percent = empty($processed) ? 0 : (int)floor(($processed / $total) 100); if ($percent >= 100) { $percent = 99; } elseif ($percent < 0) { $percent = 0; } $this->successNotice = $instance->getSuccessNotice(); $label = $instance->getJobTitle(); /* translators: 1: job title, 2: percent complete, 3: processed count, 4: total count, 5: appended background-running note / $message = sprintf( __('<div id="wp-statistics-async-background-process-notice">%1$s: <span class="percentage">%2$d%%</span> complete (<span class="processed">%3$d</span>/%4$d).<br/> %5$s</div>', 'wp-statistics'), esc_html($label), (int)$percent, (int)$processed, (int)$total, esc_html__('You can continue using the plugin. The process runs safely in the background.', 'wp-statistics') ); Notice::addNotice($message, $instance->getInitiatedKey(), 'info', false); } } /* * Registers JavaScript files required for migration execution. * * @return void / public function registerScript() { if (!$this->isValidContext()) { return; } wp_enqueue_script( 'wp-statistics-async-background-process', Admin_Assets::url('background-process-tracker.min.js'), ['jquery'], Admin_Assets::version(), ['in_footer' => true] ); wp_localize_script( 'wp-statistics-async-background-process', 'Wp_Statistics_Async_Background_Process_Data', [ 'rest_api_nonce' => wp_create_nonce('wp_rest'), 'ajax_url' => admin_url('admin-ajax.php'), 'interval' => apply_filters('wp_statistics_async_background_process_ajax_interval', 5000), 'current_process' => $this->currentProcess, 'completed_message' => esc_html__('WP Statistics: Background process completed successfully.', 'wp-statistics'), 'job_completed_message' => $this->successNotice ] ); } /* * Adds the migration process to the AJAX action list. * * @param array $list List of existing AJAX actions. * @return array Updated list including migration. / public function addAjax($list) { $list[] = [ 'class' => $this, 'action' => 'async_background_process', 'public' => false ]; return $list; } /* * Handles the AJAX request for the background process. * * @return void / public function async_background_process_action_callback() { check_ajax_referer('wp_rest', 'wps_nonce'); if (!Request::isFrom('ajax') \|\| !User::Access('manage')) { wp_send_json_error([ 'message' => esc_html__('Unauthorized request or insufficient permissions.', 'wp-statistics') ]); } $this->currentProcess = Request::get('current_process', ''); $currentJob = $this->getBackgroundProcess($this->currentProcess); if (empty($this->currentProcess)) { wp_send_json_success([ 'completed' => true, ]); } if (BackgroundProcessFactory::isProcessDone($this->currentProcess)) { wp_send_json_success([ 'completed' => true, ]); } $total = $currentJob->getTotal(); $processed = $currentJob->getProcessed(); wp_send_json_success([ 'percentage' => empty($processed) ? 0 : (int)floor(($processed / $total) 100), 'processed' => $currentJob->getProcessed(), ]); } /** * Admin handler for manually triggering a background migration. * * Hook: `admin_post_` . self::BACKGROUND_PROCESS_ACTION * Steps: verify nonce, check capability, get job via `job_key`, * optionally reset when `force=1`, run `$job->process()`, then redirect * to `Menus::admin_url($redirect)`. * * Params: `job_key` (string), `redirect` (string), `force` (bool), `nonce` (string). * * @return void */ public function handleBackgroundProcessAction() { check_admin_referer(self::BACKGROUND_PROCESS_NONCE, 'nonce'); if (!Request::compare('action', self::BACKGROUND_PROCESS_ACTION)) { return false; } $this->verifyMigrationPermission(); $jobKey = Request::get('job_key'); $isForced = Request::get('force', false, 'bool'); $redirect = Request::get('redirect'); $tab = Request::get('tab'); $job = $this->getBackgroundProcess($jobKey); if (empty($job)) { wp_die( __('Background job not found.', 'wp-statistics'), __('Job not found', 'wp-statistics'), [ 'response' => 404, ] ); } if ($isForced) { $job->stopProcess(); $job->setInitiated(false); } if ($job->isInitiated()) { wp_die( __('This background job has already been started.', 'wp-statistics'), __('Job already running', 'wp-statistics'), [ 'response' => 409, ] ); } $job->process(); $adminUrlargs = []; if (!empty($tab)) { $adminUrlargs['tab'] = $tab; } wp_redirect(Menus::admin_url($redirect, $adminUrlargs)); exit; } }

| ver. 1.4 | Github | . | PHP 8.2.31 | Generation time: 0.39 | proxy | phpinfo | Settings