Setono\SyliusStockMovementPlugin\Message\Handler\SendReportHandler

Complexity

Total Complexity

5

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	1

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	__invoke()	0	21	4

<?php

declare(strict_types=1);

namespace Setono\SyliusStockMovementPlugin\Message\Handler;

use InvalidArgumentException;
use Safe\Exceptions\StringsException;
use function Safe\sprintf;
use Setono\SyliusStockMovementPlugin\Exception\UnexpectedStatusException;
use Setono\SyliusStockMovementPlugin\Message\Command\SendReport;
use Setono\SyliusStockMovementPlugin\Model\ReportInterface;
use Setono\SyliusStockMovementPlugin\Repository\ReportRepositoryInterface;
use Setono\SyliusStockMovementPlugin\Sender\ReportSenderInterface;
use Setono\SyliusStockMovementPlugin\Writer\ReportWriterInterface;
use Symfony\Component\Messenger\Handler\MessageHandlerInterface;

class SendReportHandler implements MessageHandlerInterface
{
    /** @var ReportRepositoryInterface */
    private $reportRepository;

    /** @var ReportWriterInterface */
    private $reportWriter;

    /** @var ReportSenderInterface */
    private $reportSender;

    public function __construct(
        ReportRepositoryInterface $reportRepository,
        ReportWriterInterface $reportWriter,
        ReportSenderInterface $reportSender
    ) {
        $this->reportRepository = $reportRepository;
        $this->reportWriter = $reportWriter;
        $this->reportSender = $reportSender;
    }

    /**
     * @throws StringsException
     */
    public function __invoke(SendReport $message): void
    {
        /** @var ReportInterface|null $report */
        $report = $this->reportRepository->find($message->getReportId());
        if (null === $report) {
            throw new InvalidArgumentException(sprintf('The report with id %s was not found', $message->getReportId()));
        }

        if (!$report->isSuccessful()) {
            throw new UnexpectedStatusException($report->getStatus(), ReportInterface::STATUS_SUCCESS);

It seems like $report->getStatus() can also be of type null; however, parameter $actualStatus of Setono\SyliusStockMovementPlugin\Exception\UnexpectedStatusException::__construct() does only seem to accept string, maybe add an additional type check?

        }

        $reportConfiguration = $report->getReportConfiguration();

        if (null === $reportConfiguration) {
            throw new InvalidArgumentException(sprintf('No report configuration associated with report %s', $report->getId()));
        }

        $file = $this->reportWriter->write($report);

        $this->reportSender->send($file, $report, $reportConfiguration);
    }
}