Paraunit\Process\AbstractParaunitProcess

Complexity

Total Complexity

15

Size/Duplication

Total Lines	132
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes

0

20 Methods

Rating	Name	Duplication	Size	Complexity
	start()	0	1	?
	getOutput()	0	1	?
	isTerminated()	0	1	?
	getCommandLine()	0	1	?
	getExitCode()	0	1	?
A	__construct()	0	8	1
A	getUniqueId()	0	4	1
A	getRetryCount()	0	4	1
A	increaseRetryCount()	0	4	1
A	markAsToBeRetried()	0	6	1
A	isToBeRetried()	0	4	1
A	reset()	0	5	1
A	getFilename()	0	4	1
A	getTestClassName()	0	4	1
A	setTestClassName()	0	4	1
A	getTestResults()	0	4	1
A	addTestResult()	0	5	1
A	hasAbnormalTermination()	0	4	1
A	isWaitingForTestResult()	0	4	1
A	setWaitingForTestResult()	0	4	1

<?php

declare(strict_types=1);

namespace Paraunit\Process;

use Paraunit\TestResult\Interfaces\PrintableTestResultInterface;
use Paraunit\TestResult\TestResultWithAbnormalTermination;

/**
 * Class AbstractParaunitProcess
 * @package Paraunit\Process
 */
abstract class AbstractParaunitProcess
{
    /** @var int */
    protected $retryCount = 0;

    /** @var bool */
    protected $shouldBeRetried;

    /** @var string */
    protected $uniqueId;

    /** @var string */
    protected $filename;

    /** @var string */
    protected $testClassName;

    /** @var PrintableTestResultInterface[] */
    protected $testResults;

    /** @var bool */
    private $waitingForTestResult;

    /**
     * {@inheritdoc}
     * @throws \InvalidArgumentException
     */
    public function __construct(string $filename)
    {
        $this->filename = $filename;
        $this->uniqueId = md5($this->filename);
        $this->testResults = [];
        $this->waitingForTestResult = true;
        $this->shouldBeRetried = false;
    }

    abstract public function getOutput(): string;

    abstract public function isTerminated(): bool;

    abstract public function getCommandLine(): string;

    /**
     * @return int|null
     */
    abstract public function getExitCode();

    /**
     * @param int $pipelineNumber
     */
    abstract public function start(int $pipelineNumber);

    public function getUniqueId(): string
    {
        return $this->uniqueId;
    }

    public function getRetryCount(): int
    {
        return $this->retryCount;
    }

    public function increaseRetryCount()
    {
        ++$this->retryCount;
    }

    public function markAsToBeRetried()
    {
        $this->reset();
        $this->increaseRetryCount();
        $this->shouldBeRetried = true;
    }

    public function isToBeRetried(): bool
    {
        return $this->shouldBeRetried;
    }

    public function reset()
    {
        $this->shouldBeRetried = false;
        $this->testResults = [];
    }

    public function getFilename(): string
    {
        return $this->filename;
    }

    /**
     * @return string|null
     */
    public function getTestClassName()
    {
        return $this->testClassName;
    }

    public function setTestClassName(string $testClassName)
    {
        $this->testClassName = $testClassName;
    }

    /**
     * @return PrintableTestResultInterface[]
     */
    public function getTestResults(): array
    {
        return $this->testResults;
    }

    public function addTestResult(PrintableTestResultInterface $testResult)
    {
        $this->testResults[] = $testResult;
        $this->waitingForTestResult = false;
    }

    public function hasAbnormalTermination(): bool
    {
        return end($this->testResults) instanceof TestResultWithAbnormalTermination;
    }

    public function isWaitingForTestResult(): bool
    {
        return $this->waitingForTestResult;
    }

    public function setWaitingForTestResult(bool $waitingForTestResult)
    {
        $this->waitingForTestResult = $waitingForTestResult;
    }
}