NeedleProject\Transaction\Executor

Complexity

Total Complexity

7

Size/Duplication

Total Lines	53
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	addProcess()	0	4	1
A	execute()	0	8	2
A	rollBack()	0	14	3

<?php
namespace NeedleProject\Transaction;

/**
 * Class Executor
 *
 * @package NeedleProject\Transaction
 * @author  Adrian Tilita <adrian@tilita.ro>
 */
class Executor
{
    /**
     * @var \ArrayIterator|null
     */
    private $processList = null;

    /**
     * Executor constructor.
     */
    public function __construct()
    {
        $this->processList = new \ArrayIterator();
    }

    /**
     * @param ProcessInterface $process
     */
    public function addProcess(ProcessInterface $process)
    {
        $this->processList->append($process);
    }

    /**
     * Execute a set of processes
     */
    public function execute()
    {
        $this->processList->rewind();
        while ($this->processList->valid()) {
            $this->processList->current()->execute();
            $this->processList->next();
        }
    }

    /**
     * Rollback in reverse order
     */
    public function rollBack()
    {
        $maxOffset = $this->processList->count() - 1;

        for ($i = $maxOffset; $i >= 0; $i--) {
            /** @var ProcessInterface $currentProcess */
            $currentProcess = $this->processList->offsetGet($i);
            // Exclude rolling back processes that has not been executed
            if ($currentProcess->hasExecuted() === false) {

The method hasExecuted() does not exist on NeedleProject\Transaction\ProcessInterface. Did you maybe mean execute()?

                continue;
            }
            $currentProcess->rollBack();
        }
    }
}