lamoda / queue-bundle

src/Service/QueueRepublishService.php

<?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
    {
        $this->queueService->beginTransaction();

        try {
            $republishedQueueIds = [];
            do {

This code seems to be duplicated across your project.

                $queues = $this->queueService->getToRepublish($batchSize);
                if ($queues) {
                    foreach ($queues as $queue) {
                        $this->publisherFactory->republish($queue);
                        $this->queueService->flush($queue);
                        $republishedQueueIds[] = $queue->getId();
                    }
                }
                $this->queueService->commit();
                $this->publisherFactory->releaseAll();
            } while (count($queues) === $batchSize);

            if ($republishedQueueIds) {
                $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;
        }

        return true;
    }
}