Ackintosh\Snidel\Fork

Complexity

Total Complexity

28

Size/Duplication

Total Lines	258
Duplicated Lines	0 %

Coupling/Cohesion

Components	3
Dependencies	4

Importance

Changes	12
Bugs	1	Features	2

25 Methods

Rating	Name	Duplication	Size	Complexity
A	setStatus()	0	4	1
A	getPid()	0	4	1
A	getStatus()	0	4	1
A	__construct()	0	6	1
A	setCallable()	0	4	2
A	getCallable()	0	4	1
A	setArgs()	0	4	1
A	getArgs()	0	4	1
A	hasFinishedSuccessfully()	0	4	2
A	hasNotFinishedSuccessfully()	0	4	1
A	setResult()	0	4	1
A	getResult()	0	4	1
A	hasNoResult()	0	4	1
A	setTag()	0	4	1
A	getTag()	0	4	1
A	setQueued()	0	4	1
A	isQueued()	0	4	1
A	executeTask()	0	13	2
A	serialize()	0	7	1
A	serializeTask()	0	5	1
A	minifyAndSerialize()	0	7	1
A	minifyAndSerializeTask()	0	5	1
A	unserialize()	0	7	1
A	unserializeTask()	0	5	1
A	__clone()	0	5	1

<?php
namespace Ackintosh\Snidel;

use Ackintosh\Snidel\Pcntl;
use Ackintosh\Snidel\Result;
use Ackintosh\Snidel\Task;
use Ackintosh\Snidel\TaskFormatter;

class Fork
{
    /** @var int */
    private $pid;

    /** @var \Ackintosh\Snidel\Pcntl */
    private $pcntl;

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

    /** @var callable */
    private $callable;

    /** @var array */
    private $args;

    /** @var \Ackintosh\Snidel\Result */
    private $result;

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

    /** @var \Ackintosh\Snidel\Task */
    private $task;

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

    /** @var bool */
    private $queued = false;

    /**
     * @param   int     $pid
     */
    public function __construct($pid, $task)
    {
        $this->pid      = $pid;
        $this->task     = $task;
        $this->pcntl    = new Pcntl();
    }

    /**
     * set exit status
     *
     * @param   int     $status
     * @return  void
     */
    public function setStatus($status)
    {
        $this->status = $status;
    }

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

    /**
     * return exit status
     *
     * @return int
     */
    public function getStatus()
    {
        return $this->status;
    }

    /**
     * set callable
     *
     * @param   callable    $callable
     * @return  void
     */
    public function setCallable($callable)
    {
        $this->callable = $callable instanceof \Closure ? '*Closure*' : $callable;
    }

    public function getCallable()
    {
        return $this->callable;
    }

    /**
     * set arguments
     *
     * @param   array   $args
     * @return  void
     */
    public function setArgs($args)
    {
        $this->args = $args;
    }

    public function getArgs()
    {
        return $this->args;
    }

    /**
     * @return bool
     */
    public function hasFinishedSuccessfully()
    {
        return $this->pcntl->wifexited($this->status) && $this->pcntl->wexitstatus($this->status) === 0;
    }

    /**
     * @return bool
     */
    public function hasNotFinishedSuccessfully()
    {
        return !$this->hasFinishedSuccessfully();
    }

    /**
     *
     * @param   \Ackintosh\Snidel\Result
     * @return  void
     */
    public function setResult($result)
    {
        $this->result = $result;
    }

    /**
     * return result
     *
     * @return \Ackintosh\Snidel\Result
     */
    public function getResult()
    {
        return $this->result;
    }

    public function hasNoResult()
    {
        return $this->result === null;
    }

    /**
     * @param   string  $tag
     * @return  void
     */
    public function setTag($tag)
    {
        $this->tag = $tag;
    }

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

    /**
     * @return  void
     */
    public function setQueued()
    {
        $this->queued = true;
    }

    /**
     * @return  bool
     */
    public function isQueued()
    {
        return $this->queued;
    }

    public function executeTask()
    {
        ob_start();
        $result = new Result();
        $result->setReturn(
            call_user_func_array(
                $this->task->getCallable(),
                (is_array($args = $this->task->getArgs())) ? $args : array($args)
            )
        );
        $result->setOutput(ob_get_clean());
        $this->result = $result;
    }

    /**
     * @param   \Ackintosh\Snidel\Fork  $fork
     * @return  string
     */
    public static function serialize($fork)
    {
        $cloned = clone $fork;
        $cloned->serializeTask();

        return serialize($cloned);
    }

    /**
     * @return  void
     */
    private function serializeTask()
    {
        $this->serializedTask = TaskFormatter::serialize($this->task);
        unset($this->task);
    }

    public static function minifyAndSerialize($fork)
    {
        $cloned = clone $fork;
        $cloned->minifyAndSerializeTask();

        return serialize($cloned);
    }

    private function minifyAndSerializeTask()
    {
        $this->serializedTask = TaskFormatter::minifyAndSerialize($this->task);
        unset($this->task);
    }

    /**
     * @param   string  $serializedFork
     * @return  \Ackintosh\Snidel\Fork
     */
    public static function unserialize($serializedFork)
    {
        $fork = unserialize($serializedFork);
        $fork->unserializeTask();

        return $fork;
    }

    /**
     * @return  void
     */
    private function unserializeTask()
    {
        $this->task = TaskFormatter::unserialize($this->serializedTask);
        $this->serializedTask = null;
    }

    /**
     * @return  void
     */
    public function __clone()
    {
        // to avoid point to same object.
        $this->task = clone $this->task;
    }
}