SilverStripe\SsPak\DataExtractor\CsvTableReader

Complexity

Total Complexity

14

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes	1
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	getColumns()	0	6	2
A	getIterator()	0	10	2
A	mapToColumns()	0	12	3
A	initColumns()	0	4	1
A	getRow()	0	3	1
A	open()	0	7	2
A	close()	0	6	2

<?php

namespace SilverStripe\SsPak\DataExtractor;

class CsvTableReader implements TableReader
{

	private $filename;
	private $handle;
	private $columns;

	function __construct($filename) {

It is generally recommended to explicitly declare the visibility for methods.

		$this->filename = $filename;
	}

	function getColumns() {

It is generally recommended to explicitly declare the visibility for methods.

		if (!$this->columns) {
			$this->initColumns();
		}
		return $this->columns;
	}

	function getIterator() {

It is generally recommended to explicitly declare the visibility for methods.

		$this->columns = null;
		$this->initColumns();

		while(($row = $this->getRow()) !== false) {
			yield $this->mapToColumns($row);
		}

		$this->close();
	}

	private function mapToColumns($row) {
		$record = [];
		foreach($row as $i => $value)
		{
			if(isset($this->columns[$i])) {
				$record[$this->columns[$i]] = $value;
			} else {
				throw new \LogicException("Row contains invalid column #$i\n" . var_export($row, true));
			}
		}
		return $record;
	}

	private function initColumns() {
		$this->open();
		$this->columns = $this->getRow();
	}

	private function getRow() {
		return fgetcsv($this->handle);
	}

	private function open() {
		if ($this->handle) {
			fclose($this->handle);
			$this->handle = null;
		}
		$this->handle = fopen($this->filename, 'r');
	}

	private function close() {
		if ($this->handle) {
			fclose($this->handle);
			$this->handle = null;
		}
	}
}