StubMapBasedTest.php$0 ➔ trigger() - Code Metrics - Inspection of "Outbox workflow based on doctrine events" - dsantang/domain-events-doctrine - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#7)

by Fábio Tadeu da

created 2019-04-10 12:26 UTC

StubMapBasedTest.php$0 ➔ trigger() A

↳ Parent: anonymous//tests/Unit/Outbox/StubMapBasedTest.php$0

Complexity

Conditions

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	3
rs	10
c	0
b	0
f	0
cc	1

<?php

declare(strict_types=1);

namespace Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox;

use Doctrine\ORM\EntityManagerInterface;
use Doctrine\ORM\Event\OnFlushEventArgs;
use Doctrine\ORM\UnitOfWork;
use Dsantang\DomainEvents\Counter;
use Dsantang\DomainEvents\DomainEvent;
use Dsantang\DomainEvents\EventAware;
use Dsantang\DomainEvents\Registry\OrderedEventRegistry;
use Dsantang\DomainEventsDoctrine\Outbox\Converter;
use Dsantang\DomainEventsDoctrine\Tests\OutboxSubClass;
use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\Converters\FirstOutboxConverter;
use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\Converters\SecondOutboxConverter;
use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\Converters\ThirdOutboxConverter;
use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\DomainEvents\FirstDomainEvent;
use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\DomainEvents\SecondDomainEvent;
use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\DomainEvents\ThirdDomainEvent;
use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\OutboxEntries\FirstOutboxEntry;
use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\OutboxEntries\SecondOutboxEntry;
use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\OutboxEntries\ThirdOutboxEntry;
use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\StubMapBased;
use PHPUnit\Framework\MockObject\MockObject;
use PHPUnit\Framework\TestCase;
use function array_values;

final class StubMapBasedTest extends TestCase
{
    /** @var Converter[] */
    private $conversionMap;

    /** @var MockObject entityManager */
    private $entityManager;

    /** @var MockObject unitOfWork */
    private $unitOfWork;

    /**
     * @before
     */
    public function setUpDependencies() : void
    {
        $map = [
            'Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\DomainEvents\FirstDomainEvent'  =>
                new FirstOutboxConverter(),

            'Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\DomainEvents\SecondDomainEvent' =>
                new SecondOutboxConverter(),

            'Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\DomainEvents\ThirdDomainEvent'  =>
                new ThirdOutboxConverter(),
        ];

        $this->conversionMap = $map;

        $this->entityManager = $this->createMock(EntityManagerInterface::class);
        $this->unitOfWork    = $this->createMock(UnitOfWork::class);
    }

    public function testGetDomainsEvents() : void
    {
        Counter::reset();

        $eventArgs = $this->getEventArgs();

        self::assertEquals(3, Counter::getNext());

        $mapBasedEventsHandler = new StubMapBased(new OutboxSubClass(), $this->conversionMap);

        $eventsResult = $mapBasedEventsHandler->getDomainEvents($eventArgs);

        self::assertEquals(0, Counter::getNext());

        $eventsExpected = [new FirstDomainEvent(), new SecondDomainEvent(), new ThirdDomainEvent()];

        self::assertEquals(array_values($eventsResult), array_values($eventsExpected));
    }

    public function testPersist() : void
    {
        $eventArgs      = $this->getEventArgs();
        $outboxSubClass = new OutboxSubClass();

        $mapBasedEventsHandler = new StubMapBased($outboxSubClass, $this->conversionMap);
        $mapBasedEventsHandler->getDomainEvents($eventArgs);

        $outboxEvents = [
            new ThirdOutboxEntry(new ThirdDomainEvent()),
            new FirstOutboxEntry(new FirstDomainEvent()),
            new SecondOutboxEntry(new SecondDomainEvent()),
        ];

        $this->unitOfWork->expects(self::once())
            ->method('computeChangeSets');

        $this->entityManager->expects(self::exactly(3))
            ->method('persist');

        $mapBasedEventsHandler->persist(
            $eventArgs->getEntityManager(),
            ...$outboxEvents
        );
    }

    public function testOnFlushWithDomainEvents() : void
    {
        $eventArgs = $this->getEventArgs();

        $mapBasedEventsHandler = new StubMapBased(new OutboxSubClass(), $this->conversionMap);

        $this->entityManager->expects(self::exactly(3))
            ->method('persist');

        $mapBasedEventsHandler->onFlush($eventArgs);
    }

    public function testOnFlushWithNoDomainEvents() : void
    {
        $eventArgs = $this->getEventArgs(false);

        $mapBasedEventsHandler = new StubMapBased(new OutboxSubClass(), $this->conversionMap);
        $mapBasedEventsHandler->onFlush($eventArgs);

        $this->entityManager->expects(self::never())
            ->method('persist');
    }

