Rodenastyle / stream-parser

src/StreamParser.php

Spacing +3 added lines, -3 removed lines

@@ -15,15 +15,15 @@
 
 class StreamParser
 {
-	public static function xml(String $source){
+	public static function xml(String $source) {
 		return (new XMLParser())->from($source);
 	}
 
-	public static function json(String $source){
+	public static function json(String $source) {
 		return (new JSONParser())->from($source);
 	}
 
-	public static function csv(String $source){
+	public static function csv(String $source) {
 		return (new CSVParser())->from($source);
 	}
 }
\ No newline at end of file

src/Services/JsonCollectionParser.php

Spacing +1 added lines, -1 removed lines

@@ -43,7 +43,7 @@
 			throw $e;
 		}
 
-		if( ! fclose($stream)){
+		if ( ! fclose($stream)) {
 			throw new IncompleteParseException();
 		}
 	}

src/Parsers/XMLParser.php

Spacing +27 added lines, -27 removed lines

@@ -18,7 +18,7 @@ 
 
 class XMLParser implements StreamParserInterface
 {
-	protected $reader,$source;
+	protected $reader, $source;
 
 	protected $skipFirstElement = true;
 
@@ -29,7 +29,7 @@ 
 		return $this;
 	}
 
-	public function withoutSkippingFirstElement(){
+	public function withoutSkippingFirstElement() {
 		$this->skipFirstElement = false;
 
 		return $this;
@@ -39,8 +39,8 @@ 
 	{
 		$this->start();
 		try {
-			while($this->reader->read()){
-				if($this->searchElement($function) === false) {
+			while ($this->reader->read()) {
+				if ($this->searchElement($function) === false) {
 					break;
 				}
 			}
@@ -52,7 +52,7 @@ 
 
 	public function chunk($count, callable $function)
 	{
-		if($count <= 0) {
+		if ($count <= 0) {
 			return;
 		}
 
@@ -60,23 +60,23 @@ 
 		try {
 			$chunk = new Collection();
 
-			while($this->reader->read()){
+			while ($this->reader->read()) {
 				$this->searchElement(function($item) use (&$chunk) {
 					$chunk->push($item);
 				});
 
-				if($chunk->count() >= $count) {
+				if ($chunk->count() >= $count) {
 					$stop = $function($chunk) === false;
 
 					$chunk = new Collection();
 
-					if($stop) {
+					if ($stop) {
 						break;
 					}
 				}
 			}
 
-			if($chunk->count() > 0) {
+			if ($chunk->count() > 0) {
 				$function($chunk);
 			}
 		} catch (StopParseException $e) {
@@ -87,7 +87,7 @@ 
 
 	private function searchElement(callable $function)
 	{
-		if($this->isElement() && ! $this->shouldBeSkipped()){
+		if ($this->isElement() && ! $this->shouldBeSkipped()) {
 			return $function($this->extractElement($this->reader->name));
 		}
 	}
@@ -96,19 +96,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 {
@@ -121,10 +121,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);
 			}
 		}
@@ -141,13 +141,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;
 		}
@@ -155,23 +155,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/Parsers/CSVParser.php

Spacing +18 added lines, -18 removed lines

@@ -18,12 +18,12 @@ 
 {
 	protected $reader, $source, $headers, $currentLine;
 
-	public static $delimiters = [",", ";"];
+	public static $delimiters = [ ",", ";" ];
 
 	public 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();
 				}
@@ -43,8 +43,8 @@ 
 	{
 		$this->start();
 		try {
-			while($this->read()){
-				if($function($this->getCurrentLineAsCollection()) === false) {
+			while ($this->read()) {
+				if ($function($this->getCurrentLineAsCollection()) === false) {
 					break;
 				}
 			}
@@ -56,7 +56,7 @@ 
 
 	public function chunk($count, callable $function)
 	{
-		if($count <= 0) {
+		if ($count <= 0) {
 			return;
 		}
 
@@ -64,21 +64,21 @@ 
 		try {
 			$chunk = new Collection();
 
-			while($this->read()){
+			while ($this->read()) {
 				$chunk->push($this->getCurrentLineAsCollection());
 
-				if($chunk->count() >= $count) {
+				if ($chunk->count() >= $count) {
 					$stop = $function($chunk) === false;
 
 					$chunk = new Collection();
 
-					if($stop) {
+					if ($stop) {
 						break;
 					}
 				}
 			}
 
-			if($chunk->count() > 0) {
+			if ($chunk->count() > 0) {
 				$function($chunk);
 			}
 		} catch (StopParseException $e) {
@@ -97,8 +97,8 @@ 
 		return $this;
 	}
 
-	private function close(){
-		if( ! fclose($this->reader)){
+	private function close() {
+		if ( ! fclose($this->reader)) {
 			throw new IncompleteParseException();
 		}
 	}
@@ -116,20 +116,20 @@ 
 		return $headers->intersectByKeys($this->currentLine)->combine($values->recursive());
 	}
 
-	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 empty($value);
 				});
 			} else {

src/Parsers/JSONParser.php

Spacing +7 added lines, -7 removed lines

@@ -20,8 +20,8 @@ 
 
 	public 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();
 				}
@@ -42,7 +42,7 @@ 
 		$this->start();
 		try {
 			$this->reader->parse($this->source, function(array $item) use ($function){
-				if($function((new Collection($item))->recursive()) === false) {
+				if ($function((new Collection($item))->recursive()) === false) {
 					throw new StopParseException();
 				}
 			});
@@ -52,7 +52,7 @@ 
 
 	public function chunk($count, callable $function)
 	{
-		if($count <= 0) {
+		if ($count <= 0) {
 			return;
 		}
 
@@ -63,18 +63,18 @@ 
 			$this->reader->parse($this->source, function(array $item) use ($function, &$chunk, &$count){
 				$chunk->push((new Collection($item))->recursive());
 
-				if($chunk->count() >= $count) {
+				if ($chunk->count() >= $count) {
 					$stop = $function($chunk) === false;
 
 					$chunk = new Collection();
 
-					if($stop) {
+					if ($stop) {
 						throw new StopParseException();
 					}
 				}
 			});
 
-			if($chunk->count() > 0) {
+			if ($chunk->count() > 0) {
 				$function($chunk);
 			}
 		} catch (StopParseException $e) {