JsonDecodeStream\Source\FileSource

Complexity

Total Complexity

15

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Test Coverage

Coverage

90%

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	read()	0	3	1
A	file()	0	21	6
A	rewind()	0	3	1
A	__destruct()	0	6	3
A	isEof()	0	3	1
A	stream()	0	7	2

<?php
declare(strict_types=1);

namespace JsonDecodeStream\Source;

use JsonDecodeStream\Exception\SourceException;
use Throwable;

class FileSource implements SourceInterface
{
    /** @var string */
    protected $filename;
    /** @var resource|null */
    protected $handle;
    /** @var StreamSource|null */
    protected $streamSource;

    public function __construct(string $filename)
    {
        $this->filename = $filename;
    }

    public function __destruct()
    {
        if ($this->handle) {
            try {
                fclose($this->handle);
            } catch (Throwable $e) {
                // ignore
            }
        }
    }

    /**
     * @return resource
     * @throws SourceException
     */
    protected function file()
    {
        if (!$this->handle) {
            $exception = null;
            try {
                $handle = fopen($this->filename, 'r');
                if ($handle === false) {
                    $error = error_get_last();
                    throw new \RuntimeException($error ? $error['message'] : 'fopen error');
                }
                $this->handle = $handle;
            } catch (Throwable $e) {
                $this->handle = null;
                $exception = $e;
            }
            if (!$this->handle) {
                throw new SourceException("Could not open file '{$this->filename}'", 0, $exception);
            }
        }

        return $this->handle;
    }

    protected function stream()
    {
        if (!$this->streamSource) {
            $this->streamSource = new StreamSource($this->file());
        }

        return $this->streamSource;
    }

    public function isEof(): bool
    {
        return $this->stream()->isEof();
    }

    public function read(int $bytes): string
    {
        return $this->stream()->read($bytes);
    }

    public function rewind(): void
    {
        $this->stream()->rewind();
    }
}