CommerceLeague\ActiveCampaign\Service\Customer\SyncCustomerService

Complexity

Total Complexity

2

Size/Duplication

Total Lines	36
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	sync()	0	8	1
A	__construct()	0	6	1

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

namespace CommerceLeague\ActiveCampaign\Service\Customer;


use CommerceLeague\ActiveCampaign\Gateway\Request\CustomerBuilder as CustomerRequestBuilder;
use CommerceLeague\ActiveCampaign\MessageQueue\Topics;
use Magento\Customer\Model\Customer as MagentoCustomer;
use Magento\Framework\MessageQueue\PublisherInterface;

class SyncCustomerService
{

    /**
     * @var CustomerRequestBuilder
     */
    private $customerRequestBuilder;

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

    /**
     * @param CustomerRequestBuilder $customerRequestBuilder
     * @param PublisherInterface $publisher
     */
    public function __construct(
        CustomerRequestBuilder $customerRequestBuilder,
        PublisherInterface $publisher
    ) {
        $this->customerRequestBuilder = $customerRequestBuilder;
        $this->publisher = $publisher;
    }

    /**
     * @param MagentoCustomer $magentoCustomer
     */
    public function sync(MagentoCustomer $magentoCustomer): void
    {
        $data = [
            'magento_customer_id' => $magentoCustomer->getId(),
            'request' => $this->customerRequestBuilder->build($magentoCustomer)
        ];

        $this->publisher->publish(Topics::CUSTOMER_SYNC, json_encode($data));

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

    }
}