CommerceLeague\ActiveCampaign\Service\Contact\CreateUpdateContactService

Complexity

Total Complexity

3

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	execute()	0	15	2
A	__construct()	0	10	1

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

namespace CommerceLeague\ActiveCampaign\Service\Contact;

use CommerceLeague\ActiveCampaign\Api\ContactRepositoryInterface;
use CommerceLeague\ActiveCampaign\Gateway\Request\ContactRequestBuilder;
use CommerceLeague\ActiveCampaign\Logger\Logger;
use CommerceLeague\ActiveCampaign\MessageQueue\Contact\CreateUpdateMessage;
use CommerceLeague\ActiveCampaign\MessageQueue\Contact\CreateUpdatePublisher;
use Magento\Customer\Model\Customer;
use Magento\Framework\Exception\CouldNotSaveException;

/**
 * Class CreateUpdateContactService
 */
class CreateUpdateContactService
{
    /**
     * @var ContactRepositoryInterface
     */
    private $contactRepository;

    /**
     * @var Logger
     */
    private $logger;

    /**
     * @var ContactRequestBuilder
     */
    private $contactRequestBuilder;

    /**
     * @var CreateUpdatePublisher
     */
    private $createUpdatePublisher;

    /**
     * @param ContactRepositoryInterface $contactRepository
     * @param Logger $logger
     * @param ContactRequestBuilder $contactRequestBuilder
     * @param CreateUpdatePublisher $createUpdatePublisher
     */
    public function __construct(
        ContactRepositoryInterface $contactRepository,
        Logger $logger,
        ContactRequestBuilder $contactRequestBuilder,
        CreateUpdatePublisher $createUpdatePublisher
    ) {
        $this->contactRepository = $contactRepository;
        $this->logger = $logger;
        $this->contactRequestBuilder = $contactRequestBuilder;
        $this->createUpdatePublisher = $createUpdatePublisher;
    }

    /**
     * @param Customer $customer
     */
    public function execute(Customer $customer): void
    {
        try {
            $contact = $this->contactRepository->getOrCreateByCustomer($customer);
        } catch (CouldNotSaveException $e) {
            $this->logger->critical($e);
            return;
        }

        $message = CreateUpdateMessage::build(
            (int)$contact->getId(),
            $this->contactRequestBuilder->build($customer)
        );

        $this->createUpdatePublisher->publish($message);
    }
}