Streaming\Process\Process

Complexity

Total Complexity

12

Size/Duplication

Total Lines	96
Duplicated Lines	0 %

Importance

Changes	1
Bugs	1	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getBinary()	0	11	3
A	__construct()	0	3	1
A	addCommand()	0	8	2
A	run()	0	23	3
A	getCommand()	0	3	1
A	removeCommand()	0	7	2

<?php

/**
 * This file is part of the PHP-FFmpeg-video-streaming package.
 *
 * (c) Amin Yazdanpanah <contact@aminyazdanpanah.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */


namespace Streaming\Process;


use Streaming\Exception\Exception;
use Symfony\Component\Process\ExecutableFinder;
use Symfony\Component\Process\Process as SymphonyProcess;

class Process
{

    protected $commands = [];

    /**
     * ShakaProcess constructor.
     * @param $binary
     * @throws Exception
     */
    public function __construct($binary)
    {
        $this->commands[] = $this->getBinary($binary);
    }

    /**
     * @param $binary
     * @return mixed
     * @throws Exception
     */
    private function getBinary($binary)
    {
        if (is_executable($binary)) {
            return $binary;
        } else {
            $finder = new ExecutableFinder();

            if ($binary = $finder->find($binary)) {
                return $binary;
            } else {
                throw new Exception("We could not find 'Shaka Packager' binary.\nPlease check the path to the shaka binary");
            }
        }
    }

    /**
     * @throws Exception
     */
    public function run()
    {
        $commands = $this->getCommand();

        if (!is_executable(current($commands))) {
            throw new Exception('The binary is not executable');
        }

        $process = new SymphonyProcess($commands);
        $process->run();

        if (!$process->isSuccessful()) {
            $error = sprintf('The command "%s" failed.' . "\n\nExit Code: %s(%s)\n\nWorking directory: %s",
                $process->getCommandLine(),
                $process->getExitCode(),
                $process->getExitCodeText(),
                $process->getWorkingDirectory()
            );

            throw new Exception($error);
        }

        return $process->getOutput();
    }

    /**
     * @param array | string $command
     * @return Process
     */
    public function addCommand($command): Process
    {
        if (is_array($command)) {
            $this->commands = array_merge($this->commands, $command);
        } else {
            $this->commands[] = $command;
        }
        return $this;
    }

    /**
     * @param string $command
     * @return Process
     */
    public function removeCommand($command): Process
    {
        if (false !== ($key = array_search($command, $this->commands))) {
            unset($this->commands[$key]);
        }

        return $this;
    }

    /**
     * @return array
     */
    public function getCommand(): array
    {
        return $this->commands;
    }
}