Server IP : 104.21.14.103 / Your IP : 3.144.104.98 Web Server : LiteSpeed System : Linux business53.web-hosting.com 4.18.0-553.lve.el8.x86_64 #1 SMP Mon May 27 15:27:34 UTC 2024 x86_64 User : giankuin ( 1871) PHP Version : 7.4.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /proc/self/root/home/giankuin/thietke365.net/wp-content/plugins/mailpoet/lib/Cron/ |
Upload File : |
<?php // phpcs:ignore SlevomatCodingStandard.TypeHints.DeclareStrictTypes.DeclareStrictTypesMissing namespace MailPoet\Cron; if (!defined('ABSPATH')) exit; use MailPoet\Entities\ScheduledTaskEntity; use MailPoet\Newsletter\Sending\ScheduledTasksRepository; use MailPoet\WP\Functions as WPFunctions; use MailPoetVendor\Carbon\Carbon; class CronWorkerScheduler { /** @var WPFunctions */ private $wp; /** @var ScheduledTasksRepository */ private $scheduledTaskRepository; public function __construct( WPFunctions $wp, ScheduledTasksRepository $scheduledTaskRepository ) { $this->wp = $wp; $this->scheduledTaskRepository = $scheduledTaskRepository; } public function scheduleImmediatelyIfNotRunning($taskType, $priority = ScheduledTaskEntity::PRIORITY_LOW): ScheduledTaskEntity { $task = $this->scheduledTaskRepository->findScheduledOrRunningTask($taskType); // Do nothing when task is running if (($task instanceof ScheduledTaskEntity) && $task->getStatus() === null) { return $task; } $now = Carbon::createFromTimestamp($this->wp->currentTime('timestamp')); // Reschedule existing scheduled task if ($task instanceof ScheduledTaskEntity) { $task->setScheduledAt($now); $task->setPriority($priority); $this->scheduledTaskRepository->flush(); } // Schedule new task return $this->schedule($taskType, $now, $priority); } public function schedule($taskType, $nextRunDate, $priority = ScheduledTaskEntity::PRIORITY_LOW): ScheduledTaskEntity { $alreadyScheduled = $this->scheduledTaskRepository->findScheduledTask($taskType); if ($alreadyScheduled) { return $alreadyScheduled; } $task = new ScheduledTaskEntity(); $task->setType($taskType); $task->setStatus(ScheduledTaskEntity::STATUS_SCHEDULED); $task->setPriority($priority); $task->setScheduledAt($nextRunDate); $this->scheduledTaskRepository->persist($task); $this->scheduledTaskRepository->flush(); return $task; } public function reschedule(ScheduledTaskEntity $task, $timeout) { $scheduledAt = Carbon::createFromTimestamp($this->wp->currentTime('timestamp')); $task->setScheduledAt($scheduledAt->addMinutes($timeout)); $task->setStatus(ScheduledTaskEntity::STATUS_SCHEDULED); $this->scheduledTaskRepository->persist($task); $this->scheduledTaskRepository->flush(); } public function rescheduleProgressively(ScheduledTaskEntity $task): int { $scheduledAt = Carbon::createFromTimestamp($this->wp->currentTime('timestamp')); $rescheduleCount = $task->getRescheduleCount(); $timeout = (int)min(ScheduledTaskEntity::BASIC_RESCHEDULE_TIMEOUT * pow(2, $rescheduleCount), ScheduledTaskEntity::MAX_RESCHEDULE_TIMEOUT); $task->setScheduledAt($scheduledAt->addMinutes($timeout)); $task->setRescheduleCount($rescheduleCount + 1); $task->setStatus(ScheduledTaskEntity::STATUS_SCHEDULED); $this->scheduledTaskRepository->persist($task); $this->scheduledTaskRepository->flush(); return $timeout; } }