byrokrat\giroapp\CommandBus\ImportXmlMandateFileHandler

Complexity

Total Complexity

5

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	handle()	0	65	4

<?php
/**
 * This file is part of byrokrat\giroapp.
 *
 * byrokrat\giroapp is free software: you can redistribute it and/or
 * modify it under the terms of the GNU General Public License as published
 * by the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * byrokrat\giroapp is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with byrokrat\giroapp. If not, see <http://www.gnu.org/licenses/>.
 *
 * Copyright 2016-20 Hannes Forsgård
 */

declare(strict_types = 1);

namespace byrokrat\giroapp\CommandBus;

use byrokrat\giroapp\CommandBus;

This use statement conflicts with another class in this namespace, byrokrat\giroapp\CommandBus\CommandBus. Consider defining an alias.

use byrokrat\giroapp\DependencyInjection;
use byrokrat\giroapp\Domain\MandateSources;
use byrokrat\giroapp\Domain\NewDonor;
use byrokrat\giroapp\Domain\PostalAddress;
use byrokrat\giroapp\Domain\State\NewMandate;
use byrokrat\giroapp\Event;
use byrokrat\giroapp\Exception\DonorAlreadyExistsException;
use byrokrat\giroapp\Xml\XmlMandateCompiler;

final class ImportXmlMandateFileHandler
{
    use DependencyInjection\CommandBusProperty,
        DependencyInjection\DispatcherProperty,
        DependencyInjection\DonorRepositoryProperty;

    /** @var XmlMandateCompiler */
    private $xmlMandateCompiler;

    public function __construct(XmlMandateCompiler $xmlMandateCompiler)
    {
        $this->xmlMandateCompiler = $xmlMandateCompiler;
    }

    public function handle(ImportXmlMandateFile $command): void
    {
        $this->dispatcher->dispatch(
            new Event\InfoEvent(
                "<info>Importing mandates from {$command->getFile()->getFilename()}</info>",
                ['filename' => $command->getFile()->getFilename()]
            )
        );

        foreach ($this->xmlMandateCompiler->compileFile($command->getFile()) as $xmlMandate) {
            try {
                $this->commandBus->handle(
                    new CommandBus\AddDonor(
                        new NewDonor(
                            MandateSources::MANDATE_SOURCE_ONLINE_FORM,
                            $xmlMandate->payerNumber,
                            $xmlMandate->account,
                            $xmlMandate->donorId,
                            $xmlMandate->donationAmount
                        )
                    )
                );
            } catch (DonorAlreadyExistsException $exception) {
                // Dispatching error means that failure can be picked up in an outer layer
                $this->dispatcher->dispatch(
                    new Event\ErrorEvent(
                        $exception->getMessage(),
                        [
                            'payer_number' => $xmlMandate->payerNumber,
                            'donor_id' => $xmlMandate->donorId->format('CS-sk')
                        ]
                    )
                );

                continue;
            }

            $donor = $this->donorRepository->requireByPayerNumber($xmlMandate->payerNumber);

            $this->commandBus->handle(
                new CommandBus\UpdateState($donor, NewMandate::getStateId(), 'Mandate added from xml')
            );

            $this->commandBus->handle(new CommandBus\UpdateName($donor, $xmlMandate->name));

            $this->commandBus->handle(new CommandBus\UpdatePostalAddress($donor, new PostalAddress(
                $xmlMandate->address['line1'],
                $xmlMandate->address['line2'],
                $xmlMandate->address['line3'],
                $xmlMandate->address['postalCode'],
                $xmlMandate->address['postalCity']
            )));

            $this->commandBus->handle(new CommandBus\UpdateEmail($donor, $xmlMandate->email));

            $this->commandBus->handle(new CommandBus\UpdatePhone($donor, $xmlMandate->phone));

            $this->commandBus->handle(new CommandBus\UpdateComment($donor, $xmlMandate->comment));

            foreach ($xmlMandate->attributes as $attrKey => $attrValue) {
                $this->commandBus->handle(new CommandBus\UpdateAttribute($donor, $attrKey, $attrValue));
            }
        }

        $this->dispatcher->dispatch(new Event\XmlMandateFileImported($command->getFile()));
    }
}