OutboxCleanerFeatureStartupTask::start() - Code Metrics - phpservicebus/persistence-doctrine2 - Measure and Improve Code Quality continuously with Scrutinizer

OutboxCleanerFeatureStartupTask::start() A
last analyzed 2020-01-22 18:29 UTC

↳ Parent: OutboxCleanerFeatureStartupTask

Complexity

Conditions	3
Paths	3

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	9
CRAP Score	3

Importance

Changes

Metric	Value
dl	0
loc	14
ccs	9
cts	9
cp	1
rs	9.7998
c	0
b	0
f	0
cc	3
nc	3
nop	1
crap	3

<?php
namespace PSB\Persistence\Doctrine2\Outbox;


use PSB\Core\BusContextInterface;
use PSB\Core\Exception\UnexpectedValueException;
use PSB\Core\Feature\FeatureStartupTaskInterface;

class OutboxCleanerFeatureStartupTask implements FeatureStartupTaskInterface
{
    /**
     * @var OutboxPersister
     */
    private $outboxPersister;

    /**
     * @var \DateTime
     */
    private $now;

    /**
     * @var int|null
     */
    private $daysToKeepDeduplicationData;

    /**
     * @param OutboxPersister $outboxPersister
     * @param \DateTime       $now
     * @param int|null        $daysToKeepDeduplicationData
     */
    public function __construct(OutboxPersister $outboxPersister, \DateTime $now, $daysToKeepDeduplicationData = null)
    {
        $this->outboxPersister = $outboxPersister;
        $this->now = $now;
        $this->daysToKeepDeduplicationData = $daysToKeepDeduplicationData;
    }

    /**
     * @param BusContextInterface $busContext
     *
     * @throws UnexpectedValueException
     */
    public function start(BusContextInterface $busContext)
    {
        if ($this->daysToKeepDeduplicationData === null) {
            $this->daysToKeepDeduplicationData = 7;
        } elseif (!ctype_digit((string)$this->daysToKeepDeduplicationData)) {
            throw new UnexpectedValueException(
                "Invalid value value used for days to keep deduplication data. Please ensure it is a positive integer."
            );
        }

        $this->outboxPersister->removeEntriesOlderThan(
            $this->now->sub(new \DateInterval("P{$this->daysToKeepDeduplicationData}D"))
        );
    }
}


1		<?php
2		namespace PSB\Persistence\Doctrine2\Outbox;
3
4
5		use PSB\Core\BusContextInterface;
6		use PSB\Core\Exception\UnexpectedValueException;
7		use PSB\Core\Feature\FeatureStartupTaskInterface;
8
9		class OutboxCleanerFeatureStartupTask implements FeatureStartupTaskInterface
10		{
11		/**
12		* @var OutboxPersister
13		*/
14		private $outboxPersister;
15
16		/**
17		* @var \DateTime
18		*/
19		private $now;
20
21		/**
22		* @var int\|null
23		*/
24		private $daysToKeepDeduplicationData;
25
26		/**
27		* @param OutboxPersister $outboxPersister
28		* @param \DateTime $now
29		* @param int\|null $daysToKeepDeduplicationData
30		*/
31	4	public function __construct(OutboxPersister $outboxPersister, \DateTime $now, $daysToKeepDeduplicationData = null)
32		{
33	4	$this->outboxPersister = $outboxPersister;
34	4	$this->now = $now;
35	4	$this->daysToKeepDeduplicationData = $daysToKeepDeduplicationData;
36	4	}
37
38		/**
39		* @param BusContextInterface $busContext
40		*
41		* @throws UnexpectedValueException
42		*/
43	3	public function start(BusContextInterface $busContext)
44		{
45	3	if ($this->daysToKeepDeduplicationData === null) {
46	1	$this->daysToKeepDeduplicationData = 7;
47	2	} elseif (!ctype_digit((string)$this->daysToKeepDeduplicationData)) {
48	1	throw new UnexpectedValueException(
49	1	"Invalid value value used for days to keep deduplication data. Please ensure it is a positive integer."
50		);
51		}
52
53	2	$this->outboxPersister->removeEntriesOlderThan(
54	2	$this->now->sub(new \DateInterval("P{$this->daysToKeepDeduplicationData}D"))
55		);
56	2	}
57		}
58

phpservicebus / persistence-doctrine2

OutboxCleanerFeatureStartupTask::start() A last analyzed 2020-01-22 18:29 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

OutboxCleanerFeatureStartupTask::start() A
last analyzed 2020-01-22 18:29 UTC