SmartGecko / GovernorFramework

src/Governor/Framework/EventStore/Mongo/CursorBackedDomainEventStream.php

Spacing +1 added lines, -1 removed lines

@@ -79,7 +79,7 @@
         $this->skipUnknownTypes = $skipUnknownTypes;
         $this->callback = $callback;
 
-        $this->messagesToReturn =  new \ArrayIterator($lastSnapshotCommit);
+        $this->messagesToReturn = new \ArrayIterator($lastSnapshotCommit);
 
         $this->initializeNextItem();
     }

Indentation +5 added lines, -5 removed lines

@@ -1,10 +1,10 @@
 <?php
 /**
- * This file is part of the SmartGecko(c) business platform.
- *
- * For the full copyright and license information, please view the LICENSE
- * file that was distributed with this source code.
- */
+     * This file is part of the SmartGecko(c) business platform.
+     *
+     * For the full copyright and license information, please view the LICENSE
+     * file that was distributed with this source code.
+     */
 
 namespace Governor\Framework\EventStore\Mongo;
 

src/Governor/Framework/EventStore/Mongo/StorageStrategyInterface.php

Indentation +5 added lines, -5 removed lines

@@ -1,10 +1,10 @@
 <?php
 /**
- * This file is part of the SmartGecko(c) business platform.
- *
- * For the full copyright and license information, please view the LICENSE
- * file that was distributed with this source code.
- */
+     * This file is part of the SmartGecko(c) business platform.
+     *
+     * For the full copyright and license information, please view the LICENSE
+     * file that was distributed with this source code.
+     */
 
 namespace Governor\Framework\EventStore\Mongo;
 

src/Governor/Framework/EventStore/Orm/BatchingIterator.php

Spacing +5 added lines, -5 removed lines

