Lamoda\QueueBundle\Service\QueueRepublishService

Complexity

Total Complexity

10

Size/Duplication

Total Lines	77
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

97.14%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
B	republishQueues()	0	55	9

<?php

declare(strict_types=1);

namespace Lamoda\QueueBundle\Service;

use Lamoda\QueueBundle\ConstantMessage;
use Lamoda\QueueBundle\Factory\PublisherFactory;
use Psr\Log\LoggerInterface;
use Throwable;

class QueueRepublishService
{
    /** @var PublisherFactory */
    protected $publisherFactory;

    /** @var QueueService */
    protected $queueService;

    /** @var LoggerInterface */
    protected $logger;

    public function __construct(
        PublisherFactory $publisherFactory,
        QueueService $queueService,
        LoggerInterface $logger
    ) {
        $this->publisherFactory = $publisherFactory;
        $this->queueService = $queueService;
        $this->logger = $logger;
    }

    public function republishQueues(int $batchSize): bool
    {
        $i = 0;

        while (true) {
            $this->queueService->beginTransaction();

            try {
                $queues = $this->queueService->getToRepublish($batchSize);

                if (0 !== $i && count($queues) < $batchSize) {
                    $this->queueService->commit();

                    return true;
                }

                $republishedQueueIds = [];

                foreach ($queues as $queue) {
                    $this->publisherFactory->republish($queue);
                    $this->queueService->flush($queue);
                    $republishedQueueIds[] = $queue->getId();
                }

                $this->queueService->commit();
                $this->publisherFactory->releaseAll();

                if ($republishedQueueIds) {

The expression $republishedQueueIds of type array is implicitly converted to a boolean; are you sure this is intended? If so, consider using ! empty($expr) instead to make it clear that you intend to check for an array without elements.

                    $this->logger->info(
                        ConstantMessage::QUEUE_SUCCESS_REPUBLISH,
                        ['queuesIds' => implode(', ', $republishedQueueIds)]
                    );
                }
            } catch (Throwable $exception) {
                $this->queueService->rollback();

                $this->logger->error(
                    ConstantMessage::QUEUE_CAN_NOT_REPUBLISH,
                    [
                        'exception' => get_class($exception),
                        'message' => $exception->getMessage(),
                    ]
                );

                return false;
            }

            if (0 === $i && count($queues) < $batchSize) {
                return true;
            }
            ++$i;
        }

        return true;
    }
}