devtransition\jobbers\Job

Complexity

Total Complexity

10

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	2

Importance

Changes	1
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	18	2
A	id()	0	5	1
A	timeout()	0	5	1
A	run()	0	6	1
A	attach()	0	5	1
A	getId()	0	4	1
A	getResult()	0	4	1
A	_applyOptions()	0	11	2

<?php

namespace devtransition\jobbers;

use devtransition\Jobbers\exception\JobPendingException;

class Job
{

    private $_proxy;

    private $_id;
    private $_timeout;

    private $_result;

    /**
     * @param $proxy Proxy
     */
    public function __construct(&$proxy)
    {
        $this->_proxy = $proxy;

        $this->_applyOptions();

        /*
         * generate 16 hex random id
         */
        if (!$this->_id) {
            $this->_id = bin2hex(openssl_random_pseudo_bytes(8));
        }

        /*
         * set dummy result
         */
        $this->_result = new JobPendingException('not started yet');
    }

    public function id($id)
    {
        $this->_id = $id;
        return clone($this);
    }

    public function timeout($seconds)
    {
        $this->_timeout = $seconds;
        return clone($this);
    }

    public function &run()
    {
        $this->_result = call_user_func_array([$this->_proxy->getClass(), $this->_proxy->getMethod()],
            $this->_proxy->getArgs());
        return $this->_result;
    }

    public function &attach(Pool $pool)
    {
        $pool->add($this);
        return $this->_result;
    }

    public function getId()
    {
        return $this->_id;
    }

    public function &getResult()
    {
        return $this->_result;
    }

    private function _applyOptions()
    {
        $defaults = $this->_proxy->getDefaults();

        // Timeout
        if (isset($defaults['timeout'])) {
            $this->_timeout = $defaults['timeout'];
        }

        /* TODO: Add Priority? */
    }
}