Code Coverage
 
Classes and Traits
Functions and Methods
Lines
Total
0.00% covered (danger)
0.00%
0 / 1
66.67% covered (warning)
66.67%
2 / 3
 CRAP
97.78% covered (success)
97.78%
44 / 45
RemoteBoxedExecutor
0.00% covered (danger)
0.00%
0 / 1
66.67% covered (warning)
66.67%
2 / 3
 11
97.78% covered (success)
97.78%
44 / 45
 __construct
100.00% covered (success)
100.00%
1 / 1
 1
100.00% covered (success)
100.00%
3 / 3
 setLogger
100.00% covered (success)
100.00%
1 / 1
 1
100.00% covered (success)
100.00%
2 / 2
 executeValid
0.00% covered (danger)
0.00%
0 / 1
 9
97.50% covered (success)
97.50%
39 / 40
<?php
namespace Shellbox\Command;
use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;
use Shellbox\Client;
use Shellbox\Shellbox;
use Shellbox\ShellboxError;
/**
 * A BoxedExecutor which works by running the command on a remote server via
 * HTTP/HTTPS.
 */
class RemoteBoxedExecutor extends BoxedExecutor {
    /** @var Client */
    private $client;
    /** @var LoggerInterface */
    private $logger;
    /**
     * @param Client $client
     */
    public function __construct( Client $client ) {
        $this->client = $client;
        $this->logger = new NullLogger;
    }
    /**
     * Set the logger
     *
     * @param LoggerInterface $logger
     */
    public function setLogger( LoggerInterface $logger ) {
        $this->logger = $logger;
    }
    public function executeValid( BoxedCommand $command ) {
        $parts = [ [
            'name' => 'json-data',
            'headers' => [
                'Content-Disposition' => "json-data",
                'Content-Type' => 'application/json',
            ],
            'contents' => Shellbox::jsonEncode( [
                'action' => 'shell',
                'command' => $command->getClientData(),
            ] )
        ] ];
        foreach ( $command->getInputFiles() as $boxedName => $file ) {
            $parts[] = [
                'name' => $boxedName,
                'headers' => [
                    'Content-Disposition' =>
                        "attachment; name=\"$boxedName\"; filename=\"$boxedName\"",
                    'Content-Type' => 'application/octet-stream',
                ],
                'contents' => $file->getStreamOrString()
            ];
        }
        $stdin = $command->getStdin();
        if ( $stdin !== '' ) {
            $parts[] = [
                'name' => 'stdin',
                'headers' => [
                    'Content-Disposition' => "form-data; name=stdin",
                    'Content-Type' => 'application/octet-stream'
                ],
                'contents' => $stdin
            ];
        }
        $files = $command->getOutputFiles();
        $globs = $command->getOutputGlobs();
        $resultData = $this->client->sendRequest(
            'shell/' . $command->getRouteName(),
            $parts,
            $files,
            $globs
        );
        if ( !isset( $resultData['exitCode'] ) ) {
            throw new ShellboxError( 'Server result is missing the exit code' );
        }
        foreach ( $resultData['log'] ?? [] as $logEntry ) {
            $this->logger->log(
                $logEntry['level'],
                $logEntry['message'],
                $logEntry['context']
            );
        }
        $result = ( new BoxedResult )
            ->exitCode( $resultData['exitCode'] )
            ->stdout( $resultData['stdout'] ?? null )
            ->stderr( $resultData['stderr'] ?? null );
        foreach ( $files as $boxedName => $file ) {
            if ( $file->wasReceived() ) {
                $result->addOutputFile( $boxedName, $file );
            }
        }
        foreach ( $globs as $glob ) {
            foreach ( $glob->getFiles() as $boxedName => $file ) {
                $result->addOutputFile( $boxedName, $file );
            }
        }
        return $result;
    }
}