OrderedDoctrineEventsRecorder::onFlush() - Code Metrics - Inspection of "Ordered events" - dsantang/domain-events-doctrine - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#4)

by Davide

created 2019-02-15 15:25 UTC

OrderedDoctrineEventsRecorder::onFlush() A

↳ Parent: OrderedDoctrineEventsRecorder

Complexity

Conditions	2
Paths	2

Size

Total Lines	15
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	9
CRAP Score	2

Importance

Changes

Metric	Value
cc	2
eloc	8
nc	2
nop	1
dl	0
loc	15
ccs	9
cts	9
cp	1
crap	2
rs	10
c	0
b	0
f	0

<?php

declare(strict_types=1);

namespace Dsantang\DomainEventsDoctrine\EventsRecorder;

use Doctrine\ORM\Event\OnFlushEventArgs;
use Doctrine\ORM\UnitOfWork;
use Dsantang\DomainEvents\Counter;
use Dsantang\DomainEvents\EventAware;
use Dsantang\DomainEventsDoctrine\Aggregator;
use function array_filter;
use function array_merge;
use function ksort;

final class OrderedDoctrineEventsRecorder
{
    /** @var Aggregator */
    private $eventsAggregator;

    public function __construct(Aggregator $eventAggregator)
    {
        $this->eventsAggregator = $eventAggregator;
    }

    public function onFlush(OnFlushEventArgs $eventArgs) : void
    {
        $unitOfWork = $eventArgs->getEntityManager()
                                ->getUnitOfWork();

        $events = [];

        foreach (self::getEventAwareEntities($unitOfWork) as $entity) {
            $events += $entity->expelRecordedEvents();
        }

        ksort($events);

        Counter::reset();
        $this->eventsAggregator->aggregate(...$events);
    }

    /**
     * @return EventAware[]
     */
    private static function getEventAwareEntities(UnitOfWork $unitOfWork) : array
    {
        $entities = array_merge(
            $unitOfWork->getScheduledEntityInsertions(),
            $unitOfWork->getScheduledEntityUpdates(),
            $unitOfWork->getScheduledEntityDeletions()
        );

        return array_filter($entities, static function ($entity) {
            return $entity instanceof EventAware;
        });
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace Dsantang\DomainEventsDoctrine\EventsRecorder;
6
7		use Doctrine\ORM\Event\OnFlushEventArgs;
8		use Doctrine\ORM\UnitOfWork;
9		use Dsantang\DomainEvents\Counter;
10		use Dsantang\DomainEvents\EventAware;
11		use Dsantang\DomainEventsDoctrine\Aggregator;
12		use function array_filter;
13		use function array_merge;
14		use function ksort;
15
16		final class OrderedDoctrineEventsRecorder
17		{
18		/** @var Aggregator */
19		private $eventsAggregator;
20
21	2	public function __construct(Aggregator $eventAggregator)
22		{
23	2	$this->eventsAggregator = $eventAggregator;
24	2	}
25
26	2	public function onFlush(OnFlushEventArgs $eventArgs) : void
27		{
28	2	$unitOfWork = $eventArgs->getEntityManager()
29	2	->getUnitOfWork();
30
31	2	$events = [];
32
33	2	foreach (self::getEventAwareEntities($unitOfWork) as $entity) {
34	1	$events += $entity->expelRecordedEvents();
35		}
36
37	2	ksort($events);
38
39	2	Counter::reset();
40	2	$this->eventsAggregator->aggregate(...$events);
41	2	}
42
43		/**
44		* @return EventAware[]
45		*/
46	2	private static function getEventAwareEntities(UnitOfWork $unitOfWork) : array
47		{
48	2	$entities = array_merge(
49	2	$unitOfWork->getScheduledEntityInsertions(),
50	2	$unitOfWork->getScheduledEntityUpdates(),
51	2	$unitOfWork->getScheduledEntityDeletions()
52		);
53
54		return array_filter($entities, static function ($entity) {
55	2	return $entity instanceof EventAware;
56	2	});
57		}
58		}
59

dsantang / domain-events-doctrine

GitHub Access Token became invalid

Pull Request — master (#4)

OrderedDoctrineEventsRecorder::onFlush() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like