Odiseo\SyliusMailchimpPlugin\Command\SyncCustomersCommand

Complexity

Total Complexity

9

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	1
A	configure()	0	6	1
A	execute()	0	9	1
A	registerCustomers()	0	30	6

<?php

declare(strict_types=1);

namespace Odiseo\SyliusMailchimpPlugin\Command;

use Odiseo\SyliusMailchimpPlugin\Handler\CustomerRegisterHandlerInterface;
use Sylius\Component\Channel\Repository\ChannelRepositoryInterface;
use Sylius\Component\Core\Model\ChannelInterface;
use Sylius\Component\Core\Model\CustomerInterface;
use Sylius\Component\Core\Repository\CustomerRepositoryInterface;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;

final class SyncCustomersCommand extends BaseSyncCommand
{
    /** @var ChannelRepositoryInterface */
    private $channelRepository;

    /** @var CustomerRepositoryInterface */
    private $customerRepository;

    /** @var CustomerRegisterHandlerInterface */
    private $customerRegisterHandler;

    public function __construct(
        ChannelRepositoryInterface $channelRepository,
        CustomerRepositoryInterface $customerRepository,
        CustomerRegisterHandlerInterface $customerRegisterHandler
    ) {
        parent::__construct();

        $this->channelRepository = $channelRepository;
        $this->customerRepository = $customerRepository;
        $this->customerRegisterHandler = $customerRegisterHandler;
    }

    /**
     * {@inheritdoc}
     */
    protected function configure(): void
    {
        $this
            ->setName('odiseo:mailchimp:sync-customers')
            ->setDescription('Synchronize the customers to Mailchimp.')
            ->addOption('create-only', 'c', InputOption::VALUE_NONE, 'With this option the existing customers will be not updated.')
        ;
    }

    /**
     * {@inheritdoc}
     */
    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $this->io = new SymfonyStyle($input, $output);

        $this->io->title('Synchronizing the customers to Mailchimp');

        $this->registerCustomers($input);

        return 0;
    }

    /**
     * @param InputInterface $input
     */
    protected function registerCustomers(InputInterface $input): void
    {
        $createOnly = $input->getOption('create-only');

        $channels = $this->channelRepository->findAll();
        $customers = $this->customerRepository->findAll();

        $this->io->text('Connecting ' . count($customers) . ' customers.');
        $this->io->progressStart(count($customers));

        /** @var CustomerInterface $customer */
        foreach ($customers as $customer) {
            /** @var ChannelInterface $channel */
            foreach ($channels as $channel) {
                try {
                    $response = $this->customerRegisterHandler->register($customer, $channel, false, $createOnly);

                    if (!isset($response['id']) && $response !== false) {
                        $this->showError($response);
                    }
                } catch (\Exception $e) {
                    $this->io->error($e->getMessage());
                }
            }

            $this->io->progressAdvance(1);
        }

        $this->io->progressFinish();
        $this->io->success('The customers has been synchronized successfully.');
    }
}