@@ -115,10 +115,10 @@ 
     {
         $query = $this->em->createQuery(
             sprintf(
-                "SELECT new Governor\Framework\Serializer\SimpleSerializedDomainEventData(".
-                "e.eventIdentifier, e.aggregateIdentifier, e.scn, ".
-                "e.timestamp, e.payloadType, e.payloadRevision, e.payload, e.metaData) ".
-                "FROM %s e %s ORDER BY e.timestamp ASC, "."e.scn ASC, e.aggregateIdentifier ASC",
+                "SELECT new Governor\Framework\Serializer\SimpleSerializedDomainEventData(" .
+                "e.eventIdentifier, e.aggregateIdentifier, e.scn, " .
+                "e.timestamp, e.payloadType, e.payloadRevision, e.payload, e.metaData) " .
+                "FROM %s e %s ORDER BY e.timestamp ASC, " . "e.scn ASC, e.aggregateIdentifier ASC",
                 $this->domainEventEntryEntityName,
                 $this->buildWhereClause()
             )
@@ -145,7 +145,7 @@ 
 
         $query = "WHERE ";
         if (null !== $this->lastItem) {
-            $query .= "((e.timestamp > :timestamp) OR (e.timestamp = :timestamp AND e.scn > :scn) ".
+            $query .= "((e.timestamp > :timestamp) OR (e.timestamp = :timestamp AND e.scn > :scn) " .
                 " OR (e.timestamp = :timestamp AND e.scn = :scn AND e.aggregateIdentifier > :aggregateIdentifier))";
 
             $this->parameters[':timestamp'] = $this->lastItem->getTimestamp();

src/Governor/Framework/EventStore/Orm/DefaultEventEntryStore.php

Spacing +10 added lines, -10 removed lines

@@ -143,11 +143,11 @@ 
     ) {
         $query = $entityManager->
         createQuery(
-            "SELECT new Governor\Framework\Serializer\SimpleSerializedDomainEventData(".
-            "e.eventIdentifier, e.aggregateIdentifier, e.scn, ".
-            "e.timestamp, e.payloadType, e.payloadRevision, e.payload, e.metaData) ".
-            "FROM ".$this->snapshotEventEntryEntityName()." e ".
-            "WHERE e.aggregateIdentifier = :id AND e.type = :type ".
+            "SELECT new Governor\Framework\Serializer\SimpleSerializedDomainEventData(" .
+            "e.eventIdentifier, e.aggregateIdentifier, e.scn, " .
+            "e.timestamp, e.payloadType, e.payloadRevision, e.payload, e.metaData) " .
+            "FROM " . $this->snapshotEventEntryEntityName() . " e " .
+            "WHERE e.aggregateIdentifier = :id AND e.type = :type " .
             "ORDER BY e.scn DESC"
         )
             ->setFirstResult(0)
@@ -214,9 +214,9 @@ 
             $scnOfFirstToPrune = current($redundantSnapshots);
 
             $entityManager->createQuery(
-                "DELETE FROM ".$this->snapshotEventEntryEntityName()." e ".
-                "WHERE e.type = :type ".
-                "AND e.aggregateIdentifier = :aggregateIdentifier ".
+                "DELETE FROM " . $this->snapshotEventEntryEntityName() . " e " .
+                "WHERE e.type = :type " .
+                "AND e.aggregateIdentifier = :aggregateIdentifier " .
                 "AND e.scn <= :scnOfFirstToPrune"
             )
                 ->setParameters(
@@ -236,8 +236,8 @@ 
         EntityManager $entityManager
     ) {
         $query = $entityManager->createQuery(
-            "SELECT e.scn FROM ".$this->snapshotEventEntryEntityName()." e ".
-            "WHERE e.type = :type AND e.aggregateIdentifier = :aggregateIdentifier ".
+            "SELECT e.scn FROM " . $this->snapshotEventEntryEntityName() . " e " .
+            "WHERE e.type = :type AND e.aggregateIdentifier = :aggregateIdentifier " .
             "ORDER BY e.scn DESC"
         )
             ->setFirstResult($maxSnapshotsArchived - 1)

src/Governor/Framework/EventStore/Orm/OrmEventStore.php

Spacing +1 added lines, -1 removed lines

@@ -199,7 +199,7 @@
                 $snapshotScn = $snapshotEvent->getScn();
             } catch (\RuntimeException $ex) {
                 $this->logger->warn(
-                    "Error while reading snapshot event entry. ".
+                    "Error while reading snapshot event entry. " .
                     "Reconstructing aggregate on entire event stream. Caused by: {class} {message}",
                     array(
                         'class' => get_class($ex),

src/Governor/Framework/Saga/Annotation/AssociationValuesImpl.php

Spacing +3 added lines, -3 removed lines

@@ -107,7 +107,7 @@ 
                 $this->removedValues = array_udiff(
                     $this->removedValues,
                     array($associationValue),
-                    function (AssociationValue $a, AssociationValue $b) {
+                    function(AssociationValue $a, AssociationValue $b) {
                         return $a->compareTo($b);
                     }
                 );
@@ -153,7 +153,7 @@ 
             $this->values = array_udiff(
                 $this->values,
                 array($associationValue),
-                function (AssociationValue $a, AssociationValue $b) {
+                function(AssociationValue $a, AssociationValue $b) {
                     return $a->compareTo($b);
                 }
             );
@@ -167,7 +167,7 @@ 
                 $this->addedValues = array_udiff(
                     $this->addedValues,
                     array($associationValue),
-                    function ($a, $b) {
+                    function($a, $b) {
                         return $a->compareTo($b);
                     }
                 );

src/Governor/Framework/Saga/Annotation/SagaMethodMessageHandlerInspector.php

Spacing +1 added lines, -1 removed lines

@@ -66,7 +66,7 @@
             if (0 === count($method->getParameters())) {
                 throw new \RuntimeException(
                     sprintf(
-                        "Invalid method signature detected of %s::%s. ".
+                        "Invalid method signature detected of %s::%s. " .
                         "Methods annotated with @SagaEventHandler must have exatly one parameter with the type of the message they handle. ",
                         $reflectionClass->name,
                         $method->name

src/Governor/Framework/Serializer/JMSSerializer.php

Spacing +1 added lines, -1 removed lines

@@ -58,7 +58,7 @@
             $this->serializer = SerializerBuilder::create()
                 ->addDefaultHandlers()
                 ->configureHandlers(
-                    function (HandlerRegistry $registry) {
+                    function(HandlerRegistry $registry) {
                         $registry->registerSubscribingHandler(new RamseyUuidHandler());
                     }
                 )->build();

src/Governor/Framework/Test/Saga/EventValidator.php

Indentation +5 added lines, -5 removed lines

@@ -1,10 +1,10 @@
 <?php
 /**
- * Created by PhpStorm.
- * User: david
- * Date: 19/12/14
- * Time: 21:14
- */
+     * Created by PhpStorm.
+     * User: david
+     * Date: 19/12/14
+     * Time: 21:14
+     */
 
 namespace Governor\Framework\Test\Saga;