mauretto78 / simple-event-store-manager

src/Infrastructure/Projector/Projector.php

Spacing +6 added lines, -6 removed lines

@@ -27,8 +27,8 @@ 
     public function handle(EventInterface $event)
     {
         $method = $this->getHandleMethod($event);
-        if (! method_exists($this, $method)) {
-            throw new ProjectorHandleMethodDoesNotExistsException(get_class($this) . ' does not implement ' . $method . ' method.');
+        if (!method_exists($this, $method)) {
+            throw new ProjectorHandleMethodDoesNotExistsException(get_class($this).' does not implement '.$method.' method.');
         }
 
         $this->$method($event);
@@ -40,7 +40,7 @@ 
      */
     private function getHandleMethod($event)
     {
-        return 'apply' . $this->getLastClassParts($event);
+        return 'apply'.$this->getLastClassParts($event);
     }
 
     /**
@@ -60,8 +60,8 @@ 
     public function rollback(EventInterface $event)
     {
         $method = $this->getRollbackMethod($event);
-        if (! method_exists($this, $method)) {
-            throw new ProjectorRollbackMethodDoesNotExistsException(get_class($this) . ' does not implement ' . $method . ' method.');
+        if (!method_exists($this, $method)) {
+            throw new ProjectorRollbackMethodDoesNotExistsException(get_class($this).' does not implement '.$method.' method.');
         }
 
         $this->$method($event);
@@ -73,6 +73,6 @@ 
      */
     private function getRollbackMethod($event)
     {
-        return 'rollback' . $this->getLastClassParts($event);
+        return 'rollback'.$this->getLastClassParts($event);
     }
 }

src/Infrastructure/Projector/ProjectionManager.php

Spacing +2 added lines, -2 removed lines

@@ -54,7 +54,7 @@ 
     public function project(EventInterface $event)
     {
         if (!isset($this->projectors[get_class($event)])) {
-            throw new ProjectorDoesNotExistsException('No Projector found for event ' . get_class($event) . '.');
+            throw new ProjectorDoesNotExistsException('No Projector found for event '.get_class($event).'.');
         }
 
         $this->projectors[get_class($event)]->handle($event);
@@ -82,7 +82,7 @@ 
     public function rollback(EventInterface $event)
     {
         if (!isset($this->projectors[get_class($event)])) {
-            throw new ProjectorDoesNotExistsException('No Projector found for event ' . get_class($event) . '.');
+            throw new ProjectorDoesNotExistsException('No Projector found for event '.get_class($event).'.');
         }
 
         $this->projectors[get_class($event)]->rollback($event);

src/Infrastructure/DataTransformers/XmlEventDataTransformer.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
         $eventsCollection = new EventCollectionObjectRepresentation(
             (int) $page,
             (int) $maxPerPage,
-            (int) $numberOfPages = ceil($eventsCount/$maxPerPage),
+            (int) $numberOfPages = ceil($eventsCount / $maxPerPage),
             (int) $eventsCount,
             $this->calculateLinks($page, $numberOfPages)
         );

src/Infrastructure/DataTransformers/AbstractEventDataTransformer.php

Spacing +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
     protected function convertEventsDataToArray($events)
     {
         return array_map(
-            function (EventInterface $event) {
+            function(EventInterface $event) {
                 return [
                     'uuid' => $event->uuid(),
                     'version' => $event->version(),

src/Infrastructure/DataTransformers/YamlEventDataTransformer.php

Spacing +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
                     '_meta' => [
                         'page' => $page,
                         'records_per_page' => $maxPerPage,
-                        'total_pages' => $numberOfPages = ceil($eventsCount/$maxPerPage),
+                        'total_pages' => $numberOfPages = ceil($eventsCount / $maxPerPage),
                         'total_count' => $eventsCount
                     ],
                     '_links' => [

src/Infrastructure/Persistence/RedisEventStoreRepository.php

Spacing +1 added lines, -1 removed lines

@@ -46,7 +46,7 @@
      */
     public function byUuid(AggregateUuid $uuid, $returnType = self::RETURN_AS_ARRAY)
     {
-        $events = array_map(function($event){
+        $events = array_map(function($event) {
             return unserialize($event);
         }, $this->client->hgetall((string) $uuid));
 

src/Infrastructure/Drivers/MongoDriver.php

Spacing +1 added lines, -1 removed lines

@@ -87,7 +87,7 @@
     public function connect()
     {
         $connectionString = 'mongodb://';
-        $connectionString .= (isset($this->config['username'])  && isset($this->config['password'])) ? $this->config['username'].':'.$this->config['password'].'@' : '';
+        $connectionString .= (isset($this->config['username']) && isset($this->config['password'])) ? $this->config['username'].':'.$this->config['password'].'@' : '';
         $connectionString .= $this->config['host'].':'.$this->config['port'];
 
         $database = (isset($this->config['database'])) ? $this->config['database'] : 'eventstore';

src/Application/Event/EventQuery.php

Spacing +1 added lines, -1 removed lines

@@ -79,7 +79,7 @@
      */
     public function query(array $stream, array $filters = [])
     {
-        $qb = QueryBuilder::create((array)$stream);
+        $qb = QueryBuilder::create((array) $stream);
 
         foreach ($filters as $key => $value) {
             $qb->addCriterion($key, $value);

src/Application/Event/EventManager.php

Spacing +1 added lines, -1 removed lines

@@ -128,7 +128,7 @@
     public function setReturnType($returnType = EventStoreRepositoryInterface::RETURN_AS_ARRAY)
     {
         if (false === $this->checkReturnType($returnType)) {
-            throw new NotSupportedReturnTypeException($returnType . ' is not a valid returnType value.');
+            throw new NotSupportedReturnTypeException($returnType.' is not a valid returnType value.');
         }
 
         $this->returnType = $returnType;