    /**
     * @return OnFlushEventArgs|MockObject
     */
    private function getEventArgs(bool $withEvents = true) : OnFlushEventArgs
    {
        $insertions = $updates = $deletions = [];

        if ($withEvents) {
            $entity1 = new class() implements EventAware {
                use OrderedEventRegistry;

                public function trigger(DomainEvent $event) : void
                {
                    $this->triggeredA($event);
                }
            };

            $entity2 = new class() implements EventAware {
                use OrderedEventRegistry;

                public function trigger(DomainEvent $event) : void
                {
                    $this->triggeredA($event);
                }
            };

            $entity3 = new class() implements EventAware {
                use OrderedEventRegistry;

                public function trigger(DomainEvent $event) : void
                {
                    $this->triggeredA($event);
                }
            };

            $domainEvent1 = new FirstDomainEvent();
            $domainEvent2 = new SecondDomainEvent();
            $domainEvent3 = new ThirdDomainEvent();

            $entity1->trigger($domainEvent1);
            $entity2->trigger($domainEvent2);
            $entity3->trigger($domainEvent3);

            $updates   = [$entity3];
            $deletions = [$entity2, $entity1];
        }

        $this->unitOfWork->expects(self::once())->method('getScheduledEntityInsertions')->willReturn($insertions);
        $this->unitOfWork->expects(self::once())->method('getScheduledEntityUpdates')->willReturn($updates);
        $this->unitOfWork->expects(self::once())->method('getScheduledEntityDeletions')->willReturn($deletions);

        $this->entityManager->expects(self::any())->method('getUnitOfWork')->willReturn($this->unitOfWork);

        $eventArgs = $this->createMock(OnFlushEventArgs::class);
        $eventArgs->expects(self::any())->method('getEntityManager')->willReturn($this->entityManager);

        return $eventArgs;

    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox;
6
7			use Doctrine\ORM\EntityManagerInterface;
8			use Doctrine\ORM\Event\OnFlushEventArgs;
9			use Doctrine\ORM\UnitOfWork;
10			use Dsantang\DomainEvents\Counter;
11			use Dsantang\DomainEvents\DomainEvent;
12			use Dsantang\DomainEvents\EventAware;
13			use Dsantang\DomainEvents\Registry\OrderedEventRegistry;
14			use Dsantang\DomainEventsDoctrine\Outbox\Converter;
15			use Dsantang\DomainEventsDoctrine\Tests\OutboxSubClass;
16			use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\Converters\FirstOutboxConverter;
17			use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\Converters\SecondOutboxConverter;
18			use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\Converters\ThirdOutboxConverter;
19			use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\DomainEvents\FirstDomainEvent;
20			use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\DomainEvents\SecondDomainEvent;
21			use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\DomainEvents\ThirdDomainEvent;
22			use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\OutboxEntries\FirstOutboxEntry;
23			use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\OutboxEntries\SecondOutboxEntry;
24			use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\OutboxEntries\ThirdOutboxEntry;
25			use Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\StubMapBased;
26			use PHPUnit\Framework\MockObject\MockObject;
27			use PHPUnit\Framework\TestCase;
28			use function array_values;
29
30			final class StubMapBasedTest extends TestCase
31			{
32			/** @var Converter[] */
33			private $conversionMap;
34
35			/** @var MockObject entityManager */
36			private $entityManager;
37
38			/** @var MockObject unitOfWork */
39			private $unitOfWork;
40
41			/**
42			* @before
43			*/
44			public function setUpDependencies() : void
45			{
46			$map = [
47			'Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\DomainEvents\FirstDomainEvent' =>
48			new FirstOutboxConverter(),
49
50			'Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\DomainEvents\SecondDomainEvent' =>
51			new SecondOutboxConverter(),
52
53			'Dsantang\DomainEventsDoctrine\Tests\Unit\Outbox\Stub\DomainEvents\ThirdDomainEvent' =>
54			new ThirdOutboxConverter(),
55			];
56
57			$this->conversionMap = $map;
58
59			$this->entityManager = $this->createMock(EntityManagerInterface::class);
60			$this->unitOfWork = $this->createMock(UnitOfWork::class);
61			}
62
63			public function testGetDomainsEvents() : void
64			{
65			Counter::reset();
66
67			$eventArgs = $this->getEventArgs();
68
69			self::assertEquals(3, Counter::getNext());
70
71			$mapBasedEventsHandler = new StubMapBased(new OutboxSubClass(), $this->conversionMap);
72
73			$eventsResult = $mapBasedEventsHandler->getDomainEvents($eventArgs);
74
75			self::assertEquals(0, Counter::getNext());
76
77			$eventsExpected = [new FirstDomainEvent(), new SecondDomainEvent(), new ThirdDomainEvent()];
78
79			self::assertEquals(array_values($eventsResult), array_values($eventsExpected));
80			}
81
82			public function testPersist() : void
83			{
84			$eventArgs = $this->getEventArgs();
85			$outboxSubClass = new OutboxSubClass();
86
87			$mapBasedEventsHandler = new StubMapBased($outboxSubClass, $this->conversionMap);
88			$mapBasedEventsHandler->getDomainEvents($eventArgs);
89
90			$outboxEvents = [
91			new ThirdOutboxEntry(new ThirdDomainEvent()),
92			new FirstOutboxEntry(new FirstDomainEvent()),
93			new SecondOutboxEntry(new SecondDomainEvent()),
94			];
95
96			$this->unitOfWork->expects(self::once())
97			->method('computeChangeSets');
98
99			$this->entityManager->expects(self::exactly(3))
100			->method('persist');
101
102			$mapBasedEventsHandler->persist(
103			$eventArgs->getEntityManager(),
104			...$outboxEvents
105			);
106			}
107
108			public function testOnFlushWithDomainEvents() : void
109			{
110			$eventArgs = $this->getEventArgs();
111
112			$mapBasedEventsHandler = new StubMapBased(new OutboxSubClass(), $this->conversionMap);
113
114			$this->entityManager->expects(self::exactly(3))
115			->method('persist');
116
117			$mapBasedEventsHandler->onFlush($eventArgs);
118			}
119
120			public function testOnFlushWithNoDomainEvents() : void
121			{
122			$eventArgs = $this->getEventArgs(false);
123
124			$mapBasedEventsHandler = new StubMapBased(new OutboxSubClass(), $this->conversionMap);
125			$mapBasedEventsHandler->onFlush($eventArgs);
126
127			$this->entityManager->expects(self::never())
128			->method('persist');
129			}
130
131			/**
132			* @return OnFlushEventArgs\|MockObject
133			*/
134			private function getEventArgs(bool $withEvents = true) : OnFlushEventArgs
135			{
136			$insertions = $updates = $deletions = [];
137
138			if ($withEvents) {
139			$entity1 = new class() implements EventAware {
140			use OrderedEventRegistry;
141
142			public function trigger(DomainEvent $event) : void
143			{
144			$this->triggeredA($event);
145			}
146			};
147
148			$entity2 = new class() implements EventAware {
149			use OrderedEventRegistry;
150
151			public function trigger(DomainEvent $event) : void
152			{
153			$this->triggeredA($event);
154			}
155			};
156
157			$entity3 = new class() implements EventAware {
158			use OrderedEventRegistry;
159
160			public function trigger(DomainEvent $event) : void
161			{
162			$this->triggeredA($event);
163			}
164			};
165
166			$domainEvent1 = new FirstDomainEvent();
167			$domainEvent2 = new SecondDomainEvent();
168			$domainEvent3 = new ThirdDomainEvent();
169
170			$entity1->trigger($domainEvent1);
171			$entity2->trigger($domainEvent2);
172			$entity3->trigger($domainEvent3);
173
174			$updates = [$entity3];
175			$deletions = [$entity2, $entity1];
176			}
177
178			$this->unitOfWork->expects(self::once())->method('getScheduledEntityInsertions')->willReturn($insertions);
179			$this->unitOfWork->expects(self::once())->method('getScheduledEntityUpdates')->willReturn($updates);
180			$this->unitOfWork->expects(self::once())->method('getScheduledEntityDeletions')->willReturn($deletions);
181
182			$this->entityManager->expects(self::any())->method('getUnitOfWork')->willReturn($this->unitOfWork);
183
184			$eventArgs = $this->createMock(OnFlushEventArgs::class);
185			$eventArgs->expects(self::any())->method('getEntityManager')->willReturn($this->entityManager);
186
187			return $eventArgs;
			0 ignored issues – show Bug Best Practice introduced 2019-04-10 09:31 UTC by Report Bug Copy Issue Report The expression `return $eventArgs` returns the type `PHPUnit\Framework\MockObject\MockObject` which is incompatible with the type-hinted return `Doctrine\ORM\Event\OnFlushEventArgs`. Loading history...
188			}
189			}
190

dsantang / domain-events-doctrine

GitHub Access Token became invalid

Pull Request — master (#7)

StubMapBasedTest.php$0 ➔ trigger() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like