PSB\Persistence\Doctrine2\Outbox\OutboxCleanerFeatureStartupTask

Complexity

Total Complexity

4

Size/Duplication

Total Lines	49
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	start()	0	14	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"))
        );
    }
}