DefaultDataStream::__construct() - Code Metrics - Inspection of "update scrutinizer-CI to frictionlessdata repo" - frictionlessdata/datapackage-php - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Branch — master (7d7b3f)

by Ori

created 2017-07-30 07:21 UTC

DefaultDataStream::__construct() A

↳ Parent: DefaultDataStream

Complexity

Conditions	2
Paths	2

Size

Total Lines	9
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	2
eloc	6
nc	2
nop	2
dl	0
loc	9
rs	9.6666
c	0
b	0
f	0

<?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 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;
}


1			<?php
2
3			namespace frictionlessdata\datapackage\DataStreams;
4
5			use frictionlessdata\datapackage\Exceptions\DataStreamOpenException;
6
7			/**
8			* streams the raw data without processing - used for default data package resources.
9			*/
10			class DefaultDataStream extends BaseDataStream
11			{
12			public $fopenResource;
13
14			/**
15			* @param string $dataSource
16			*
17			* @throws DataStreamOpenException
18			*/
19			public function __construct($dataSource, $dataSourceOptions = null)
20			{
21			parent::__construct($dataSource, $dataSourceOptions);
22			try {
23			$this->fopenResource = fopen($this->dataSource, 'r');
24			} catch (\Exception $e) {
25			throw new DataStreamOpenException('Failed to open data source '.json_encode($this->dataSource).': '.json_encode($e->getMessage()));
26			}
27			}
28
29			public function __destruct()
30			{
31			fclose($this->fopenResource);
32			}
33
34			public function rewind()
35			{
36			if ($this->currentLineNumber == 0) {
37			// starting iterations
38			$this->currentLineNumber = 1;
39			} else {
40			throw new \Exception('DataStream does not support rewinding a stream, sorry');
41			}
42			}
43
44			public function current()
45			{
46			return fgets($this->fopenResource);
47			}
48
49			public function key()
50			{
51			return $this->currentLineNumber;
52			}
53
54			public function next()
55			{
56			++$this->currentLineNumber;
57			}
58
59			public function valid()
60			{
61			return !feof($this->fopenResource);
62			}
63
64			protected $currentLineNumber = 0;
65			}
66

frictionlessdata / datapackage-php

Branch — master (7d7b3f)

DefaultDataStream::__construct() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like