Resta\Worker\WorkerManagerAbstract

Complexity

Total Complexity

15

Size/Duplication

Total Lines	127
Duplicated Lines	0 %

Importance

Changes	1
Bugs	1	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	getData()	0	7	2
A	pause()	0	7	2
A	isWorkerAvailable()	0	3	1
A	getPauseValue()	0	7	2
A	getWorker()	0	7	2
A	__construct()	0	11	2
A	getApply()	0	7	2
A	__call()	0	8	2

<?php

namespace Resta\Worker;

use Resta\Support\Utils;
use Resta\Foundation\ApplicationProvider;
use Resta\Contracts\ApplicationContracts;

abstract class WorkerManagerAbstract extends ApplicationProvider
{
    /**
     * @var array
     */
    protected $args = array();

    /**
     * @var null|object
     */
    protected $worker;

    /**
     * WorkerManager constructor.
     *
     * @param ApplicationContracts $app
     * @param array $args
     */
    public function __construct(ApplicationContracts $app, $args=array())
    {
        parent::__construct($app);

        if($this->app->runningInConsole()===false){
            exception()->runtime('The worker can only be run as cli..');
        }

        $this->args = $args;

        $this->worker = $this->app->get('worker');
    }

    /**
     * get apply from cli for worker
     *
     * @return mixed
     */
    public function getApply()
    {
        if(isset($this->args['apply'])){
            return $this->args['apply'];
        }

        return 'default';
    }

    /**
     * get data from cli for worker
     *
     * @return mixed
     */
    public function getData()
    {
        if(isset($this->args['data'])){
            return $this->args['data'];
        }

        return null;
    }

    /**
     * get pause value
     *
     * @return int|mixed
     */
    public function getPauseValue()
    {
        if(isset($this->args['pause'])){
            return $this->args['pause'];
        }

        return 0;
    }

    /**
     * get worker name
     *
     * @return mixed|void
     */
    public function getWorker()
    {
        if(isset($this->args['worker'],$this->worker[$worker = strtolower($this->args['worker'])])){
            return $worker;
        }

        exception()->runtime('Any worker is not available in the container');
    }

    /**
     * check if worker is available
     *
     * @return bool
     */
    public function isWorkerAvailable()
    {
        return isset($this->worker[$this->getWorker()]);
    }

    /**
     * get pause for worker
     *
     * @param null|\int $pause
     */
    public function pause($pause=null)
    {
        if(is_null($pause)){
            sleep($this->getPauseValue());
        }
        else{
            sleep($pause);

$pause of type int is incompatible with the type integer expected by parameter $seconds of sleep().

        }
    }

    /**
     * run job class
     *
     * @param $name
     * @param $arguments
     * @return mixed|void
     */
    public function __call($name, $arguments)
    {
        $job = __NAMESPACE__.'\\'.ucfirst($name).'Job';
        if(Utils::isNamespaceExists($job)){
            return $this->app->resolve($job,['worker'=>$this])->execute();
        }

        exception()->runtime('Job Class not found');
    }
}