Repository::get() - Code Metrics - Inspection of "Moving save handling to Middleware and fixing test..." - C4Tech/laravel-ray-emitter - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 97a348...a4dab2 )

by Christopher

created 2016-01-25 22:21 UTC

Repository::get() A

↳ Parent: Repository

Complexity

Conditions	1
Paths	1

Size

Total Lines	6
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	1

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	6
ccs	3
cts	3
cp	1
rs	9.4285
cc	1
eloc	3
nc	1
nop	1
crap	1

<?php namespace C4tech\RayEmitter\Domain;

use C4tech\RayEmitter\Contracts\Domain\Aggregate as AggregateInterface;
use C4tech\RayEmitter\Contracts\Domain\Command as CommandInterface;
use C4tech\RayEmitter\Contracts\Domain\Repository as RepositoryInterface;
use C4tech\RayEmitter\Facades\EventStore;
use C4tech\RayEmitter\Exceptions\OutdatedSequence;
use C4tech\RayEmitter\Exceptions\SequenceMismatch;

abstract class Repository implements RepositoryInterface
{
    /**
     * @inheritDoc
     */
    public static function get($identifier)
    {
        $aggregate = static::find($identifier);

        return $aggregate->getEntity();
    }

    /**
     * @inheritDoc
     */
    public static function handle(CommandInterface $command)
    {
        $aggregate = static::find($command->getAggregateId());

        // Optimistic concurrency handling
        $expected = $command->getExpectedSequence();
        $current = $aggregate->getSequence();
        if ($expected < $current) {
            throw new OutdatedSequence(
                sprintf(
                    'The Aggregate %s has newer data than expected.',
                    get_class($aggregate)
                ),
                409
            );
        } elseif ($expected > $current) {
            throw new SequenceMismatch(
                sprintf(
                    'The Aggregate %s is expected to have more data than it does',
                    get_class($aggregate)
                ),
                422
            );
        }

        if ($event = $aggregate->handle($command)) {
            $aggregate->apply($event);
            EventStore::enqueue($event);
        }
    }

    /**
     * Create
     *
     * Generate a new Aggregate with no history.
     * @return Aggregate
     */
    abstract protected static function create();

    /**
     * Find
     *
     * Restore an existing Aggregate from the recorded events related to it.
     * @param  void|string $identifier Aggregate root entity identifier.
     * @return Aggregate
     */
    protected static function find($identifier = null)
    {
        $aggregate = static::create();

        if ($identifier) {
''   == false // true
''   == null  // true
'ab' == false // false
'ab' == null  // false

// It is often better to use strict comparison
'' === false // false
'' === null  // false
            $events = EventStore::getFor($identifier);
            $aggregate->hydrate($events);
        }

        return $aggregate;
    }
}


1		<?php namespace C4tech\RayEmitter\Domain;
2
3		use C4tech\RayEmitter\Contracts\Domain\Aggregate as AggregateInterface;
4		use C4tech\RayEmitter\Contracts\Domain\Command as CommandInterface;
5		use C4tech\RayEmitter\Contracts\Domain\Repository as RepositoryInterface;
6		use C4tech\RayEmitter\Facades\EventStore;
7		use C4tech\RayEmitter\Exceptions\OutdatedSequence;
8		use C4tech\RayEmitter\Exceptions\SequenceMismatch;
9
10		abstract class Repository implements RepositoryInterface
11		{
12		/**
13		* @inheritDoc
14		*/
15	1	public static function get($identifier)
16		{
17	1	$aggregate = static::find($identifier);
18
19	1	return $aggregate->getEntity();
20		}
21
22		/**
23		* @inheritDoc
24		*/
25	4	public static function handle(CommandInterface $command)
26		{
27	4	$aggregate = static::find($command->getAggregateId());
28
29		// Optimistic concurrency handling
30	4	$expected = $command->getExpectedSequence();
31	4	$current = $aggregate->getSequence();
32	4	if ($expected < $current) {
33	1	throw new OutdatedSequence(
34	1	sprintf(
35	1	'The Aggregate %s has newer data than expected.',
36	1	get_class($aggregate)
37	1	),
38		409
39	1	);
40	3	} elseif ($expected > $current) {
41	1	throw new SequenceMismatch(
42	1	sprintf(
43	1	'The Aggregate %s is expected to have more data than it does',
44	1	get_class($aggregate)
45	1	),
46		422
47	1	);
48		}
49
50	2	if ($event = $aggregate->handle($command)) {
51	1	$aggregate->apply($event);
52	1	EventStore::enqueue($event);
53	1	}
54	2	}
55
56		/**
57		* Create
58		*
59		* Generate a new Aggregate with no history.
60		* @return Aggregate
61		*/
62		abstract protected static function create();
63
64		/**
65		* Find
66		*
67		* Restore an existing Aggregate from the recorded events related to it.
68		* @param void\|string $identifier Aggregate root entity identifier.
69		* @return Aggregate
70		*/
71	6	protected static function find($identifier = null)
72		{
73	6	$aggregate = static::create();
74
75	6	if ($identifier) {
		0 ignored issues – show Bug Best Practice introduced 2016-01-25 22:26 UTC by Report Bug Copy Issue Report The expression `$identifier` of type `null\|string` is loosely compared to `true`; this is ambiguous if the string can be empty. You might want to explicitly use `!== null` instead. In PHP, under loose comparison (like `==`, or `!=`, or `switch` conditions), values of different types might be equal. For `string` values, the empty string `''` is a special case, in particular the following results might be unexpected: '' == false // true '' == null // true 'ab' == false // false 'ab' == null // false // It is often better to use strict comparison '' === false // false '' === null // false Loading history...
76	5	$events = EventStore::getFor($identifier);
77	5	$aggregate->hydrate($events);
78	5	}
79
80	6	return $aggregate;
81		}
82		}
83

C4Tech / laravel-ray-emitter

Push — master ( 97a348...a4dab2 )

Repository::get() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like