commerceleague / magento2-module-activecampaign

Cron/ExportOmittedCustomers.php

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

namespace CommerceLeague\ActiveCampaign\Cron;


use CommerceLeague\ActiveCampaign\Helper\Config as ConfigHelper;
use CommerceLeague\ActiveCampaign\MessageQueue\Topics;
use CommerceLeague\ActiveCampaign\Model\ResourceModel\Customer\Collection as CustomerCollection;
use CommerceLeague\ActiveCampaign\Model\ResourceModel\Customer\CollectionFactory as CustomerCollectionFactory;

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

use Magento\Framework\MessageQueue\PublisherInterface;

/**
 * Class ExportOmittedCustomers
 */
class ExportOmittedCustomers implements CronInterface
{
    /**
     * @var ConfigHelper
     */
    private $configHelper;

    /**
     * @var CustomerCollectionFactory
     */
    private $customerCollectionFactory;

    /**
     * @var PublisherInterface
     */
    private $publisher;

    /**
     * @param ConfigHelper $configHelper
     * @param CustomerCollectionFactory $customerCollectionFactory
     * @param PublisherInterface $publisher
     */
    public function __construct(
        ConfigHelper $configHelper,
        CustomerCollectionFactory $customerCollectionFactory,
        PublisherInterface $publisher
    ) {
        $this->configHelper = $configHelper;
        $this->customerCollectionFactory = $customerCollectionFactory;
        $this->publisher = $publisher;
    }

    /**
     * @inheritDoc
     */
    public function run(): void
    {
        if (!$this->configHelper->isEnabled() || !$this->configHelper->isCustomerExportEnabled()) {
            return;
        }

        $customerIds = $this->getCustomerIds();

        foreach ($customerIds as $customerId) {
            $this->publisher->publish(
                Topics::CUSTOMER_CUSTOMER_EXPORT,
                json_encode(['magento_customer_id' => $customerId])

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

            );
        }
    }

    /**
     * @return array
     */
    private function getCustomerIds(): array
    {
        /** @var CustomerCollection $customerCollection */
        $customerCollection = $this->customerCollectionFactory->create();
        $customerCollection->addCustomerOmittedFilter();

        return $customerCollection->getAllIds();
    }
}