BitBag\SyliusVueStorefrontPlugin\CommandHandler\User\UpdateUserHandler

Complexity

Total Complexity

4

Size/Duplication

Total Lines	73
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	13	1
A	__invoke()	0	41	3

<?php

/*
 * This file has been created by developers from BitBag.
 * Feel free to contact us once you face any issues or want to start
 * another great project.
 * You can find more information about us on https://bitbag.io and write us
 * an email on hello@bitbag.io.
 */

declare(strict_types=1);

namespace BitBag\SyliusVueStorefrontPlugin\CommandHandler\User;

use BitBag\SyliusVueStorefrontPlugin\Command\User\UpdateUser;
use BitBag\SyliusVueStorefrontPlugin\Sylius\Modifier\DefaultAddressModifierInterface;
use Doctrine\Common\Collections\Criteria;
use Doctrine\Persistence\ObjectManager;
use Sylius\Component\Addressing\Model\AddressInterface;
use Sylius\Component\Core\Factory\AddressFactoryInterface;
use Sylius\Component\Core\Model\CustomerInterface;
use Sylius\Component\Core\Repository\AddressRepositoryInterface;
use Sylius\Component\Core\Repository\CustomerRepositoryInterface;
use Symfony\Component\Messenger\Handler\MessageHandlerInterface;

final class UpdateUserHandler implements MessageHandlerInterface
{
    /** @var CustomerRepositoryInterface */
    private $customerRepository;

    /** @var AddressRepositoryInterface */
    private $addressRepository;

    /** @var AddressFactoryInterface */
    private $addressFactory;

    /** @var ObjectManager */
    private $objectManager;

    /** @var DefaultAddressModifierInterface */
    private $defaultAddressModifier;

    public function __construct(
        CustomerRepositoryInterface $customerRepository,
        AddressRepositoryInterface $addressRepository,
        AddressFactoryInterface $addressFactory,
        ObjectManager $objectManager,
        DefaultAddressModifierInterface $defaultAddressModifier
    ) {
        $this->customerRepository = $customerRepository;
        $this->addressRepository = $addressRepository;
        $this->addressFactory = $addressFactory;
        $this->objectManager = $objectManager;
        $this->defaultAddressModifier = $defaultAddressModifier;
    }

    public function __invoke(UpdateUser $command): void
    {
        /** @var CustomerInterface $customer */
        $customer = $this->customerRepository->findOneBy(['email' => $command->customer()->email]);

        $customer->setFirstName($command->customer()->firstname);
        $customer->setLastName($command->customer()->lastname);

        $addresses = $command->customer()->addresses();

        foreach ($addresses as $address) {
            /** @var AddressInterface $syliusAddress */
            $syliusAddress = $customer->getAddresses()
                ->matching(
                    Criteria::create()
                        ->where(Criteria::expr()->eq('id', $address->id))
                )
                ->first();

            if (false === $syliusAddress) {
                $syliusAddress = $this->addressFactory->createForCustomer($customer);
            }

            $syliusAddress->setProvinceCode((string) $address->region_id);
            $syliusAddress->setProvinceName((string) $address->region()->region);
            $syliusAddress->setCompany($address->company);
            $syliusAddress->setPhoneNumber($address->telephone);
            $syliusAddress->setPostcode($address->postcode);
            $syliusAddress->setCountryCode($address->country_id);
            $syliusAddress->setStreet(\implode(' ', $address->street));
            $syliusAddress->setCity($address->city);
            $syliusAddress->setFirstName($address->firstname);
            $syliusAddress->setLastName($address->lastname);

            $this->addressRepository->add($syliusAddress);

            $this->defaultAddressModifier->modify($customer, $syliusAddress);
        }

        $this->objectManager->flush();
    }
}