SagaRepository::isEventAlreadyDispatched() - Code Metrics - Inspection of "some relaxing on the SagaPersistence" - xprt64/cqrs-es - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 6b9dac...24d110 )

by Constantin

created 2017-04-07 11:40 UTC

SagaRepository::isEventAlreadyDispatched() B

↳ Parent: SagaRepository

Complexity

Conditions	6
Paths	8

Size

Total Lines	13
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	7
CRAP Score	6

Importance

Changes

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

<?php
/**
 * Copyright (c) 2017 Constantin Galbenu <[email protected]>
 */

namespace Gica\Cqrs\Saga;


class SagaRepository
{

    /**
     * @var SagaPersistence
     */
    private $sagaPersistence;

    public function __construct(
        SagaPersistence $sagaPersistence
    )
    {
        $this->sagaPersistence = $sagaPersistence;
    }

    public function isEventAlreadyDispatched(string $sagaId, int $sequence, int $index): bool
    {
        $data = $this->sagaPersistence->loadData($sagaId);

        $lastSequence = $data ? $data['sequence'] : -10000;
        $lastIndex = $data ? $data['index'] : -1000;

        if ($sequence > $lastSequence || ($sequence == $lastSequence && $index > $lastIndex)) {
            return false;
        }

        return true;
    }

    public function persistLastProcessedEventBySaga(string $sagaId, int $sequence, int $index)
    {
        $this->sagaPersistence->saveData($sagaId, [
            'sequence' => $sequence,
            'index'    => $index,
        ]);
    }

    public function getLastPersistedEventSequenceAndIndex(string $sagaId)
    {
        $data = $this->sagaPersistence->loadData($sagaId);

        return $data ? [$data['sequence'], $data['index']] : [];
    }
}

1		<?php
2		/**
3		* Copyright (c) 2017 Constantin Galbenu <[email protected]>
4		*/
5
6		namespace Gica\Cqrs\Saga;
7
8
9		class SagaRepository
10		{
11
12		/**
13		* @var SagaPersistence
14		*/
15		private $sagaPersistence;
16
17	5	public function __construct(
18		SagaPersistence $sagaPersistence
19		)
20		{
21	5	$this->sagaPersistence = $sagaPersistence;
22	5	}
23
24	3	public function isEventAlreadyDispatched(string $sagaId, int $sequence, int $index): bool
25		{
26	3	$data = $this->sagaPersistence->loadData($sagaId);
27
28	3	$lastSequence = $data ? $data['sequence'] : -10000;
29	3	$lastIndex = $data ? $data['index'] : -1000;
30
31	3	if ($sequence > $lastSequence \|\| ($sequence == $lastSequence && $index > $lastIndex)) {
32	2	return false;
33		}
34
35	1	return true;
36		}
37
38	1	public function persistLastProcessedEventBySaga(string $sagaId, int $sequence, int $index)
39		{
40	1	$this->sagaPersistence->saveData($sagaId, [
41	1	'sequence' => $sequence,
42	1	'index' => $index,
43		]);
44	1	}
45
46	1	public function getLastPersistedEventSequenceAndIndex(string $sagaId)
47		{
48	1	$data = $this->sagaPersistence->loadData($sagaId);
49
50	1	return $data ? [$data['sequence'], $data['index']] : [];
51		}
52		}

xprt64 / cqrs-es

Push — master ( 6b9dac...24d110 )

SagaRepository::isEventAlreadyDispatched() B

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like