Graze\CsvToken\Buffer\StreamBuffer

Complexity

Total Complexity

15

Size/Duplication

Total Lines	141
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes	2
Bugs	0	Features	1

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	getContents()	0	4	1
A	getLength()	0	4	1
A	isEof()	0	4	1
A	read()	0	14	3
A	move()	0	8	1
A	canRead()	0	5	3
A	isSourceEof()	0	4	1
A	getPosition()	0	4	1
A	getMinBufferSize()	0	4	1
A	setMinBufferSize()	0	5	1

<?php

namespace Graze\CsvToken\Buffer;

class StreamBuffer implements BufferInterface
{
    const READ_LENGTH = 128;

    /** @var string */
    protected $contents;
    /** @var int */
    protected $length;
    /** @var int */
    protected $position;
    /** @var bool */
    protected $eof = false;
    /** @var int */
    protected $minSize;

    /** @var resource */
    private $stream;
    /** @var int */
    private $readLength;

    /**
     * Create a buffer around a stream
     *
     * @param resource $stream
     * @param int      $readLength
     * @param int      $minSize
     */
    public function __construct($stream, $readLength = self::READ_LENGTH, $minSize = -1)
    {
        $this->stream = $stream;
        $this->readLength = $readLength;
        $this->position = ftell($stream);
        $this->minSize = $minSize;
        $this->length = 0;
        $this->eof = false;
    }

    /**
     * @return string
     */
    public function getContents()
    {
        return $this->contents;
    }

    /**
     * @return int
     */
    public function getLength()
    {
        return $this->length;
    }

    /**
     * @return bool
     */
    public function isEof()
    {
        return $this->length === 0;
    }

    /**
     * @return bool
     */
    public function read()
    {
        if ($this->canRead()) {
            $next = fread($this->stream, $this->readLength);
            if (strlen($next) > 0) {
                $this->contents .= $next;
                $this->length += strlen($next);
                return true;
            } else {
                $this->eof = true;
            }
        }
        return false;
    }

    /**
     * Remove the first $length characters from the buffer
     *
     * @param int $length
     *
     * @return bool
     */
    public function move($length)
    {
        $this->contents = substr($this->contents, $length);
        $newLen = max(0, $this->length - $length);
        $this->position += $this->length - $newLen;
        $this->length = $newLen;
        return true;
    }

    /**
     * Determine if we can read more from the stream
     *
     * @return bool
     */
    private function canRead()
    {
        return ((!$this->eof)
            && ($this->minSize < 0 || $this->length <= $this->minSize));
    }

    /**
     * @return bool
     */
    public function isSourceEof()
    {
        return $this->eof;
    }

    /**
     * @return int
     */
    public function getPosition()
    {
        return $this->position;
    }

    /**
     * @return int
     */
    public function getMinBufferSize()
    {
        return $this->minSize;
    }

    /**
     * @param int $size
     *
     * @return $this
     */
    public function setMinBufferSize($size)
    {
        $this->minSize = $size;
        return $this;
    }
}