Oliverde8\PhpEtlBundle\Etl\Operation\Cleanup\FindOldExecutionsOperation

Complexity

Total Complexity

3

Size/Duplication

Total Lines	29
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	processStop()	0	10	2

<?php

namespace Oliverde8\PhpEtlBundle\Etl\Operation\Cleanup;

use Oliverde8\Component\PhpEtl\ChainOperation\AbstractChainOperation;
use Oliverde8\Component\PhpEtl\Item\GroupedItem;
use Oliverde8\Component\PhpEtl\Item\ItemInterface;
use Oliverde8\PhpEtlBundle\Repository\EtlExecutionRepository;

class FindOldExecutionsOperation extends AbstractChainOperation
{
    protected EtlExecutionRepository $etlExecutionRepository;

    protected \DateTime $minKeep;

    protected $endProcess = false;

    /**
     * FindOldExecutions constructor.
     * @param EtlExecutionRepository $etlExecutionRepository
     * @param string $minKeep
     */
    public function __construct(EtlExecutionRepository $etlExecutionRepository, \DateTime $minKeep)
    {
        $this->etlExecutionRepository = $etlExecutionRepository;
        $this->minKeep = $minKeep;
    }

    protected function processStop(ItemInterface $item, array &$context)

The parameter $context is not used and could be removed.

    {
        if ($this->endProcess) {
            return $item;
        }

        $this->endProcess = true;
        $iterator = $this->etlExecutionRepository->getOldExecutions($this->minKeep);

        return new GroupedItem($iterator);
    }
}