CSVelte\IO\IteratorStream

Complexity

Total Complexity

32

Size/Duplication

Total Lines	327
Duplicated Lines	0 %

Coupling/Cohesion

Components	3
Dependencies	3

Test Coverage

Coverage

97.62%

Importance

Changes

0

17 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	16	4
A	__toString()	0	6	1
A	isReadable()	0	4	1
A	read()	0	20	5
A	getContents()	0	13	2
A	getSize()	0	4	1
A	tell()	0	4	1
A	eof()	0	6	2
A	rewind()	0	5	1
A	getMetadata()	0	8	3
A	close()	0	11	3
A	detach()	0	9	1
A	isWritable()	0	4	1
A	write()	0	4	1
A	isSeekable()	0	4	1
A	seek()	0	4	1
A	inflateBuffer()	0	8	3

<?php

/*
 * CSVelte: Slender, elegant CSV for PHP
 * Inspired by Python's CSV module and Frictionless Data and the W3C's CSV
 * standardization efforts, CSVelte was written in an effort to take all the
 * suck out of working with CSV.
 *
 * @version   {version}
 * @copyright Copyright (c) 2016 Luke Visinoni <luke.visinoni@gmail.com>
 * @author    Luke Visinoni <luke.visinoni@gmail.com>
 * @license   https://github.com/deni-zen/csvelte/blob/master/LICENSE The MIT License (MIT)
 */
namespace CSVelte\IO;

use CSVelte\Contract\Streamable;
use CSVelte\Traits\IsReadable;
use CSVelte\Traits\IsWritable;
use InvalidArgumentException;
use Iterator;

/**
 * Iterator Stream.
 *
 * A read-only stream that uses an iterable to continuously fill up a buffer as
 * read operations deplete it.
 *
 * @package    CSVelte
 * @subpackage CSVelte\IO
 *
 * @copyright  (c) 2016, Luke Visinoni <luke.visinoni@gmail.com>
 * @author     Luke Visinoni <luke.visinoni@gmail.com>
 *
 * @since      v0.2.1
 */
class IteratorStream implements Streamable
{
    use IsReadable, IsWritable;

    /**
     * Buffer stream.
     *
     * @var BufferStream A BufferStream object
     */
    protected $buffer;

    /**
     * Iterator to read from.
     *
     * @var Iterator
     */
    protected $iter;

    /**
     * Is stream readable?
     *
     * @var bool Whether stream is readable
     */
    protected $readable = true;

    /**
     * Is stream writable?
     *
     * @var bool Whether stream is writable
     */
    protected $writable = false;

    /**
     * Is stream seekable?
     *
     * @var bool Whether stream is seekable
     */
    protected $seekable = false;

    /**
     * @var array Any additional options / meta data
     */
    protected $meta = [

    ];

    /**
     * Instantiate an iterator stream.
     *
     * Instantiate a new iterator stream. The iterator is used to continually
     * refill a buffer as it is drained by read operations.
     *
     * @param \Iterator The iterator to stream data from
     * @param BufferStream|null Either a buffer or null (to use
     *     default buffer)
     * @param null|mixed $buffer
     *
     * @todo this should expect a BufferInterface or a Bufferable rather than
     * a BufferStream
     */
    public function __construct(Iterator $iter, $buffer = null)
    {
        $this->iter = $iter;
        if (is_null($buffer)) {
            $buffer = new BufferStream;
        }
        if (!($buffer instanceof BufferStream)) {
            throw new InvalidArgumentException(sprintf(
                '%s expected %s as second argument, got: %s',
                __CLASS__,
                BufferStream::class,
                is_object($buffer) ? get_class($buffer) : gettype($buffer)
            ));
        }
        $this->buffer = $buffer;
    }

    /**
     * Read the entire stream, beginning to end.
     *
     * In most stream implementations, __toString() differs from getContents()
     * in that it returns the entire stream rather than just the remainder, but
     * due to the way this stream works (sort of like a conveyor belt), this
     * method is an alias to getContents()
     *
     * @return string The entire stream, beginning to end
     */
    public function __toString()
    {
        $this->rewind();

        return $this->getContents();
    }

    /**
     * Readability accessor.
     *
     * Despite the fact that any class that implements this interface must also
     * define methods such as read and readLine, that is no guarantee that an
     * object will necessarily be readable. This method should tell the user
     * whether a stream is, in fact, readable.
     *
     * @return bool True if readable, false otherwise
     */
    public function isReadable()
    {
        return $this->readable;
    }

