shelladapter.php

<?php
namespace Bitrix\Scale;
 
class ShellAdapter
{
    const SUCCESS_RESULT = 0;
 
    protected $resOutput = "";
    protected $resError = "";
 
    protected function prepareExecution($command)
    {
        if($command == '')
            throw new \Bitrix\Main\ArgumentNullException("command");
 
        $this->resOutput = "";
        $this->resError = "";
 
        return  escapeshellcmd($command);
    }
 
    public function asyncExec($command)
    {
        $outputPath = "/dev/null";
        $command = $this->prepareExecution($command);
        exec($command. " > ".$outputPath." 2>&1 &");
        return true;
    }
 
    public function getLastOutput()
    {
        return $this->resOutput;
    }
 
    public function getLastError()
    {
        return $this->resError;
    }
 
    public function syncExec($command)
    {
        $command = $this->prepareExecution($command);
        $retVal = 1;
 
        $descriptorspec = array(
            0 => array("pipe", "r"),  // stdin
            1 => array("pipe", "w"),  // stdout
            2 => array("pipe", "w") // stderr
        );
 
        $pipes = array();
        $process = proc_open('/bin/bash', $descriptorspec, $pipes);
 
        if (is_resource($process))
        {
            fwrite($pipes[0], $command);
            fclose($pipes[0]);
 
            $this->resOutput = stream_get_contents($pipes[1]);
            fclose($pipes[1]);
 
            $this->resError = stream_get_contents($pipes[2]);
            fclose($pipes[2]);
 
            $retVal = proc_close($process);
        }
 
        return $retVal == static::SUCCESS_RESULT;
    }
}