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/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/PdoFinder.php

Spacing +9 added lines, -9 removed lines

@@ -79,7 +79,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;
@@ -207,16 +207,16 @@ 
     protected function computeQuery($fields = '*')
     {
         $parts = array(
-            'SELECT ' . $fields,
-            'FROM ' . $this->quote($this->table),
+            'SELECT '.$fields,
+            'FROM '.$this->quote($this->table),
         );
 
         if (!empty($this->conditions)) {
-            $parts[] = 'WHERE ' . $this->normalizeConditions();
+            $parts[] = 'WHERE '.$this->normalizeConditions();
         }
 
         if (!empty($this->sorts)) {
-            $parts[] = 'ORDER BY ' . $this->normalizeSorts();
+            $parts[] = 'ORDER BY '.$this->normalizeSorts();
         }
 
         if (null !== $this->limit) {
@@ -233,9 +233,9 @@ 
      */
     protected function normalizeConditions()
     {
-        $joiner = ' ' . CompositeExpressionInterface::LOGICAL_AND . ' ';
+        $joiner = ' '.CompositeExpressionInterface::LOGICAL_AND.' ';
 
-        return implode($joiner, array_map(function ($item) {
+        return implode($joiner, array_map(function($item) {
             return (string) $item;
         }, $this->conditions));
     }
@@ -249,7 +249,7 @@ 
     {
         $sorts = array();
         foreach ($this->sorts as $field => $direction) {
-            $sorts[] = $this->quote($field) . ' ' . $direction;
+            $sorts[] = $this->quote($field).' '.$direction;
         }
 
         return implode(', ', $sorts);
@@ -264,6 +264,6 @@ 
      */
     protected function quote($field)
     {
-        return $this->quote . $field . $this->quote;
+        return $this->quote.$field.$this->quote;
     }
 }

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();
         }