    public function read($bytes)
    {
        if ($this->buffer) {
            $data = '';
            while (strlen($data) < $bytes) {
                if ($this->buffer->isEmpty()) {
                    $this->inflateBuffer();
                }

                if (!$read = $this->buffer->read($bytes - strlen($data))) {
                    break;
                }
                $data .= $read;
            }

            return $data;
        }

        return false;
    }

    /**
     * Read the remainder of the stream.
     *
     * @return string The remainder of the stream
     */
    public function getContents()
    {
        $contents = '';
        while (!$this->eof()) {
            $contents .= $this->read(
                // kind of arbitrary... we have to specify something for the
                // chunk length, so I just used the buffer's "high water mark"
                $this->buffer->getMetadata('hwm')
            );
        }

        return $contents;
    }

    /**
     * Return the size (in bytes) of this stream (if known).
     *
     * @return int|null Size (in bytes) of this stream
     */
    public function getSize()
    {
        // no way to know so return null
    }

    /**
     * Return the current position within the stream/readable.
     *
     * I can't decide whether there is any meaningful way to "tell" the
     * current position within this type of stream. For now I'm just
     * going to return false because the nature of this type of stream
     * means that it technically has no definitive beginning or end and
     * therefor no absolute position. If a "tell" is truly needed, I
     * suppose I could keep track of how many bytes have been read over
     * the lifetime of the object, but I don't think that is meaningful
     * and/or useful.
     *
     * @return int|false The current position within readable
     */
    public function tell()
    {
        return false;
    }

    /**
     * Determine whether the end of the stream has been reached.
     *
     * @return bool Whether we're at the end of the stream
     */
    public function eof()
    {
        return
            !$this->iter->valid() &&
            $this->buffer->eof();
    }

    /**
     * Rewind to beginning of stream.
     */
    public function rewind()
    {
        $this->iter->rewind();
        $this->buffer->rewind();
    }

    /**
     * Get stream metadata as an associative array or retrieve a specific key.
     *
     * The keys returned are identical to the keys returned from PHP's
     * stream_get_meta_data() function.
     *
     * @param string $key Specific metadata to retrieve.
     *
     * @return array|mixed|null Returns an associative array if no key is
     *                          provided. Returns a specific key value if a key is provided and the
     *                          value is found, or null if the key is not found.
     *
     * @see http://php.net/manual/en/function.stream-get-meta-data.php
     */
    public function getMetadata($key = null)
    {
        if (!is_null($key)) {
            return isset($this->meta[$key]) ? $this->meta[$key] : null;
        }

        return $this->meta;
    }

    /**
     * Closes the stream and any underlying resources.
     *
     * @return bool
     */
    public function close()
    {
        $buff = $this->buffer->close();
        $iter = true;
        if (method_exists($this->iter, 'close')) {
            $iter = $this->iter->close();
        }
        $this->buffer = null;

        return $buff && $iter;
    }

    /**
     * Separates any underlying resources from the stream.
     *
     * After the stream has been detached, the stream is in an unusable state.
     * Because there is no underlying stream resource, the actual data in the
     * buffer is returned instead.
     *
     * @return string
     */
    public function detach()
    {
        $data           = (string) $this;
        $this->buffer   = null;
        $this->iter     = null;
        $this->readable = false;

        return $data;
    }

    /**
     * Writability accessor.
     *
     * Despite the fact that any class that implements this interface must also
     * define methods such as write and writeLine, that is no guarantee that an
     * object will necessarily be writable. This method should tell the user
     * whether a stream is, in fact, writable.
     *
     * @return bool True if writable, false otherwise
     */
    public function isWritable()
    {
        return $this->writable;
    }

    /**
     * Write data to the output.
     *
     * @param string $data The data to write
     *
     * @return int|false The number of bytes written
     */
    public function write($data)
    {
        return false;
    }

    /**
     * Seekability accessor.
     *
     * Despite the fact that any class that implements this interface must also
     * define methods such as seek, that is no guarantee that an
     * object will necessarily be seekable. This method should tell the user
     * whether a stream is, in fact, seekable.
     *
     * @return bool True if seekable, false otherwise
     */
    public function isSeekable()
    {
        return $this->seekable;
    }

    /**
     * Seek to specified offset.
     *
     * @param int $offset Offset to seek to
     * @param int $whence Position from whence the offset should be applied
     *
     * @return bool True if seek was successful
     */
    public function seek($offset, $whence = SEEK_SET)
    {
        return $this->seekable;
    }

    /**
     * Inflate the buffer.
     *
     * Loop through the iterator and fill the buffer with its contents.
     */
    protected function inflateBuffer()
    {
        while (!$this->buffer->isFull() && $this->iter->valid()) {
            $data = $this->iter->current();
            $this->buffer->write($data);
            $this->iter->next();
        }
    }
}