nebula\route\collection\ReadLineIterator

Complexity

Total Complexity

7

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	getIterator()	0	22	6
A	__construct()	0	5	1

<?php
namespace nebula\route\collection;

use Iterator;
use IteratorAggregate;

/**
 * 逐行读文件迭代器
 *
 */
class ReadLineIterator implements IteratorAggregate
{
    protected $path;
    protected $bufferSize;
    protected $offset;

    /**
     * 构建迭代器
     *
     * @param string $path 路径
     * @param integer|null $offset 起始偏移
     * @param integer $bufferSize
     */
    public function __construct(string $path, ?int $offset = 0, int $bufferSize = 1024)
    {
        $this->path = $path;
        $this->offset = $offset;
        $this->bufferSize = $bufferSize;
    }

    /**
     * 获取迭代器
     *
     * @return Iterator
     */
    public function getIterator():Iterator
    {
        if (file_exists($this->path)) {
            $fp = fopen($this->path, 'rb');
            $offset = 0;
            while (!feof($fp)) {

It seems like $fp can also be of type false; however, parameter $handle of feof() does only seem to accept resource, maybe add an additional type check?

                fseek($fp, $offset);

It seems like $fp can also be of type false; however, parameter $handle of fseek() does only seem to accept resource, maybe add an additional type check?

                $content = fread($fp, $this->bufferSize);

It seems like $fp can also be of type false; however, parameter $handle of fread() does only seem to accept resource, maybe add an additional type check?

                $content.=(feof($fp))? "\n":'';
                $size = strpos($content, "\n");
                $offset += $size;
                if ($content[$size - 1] === "\r") {
                    $content = substr($content, 0, $size -1);
                }
                if (is_null($this->offset)) {
                    yield $content;
                } else {
                    yield $offset => $content;
                }
            }
        } else {
            throw new \Exception(sprintf('readline iterator: file note exists %s', $this->path));
        }
    }
}