Odiseo\SyliusMailchimpPlugin\Command\SyncStoresCommand

Complexity

Total Complexity

11

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	7	1
A	__construct()	0	8	1
B	registerStores()	0	43	8
A	execute()	0	9	1

<?php

declare(strict_types=1);

namespace Odiseo\SyliusMailchimpPlugin\Command;

use Odiseo\SyliusMailchimpPlugin\Handler\StoreRegisterHandlerInterface;
use Sylius\Component\Channel\Repository\ChannelRepositoryInterface;
use Sylius\Component\Core\Model\ChannelInterface;
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 SyncStoresCommand extends BaseSyncCommand
{
    /** @var ChannelRepositoryInterface */
    private $channelRepository;

    /** @var StoreRegisterHandlerInterface */
    private $storeRegisterHandler;

    public function __construct(
        ChannelRepositoryInterface $channelRepository,
        StoreRegisterHandlerInterface $storeRegisterHandler
    ) {
        parent::__construct();

        $this->channelRepository = $channelRepository;
        $this->storeRegisterHandler = $storeRegisterHandler;
    }

    /**
     * {@inheritdoc}
     */
    protected function configure(): void
    {
        $this
            ->setName('odiseo:mailchimp:sync-stores')
            ->setDescription('Synchronize the Sylius stores (channels) to Mailchimp.')
            ->addOption('purge', 'p', InputOption::VALUE_NONE, 'Remove all stores before create the new ones.')
            ->addOption('isSyncing', 's', InputOption::VALUE_NONE, 'Mark the stores with "is_syncing" field like true.')
        ;
    }

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

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

        $this->registerStores($input);

        return 0;
    }

    /**
     * @param InputInterface $input
     */
    protected function registerStores(InputInterface $input): void
    {
        $withPurge = $input->getOption('purge');
        $isSyncing = $input->getOption('isSyncing');

        $channels = $this->channelRepository->findBy([
            'enabled' => true,
        ]);

        /** @var ChannelInterface $channel */
        foreach ($channels as $channel) {
            if ($withPurge) {
                $this->io->write('Removing the "' . $channel->getName() . '" store...');

                try {
                    $this->storeRegisterHandler->unregister($channel);
                    $this->io->writeln('Done.');
                } catch (\Exception $e) {
                    $this->io->writeln('Error.');
                    $this->io->error($e->getMessage());
                }
            }

            $this->io->write('Connecting the "' . $channel->getName() . '" store with is_syncing = '.($isSyncing?'true':'false').'...');

            try {
                $response = $this->storeRegisterHandler->register($channel, $isSyncing);

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

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