CommerceLeague\ActiveCampaign\Test\Unit\MessageQueue\Newsletter\ExportContactConsumerTest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	200
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	26	1
A	testConsumeApiRequestException()	0	46	1
A	testConsumeWithAbsentSubscriber()	0	21	1
A	testConsume()	0	52	1

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

namespace CommerceLeague\ActiveCampaign\Test\Unit\MessageQueue\Newsletter;

use CommerceLeague\ActiveCampaign\Api\ContactRepositoryInterface;
use CommerceLeague\ActiveCampaign\Api\Data\ContactInterface;
use CommerceLeague\ActiveCampaign\Gateway\Client;
use CommerceLeague\ActiveCampaign\Gateway\Request\ContactBuilder as ContactRequestBuilder;
use CommerceLeague\ActiveCampaign\Logger\Logger;
use CommerceLeague\ActiveCampaign\MessageQueue\Newsletter\ExportContactConsumer;
use CommerceLeague\ActiveCampaignApi\Api\ContactApiResourceInterface;
use CommerceLeague\ActiveCampaignApi\Exception\HttpException;
use Magento\Framework\Phrase;
use Magento\Newsletter\Model\Subscriber;
use PHPUnit\Framework\MockObject\MockObject;
use PHPUnit\Framework\TestCase;
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?

class ExportContactConsumerTest extends TestCase
{

    /**
     * @var MockObject|SubscriberFactory
     */
    protected $subscriberFactory;

    /**
     * @var MockObject|Subscriber
     */
    protected $subscriber;

    /**
     * @var MockObject|Logger
     */
    protected $logger;

    /**
     * @var MockObject|ContactRepositoryInterface
     */
    protected $contactRepository;

    /**
     * @var MockObject|ContactRequestBuilder
     */
    protected $contactRequestBuilder;

    /**
     * @var MockObject|Client
     */
    protected $client;

    /**
     * @var MockObject|ContactInterface
     */
    protected $contact;

    /**
     * @var MockObject|ContactApiResourceInterface
     */
    protected $contactApi;

    /**
     * @var ExportContactConsumer
     */
    protected $exportContactConsumer;

    protected function setUp()
    {
        $this->subscriberFactory = $this->getMockBuilder(SubscriberFactory::class)
            ->disableOriginalConstructor()
            ->setMethods(['create'])
            ->getMock();

        $this->subscriber = $this->createMock(Subscriber::class);

        $this->subscriberFactory->expects($this->any())
            ->method('create')
            ->willReturn($this->subscriber);

        $this->logger = $this->createMock(Logger::class);
        $this->contactRepository = $this->createMock(ContactRepositoryInterface::class);
        $this->contactRequestBuilder = $this->createMock(ContactRequestBuilder::class);
        $this->client = $this->createMock(Client::class);
        $this->contact = $this->createMock(ContactInterface::class);
        $this->contactApi = $this->createMock(ContactApiResourceInterface::class);

        $this->exportContactConsumer = new ExportContactConsumer(
            $this->subscriberFactory,
            $this->logger,
            $this->contactRepository,
            $this->contactRequestBuilder,
            $this->client
        );
    }

    public function testConsumeWithAbsentSubscriber()
    {
        $email = 'example@example.com';

        $this->subscriber->expects($this->once())
            ->method('loadByEmail')

The method method() does not exist on PHPUnit\Framework\MockObject\MockObject.

            ->with($email)

The method with() does not exist on PHPUnit\Framework\MockObject\MockObject.

            ->willReturnSelf();

The method willReturnSelf() does not exist on PHPUnit\Framework\MockObject\MockObject.

        $this->subscriber->expects($this->once())
            ->method('getId')
            ->willReturn(null);

The method willReturn() does not exist on PHPUnit\Framework\MockObject\MockObject.

        $this->logger->expects($this->once())

The method expects() does not exist on CommerceLeague\ActiveCampaign\Logger\Logger.

            ->method('error')
            ->with(new Phrase('The Subscriber with the "%1" email doesn\'t exist', [$email]));

        $this->contactRepository->expects($this->never())

The method expects() does not exist on CommerceLeague\ActiveCampaign\Api\ContactRepositoryInterface.

            ->method('getOrCreateByEmail');

        $this->exportContactConsumer->consume(json_encode(['email' => $email]));
    }

    public function testConsumeApiRequestException()
    {
        $email = 'example@example.com';
        $request = ['request'];

        $this->subscriber->expects($this->once())
            ->method('loadByEmail')
            ->with($email)
            ->willReturnSelf();

        $this->subscriber->expects($this->once())
            ->method('getId')
            ->willReturn(123);

        $this->subscriber->expects($this->once())
            ->method('getEmail')
            ->willReturn($email);

        $this->contactRepository->expects($this->once())
            ->method('getOrCreateByEmail')
            ->with($email)
            ->willReturn($this->contact);

        $this->contactRequestBuilder->expects($this->once())

The method expects() does not exist on CommerceLeague\ActiveCampaign\Gateway\Request\ContactBuilder.

            ->method('buildWithSubscriber')
            ->willReturn($request);

        $this->client->expects($this->once())

The method expects() does not exist on CommerceLeague\ActiveCampaign\Gateway\Client.

            ->method('getContactApi')
            ->willReturn($this->contactApi);

        /** @var MockObject|HttpException $httpException */
        $httpException = $this->createMock(HttpException::class);

        $this->contactApi->expects($this->once())

The method expects() does not exist on CommerceLeague\ActiveCampaignApi\Api\ContactApiResourceInterface.

            ->method('upsert')
            ->with(['contact' => $request])
            ->willThrowException($httpException);

        $this->logger->expects($this->once())
            ->method('error');

        $this->contact->expects($this->never())

The method expects() does not exist on CommerceLeague\ActiveCampaign\Api\Data\ContactInterface. Since it exists in all sub-types, consider adding an abstract or default implementation to CommerceLeague\ActiveCampaign\Api\Data\ContactInterface.

            ->method('setActiveCampaignId');

        $this->exportContactConsumer->consume(json_encode(['email' => $email]));
    }

    public function testConsume()
    {
        $email = 'example@example.com';
        $request = ['request'];
        $activeCampaignId = 456;
        $response = ['contact' => ['id' => $activeCampaignId]];

        $this->subscriber->expects($this->once())
            ->method('loadByEmail')
            ->with($email)
            ->willReturnSelf();

        $this->subscriber->expects($this->once())
            ->method('getId')
            ->willReturn(123);

        $this->subscriber->expects($this->once())
            ->method('getEmail')
            ->willReturn($email);

        $this->contactRepository->expects($this->once())
            ->method('getOrCreateByEmail')
            ->with($email)
            ->willReturn($this->contact);

        $this->contactRequestBuilder->expects($this->once())
            ->method('buildWithSubscriber')
            ->willReturn($request);

        $this->client->expects($this->once())
            ->method('getContactApi')
            ->willReturn($this->contactApi);


        $this->contactApi->expects($this->once())
            ->method('upsert')
            ->with(['contact' => $request])
            ->willReturn($response);

        $this->contact->expects($this->once())
            ->method('setActiveCampaignId')
            ->with($activeCampaignId)
            ->willReturnSelf();

        $this->contactRepository->expects($this->once())
            ->method('save')
            ->with($this->contact);

        $this->logger->expects($this->never())
            ->method('error');

        $this->exportContactConsumer->consume(json_encode(['email' => $email]));
    }
}