SupervisorJob::execute() - Code Metrics - Inspection of "worker format" - php-resta/resta-core - Measure and Improve Code Quality continuously with Scrutinizer

Test Setup Failed

Push — master ( 1dec6d...a46529 )

by Php Easy Api

created 2019-06-26 09:08 UTC

SupervisorJob::execute() A

↳ Parent: SupervisorJob

Complexity

Conditions	1
Paths	1

Size

Total Lines	7
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	1
eloc	3
nc	1
nop	0
dl	0
loc	7
rs	10
c	1
b	0
f	0

<?php

namespace Resta\Worker;

use Resta\Contracts\JobContracts;

class SupervisorJob extends JobAbstract implements JobContracts
{
    /**
     * execute job
     *
     * @return mixed|void
     */
    public function execute()
    {
        $this->isSupervisorRunning();

        $this->{$this->jobProcessor()}();

        echo $this->getWorkersForSupervisor();
class A
{
    function getObject()
    {
        return null;
    }

}

$a = new A();
if ($a->getObject()) {
    }

    /**
     * start job
     *
     * @return mixed|void
     */
    public function start()
    {
        $this->putConfigurationFile();

        $this->reReadForSupervisor();

        $this->updateForSupervisor();

        $this->startWorkerForSupervisor();
    }

    /**
     * stop job
     *
     * @return mixed|void
     */
    public function stop()
    {
        $this->stopWorkerForSupervisor();
    }

    /**
     * get status worker
     *
     * @return mixed|void
     */
    public function status()
    {
        $this->getWorkersForSupervisor();
    }

    /**
     * cleans worker
     *
     * @return mixed|void
     */
    public function clear()
    {
        $this->cleanWorkerForSupervisor();
    }

    /**
     * get workers for supervisor
     *
     * @return mixed
     */
    private function cleanWorkerForSupervisor()
    {
        return $this->process->command(config('supervisor.commands.remove').' '.$this->app->get('WORKER').'');
class A
{
    function getObject()
    {
        return null;
    }

}

$a = new A();
if ($a->getObject()) {
    }

    /**
     * get workers for supervisor
     *
     * @return mixed
     */
    public function getWorkersForSupervisor()
    {
        return $this->process->command(config('supervisor.commands.workers'));
class A
{
    function getObject()
    {
        return null;
    }

}

$a = new A();
if ($a->getObject()) {
    }

    /**
     * check if the supervisor is or not running
     *
     * @return mixed|void
     */
    public function isSupervisorRunning()
    {
        $this->process->command(config('supervisor.commands.status'));
    }

    /**
     * reread for supervisor
     *
     * @return mixed
     */
    public function reReadForSupervisor()
    {
        return $this->process->command(config('supervisor.commands.reread'));
class A
{
    function getObject()
    {
        return null;
    }

}

$a = new A();
if ($a->getObject()) {
    }

    /**
     * start Worker for supervisor
     *
     * @return mixed
     */
    public function startWorkerForSupervisor()
    {
        return $this->process->command(config('supervisor.commands.start').' '.$this->app->get('WORKER').':*');
class A
{
    function getObject()
    {
        return null;
    }

}

$a = new A();
if ($a->getObject()) {
    }

    /**
     * stop worker for supervisor
     *
     * @return mixed|void
     */
    public function stopWorkerForSupervisor()
    {
        $this->process->command(config('supervisor.commands.stop').' '.$this->app->get('WORKER').':*');
    }

    /**
     * put configutation file for supervisor
     *
     * @return mixed|void
     */
    public function putConfigurationFile()
    {
        $path = config('supervisor.path').'/'.$this->app->get('WORKER').'.conf';

        if(files()->exists($path)===false){
            files()->put($path,'
[program:'.$this->app()->get('WORKER').']
process_name=%(program_name)s_%(process_num)02d
command=php '.root.'/api worker start '.$this->app->get('PROJECT_NAME').' worker:'.$this->worker->getWorker().' apply:default
command=php '.root.'/api worker start '.$this->app->get('PROJECT_NAME').' worker:'.$this->worker->/** @scrutinizer ignore-call */ getWorker().' apply:default
autostart=true
autorestart=true
user=root
numprocs=1
redirect_stderr=true
stdout_logfile='.config('supervisor.log').'/worker.log
');
        }

    }

    /**
     * update for supervisor
     *
     * @return mixed
     */
    public function updateForSupervisor()
    {
        return $this->process->command(config('supervisor.commands.update'));
class A
{
    function getObject()
    {
        return null;
    }

}

$a = new A();
if ($a->getObject()) {
    }
}

php-resta / resta-core

Push — master ( 1dec6d...a46529 )

SupervisorJob::execute() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like