Wonderland\Thread\AbstractThread

Complexity

Total Complexity

7

Size/Duplication

Total Lines	80
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setPid()	0	5	1
A	run()	0	16	3
A	getProcessName()	0	3	1
A	getPid()	0	3	1
A	__construct()	0	3	1

<?php

namespace Wonderland\Thread;

use Wonderland\Thread\Exception\ThreadException;

abstract class AbstractThread extends AbstractThreadMediator
{
	const EXIT_STATUS_SUCCESS = 0;
	const EXIT_STATUS_ERROR = 1;

	/** @var int $pid */
	private $pid;

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

    /**
     * AbstractThread constructor.
     *
     * @param string $processName
     */
	public function __construct(string $processName)
    {
        $this->processName = $processName;
    }

    /**
     * Return the name of the method to process during the thread
     * @return string
     */
	abstract protected function getMethodName(): string;

    /**
     * Return the list of dependencies that will be passed as parameters of the method referenced by getMethodName
     * @return array
     */
	abstract protected function getDependencies(): array;

	/**
	 * @return int|null
	 */
	public function getPid(): ?int
	{
		return $this->pid;
	}

	/**
	 * @param int $pid
	 * @return AbstractThread
	 */
	public function setPid(int $pid): self
	{
		$this->pid = $pid;

		return $this;
	}

	/**
	 * @return string
	 */
	public function getProcessName(): ?string
	{
		return $this->processName;
	}

	/**
	 * @return int
	 * @throws ThreadException
	 */
	public function run(): int
	{
		if (false === method_exists($this, $this->getMethodName())) {
			throw new ThreadException('No proper method defined for the thread');
		}

		$status = call_user_func_array(
            [$this, $this->getMethodName()],
            array_merge([$this->getProcessName()], $this->getDependencies())
        );

		if (null === $status) {
			throw new ThreadException('Error. You must return a process status in your callback function');
		}

		return $status;
	}

}