BOTK\SimpleCsvGateway

Complexity

Total Complexity

10

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

0%

Importance

Changes

0

<?php
class SimpleCsvGateway 
{
	
	protected $options;
	protected $factsFactory;
	protected $currentRow = 0;
	
	
	public static function factory(array $options)
	{
		return new static($options);
	}
	
	
	public function __construct(array $options)
	{
		$defaults = array(
			'factsProfile'		=> array(),
			'missingFactsIsError' => true, // if a missing fact must considered an error
			'bufferSize' 		=> 2000,
			'skippFirstLine'	=> true,
			'fieldDelimiter' 	=> ',',
		    'silent'            => false,
		);
		$this->options = array_merge($defaults,$options);
		$this->factsFactory = new \BOTK\FactsFactory($options['factsProfile']);
	}
	
	
	protected function readRawData()
	{
		$this->currentRow++;
		return fgetcsv(STDIN, $this->options['bufferSize'], $this->options['fieldDelimiter']);
	}
	
	protected function message($message)
	{
	    if (!this->options['silent']){

This code did not parse for me. Apparently, there is an error somewhere around this line:

Syntax error, unexpected T_OBJECT_OPERATOR

	        echo $message;
	    }
	}
	
	
	public function run()
	{
		echo $this->factsFactory->generateLinkedDataHeader();
	
	    while ($rawdata = $this->readRawData()) {
	    	if($this->currentRow==1 && $this->options['skippFirstLine']){
	    	    $this->message ("# Header skipped\n");
	    		continue;
			}
    		try {
    			$facts =$this->factsFactory->factualize($rawdata);
	    		echo $facts->asTurtleFragment(), "\n";
				$droppedFields = $facts->getDroppedFields();
		    	if(!empty($droppedFields) && $this->options['missingFactsIsError']) {
		    	    $this->message ("\n# WARNING MISSING FACT on row {$this->currentRow}: dropped ".implode(",", $droppedFields)."\n");
					$this->factsFactory->addToCounter('error');
				}	    
			} catch (\BOTK\Exception\Warning $e) {