borobudur-php / borobudur-cqrs

src/AbstractEntity.php

Indentation +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
     {
         if (null !== $this->aggregateRoot && $aggregateRoot !== $this->aggregateRoot) {
             throw new InvalidArgumentException(sprintf(
-               'Aggregate root "%s" already registered on "%s".',
+                'Aggregate root "%s" already registered on "%s".',
                 get_class($aggregateRoot),
                 get_called_class()
             ));

src/Bus/EventBus.php

Spacing +1 added lines, -1 removed lines

@@ -108,7 +108,7 @@
      */
     protected function getClosureHandler($handler, $class)
     {
-        return function (MessageInterface $message) use ($handler, $class) {
+        return function(MessageInterface $message) use ($handler, $class) {
             $class = ltrim(get_class($message), '\\');
             if (!isset($this->messages[$class])) {
                 throw new LogicException(sprintf('Message "%s" does not have handler.', $class));

src/Collection.php

Spacing +2 added lines, -2 removed lines

@@ -78,7 +78,7 @@ 
         $fields = func_get_args();
         $elements = array();
         if ($fields || (isset($this->elements[0]) && is_array($this->elements[0]))) {
-            $this->each(function ($element) use (&$elements, $fields) {
+            $this->each(function($element) use (&$elements, $fields) {
                 if ($element instanceof ReadModelInterface) {
                     $element = $element->serialize();
                 }
@@ -110,7 +110,7 @@ 
         $elements = parent::toArray($resortIndex);
 
         if (null !== $this->classMapper) {
-            return array_map(function (SerializableInterface $element) {
+            return array_map(function(SerializableInterface $element) {
                 return $element->serialize();
             }, (array) $elements);
         }

src/ReadModel/Storage/Pdo/Exception/PdoException.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
      */
     public function __construct(\PDOException $e)
     {
-        if(strstr($e->getMessage(), 'SQLSTATE[')) {
+        if (strstr($e->getMessage(), 'SQLSTATE[')) {
             preg_match('/SQLSTATE\[(\w+)\] \[(\w+)\] (.*)/', $e->getMessage(), $matches);
             if (count($matches)) {
                 $this->code = ($matches[1] == 'HT000' ? $matches[2] : $matches[1]);

src/ReadModel/Storage/Pdo/Parser/DefaultParser.php

Spacing +1 added lines, -1 removed lines

@@ -37,7 +37,7 @@
      */
     public function comparison($field, $comparison, $value)
     {
-        return $this->quote.$field.$this->quote . ' ' . $comparison . ' ' . $this->normalizeValue($value);
+        return $this->quote . $field . $this->quote . ' ' . $comparison . ' ' . $this->normalizeValue($value);
     }
 
     /**

src/ReadModel/Storage/Pdo/Pdo.php

Spacing +1 added lines, -1 removed lines

@@ -307,6 +307,6 @@
      */
     protected function quote($field)
     {
-        return $this->quote.$field.$this->quote;
+        return $this->quote . $field . $this->quote;
     }
 }

src/ReadModel/Storage/Pdo/PdoFinder.php

Spacing +2 added lines, -2 removed lines

@@ -80,7 +80,7 @@ 
      * @param ParserInterface $parser
      * @param string          $quote
      */
-    public function __construct(Pdo &$conn, $table, $class, $parser, $quote)
+    public function __construct(Pdo & $conn, $table, $class, $parser, $quote)
     {
         $this->conn = $conn;
         $this->table = $table;
@@ -220,7 +220,7 @@ 
     {
         $joiner = ' ' . CompositeExpressionInterface::LOGICAL_AND . ' ';
 
-        return implode($joiner, array_map(function ($item) {
+        return implode($joiner, array_map(function($item) {
             return (string) $item;
         }, $this->conditions));
     }

src/ViewModel/Aggregate.php

Spacing +6 added lines, -6 removed lines

@@ -67,7 +67,7 @@ 
     public function sum($fields)
     {
         $total = 0;
-        $this->walk($fields, function () use (&$total) {
+        $this->walk($fields, function() use (&$total) {
             $total += array_sum(func_get_args());
         });
 
@@ -96,7 +96,7 @@ 
     public function max($fields)
     {
         $max = 0;
-        $this->walk($fields, function () use (&$max) {
+        $this->walk($fields, function() use (&$max) {
             $cur = max(func_get_args());
             if ($cur > $max) {
                 $max = $cur;
@@ -116,7 +116,7 @@ 
     public function min($fields)
     {
         $min = null;
-        $this->walk($fields, function () use (&$min) {
+        $this->walk($fields, function() use (&$min) {
             $cur = min(func_get_args());
             if (null === $min) {
                 $min = $cur;
@@ -145,7 +145,7 @@ 
 
         $num = 0;
 
-        $this->walk($fields, function () use (&$num) {
+        $this->walk($fields, function() use (&$num) {
             $num += count(array_filter(func_get_args()));
         });
 
@@ -213,7 +213,7 @@ 
         $this->viewModel->setForceSingle();
         $fields = explode(',', trim($fields));
 
-        return array_walk($this->data, function (array $record) use ($fields, $callback) {
+        return array_walk($this->data, function(array $record) use ($fields, $callback) {
             $args = $this->getArguments($fields, $record);
 
             return call_user_func_array($callback, $args);
@@ -265,6 +265,6 @@ 
      */
     private function getMethodName($name)
     {
-        return $this->prefixMethod.ucfirst($name);
+        return $this->prefixMethod . ucfirst($name);
     }
 }

src/ViewModel/ViewModel.php

Spacing +2 added lines, -2 removed lines

@@ -104,10 +104,10 @@
 
         if ($record instanceof ReadModelInterface) {
             $built = $this->serialize($record, $record->serialize());
-        } elseif(is_array($record)) {
+        } elseif (is_array($record)) {
             $built = $this->serialize($record, $record);
         } else {
-            $built = array_map(function ($readModel) use ($record) {
+            $built = array_map(function($readModel) use ($record) {
                 if ($readModel instanceof ReadModelInterface) {
                     $readModel = $readModel->serialize();
                 }