Tworzenieweb\SqlProvisioner\Processor\CandidateProcessor

Complexity

Total Complexity

11

Size/Duplication

Total Lines	94
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	1

Importance

Changes	3
Bugs	1	Features	1

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	addCheck()	0	4	1
A	addPostCheck()	0	4	1
A	isValid()	0	14	3
A	postValidate()	0	8	3
A	getLastError()	0	4	1
A	getLastErrorMessage()	0	4	1

<?php

namespace Tworzenieweb\SqlProvisioner\Processor;

use RuntimeException;
use Tworzenieweb\SqlProvisioner\Check\CheckInterface;
use Tworzenieweb\SqlProvisioner\Model\Candidate;

/**
 * @author Luke Adamczewski
 * @package Tworzenieweb\SqlProvisioner\Processor
 */
class CandidateProcessor
{
    const FATAL_POST_CHECK_ERROR = 'Your candidate query has failed. There was no entry in target changelog table added. Try adding query manually for more error.';
    /** @var CheckInterface[] */
    private $checks;

    /** @var string */
    private $lastError;

    /** @var string */
    private $lastErrorMessage;

    /** @var CheckInterface[] */
    private $postChecks;



    /**
     * CandidateProcessor constructor
     */
    public function __construct()
    {
        $this->postChecks = [];
        $this->checks = [];
    }



    /**
     * @param CheckInterface $check
     */
    public function addCheck(CheckInterface $check)
    {
        array_push($this->checks, $check);
    }



    public function addPostCheck(CheckInterface $check)
    {
        array_push($this->postChecks, $check);
    }

    /**
     * @param Candidate $candidate
     * @return bool
     */
    public function isValid(Candidate $candidate)
    {
        $this->lastError = null;
        foreach ($this->checks as $check) {
            if ($check->execute($candidate)) {
                $this->lastError = $check->getErrorCode();
                $this->lastErrorMessage = $check->getLastErrorMessage();

                return false;
            }
        }

        return true;
    }



    /**
     * @param Candidate $candidate
     */
    public function postValidate(Candidate $candidate)
    {
        foreach ($this->postChecks as $check) {
            if (!$check->execute($candidate)) {
                throw new RuntimeException(sprintf(self::FATAL_POST_CHECK_ERROR));
            }
        }
    }

    /**
     * @return string
     */
    public function getLastError()
    {
        return $this->lastError;
    }



    /**
     * @return string
     */
    public function getLastErrorMessage()
    {
        return $this->lastErrorMessage;
    }
}