Server IP : 104.21.14.103 / Your IP : 3.12.36.65 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/Tasks/Subscribers/ |
Upload File : |
<?php // phpcs:ignore SlevomatCodingStandard.TypeHints.DeclareStrictTypes.DeclareStrictTypesMissing namespace MailPoet\Tasks\Subscribers; if (!defined('ABSPATH')) exit; use MailPoet\DI\ContainerWrapper; use MailPoet\Newsletter\Sending\ScheduledTaskSubscribersRepository; /** * @implements \Iterator<null, array> */ class BatchIterator implements \Iterator, \Countable { private $taskId; private $batchSize; private $lastProcessedId = 0; private $batchLastId; /** @var ScheduledTaskSubscribersRepository */ private $scheduledTaskSubscribersRepository; public function __construct( $taskId, $batchSize ) { if ($taskId <= 0) { throw new \Exception('Task ID must be greater than zero'); } elseif ($batchSize <= 0) { throw new \Exception('Batch size must be greater than zero'); } $this->taskId = (int)$taskId; $this->batchSize = (int)$batchSize; $this->scheduledTaskSubscribersRepository = ContainerWrapper::getInstance()->get(ScheduledTaskSubscribersRepository::class); } public function rewind(): void { $this->lastProcessedId = 0; } /** * @return mixed - it's required for PHP8.1 to prevent using ReturnTypeWillChange that cause an error in PHPStan with PHP7 */ #[\ReturnTypeWillChange] public function current() { $subscribers = $this->scheduledTaskSubscribersRepository->getSubscriberIdsBatchForTask($this->taskId, $this->lastProcessedId, $this->batchSize); $this->batchLastId = end($subscribers); return $subscribers; } /** * @return string|float|int|bool|null - it's required for PHP8.1 to prevent using ReturnTypeWillChange that cause an error in PHPStan with PHP7 */ #[\ReturnTypeWillChange] public function key() { return null; } public function next(): void { $this->lastProcessedId = $this->batchLastId; } public function valid(): bool { return $this->count() > 0; } public function count(): int { return $this->scheduledTaskSubscribersRepository->countSubscriberIdsBatchForTask($this->taskId, $this->lastProcessedId); } }