CommerceLeague\ActiveCampaign\Console\Command\ExportContactCommand

Complexity

Total Complexity

8

Size/Duplication

Total Lines	116
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	getMagentoCustomerIds()	0	5	1
A	getSubscriberEmails()	0	14	2
A	configure()	0	3	1
A	__construct()	0	9	1
A	execute()	0	45	3

<?php
declare(strict_types=1);
/**
 */

namespace CommerceLeague\ActiveCampaign\Console\Command;

use CommerceLeague\ActiveCampaign\MessageQueue\Topics;
use Magento\Customer\Model\ResourceModel\Customer\Collection as MagentoCustomerCollection;
use Magento\Customer\Model\ResourceModel\Customer\CollectionFactory as MagentoCustomerCollectionFactory;

The type Magento\Customer\Model\ResourceModel\Customer\CollectionFactory was not found. Maybe you did not declare it correctly or list all dependencies?

use Magento\Framework\Console\Cli;
use Magento\Framework\MessageQueue\PublisherInterface;
use Magento\Newsletter\Model\ResourceModel\Subscriber\CollectionFactory as SubscriberCollectionFactory;

The type Magento\Newsletter\Model\ResourceModel\Subscriber\CollectionFactory was not found. Maybe you did not declare it correctly or list all dependencies?

use Magento\Newsletter\Model\ResourceModel\Subscriber\Collection as SubscriberCollection;
use Magento\Newsletter\Model\Subscriber;
use Symfony\Component\Console\Helper\ProgressBarFactory;

The type Symfony\Component\Console\Helper\ProgressBarFactory was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

/**
 * Class ExportContactCommand
 */
class ExportContactCommand extends AbstractExportCommand
{
    private const NAME = 'activecampaign:export:contact';

    /**
     * @var MagentoCustomerCollectionFactory
     */
    private $magentoCustomerCollectionFactory;

    /**
     * @var SubscriberCollectionFactory
     */
    private $subscriberCollectionFactory;

    /**
     * @param MagentoCustomerCollectionFactory $magentoCustomerCollectionFactory
     * @param SubscriberCollectionFactory $subscriberCollectionFactory
     * @param PublisherInterface $publisher
     * @param ProgressBarFactory $progressBarFactory
     */
    public function __construct(
        MagentoCustomerCollectionFactory $magentoCustomerCollectionFactory,
        SubscriberCollectionFactory $subscriberCollectionFactory,
        PublisherInterface $publisher,
        ProgressBarFactory $progressBarFactory
    ) {
        $this->magentoCustomerCollectionFactory = $magentoCustomerCollectionFactory;
        $this->subscriberCollectionFactory = $subscriberCollectionFactory;
        parent::__construct($progressBarFactory, $publisher);
    }

    /**
     * @inheritDoc
     */
    protected function configure()
    {
        $this->setName(self::NAME);
    }

    /**
     * @inheritDoc
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $magentoCustomerIds = $this->getMagentoCustomerIds();

        $progressBar = $this->createProgressBar(
            $output,
            count($magentoCustomerIds),
            'Export Magento Customer(s)'
        );

        foreach ($magentoCustomerIds as $magentoCustomerId) {
            $this->publisher->publish(
                Topics::CUSTOMER_CONTACT_EXPORT,
                json_encode(['magento_customer_id' => $magentoCustomerId])

json_encode(array('magento_customer_id' => $magentoCustomerId)) of type string is incompatible with the type array|object expected by parameter $data of Magento\Framework\MessageQueue\PublisherInterface::publish().

            );

            $progressBar->advance();
        }

        $output->writeln('');

        $subscriberEmails = $this->getSubscriberEmails();

        $progressBar = $this->createProgressBar(
            $output,
            count($subscriberEmails),
            'Export Newsletter Subscriber(s)'
        );

        foreach ($subscriberEmails as $subscriberEmail) {
            $this->publisher->publish(
                Topics::NEWSLETTER_CONTACT_EXPORT,
                json_encode(['email' => $subscriberEmail])
            );

            $progressBar->advance();
        }

        $output->writeln('');
        $output->writeln(sprintf(
            '<info>Exported %s contact(s)</info>',
            (count($magentoCustomerIds) + count($subscriberEmails)))
        );

        return Cli::RETURN_SUCCESS;
    }

    /**
     * @return array
     */
    private function getMagentoCustomerIds(): array
    {
        /** @var MagentoCustomerCollection $magentoCustomerCollection */
        $magentoCustomerCollection = $this->magentoCustomerCollectionFactory->create();
        return $magentoCustomerCollection->getAllIds();
    }

    /**
     * @return array
     */
    private function getSubscriberEmails(): array
    {
        /** @var SubscriberCollection $subscriberCollection */
        $subscriberCollection = $this->subscriberCollectionFactory->create();
        $subscriberCollection->addFieldToFilter('customer_id', 0);

        $subscriberEmails = [];

        /** @var Subscriber $subscriber */
        foreach ($subscriberCollection as $subscriber) {
            $subscriberEmails[] = $subscriber->getEmail();
        }

        return $subscriberEmails;
    }
}