Resta\Console\Source\Worker\Worker

Complexity

Total Complexity

9

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	create()	0	17	2
B	run()	0	30	7

<?php


namespace Resta\Console\Source\Worker;


use Resta\Console\ConsoleOutputter;

use Resta\Console\ConsoleListAccessor;

use Resta\Support\Utils;


class Worker extends ConsoleOutputter {


    use ConsoleListAccessor;


    /**

     * @var $type

The doc comment $type at position 0 could not be parsed: Unknown type name '$type' at position 0 in $type.

     */

    public $type = 'worker';


    /**

     * @var $define

The doc comment $define at position 0 could not be parsed: Unknown type name '$define' at position 0 in $define.

     */

    public $define = 'begins worker for application';


    /**

     * @var $commandRule

The doc comment $commandRule at position 0 could not be parsed: Unknown type name '$commandRule' at position 0 in $commandRule.

     */

    public $commandRule = ['worker'];


    /**

     * @inheritDoc

     */

    public function run()

    {

        $worker = strtolower($this->argument['worker']);


        $registeredWorkers = app()->get('worker');


        if(isset($registeredWorkers[$worker])){


            if(!is_callable($registeredWorkers[$worker]) && Utils::isNamespaceExists($registeredWorkers[$worker])) {

                $resolve = app()->resolve($registeredWorkers[$worker],['data'=>(array)$this->argument['data']]);

            }


            while(true){


                if(isset($resolve)){

                    $result = $resolve->handle();

                    echo $this->classical($worker.' worker called : '.$result);

                    sleep($resolve->getSleep());

                }


                if(is_callable($registeredWorkers[$worker])){

                    echo $this->classical($registeredWorkers[$worker](1));

                    sleep(10);

                }


            }

            exit();

Using exit here is not recommended.

        }


        exception()->runtime('Any worker is not available');

    }


    /**

     * @inheritDoc

     */

    public function create()

    {

        if(!file_exists(app()->path()->workers())){

            $this->directory['worker'] = app()->path()->workers();

            $this->file->makeDirectory($this);

        }


        $this->argument['workerNamespace'] = app()->namespace()->workers();

        $this->argument['workerClass'] = ucfirst($this->argument['worker']).'';

        $this->argument['projectName'] = strtolower($this->projectName());


        $this->touch['worker/worker']= app()->path()->workers().'/'.$this->argument['worker'].'.php';



        $this->file->touch($this);


        echo $this->classical(' > Worker file called as "'.$this->argument['worker'].'" has been successfully created in the '.app()->path()->workers().'');

    }



}