borobudur-php / borobudur-cqrs

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/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/ViewModel/Aggregate.php

Spacing +5 added lines, -5 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);

src/ViewModel/ViewModel.php

Spacing +3 added lines, -3 removed lines

@@ -107,7 +107,7 @@ 
         } 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();
                 }
@@ -296,7 +296,7 @@ 
      */
     private function computeViewModelValue($results, array $record, $field)
     {
-        $method = $this->prefixMethod . ucfirst($field);
+        $method = $this->prefixMethod.ucfirst($field);
         if (method_exists($this, $method)) {
             return call_user_func_array(
                 array($this, $method),
@@ -376,7 +376,7 @@ 
     {
         if (!$data instanceof ReadModelInterface && !$data instanceof Collection && !is_array($data)) {
             throw new InvalidArgumentException(sprintf(
-                'Acceptable data type is \Borobudur\Cqrs\ReadModel\ReadModelInterface, ' .
+                'Acceptable data type is \Borobudur\Cqrs\ReadModel\ReadModelInterface, '.
                 '\Borobudur\Cqrs\Collection, Borobudur\Cqrs\ViewModel\ViewModel or nested array, but got "%s".',
                 gettype($data)
             ));

src/Collection.php

Spacing +5 added lines, -5 removed lines

@@ -100,12 +100,12 @@ 
         $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 (is_object($element)) {
                     if ($fields) {
                         foreach ($fields as $field) {
-                            $methodGet = 'get' . ucfirst($field);
-                            $methodIs = 'is' . ucfirst($field);
+                            $methodGet = 'get'.ucfirst($field);
+                            $methodIs = 'is'.ucfirst($field);
 
                             if (method_exists($element, $methodGet)) {
                                 $elements[] = $element->{$methodGet}();
@@ -147,7 +147,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);
         }
@@ -165,7 +165,7 @@ 
     private function assertValidClassMapper($classMapper)
     {
         if (null !== $classMapper) {
-            $classMapper = '\\' . ltrim($classMapper, '\\');
+            $classMapper = '\\'.ltrim($classMapper, '\\');
             if (!class_exists($classMapper)) {
                 throw new InvalidArgumentException(sprintf('Class "%s" is undefined.', $classMapper));
             }

src/ReadModel/Storage/Pdo/Expression/PdoCompositeExpression.php

Spacing +1 added lines, -1 removed lines

@@ -81,7 +81,7 @@
      */
     public function process()
     {
-        return sprintf('(%s)', implode(' ' . $this->logic . ' ', $this->parts));
+        return sprintf('(%s)', implode(' '.$this->logic.' ', $this->parts));
     }
 
     /**

src/ReadModel/Storage/Pdo/PdoConfig.php

Spacing +1 added lines, -1 removed lines

@@ -167,7 +167,7 @@
      */
     protected function createParser()
     {
-        switch(strtolower($this->engine)) {
+        switch (strtolower($this->engine)) {
             case 'pgsql':
                 return new PostgresParser();
         }

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

Spacing +1 added lines, -1 removed lines

@@ -15,7 +15,7 @@
     {
         return sprintf(
             '%s %s %s',
-            $this->transformField($comparison, $this->quote . $field . $this->quote),
+            $this->transformField($comparison, $this->quote.$field.$this->quote),
             $this->transformComparison($comparison, $value),
             $this->normalizeValue($value)
         );

src/UnitOfWorkTransaction.php

Spacing +3 added lines, -3 removed lines

@@ -51,7 +51,7 @@ 
     public function beginTransaction()
     {
         $this->execute(
-            function (TransactionalInterface $handler) {
+            function(TransactionalInterface $handler) {
                 $handler->beginTransaction();
             }
         );
@@ -63,7 +63,7 @@ 
     public function rollback()
     {
         $this->execute(
-            function (TransactionalInterface $handler) {
+            function(TransactionalInterface $handler) {
                 $handler->rollback();
             }
         );
@@ -75,7 +75,7 @@ 
     public function commit()
     {
         $this->execute(
-            function (TransactionalInterface $handler) {
+            function(TransactionalInterface $handler) {
                 $handler->commit();
             }
         );