Tarantool\Client\Tests\Integration\FakeServer\FakeServerBuilder

Complexity

Total Complexity

12

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

<?php
final class FakeServerBuilder
{
    private $handler;
    private $uri = 'tcp://0.0.0.0:8000';
    private $ttl = 5;
    private $logFile;

    public function __construct(Handler $handler)
    {
        $this->handler = $handler;
        $this->logFile = sys_get_temp_dir().'/tarantool_php_client_fake_server.log';
    }

    public function setUri(string $uri) : self
    {
        $this->uri = $uri;

        return $this;
    }

    public function setTtl(int $ttl) : self
    {
        $this->ttl = $ttl;

        return $this;
    }

    public function setLogFile(string $logFile) : self
    {
        $this->logFile = $logFile;

        return $this;
    }

    public function getCommand() : string
    {
        return sprintf(
            'php %s/fake_server.php \
                --handler=%s \
                --uri=%s \
                --ttl=%d \
            >> %s 2>&1 &',
            __DIR__,
            escapeshellarg(base64_encode(serialize($this->handler))),
            escapeshellarg($this->uri),
            $this->ttl,
            escapeshellarg($this->logFile)
        );
    }

    public function start() : void
    {
        exec($this->getCommand(), $output, $result);
        if (0 !== $result) {
            throw new \RuntimeException("Unable to start fake server ($this->uri)");
        }

        $stopTime = time() + 5;
        while (time() < $stopTime) {
            if ($stream = @stream_socket_client($this->uri)) {
                fclose($stream);

                return;
            }
            usleep(100);
        }

        throw new \RuntimeException("Unable to connect to fake server ($this->uri)");
    }

    public static function create(Handler ...$handlers) : self
    {
        if (!$handlers) {
            return new self(new NoopHandler());
        }

        return count($handlers) > 1
            ? new self(new ChainHandler($handlers))
            : new self($handlers[0]);
    }
}