SfCod\SocketIoBundle\Service\Process

Complexity

Total Complexity

10

Size/Duplication

Total Lines	89
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getParallelEnv()	0	4	2
A	run()	0	12	2
A	inWork()	0	13	4
A	push()	0	12	1

<?php

namespace SfCod\SocketIoBundle\Service;

/**
 * Class Process.
 *
 * @package SfCod\SocketIoBundle
 */
class Process
{
    /**
     * @var array
     */
    private static $_inWork = [];

    /**
     * Run script name.
     *
     * @var string
     */
    private $scriptName;

    /**
     * Bin folder path.
     *
     * @var string
     */
    private $binPath;

    /**
     * Process constructor.
     */
    public function __construct(string $scriptName, string $binPath)
    {
        $this->scriptName = $scriptName;
        $this->binPath = $binPath;
    }

    /**
     * Get parallel processes count.
     */
    public function getParallelEnv(): int
    {
        return getenv('SOCKET_IO.PARALLEL') ? getenv('SOCKET_IO.PARALLEL') : 10;
    }

    /**
     * Run process. If more then limit then wait and try run process on more time.
     *
     * @return \Symfony\Component\Process\Process
     */
    public function run(string $handle, array $data)
    {
        $this->inWork();

        while (count(self::$_inWork) >= $this->getParallelEnv()) {
            usleep(100);

            $this->inWork();
        }

        return $this->push($handle, $data);
    }

    /**
     * In work processes.
     */
    private function inWork()
    {
        foreach (self::$_inWork as $i => $proccess) {
            /** @var \Symfony\Component\Process\Process $proccess * */
            if (false === $proccess->isRunning()) {
                unset(self::$_inWork[$i]);
            }
            // Client should not get any errors. But if get any errors they will be displayed on a display.
            if ($proccess->getErrorOutput()) {
                echo $proccess->getErrorOutput();
            }
        }
    }

    /**
     * Create cmd process and push to queue.
     */
    private function push(string $handle, array $data): \Symfony\Component\Process\Process
    {
        $cmd = sprintf('php %s socket-io:process --handler=%s --data=%s --env=%s', $this->scriptName, escapeshellarg($handle), escapeshellarg(serialize($data)), getenv('APP_ENV'));

        $process = new \Symfony\Component\Process\Process($cmd, $this->binPath);

$cmd is of type string, but the function expects a array.

        $process->setTimeout(10);
        $process->start();

        self::$_inWork[] = $process;

        return $process;
    }
}