@@ -1041,7 +1043,7 @@ protected function renderQueuesDrivers(): void
- +
| + | @@ -1097,7 +1099,7 @@ protected function renderQueuesDrivers(): void |
|---|
define('WP_QUEUE_DRIVER', 'database'); // or 'redis', 'memcached', 'sync', 'auto'| + | |||
|---|---|---|---|
| + | + + + + + + | +||
| - + @@ -1878,16 +1916,19 @@ protected function renderSystemStatus(): void |
'completed',
- 'warning' => 'pending',
- default => 'failed',
+ $lbBadgeClass = match ($loopbackStatus) {
+ 'ok' => 'status-completed',
+ 'warning' => 'status-pending',
+ default => 'status-failed',
+ };
+ $lbStatusLabel = match ($loopbackStatus) {
+ 'ok' => __('OK', 'wp-queue'),
+ 'warning' => __('Warning', 'wp-queue'),
+ 'error' => __('Error', 'wp-queue'),
+ default => __('Unknown', 'wp-queue'),
};
?>
-
-
-
+
@@ -2235,6 +2276,101 @@ protected function renderSchedulerPaused(): void
+
+
+ runDaemon($queue, $assocArgs);
+
+ return;
+ }
+
$limit = (int) ($assocArgs['limit'] ?? 100);
// Get default memory limit from WordPress
@@ -132,13 +142,6 @@ public function work(array $args, array $assocArgs): void
$worker = WPQueue::worker();
$worker->setMemoryLimit($memory);
- if (isset($assocArgs['daemon'])) {
- WP_CLI::log("Starting daemon worker for queue: {$queue}");
- $worker->daemon($queue);
-
- return;
- }
-
$processed = 0;
while ($processed < $limit) {
@@ -152,6 +155,26 @@ public function work(array $args, array $assocArgs): void
WP_CLI::success("Processed {$processed} jobs from queue: {$queue}");
}
+ /**
+ * Run a daemon worker that continuously polls the queue.
+ */
+ protected function runDaemon(string $queue, array $assocArgs): void
+ {
+ // Mark this process as the daemon so loopback/cron do not trigger
+ // additional workers inside the same process.
+ if (! defined('WP_QUEUE_DAEMON')) {
+ define('WP_QUEUE_DAEMON', true);
+ }
+
+ $memory = (int) ($assocArgs['memory'] ?? 256);
+
+ WP_CLI::log("Starting daemon worker for queue: {$queue} (memory limit: {$memory}MB)");
+
+ $worker = WPQueue::worker();
+ $worker->setMemoryLimit($memory);
+ $worker->daemon($queue);
+ }
+
/**
* Clear all jobs from a queue.
*
diff --git a/src/Jobs/PendingDispatch.php b/src/Jobs/PendingDispatch.php
index a4ee631..d12cb7b 100644
--- a/src/Jobs/PendingDispatch.php
+++ b/src/Jobs/PendingDispatch.php
@@ -5,12 +5,17 @@
namespace WPQueue\Jobs;
use WPQueue\Contracts\JobInterface;
+use WPQueue\Loopback\LoopbackDispatcher;
use WPQueue\QueueManager;
class PendingDispatch
{
protected bool $shouldDispatch = true;
+ protected static bool $spawnRegistered = false;
+
+ protected static bool $spawnQueued = false;
+
public function __construct(
protected JobInterface $job,
protected QueueManager $manager,
@@ -66,5 +71,40 @@ protected function send(): void
{
$queue = $this->manager->connection();
$queue->push($this->job);
+
+ $queueName = $this->job->getQueue() ?: 'default';
+ LoopbackDispatcher::spawn($queueName);
+ self::scheduleImmediateProcessing($queueName);
+ }
+
+ protected static function scheduleImmediateProcessing(string $queue): void
+ {
+ if (! function_exists('wp_schedule_single_event') || ! function_exists('spawn_cron')) {
+ return;
+ }
+
+ if (! self::$spawnRegistered) {
+ self::$spawnRegistered = true;
+
+ register_shutdown_function(static function (): void {
+ if (! self::$spawnQueued) {
+ return;
+ }
+
+ self::$spawnQueued = false;
+
+ try {
+ spawn_cron();
+ } catch (\Throwable $e) {
+ error_log('WP Queue: spawn_cron failed: '.$e->getMessage());
+ }
+ });
+ }
+
+ if (wp_next_scheduled('wp_queue_process', [$queue]) === false) {
+ wp_schedule_single_event(time(), 'wp_queue_process', [$queue]);
+ }
+
+ self::$spawnQueued = true;
}
}
diff --git a/src/Loopback/LoopbackDispatcher.php b/src/Loopback/LoopbackDispatcher.php
new file mode 100644
index 0000000..006f379
--- /dev/null
+++ b/src/Loopback/LoopbackDispatcher.php
@@ -0,0 +1,151 @@
+get_error_message()));
+ } elseif (is_array($response) && ($response['response']['code'] ?? 0) >= 400) {
+ error_log(sprintf(
+ 'WP Queue: loopback spawn returned HTTP %s for queue %s',
+ $response['response']['code'] ?? 'unknown',
+ $queue,
+ ));
+ }
+ }
+
+ /**
+ * Build the loopback URL with nonce.
+ */
+ public static function buildUrl(string $queue): string
+ {
+ $args = [
+ 'action' => 'wp_queue_loopback',
+ 'queue' => self::sanitizeQueue($queue),
+ 'nonce' => wp_create_nonce(self::nonceAction($queue)),
+ ];
+
+ $url = add_query_arg($args, admin_url('admin-ajax.php'));
+
+ /**
+ * Filters the loopback URL used to trigger immediate queue processing.
+ *
+ * @param string $url The loopback URL.
+ * @param string $queue Queue name.
+ */
+ return apply_filters('wp_queue_loopback_url', $url, $queue);
+ }
+
+ /**
+ * Build the loopback POST arguments.
+ */
+ public static function buildPostArgs(): array
+ {
+ $args = [
+ 'timeout' => 0.01,
+ 'blocking' => false,
+ 'sslverify' => apply_filters('https_local_ssl_verify', false),
+ 'cookies' => $_COOKIE,
+ 'headers' => [
+ 'Referer' => home_url(),
+ ],
+ ];
+
+ /**
+ * Filters the POST arguments used for the loopback request.
+ *
+ * @param array $args
+ */
+ return apply_filters('wp_queue_loopback_post_args', $args);
+ }
+
+ /**
+ * Nonce verification action name.
+ */
+ public static function nonceAction(string $queue): string
+ {
+ return 'wp_queue_loopback_'.$queue;
+ }
+
+ /**
+ * Sanitize queue name.
+ */
+ public static function sanitizeQueue(string $queue): string
+ {
+ return preg_replace('/[^a-z0-9_-]/', '', $queue) ?: 'default';
+ }
+
+ /**
+ * Whether loopback dispatch is enabled.
+ *
+ * Disable by defining WP_QUEUE_LOOPBACK as false in wp-config.php.
+ * Also disabled automatically when the runtime mode is set to daemon,
+ * because a daemon process is already polling the queue.
+ */
+ public static function isEnabled(): bool
+ {
+ if (defined('WP_QUEUE_LOOPBACK')) {
+ return (bool) WP_QUEUE_LOOPBACK;
+ }
+
+ if (! RuntimeMode::useLoopback()) {
+ return false;
+ }
+
+ /**
+ * Filters whether loopback dispatch is enabled.
+ *
+ * @param bool $enabled Default true.
+ */
+ return apply_filters('wp_queue_loopback_enabled', true);
+ }
+}
diff --git a/src/Loopback/LoopbackHandler.php b/src/Loopback/LoopbackHandler.php
new file mode 100644
index 0000000..d7f5b59
--- /dev/null
+++ b/src/Loopback/LoopbackHandler.php
@@ -0,0 +1,61 @@
+verifyNonce($queue)) {
+ wp_die('Unauthorized', 'Unauthorized', ['response' => 403]);
+ }
+
+ if (WPQueue::isProcessing($queue)) {
+ wp_die('Already processing', 'Already processing', ['response' => 200]);
+ }
+
+ // Trigger the same handler the cron job uses.
+ do_action('wp_queue_process', $queue);
+
+ wp_die('OK', 'OK', ['response' => 200]);
+ }
+
+ /**
+ * Verify the loopback nonce.
+ */
+ protected function verifyNonce(string $queue): bool
+ {
+ $nonce = $_REQUEST['nonce'] ?? '';
+
+ if (empty($nonce)) {
+ return false;
+ }
+
+ return wp_verify_nonce(sanitize_text_field(wp_unslash($nonce)), LoopbackDispatcher::nonceAction($queue)) !== false;
+ }
+}
diff --git a/src/PendingBatch.php b/src/PendingBatch.php
index a4d637b..6b6414c 100644
--- a/src/PendingBatch.php
+++ b/src/PendingBatch.php
@@ -5,6 +5,7 @@
namespace WPQueue;
use WPQueue\Contracts\JobInterface;
+use WPQueue\Loopback\LoopbackDispatcher;
class PendingBatch
{
@@ -35,6 +36,8 @@ public function dispatch(): string
$connection->push($job);
}
+ LoopbackDispatcher::spawn($this->queue);
+
return $batchId;
}
}
diff --git a/src/PendingChain.php b/src/PendingChain.php
index 5664947..33a2280 100644
--- a/src/PendingChain.php
+++ b/src/PendingChain.php
@@ -6,6 +6,7 @@
use WPQueue\Contracts\JobInterface;
use WPQueue\Jobs\ChainedJob;
+use WPQueue\Loopback\LoopbackDispatcher;
class PendingChain
{
@@ -40,5 +41,7 @@ public function dispatch(): void
$chainedJob->onQueue($this->queue);
$this->manager->connection()->push($chainedJob);
+
+ LoopbackDispatcher::spawn($this->queue);
}
}
diff --git a/src/QueueManager.php b/src/QueueManager.php
index 0029b89..fac6690 100644
--- a/src/QueueManager.php
+++ b/src/QueueManager.php
@@ -557,6 +557,106 @@ public function extend(string $driver, callable $callback): void
$this->customCreators[$driver] = $callback;
}
+ /**
+ * Discover all queue names from the current driver.
+ *
+ * @return string[]
+ */
+ public function discoverQueues(): array
+ {
+ $driver = $this->getDefaultDriver();
+ $queues = ['default'];
+
+ try {
+ switch ($driver) {
+ case 'redis':
+ $queues = $this->discoverRedisQueues();
+ break;
+
+ case 'memcached':
+ // Memcached doesn't support key scanning, use known queues
+ $queues = $this->discoverKnownQueues();
+ break;
+
+ case 'database':
+ default:
+ $queues = $this->discoverDatabaseQueues();
+ break;
+ }
+ } catch (\Throwable $e) {
+ if (function_exists('error_log')) {
+ error_log('[WP Queue] Failed to discover queues: '.$e->getMessage());
+ }
+ }
+
+ // Always include default queue
+ if (! in_array('default', $queues, true)) {
+ array_unshift($queues, 'default');
+ }
+
+ return array_unique($queues);
+ }
+
+ /**
+ * Discover queues from Redis.
+ *
+ * @return string[]
+ */
+ protected function discoverRedisQueues(): array
+ {
+ $queue = $this->connection('redis');
+
+ if (! $queue instanceof RedisQueue) {
+ return ['default'];
+ }
+
+ // Use reflection to access getAllQueues method
+ $reflection = new \ReflectionMethod($queue, 'getAllQueues');
+ $reflection->setAccessible(true);
+
+ return $reflection->invoke($queue);
+ }
+
+ /**
+ * Discover queues from database (wp_options).
+ *
+ * @return string[]
+ */
+ protected function discoverDatabaseQueues(): array
+ {
+ global $wpdb;
+
+ $results = $wpdb->get_col(
+ $wpdb->prepare(
+ "SELECT option_name FROM {$wpdb->options} WHERE option_name LIKE %s",
+ 'wp_queue_jobs_%',
+ ),
+ );
+
+ $queues = ['default'];
+ foreach ($results as $optionName) {
+ $name = str_replace('wp_queue_jobs_', '', $optionName);
+ if ($name && ! in_array($name, $queues, true)) {
+ $queues[] = $name;
+ }
+ }
+
+ return $queues;
+ }
+
+ /**
+ * Get known queues from scheduled jobs.
+ *
+ * Used as fallback when driver doesn't support queue discovery.
+ *
+ * @return string[]
+ */
+ protected function discoverKnownQueues(): array
+ {
+ // Known queues used by iiko plugin
+ return ['default', 'imports', 'sync', 'cleanup'];
+ }
+
protected function resolve(string $name): QueueInterface
{
if (isset($this->customCreators[$name])) {
diff --git a/src/Runtime/RuntimeMode.php b/src/Runtime/RuntimeMode.php
new file mode 100644
index 0000000..4785687
--- /dev/null
+++ b/src/Runtime/RuntimeMode.php
@@ -0,0 +1,75 @@
+getTableName();
- $rows = $wpdb->get_results("SELECT * FROM {$table} ORDER BY created_at ASC", ARRAY_A) ?: [];
+ $sql = "SELECT * FROM {$table} ORDER BY created_at ASC";
+ $rows = $wpdb->get_results($sql, ARRAY_A) ?: [];
+
+ if ($this->isMissingTableError($wpdb->last_error)) {
+ WPQueue::install();
+ $rows = $wpdb->get_results($sql, ARRAY_A) ?: [];
+ }
return array_map(static function (array $row): array {
return [
@@ -106,10 +112,13 @@ public function failed(): array
$table = $this->getTableName();
- $rows = $wpdb->get_results(
- $wpdb->prepare("SELECT * FROM {$table} WHERE status = %s ORDER BY created_at DESC", 'failed'),
- ARRAY_A,
- ) ?: [];
+ $sql = $wpdb->prepare("SELECT * FROM {$table} WHERE status = %s ORDER BY created_at DESC", 'failed');
+ $rows = $wpdb->get_results($sql, ARRAY_A) ?: [];
+
+ if ($this->isMissingTableError($wpdb->last_error)) {
+ WPQueue::install();
+ $rows = $wpdb->get_results($sql, ARRAY_A) ?: [];
+ }
return array_map(static function (array $row): array {
return [
@@ -136,10 +145,13 @@ public function completed(): array
$table = $this->getTableName();
- $rows = $wpdb->get_results(
- $wpdb->prepare("SELECT * FROM {$table} WHERE status = %s ORDER BY created_at DESC", 'completed'),
- ARRAY_A,
- ) ?: [];
+ $sql = $wpdb->prepare("SELECT * FROM {$table} WHERE status = %s ORDER BY created_at DESC", 'completed');
+ $rows = $wpdb->get_results($sql, ARRAY_A) ?: [];
+
+ if ($this->isMissingTableError($wpdb->last_error)) {
+ WPQueue::install();
+ $rows = $wpdb->get_results($sql, ARRAY_A) ?: [];
+ }
return array_map(static function (array $row): array {
return [
@@ -165,9 +177,13 @@ public function clearOld(int $daysOld = 7): int
$table = $this->getTableName();
$cutoff = gmdate('Y-m-d H:i:s', time() - ($daysOld * DAY_IN_SECONDS));
- $deleted = $wpdb->query(
- $wpdb->prepare("DELETE FROM {$table} WHERE created_at < %s", $cutoff),
- );
+ $sql = $wpdb->prepare("DELETE FROM {$table} WHERE created_at < %s", $cutoff);
+ $deleted = $wpdb->query($sql);
+
+ if ($this->isMissingTableError($wpdb->last_error)) {
+ WPQueue::install();
+ $deleted = $wpdb->query($sql);
+ }
return (int) $deleted;
}
@@ -180,7 +196,13 @@ public function clear(): void
global $wpdb;
$table = $this->getTableName();
- $wpdb->query("TRUNCATE TABLE {$table}");
+ $sql = "TRUNCATE TABLE {$table}";
+ $wpdb->query($sql);
+
+ if ($this->isMissingTableError($wpdb->last_error)) {
+ WPQueue::install();
+ $wpdb->query($sql);
+ }
}
/**
@@ -194,7 +216,13 @@ public function metrics(): array
$table = $this->getTableName();
- $rows = $wpdb->get_results("SELECT queue, job_class, status FROM {$table}", ARRAY_A) ?: [];
+ $sql = "SELECT queue, job_class, status FROM {$table}";
+ $rows = $wpdb->get_results($sql, ARRAY_A) ?: [];
+
+ if ($this->isMissingTableError($wpdb->last_error)) {
+ WPQueue::install();
+ $rows = $wpdb->get_results($sql, ARRAY_A) ?: [];
+ }
$metrics = [
'total' => count($rows),
diff --git a/src/WPQueue.php b/src/WPQueue.php
index c7e0faa..9741853 100644
--- a/src/WPQueue.php
+++ b/src/WPQueue.php
@@ -8,6 +8,8 @@
use WPQueue\Admin\RestApi;
use WPQueue\Contracts\JobInterface;
use WPQueue\Jobs\PendingDispatch;
+use WPQueue\Loopback\LoopbackHandler;
+use WPQueue\Runtime\RuntimeMode;
use WPQueue\Storage\LogStorage;
/**
@@ -73,30 +75,27 @@ public static function boot(): void
add_action('wp_queue_process', static function (string $queue = 'default'): void {
error_log('WP Queue: Processing started for queue: '.$queue);
+ if (self::isProcessing($queue)) {
+ error_log('WP Queue: Processing already running for queue: '.$queue);
+
+ return;
+ }
+
+ $lockKey = 'wp_queue_lock_'.$queue;
+ $lockTtl = 120;
+
+ set_site_transient($lockKey, 1, $lockTtl);
+
$instance = self::getInstance();
$instance->worker->setMaxJobs(50);
$instance->worker->setMaxTime(50);
- // Start with the queue passed from the cron event (default: "default")
- $queues = [$queue];
-
- // Auto-discover all queues stored in options (wp_queue_jobs_*)
- if (function_exists('get_option')) {
- global $wpdb;
+ // Discover all queues from the current driver
+ $queues = $instance->manager->discoverQueues();
- $results = $wpdb->get_col(
- $wpdb->prepare(
- "SELECT option_name FROM {$wpdb->options} WHERE option_name LIKE %s",
- 'wp_queue_jobs_%',
- ),
- );
-
- foreach ($results as $optionName) {
- $name = str_replace('wp_queue_jobs_', '', $optionName);
- if (! in_array($name, $queues, true)) {
- $queues[] = $name;
- }
- }
+ // Ensure default queue is always processed
+ if (! in_array($queue, $queues, true)) {
+ array_unshift($queues, $queue);
}
// Process each discovered queue until worker reaches its limits
@@ -108,11 +107,19 @@ public static function boot(): void
}
}
- error_log('WP Queue: Processing completed. Jobs processed: '.$instance->worker->getJobsProcessed());
+ try {
+ error_log('WP Queue: Processing completed. Jobs processed: '.$instance->worker->getJobsProcessed());
+ } finally {
+ delete_site_transient($lockKey);
+ }
});
// Schedule queue processing
add_action('init', static function (): void {
+ if (! RuntimeMode::useCron()) {
+ return;
+ }
+
if (! wp_next_scheduled('wp_queue_process')) {
wp_schedule_event(time(), 'min', 'wp_queue_process');
}
@@ -123,6 +130,11 @@ public static function boot(): void
new AdminPage();
}
+ // Loopback async handler (must be outside is_admin())
+ if (RuntimeMode::useLoopback()) {
+ new LoopbackHandler();
+ }
+
// REST API (must be outside is_admin() for REST requests to work)
new RestApi();
@@ -160,7 +172,7 @@ public static function deactivate(): void
public static function install(): void
{
// Schedule queue processing
- if (! wp_next_scheduled('wp_queue_process')) {
+ if (RuntimeMode::useCron() && ! wp_next_scheduled('wp_queue_process')) {
wp_schedule_event(time(), 'min', 'wp_queue_process');
}
@@ -171,7 +183,9 @@ public static function install(): void
public static function uninstall(): void
{
// Отключаем крон
- wp_clear_scheduled_hook('wp_queue_process');
+ if (RuntimeMode::useCron()) {
+ wp_clear_scheduled_hook('wp_queue_process');
+ }
// Удаляем таблицу логов при деактивации
global $wpdb;
diff --git a/tests/Feature/AdminPageTest.php b/tests/Feature/AdminPageTest.php
index 3356017..ac0d831 100644
--- a/tests/Feature/AdminPageTest.php
+++ b/tests/Feature/AdminPageTest.php
@@ -37,6 +37,7 @@ function add_menu_page(string $page_title, string $menu_title, string $capabilit
test('AdminPage имеет 3 основные вкладки', function (): void {
$adminPage = new AdminPage();
+ $adminPage->initTabs();
$reflection = new ReflectionClass($adminPage);
// Получаем приватное свойство tabs
@@ -53,6 +54,7 @@ function add_menu_page(string $page_title, string $menu_title, string $capabilit
test('AdminPage имеет секции для каждой вкладки', function (): void {
$adminPage = new AdminPage();
+ $adminPage->initTabs();
$reflection = new ReflectionClass($adminPage);
$sectionsProperty = $reflection->getProperty('sections');
@@ -67,6 +69,7 @@ function add_menu_page(string $page_title, string $menu_title, string $capabilit
test('Вкладка Очереди имеет 5 секций', function (): void {
$adminPage = new AdminPage();
+ $adminPage->initTabs();
$reflection = new ReflectionClass($adminPage);
$sectionsProperty = $reflection->getProperty('sections');
@@ -83,6 +86,7 @@ function add_menu_page(string $page_title, string $menu_title, string $capabilit
test('Вкладка Планировщик заданий имеет 4 секции', function (): void {
$adminPage = new AdminPage();
+ $adminPage->initTabs();
$reflection = new ReflectionClass($adminPage);
$sectionsProperty = $reflection->getProperty('sections');
@@ -96,16 +100,18 @@ function add_menu_page(string $page_title, string $menu_title, string $capabilit
expect($sections['scheduler'])->toHaveKey('scheduled');
});
-test('Вкладка Система имеет 3 секции', function (): void {
+test('Вкладка Система имеет 4 секции', function (): void {
$adminPage = new AdminPage();
+ $adminPage->initTabs();
$reflection = new ReflectionClass($adminPage);
$sectionsProperty = $reflection->getProperty('sections');
$sectionsProperty->setAccessible(true);
$sections = $sectionsProperty->getValue($adminPage);
- expect($sections['system'])->toHaveCount(3);
+ expect($sections['system'])->toHaveCount(4);
expect($sections['system'])->toHaveKey('status');
+ expect($sections['system'])->toHaveKey('daemon');
expect($sections['system'])->toHaveKey('tools');
expect($sections['system'])->toHaveKey('help');
});
@@ -167,6 +173,12 @@ function add_menu_page(string $page_title, string $menu_title, string $capabilit
expect(method_exists($adminPage, 'renderSchedulerEvents'))->toBeTrue();
});
+test('AdminPage рендерит метод для секции Демон', function (): void {
+ $adminPage = new AdminPage();
+
+ expect(method_exists($adminPage, 'renderSystemDaemon'))->toBeTrue();
+});
+
test('Метод getStatusLabel возвращает корректные метки', function (): void {
$adminPage = new AdminPage();
$reflection = new ReflectionClass($adminPage);
diff --git a/wp-queue.php b/wp-queue.php
index 9007eb4..9a67827 100644
--- a/wp-queue.php
+++ b/wp-queue.php
@@ -6,7 +6,7 @@
* Plugin Name: WP Queue
* Plugin URI: https://github.com/rwsite/wp-queue
* Description: Background job processing and WP-Cron management for WordPress. Schedule tasks, manage queues, and monitor cron events.
- * Version: 1.1.0
+ * Version: 1.2.0
* Author: Aleksei Tikhomirov
* Author URI: https://rwsite.ru
* License: GPL-2.0-or-later
@@ -26,7 +26,7 @@
return;
}
-define('WP_QUEUE_VERSION', '1.1.0');
+define('WP_QUEUE_VERSION', '1.2.0');
define('WP_QUEUE_FILE', __FILE__);
define('WP_QUEUE_PATH', plugin_dir_path(__FILE__));
define('WP_QUEUE_URL', plugin_dir_url(__FILE__));
@@ -53,19 +53,19 @@
});
}
-// Bootstrap
-add_action('plugins_loaded', static function (): void {
- \WPQueue\WPQueue::boot();
-});
-
-// Load text domain
-add_action('init', static function (): void {
+// Load text domain at after_setup_theme (WordPress 6.7+ requires this or later)
+add_action('after_setup_theme', static function (): void {
load_plugin_textdomain(
'wp-queue',
false,
dirname(plugin_basename(__FILE__)).'/languages/',
);
-});
+}, 1);
+
+// Bootstrap after text domain is loaded
+add_action('after_setup_theme', static function (): void {
+ \WPQueue\WPQueue::boot();
+}, 2);
// Activation
register_activation_hook(__FILE__, static function (): void {
+
+
+
+
+
+
+
+
+
+
+
+ |