PhpSchool\Terminal\IO\ResourceInputStream

Complexity

Total Complexity

11

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Importance

Changes	4
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	isInteractive()	0	3	1
A	read()	0	12	5
A	__construct()	0	12	5

<?php

namespace PhpSchool\Terminal\IO;

use function is_resource;
use function get_resource_type;
use function stream_get_meta_data;
use function strpos;

/**
 * @author Aydin Hassan <aydin@hotmail.co.uk>
 */
class ResourceInputStream implements InputStream
{
    /**
     * @var resource
     */
    private $stream;

    public function __construct($stream = \STDIN)
    {
        if (!is_resource($stream) || get_resource_type($stream) !== 'stream') {
            throw new \InvalidArgumentException('Expected a valid stream');
        }

        $meta = stream_get_meta_data($stream);
        if (strpos($meta['mode'], 'r') === false && strpos($meta['mode'], '+') === false) {
            throw new \InvalidArgumentException('Expected a readable stream');
        }

        $this->stream = $stream;
    }

    public function read(int $numBytes, callable $callback) : void
    {
        $meta = stream_get_meta_data($this->stream);
        if ($meta['blocked'] && ($meta['unread_bytes'] > 0)) {
            stream_set_blocking($this->stream, false);
        }
        $buffer = fread($this->stream, $numBytes);
        if ($meta['blocked'] && ($meta['unread_bytes'] > 0)) {
            stream_set_blocking($this->stream, true);
        }

        $callback($buffer);
    }

    /**
     * Whether the stream is connected to an interactive terminal
     */
    public function isInteractive() : bool
    {
        return posix_isatty($this->stream);
    }
}