Setono\SyliusStockMovementPlugin\Processor\ReportConfigurationProcessor

Complexity

Total Complexity

4

Size/Duplication

Total Lines	27
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	process()	0	11	3

<?php

declare(strict_types=1);

namespace Setono\SyliusStockMovementPlugin\Processor;

use Psr\Log\LoggerAwareTrait;
use Setono\SyliusStockMovementPlugin\Message\Command\ProcessReportConfiguration;
use Setono\SyliusStockMovementPlugin\Provider\ReportConfigurationProviderInterface;
use Symfony\Component\Messenger\MessageBusInterface;

final class ReportConfigurationProcessor implements ReportConfigurationProcessorInterface
{
    use LoggerAwareTrait;

    /** @var ReportConfigurationProviderInterface */
    private $reportConfigurationProvider;

    /** @var MessageBusInterface */
    private $commandBus;

    public function __construct(ReportConfigurationProviderInterface $reportConfigurationProvider, MessageBusInterface $commandBus)
    {
        $this->reportConfigurationProvider = $reportConfigurationProvider;
        $this->commandBus = $commandBus;
    }

    public function process(): void
    {
        $reportConfigurations = $this->reportConfigurationProvider->getReportConfigurations();

        if (count($reportConfigurations) === 0) {
            $this->logger->info('No report configurations due');
        }

        foreach ($reportConfigurations as $reportConfiguration) {
            $this->logger->info('Processing report configuration: ' . $reportConfiguration->getName());
            $this->commandBus->dispatch(new ProcessReportConfiguration($reportConfiguration->getId()));
        }
    }
}