SupervisorJob::stop() - Code Metrics - Inspection of "supervisor up" - php-resta/resta-core - Measure and Improve Code Quality continuously with Scrutinizer

Test Setup Failed

Push — master ( f28239...baad1a )

by Php Easy Api

created 2019-06-27 06:18 UTC

SupervisorJob::stop() A

↳ Parent: SupervisorJob

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
eloc	1
nc	1
nop	0
dl	0
loc	3
rs	10
c	0
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();
    }

    /**
     * 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|void
     */
    private function cleanWorkerForSupervisor()
    {
        $this->process->command(config('supervisor.commands.remove').' '.$this->app->get('WORKER').'');
    }

    /**
     * get workers for supervisor
     *
     * @return mixed
     */
    public function getWorkersForSupervisor()
    {
        $list = [];

        $status = array_filter(explode("\n",$this->process->command(config('supervisor.commands.workers'))),'strlen');
        $status = array_filter(explode("\n",/** @scrutinizer ignore-type */ $this->process->command(config('supervisor.commands.workers'))),'strlen');

        foreach ($status as $item){
            if(preg_match('@'.$this->app->get('PROJECT_NAME').'.*@is',$item,$array)){
                $list[] = $item;
            }
        }

        return implode(PHP_EOL,$list).''.PHP_EOL;
    }

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

        if(false===$supervisorStatus){
            $this->upSupervisor();
        }
        return $this->process->command(config('supervisor.commands.status'));
    }

    /**
     * up service supervisor
     *
     * @return mixed|void
     */
    public function upSupervisor()
    {
        return $this->process->command(config('supervisor.commands.up'));
    }

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

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

    /**
     * stop worker for supervisor
     *
     * @return mixed|void
     */
    public function stopWorkerForSupervisor()
    {
        return $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,'
[group:'.$this->app->get('PROJECT_NAME').']
[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'));
    }
}

php-resta / resta-core

Push — master ( f28239...baad1a )

SupervisorJob::stop() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like