Interfaces\Console\Commands\StartGitterPool

Complexity

Total Complexity

8

Size/Duplication

Total Lines	89
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	handle()	0	20	4
A	start()	0	7	2
A	stop()	0	13	2

<?php
/**
 * This file is part of GitterBot package.
 *
 * @author Serafim <nesk@xakep.ru>
 * @date 11.10.2015 22:50
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */
namespace Interfaces\Console\Commands;


use Illuminate\Console\Command;
use Illuminate\Contracts\Config\Repository;
use Illuminate\Contracts\Container\Container;
use Symfony\Component\Finder\Finder;

/**
 * Class StartGitterPool
 */
class StartGitterPool extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'gitter:pool {action=start}';


    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Start gitter chat pool.';


    /**
     * @var Container
     */
    protected $container;

    /**
     * @var Repository
     */
    protected $config;

    /**
     * Execute the console command.
     *
     * @param Repository $config
     * @param Container $container
     *
     * @return mixed
     * @throws \InvalidArgumentException
     * @throws \RuntimeException
     * @throws \LogicException
     * @throws \Exception
     */
    public function handle(Repository $config, Container $container)
    {
        $this->container = $container;
        $this->config = $config;


        $action = $this->argument('action');
        switch ($action) {
            case 'start':
            case 'restart':
                $this->stop();
                $this->start();
                break;
            case 'stop':
                $this->stop();
                break;
            default:
                throw new \InvalidArgumentException('Action ' . $action . ' not found');
        }
    }

    /**
     * Start processes
     */
    protected function start()
    {
        foreach ($this->container['room.manager']->all() as $room) {
            shell_exec('nohup php artisan gitter:listen '.$room->id().' > /dev/null 2>&1 &');
            $this->line('Starting ' . $room->id() . ' listener.');
        }
    }

    /**
     * Stop all processes
     */
    protected function stop()
    {
        $finder = (new Finder())
            ->files()
            ->name('*.pid')
            ->in(storage_path('pids'));

        foreach ($finder as $file) {
            $pid = file_get_contents($file->getRealpath());
            shell_exec('kill ' . $pid);
            unlink($file->getRealpath());
        }
    }
}