Phing\Io\BufferedReader

Complexity

Total Complexity

21

Size/Duplication

Total Lines	155
Duplicated Lines	0 %

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	close()	0	3	1
A	readChar()	0	25	5
A	eof()	0	3	1
A	reset()	0	3	1
A	read()	0	28	5
A	skip()	0	3	1
A	__construct()	0	4	1
A	getResource()	0	3	1
A	readLine()	0	18	5

<?php

/**
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 * This software consists of voluntary contributions made by many individuals
 * and is licensed under the LGPL. For more information please see
 * <http://phing.info>.
 */

namespace Phing\Io;

/**
 * Convenience class for reading files.
 *
 * @author <a href="mailto:yl@seasonfive.com">Yannick Lecaillez</a>
 *
 * @see FilterReader
 */
class BufferedReader extends Reader
{
    private $bufferSize = 0;
    private $buffer;
    private $bufferPos = 0;

    /**
     * The Reader we are buffering for.
     *
     * @var InputStreamReader
     */
    private $in;

    /**
     * @param Reader $reader   The reader (e.g. FileReader).
     * @param int               $buffsize The size of the buffer we should use for reading files.
     *                                    A large buffer ensures that most files (all scripts?)
     *                                    are parsed in 1 buffer.
     */
    public function __construct(Reader $reader, $buffsize = 65536)
    {
        $this->in = $reader;

$reader is of type Phing\Io\Reader, but the property $in was declared to be of type Phing\Io\InputStreamReader. Are you sure that you always receive this specific sub-class here, or does it make sense to add an instanceof check?

        $this->bufferSize = $buffsize;
    }

    /**
     * Reads and returns a chunk of data.
     *
     * @param int $len Number of bytes to read.  Default is to read configured buffer size number of bytes.
     *
     * @return mixed buffer or -1 if EOF
     */
    public function read($len = null)
    {
        // if $len is specified, we'll use that; otherwise, use the configured buffer size.
        if (null === $len) {
            $len = $this->bufferSize;
        }

        if (($data = $this->in->read($len)) !== -1) {
            // not all files end with a newline character, so we also need to check EOF
            if (!$this->in->eof()) {
                $notValidPart = strrchr($data, "\n");
                $notValidPartSize = strlen($notValidPart);

                if ($notValidPartSize > 1) {
                    // Block doesn't finish on a EOL
                    // Find the last EOL and forget all following stuff
                    $dataSize = strlen($data);
                    $validSize = $dataSize - $notValidPartSize + 1;

                    $data = substr($data, 0, $validSize);

                    // Rewind to the beginning of the forgotten stuff.
                    $this->in->skip(-$notValidPartSize + 1);
                }
            } // if !EOF
        }

        return $data;
    }

    /**
     * @param int $n
     *
     * @return int
     */
    public function skip($n)
    {
        return $this->in->skip($n);
    }

    public function reset()
    {
        $this->in->reset();
    }

    public function close()
    {
        $this->in->close();
    }

    /**
     * Read a line from input stream.
     */
    public function readLine()
    {
        $line = null;
        while (($ch = $this->readChar()) !== -1) {
            if ("\n" === $ch) {
                $line = rtrim((string) $line);

                break;
            }
            $line .= $ch;
        }

        // Warning : Not considering an empty line as an EOF
        if (null === $line && -1 !== $ch) {
            return '';
        }

        return $line;
    }

    /**
     * Reads a single char from the reader.
     *
     * @return string single char or -1 if EOF
     */
    public function readChar()
    {
        if (null === $this->buffer) {
            // Buffer is empty, fill it ...
            $read = $this->in->read($this->bufferSize);
            if (-1 === $read) {
                $ch = -1;
            } else {
                $this->buffer = $read;

                return $this->readChar(); // recurse
            }
        } else {
            // Get next buffered char ...
            // handle case where buffer is read-in, but is empty.  The next readChar() will return -1 EOF,
            // so we just return empty string (char) at this point.  (Probably could also return -1 ...?)
            $ch = ('' !== $this->buffer) ? $this->buffer[$this->bufferPos] : '';
            ++$this->bufferPos;
            if ($this->bufferPos >= strlen($this->buffer)) {
                $this->buffer = null;
                $this->bufferPos = 0;
            }
        }

        return $ch;
    }

    /**
     * Returns whether eof has been reached in stream.
     * This is important, because filters may want to know if the end of the file (and not just buffer)
     * has been reached.
     *
     * @return bool
     */
    public function eof()
    {
        return $this->in->eof();
    }

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