frictionlessdata\datapackage\DataStreams\DefaultDataStream

Complexity

Total Complexity

10

Size/Duplication

Total Lines	63
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	2

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	2
A	__destruct()	0	4	1
A	rewind()	0	9	2
A	save()	0	6	1
A	current()	0	4	1
A	key()	0	4	1
A	next()	0	4	1
A	valid()	0	4	1

<?php

namespace frictionlessdata\datapackage\DataStreams;

use frictionlessdata\datapackage\Exceptions\DataStreamOpenException;

/**
 * streams the raw data without processing - used for default data package resources.
 */
class DefaultDataStream extends BaseDataStream
{
    public $fopenResource;

    /**
     * @param string $dataSource
     *
     * @throws DataStreamOpenException
     */
    public function __construct($dataSource, $dataSourceOptions = null)
    {
        parent::__construct($dataSource, $dataSourceOptions);
        try {
            $this->fopenResource = fopen($this->dataSource, 'r');
        } catch (\Exception $e) {
            throw new DataStreamOpenException('Failed to open data source '.json_encode($this->dataSource).': '.json_encode($e->getMessage()));
        }
    }

    public function __destruct()
    {
        fclose($this->fopenResource);
    }

    public function rewind()
    {
        if ($this->currentLineNumber == 0) {
            // starting iterations
            $this->currentLineNumber = 1;
        } else {
            throw new \Exception('DataStream does not support rewinding a stream, sorry');
        }
    }

    public function save($filename)
    {
        $target = fopen($filename, 'w');
        stream_copy_to_stream($this->fopenResource, $target);
        fclose($target);
    }

    public function current()
    {
        return fgets($this->fopenResource);
    }

    public function key()
    {
        return $this->currentLineNumber;
    }

    public function next()
    {
        ++$this->currentLineNumber;
    }

    public function valid()
    {
        return !feof($this->fopenResource);
    }

    protected $currentLineNumber = 0;
}