ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: home / lab2454c / caimegroup.com / wp-content / plugins / mailpoet / lib / Cron / Workers / SendingQueue

<?php // phpcs:ignore SlevomatCodingStandard.TypeHints.DeclareStrictTypes.DeclareStrictTypesMissing

namespace MailPoet\Cron\Workers\SendingQueue;

if (!defined('ABSPATH')) exit;

use MailPoet\Entities\ScheduledTaskEntity;
use MailPoet\Entities\SendingQueueEntity;
use MailPoet\Logging\LoggerFactory;
use MailPoet\Mailer\MailerError;
use MailPoet\Mailer\MailerLog;
use MailPoet\Newsletter\Sending\ScheduledTaskSubscribersRepository;
use MailPoet\Newsletter\Sending\SendingQueuesRepository;

class SendingErrorHandler {
  /** @var ScheduledTaskSubscribersRepository */
  private $scheduledTaskSubscribersRepository;

/** @var SendingThrottlingHandler */
  private $throttlingHandler;

/** @var SendingQueuesRepository */
  private $sendingQueuesRepository;

/** @var LoggerFactory */
  private $loggerFactory;

public function __construct(
    ScheduledTaskSubscribersRepository $scheduledTaskSubscribersRepository,
    SendingThrottlingHandler $throttlingHandler,
    SendingQueuesRepository $sendingQueuesRepository,
    LoggerFactory $loggerFactory
  ) {
    $this->scheduledTaskSubscribersRepository = $scheduledTaskSubscribersRepository;
    $this->throttlingHandler = $throttlingHandler;
    $this->sendingQueuesRepository = $sendingQueuesRepository;
    $this->loggerFactory = $loggerFactory;
  }

public function processError(
    MailerError $error,
    ScheduledTaskEntity $task,
    array $preparedSubscribersIds,
    array $preparedSubscribers
  ) {
    if ($error->getLevel() === MailerError::LEVEL_HARD) {
      return $this->processHardError($error);
    }
    $this->processSoftError($error, $task, $preparedSubscribersIds, $preparedSubscribers);
  }

private function processHardError(MailerError $error) {
    if ($error->getRetryInterval() !== null) {
      MailerLog::processNonBlockingError($error->getOperation(), $error->getMessageWithFailedSubscribers(), $error->getRetryInterval());
    } else {
      $throttledBatchSize = null;
      if ($error->getOperation() === MailerError::OPERATION_CONNECT) {
        $throttledBatchSize = $this->throttlingHandler->throttleBatchSize();
      }
      MailerLog::processError($error->getOperation(), $error->getMessageWithFailedSubscribers(), null, false, $throttledBatchSize);
    }
  }

private function processSoftError(MailerError $error, ScheduledTaskEntity $task, $preparedSubscribersIds, $preparedSubscribers) {
    foreach ($error->getSubscriberErrors() as $subscriberError) {
      $subscriberIdIndex = array_search($subscriberError->getEmail(), $preparedSubscribers);
      $message = $subscriberError->getMessage() ?: $error->getMessage();
      $this->scheduledTaskSubscribersRepository->saveError($task, $preparedSubscribersIds[$subscriberIdIndex], $message ?? '');
    }

$queue = $task->getSendingQueue();

if ($queue instanceof SendingQueueEntity) {
      if ($error->getOperation() === MailerError::OPERATION_DOMAIN_AUTHORIZATION) {
        $this->loggerFactory->getLogger(LoggerFactory::TOPIC_NEWSLETTERS)->info(
          'Paused task in sending queue due to sender domain authorization error',
          ['task_id' => $task->getId()]
        );
        $this->sendingQueuesRepository->pause($queue);
        return;
      }
      $this->sendingQueuesRepository->updateCounts($queue);
    }
  }
}

[-] index.php [edit]
[+] ..
[+] Tasks
[-] SendingThrottlingHandler.php [edit]
[-] SendingErrorHandler.php [edit]
[-] SendingQueue.php [edit]