CommerceLeague\ActiveCampaign\Controller\Webhook\Contact\Unsubscribe

Complexity

Total Complexity

6

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	1
A	execute()	0	25	5

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

namespace CommerceLeague\ActiveCampaign\Controller\Webhook\Contact;

use CommerceLeague\ActiveCampaign\Controller\AbstractWebhook;
use CommerceLeague\ActiveCampaign\Helper\Config as ConfigHelper;
use CommerceLeague\ActiveCampaign\Logger\Logger;
use Magento\Framework\App\Action\Context;
use Magento\Framework\Controller\Result\RawFactory as RawResultFactory;

The type Magento\Framework\Controller\Result\RawFactory was not found. Maybe you did not declare it correctly or list all dependencies?

use Magento\Framework\Exception\LocalizedException;
use Magento\Newsletter\Model\SubscriberFactory;

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

use Magento\Newsletter\Model\Subscriber;

/**
 * Class Unsubscribe
 */
class Unsubscribe extends AbstractWebhook
{
    /**
     * @var SubscriberFactory
     */
    private $subscriberFactory;

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

    /**
     * @param Context $context
     * @param ConfigHelper $configHelper
     * @param RawResultFactory $rawResultFactory
     * @param SubscriberFactory $subscriberFactory
     * @param Logger $logger
     */
    public function __construct(
        Context $context,
        ConfigHelper $configHelper,
        RawResultFactory $rawResultFactory,
        SubscriberFactory $subscriberFactory,
        Logger $logger
    ) {
        parent::__construct($context, $configHelper, $rawResultFactory);
        $this->subscriberFactory = $subscriberFactory;
        $this->logger = $logger;
    }

    /**
     * @inheritDoc
     */
    public function execute()
    {
        $params = $this->getRequest()->getParams();

        if (!isset($params['contact']) || !(isset($params['contact']['email']))) {
            $this->logger->error(__('Invalid webhook params received'));
            return;
        }

        $email = $params['contact']['email'];

        /** @var Subscriber $subscriber */
        $subscriber = $this->subscriberFactory->create();
        $subscriber->loadByEmail($email);

        if (!$subscriber->getId()) {
            $this->logger->error(__('Unable to find subscriber with email "%s"', $email));
            return;
        }

        try {
            $subscriber->unsubscribe();
        } catch (LocalizedException $e) {
            $this->logger->error($e->getMessage());
            return;
        }
    }
}