Rodenastyle / stream-parser

src/Parsers/XMLParser.php

Spacing +21 added lines, -21 removed lines

@@ -17,7 +17,7 @@ 
 
 class XMLParser implements StreamParserInterface
 {
-	protected $reader,$source;
+	protected $reader, $source;
 
 	protected $skipFirstElement = true;
 
@@ -28,7 +28,7 @@ 
 		return $this;
 	}
 
-	public function withoutSkippingFirstElement(){
+	public function withoutSkippingFirstElement() {
 		$this->skipFirstElement = false;
 
 		return $this;
@@ -37,7 +37,7 @@ 
 	public function each(callable $function)
 	{
 		$this->start();
-		while($this->reader->read()){
+		while ($this->reader->read()) {
 			$this->searchElement($function);
 		}
 		$this->stop();
@@ -45,7 +45,7 @@ 
 
 	private function searchElement(callable $function)
 	{
-		if($this->isElement() && ! $this->shouldBeSkipped()){
+		if ($this->isElement() && ! $this->shouldBeSkipped()) {
 			$function($this->extractElement($this->reader->name));
 		}
 	}
@@ -54,19 +54,19 @@ 
 	{
 		$elementCollection = (new Collection())->merge($this->getCurrentElementAttributes());
 
-		while($this->reader->read()){
-			if($this->isEndElement($elementName)){
+		while ($this->reader->read()) {
+			if ($this->isEndElement($elementName)) {
 				break;
 			}
-			if($this->isValue()){
-				if($elementCollection->isEmpty()){
+			if ($this->isValue()) {
+				if ($elementCollection->isEmpty()) {
 					return trim($this->reader->value);
 				} else {
 					return $elementCollection->put($elementName, trim($this->reader->value));
 				}
 			}
-			if($this->isElement()){
-				if($couldBeAnElementsList){
+			if ($this->isElement()) {
+				if ($couldBeAnElementsList) {
 					$foundElementName = $this->reader->name;
 					$elementCollection->push(new Collection($this->extractElement($foundElementName)));
 				} else {
@@ -79,10 +79,10 @@ 
 		return $elementCollection;
 	}
 
-	private function getCurrentElementAttributes(){
+	private function getCurrentElementAttributes() {
 		$attributes = new Collection();
-		if($this->reader->hasAttributes)  {
-			while($this->reader->moveToNextAttribute()) {
+		if ($this->reader->hasAttributes) {
+			while ($this->reader->moveToNextAttribute()) {
 				$attributes->put($this->reader->name, $this->reader->value);
 			}
 		}
@@ -99,13 +99,13 @@ 
 
 	private function stop()
 	{
-		if( ! $this->reader->close()){
+		if ( ! $this->reader->close()) {
 			throw new IncompleteParseException();
 		}
 	}
 
-	private function shouldBeSkipped(){
-		if($this->skipFirstElement){
+	private function shouldBeSkipped() {
+		if ($this->skipFirstElement) {
 			$this->skipFirstElement = false;
 			return true;
 		}
@@ -113,23 +113,23 @@ 
 		return false;
 	}
 
-	private function isElement(String $elementName = null){
-		if($elementName){
+	private function isElement(String $elementName = null) {
+		if ($elementName) {
 			return $this->reader->nodeType == XMLReader::ELEMENT && $this->reader->name === $elementName;
 		} else {
 			return $this->reader->nodeType == XMLReader::ELEMENT;
 		}
 	}
 
-	private function isEndElement(String $elementName = null){
-		if($elementName){
+	private function isEndElement(String $elementName = null) {
+		if ($elementName) {
 			return $this->reader->nodeType == XMLReader::END_ELEMENT && $this->reader->name === $elementName;
 		} else {
 			return $this->reader->nodeType == XMLReader::END_ELEMENT;
 		}
 	}
 
-	private function isValue(){
+	private function isValue() {
 		return $this->reader->nodeType == XMLReader::TEXT || $this->reader->nodeType === XMLReader::CDATA;
 	}
 }

src/Services/JsonCollectionParser.php

Spacing +2 added lines, -2 removed lines

@@ -43,7 +43,7 @@ 
 			throw $e;
 		}
 
-		if( ! fclose($stream)){
+		if ( ! fclose($stream)) {
 			throw new IncompleteParseException();
 		}
 	}
@@ -58,7 +58,7 @@ 
 	{
 		$stream = @fopen($filePath, 'r');
 		if (false === $stream) {
-			throw new \Exception('Unable to open file for read: ' . $filePath);
+			throw new \Exception('Unable to open file for read: '.$filePath);
 		}
 
 		return $stream;

src/Parsers/CSVParser.php

Spacing +16 added lines, -16 removed lines

@@ -17,7 +17,7 @@ 
 {
 	protected $reader, $source, $headers, $currentLine;
 
-	public static $delimiters = [",", ";"];
+	public static $delimiters = [ ",", ";" ];
 	public static $skipsEmptyLines = true;
 
 	public function from(String $source): StreamParserInterface
@@ -30,8 +30,8 @@ 
 	public function each(callable $function)
 	{
 		$this->start();
-		while($this->read()){
-			if($this->currentLineIsValid()){
+		while ($this->read()) {
+			if ($this->currentLineIsValid()) {
 				$function($this->getCurrentLineAsCollection());
 			}
 		}
@@ -48,8 +48,8 @@ 
 		return $this;
 	}
 
-	private function close(){
-		if( ! fclose($this->reader)){
+	private function close() {
+		if ( ! fclose($this->reader)) {
 			throw new IncompleteParseException();
 		}
 	}
@@ -62,20 +62,20 @@ 
 	}
 
 	private function currentLineIsValid(): bool{
-		if(static::$skipsEmptyLines){
+		if (static::$skipsEmptyLines) {
 			return ! $this->currentLineIsEmpty();
 		}
 
 		return true;
 	}
 
-	private function currentLineIsEmpty(){
-		return $this->currentLine->reject(function($value){
+	private function currentLineIsEmpty() {
+		return $this->currentLine->reject(function($value) {
 			return $this->isEmptyValue($value);
 		})->isEmpty();
 	}
 
-	private function isEmptyValue($value){
+	private function isEmptyValue($value) {
 		return $value === "" || $value === null;
 	}
 
@@ -86,25 +86,25 @@ 
 
 		return $headers->intersectByKeys($this->currentLine)
 			->combine($values->recursive())
-			->reject(function($value){
+			->reject(function($value) {
 				return $this->isEmptyValue($value);
 			});
 	}
 
-	private function formatCurrentLineValues(Collection $collection){
+	private function formatCurrentLineValues(Collection $collection) {
 		$this->explodeCollectionValues($collection);
 		return $collection;
 	}
 
-	private function explodeCollectionValues(Collection $collection){
-		$collection->transform(function($value){
+	private function explodeCollectionValues(Collection $collection) {
+		$collection->transform(function($value) {
 			(new Collection(static::$delimiters))->each(function($delimiter) use (&$value){
-				if( ! is_array($value) && strpos($value, $delimiter) !== false){
+				if ( ! is_array($value) && strpos($value, $delimiter) !== false) {
 					$value = explode($delimiter, $value);
 				}
 			});
-			if(is_array($value)){
-				return (new Collection($value))->reject(function($value){
+			if (is_array($value)) {
+				return (new Collection($value))->reject(function($value) {
 					return $this->isEmptyValue($value);
 				});
 			} else {

src/Extensions/ChunkExtension.php

Indentation +71 added lines, -71 removed lines

@@ -13,87 +13,87 @@
  */
 class ChunkExtension implements \Rodenastyle\StreamParser\StreamParserInterface
 {
-    const DEFAULT_CHUNK_SIZE = 5000;
+	const DEFAULT_CHUNK_SIZE = 5000;
 
-    /**
-     * @var \Rodenastyle\StreamParser\StreamParserInterface
-     */
-    private $parser;
-    private $iterationCount = 0;
-    private $chunkSize;
-    /** @var  callable $onChunkCompleteCallback */
-    private $onChunkCompleteCallback;
+	/**
+	 * @var \Rodenastyle\StreamParser\StreamParserInterface
+	 */
+	private $parser;
+	private $iterationCount = 0;
+	private $chunkSize;
+	/** @var  callable $onChunkCompleteCallback */
+	private $onChunkCompleteCallback;
 
-    public function __construct(\Rodenastyle\StreamParser\StreamParserInterface $parser, $chunkSize = self::DEFAULT_CHUNK_SIZE)
-    {
-        $this->parser = $parser;
-        $this->chunkSize = $chunkSize;
-    }
+	public function __construct(\Rodenastyle\StreamParser\StreamParserInterface $parser, $chunkSize = self::DEFAULT_CHUNK_SIZE)
+	{
+		$this->parser = $parser;
+		$this->chunkSize = $chunkSize;
+	}
 
-    public function from(String $source): \Rodenastyle\StreamParser\StreamParserInterface
-    {
-        return $this->parser->from($source);
-    }
+	public function from(String $source): \Rodenastyle\StreamParser\StreamParserInterface
+	{
+		return $this->parser->from($source);
+	}
 
-    public function eachChunk(callable $function): StreamParserInterface
-    {
-        $this->onChunkCompleteCallback = $function;
-        return $this;
-    }
+	public function eachChunk(callable $function): StreamParserInterface
+	{
+		$this->onChunkCompleteCallback = $function;
+		return $this;
+	}
 
-    public function each(callable $function)
-    {
-        if ($this->onChunkCompleteCallback === null) {
-            throw new UndefinedCallbackException("No callback is set on chunk complete");
-        }
-        // decorate function to apply both its behavior and the chunk process
-        $function = function ($collection) use ($function) {
-            $this->iterationCount++;
-            $function($collection);
+	public function each(callable $function)
+	{
+		if ($this->onChunkCompleteCallback === null) {
+			throw new UndefinedCallbackException("No callback is set on chunk complete");
+		}
+		// decorate function to apply both its behavior and the chunk process
+		$function = function ($collection) use ($function) {
+			$this->iterationCount++;
+			$function($collection);
 
-            if ($this->iterationCount % $this->chunkSize === 0) {
-                $this->executeChunkCompleteCallback();
-            }
-        };
-        $this->parser->each($function);
+			if ($this->iterationCount % $this->chunkSize === 0) {
+				$this->executeChunkCompleteCallback();
+			}
+		};
+		$this->parser->each($function);
 
-        // make sure no entry is left out
-        $this->processLastEntries();
-        return $this;
-    }
+		// make sure no entry is left out
+		$this->processLastEntries();
+		return $this;
+	}
 
-    /**
-     * @param $this
-     */
-    protected function executeChunkCompleteCallback()
-    {
-        $this->iterationCount = 0;
-        ($this->onChunkCompleteCallback)();
-    }
+	/**
+	 * @param $this
+	 */
+	protected function executeChunkCompleteCallback()
+	{
+		$this->iterationCount = 0;
+		($this->onChunkCompleteCallback)();
+	}
 
-    protected function processLastEntries()
-    {
-        if ($this->iterationCount % $this->chunkSize !== 0) {
-            $this->executeChunkCompleteCallback();
-        }
-    }
+	protected function processLastEntries()
+	{
+		if ($this->iterationCount % $this->chunkSize !== 0) {
+			$this->executeChunkCompleteCallback();
+		}
+	}
 
 
-    /**
-     * @param int $chunkSize
-     * @return ChunkExtension
-     */
-    public function setChunkSize(int $chunkSize): ChunkExtension
-    {
-        $this->chunkSize = $chunkSize;
-        return $this;
-    }
+	/**
+	 * @param int $chunkSize
+	 * @return ChunkExtension
+	 */
+	public function setChunkSize(int $chunkSize): ChunkExtension
+	{
+		$this->chunkSize = $chunkSize;
+		return $this;
+	}
 
-    /**
-     * @return \Rodenastyle\StreamParser\StreamParserInterface
-     */
-    public function getParser(): \Rodenastyle\StreamParser\StreamParserInterface
-    {
-        return $this->parser;
-    }
+	/**
+	 * @return \Rodenastyle\StreamParser\StreamParserInterface
+	 */
+	public function getParser(): \Rodenastyle\StreamParser\StreamParserInterface
+	{
+		return $this->parser;
+	}
 }
\ No newline at end of file

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
             throw new UndefinedCallbackException("No callback is set on chunk complete");
         }
         // decorate function to apply both its behavior and the chunk process
-        $function = function ($collection) use ($function) {
+        $function = function($collection) use ($function) {
             $this->iterationCount++;
             $function($collection);
 

src/StreamParser.php

Indentation +3 added lines, -3 removed lines

@@ -44,8 +44,8 @@
 		return (new CSVParser())->from($source);
 	}
 
-    private function chunk(StreamParserInterface $parser)
-    {
-        return new ChunkExtension($parser);
+	private function chunk(StreamParserInterface $parser)
+	{
+		return new ChunkExtension($parser);
 	}
 }
\ No newline at end of file

Spacing +5 added lines, -5 removed lines

@@ -22,8 +22,8 @@ 
 
 	private function __construct()
 	{
-		Collection::macro('recursive', function () {
-			return $this->map(function ($value) {
+		Collection::macro('recursive', function() {
+			return $this->map(function($value) {
 				if (is_array($value) || is_object($value)) {
 					return (new Collection($value))->recursive();
 				}
@@ -32,15 +32,15 @@ 
 		});
 	}
 
-	private function xml(String $source){
+	private function xml(String $source) {
 		return (new XMLParser())->from($source);
 	}
 
-	private function json(String $source){
+	private function json(String $source) {
 		return (new JSONParser())->from($source);
 	}
 
-	private function csv(String $source){
+	private function csv(String $source) {
 		return (new CSVParser())->from($source);
 	}