Ivan1986\SupervisorBundle\Service\Supervisor

Complexity

Total Complexity

9

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	6
Bugs	2	Features	1

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	2
A	genProgrammConf()	0	6	2
A	execute()	0	8	1
A	reloadAndUpdate()	0	5	1
A	run()	0	9	3

<?php

namespace Ivan1986\SupervisorBundle\Service;

use Symfony\Bundle\TwigBundle\TwigEngine;
use Symfony\Component\Process\Process;

class Supervisor
{
    /** @var TwigEngine */
    protected $templating;
    private $appDir;
    private $name;

    public function __construct($templating, $appDir, $name)
    {
        $this->templating = $templating;
        $this->appDir = $appDir;
        $this->name = $name ? (' -i '.$name) : '';
    }

    /**
     * Сгенерировать конфиг для программы
     *
     * @param $fileName string file in app/supervisor dir
     * @param $vars array array(name,command,[numprocs])
     * @param bool $template string non default template
     */
    public function genProgrammConf($fileName, $vars, $template = false)
    {
        $template = $template?:'@Supervisor/programm.conf.twig';
        $content = $this->templating->render($template, $vars);

It seems like $template defined by $template ?: '@Supervisor/programm.conf.twig' on line 31 can also be of type boolean; however, Symfony\Bundle\TwigBundle\TwigEngine::render() does only seem to accept string|object<Symfony\Component\Templating\TemplateReferenceInterface>, maybe add an additional type check?

        file_put_contents($this->appDir.'/supervisor/'.$fileName.'.conf', $content);
    }

    /**
     * Выполняет команду супервизора
     *
     * @param string $cmd string supervisorctl command
     * @return Process Завершенный процесс
     */
    public function execute($cmd)
    {
        $p = new Process("supervisorctl ".$cmd);
        $p->setWorkingDirectory($this->appDir);
        $p->run();
        $p->wait();
        return $p;
    }

    /**
     * Перечитать конфиг и перезапустить процессы
     */
    public function reloadAndUpdate()
    {
        $this->execute('reread');
        $this->execute('update');
    }

    /**
     * Запустить демона, если он не работает
     */
    public function run()
    {
        $result = $this->execute('status')->getOutput();
        if (strpos($result, 'sock no such file') || strpos($result, 'refused connection')) {
            $p = new Process('supervisord'.$this->name);
            $p->setWorkingDirectory($this->appDir);
            $p->run();
        }
    }
}