blixit / event-sourcing

src/Utils/Accessor.php

Spacing +2 added lines, -2 removed lines

@@ -25,7 +25,7 @@ 
      */
     protected function readProperty($object, string $property)
     {
-        return (function ($property) {
+        return (function($property) {
             return $this->$property;
         })->bindTo($object)->call($object, $property);
     }
@@ -36,7 +36,7 @@ 
      */
     protected function writeProperty(&$object, string $property, $value) : void
     {
-        (function ($property, $value) : void {
+        (function($property, $value) : void {
             $this->$property = $value;
         })->bindTo($object)->call($object, $property, $value);
     }

src/Store/EventStore.php

Spacing +4 added lines, -4 removed lines

@@ -87,7 +87,7 @@ 
         $stream = new ReadableStream(
             $streamName,
             $events,
-            static function (EventInterface $event) use ($beforeRead, $aggregate) : void {
+            static function(EventInterface $event) use ($beforeRead, $aggregate) : void {
                 $beforeRead($aggregate, $event);
             }
         );
@@ -143,7 +143,7 @@ 
         $stream = new StorableStream(
             $streamName,
             $aggregateRoot->getRecordedEvents(),
-            static function (EventInterface $event) use ($beforeWrite, $aggregateRoot) : void {
+            static function(EventInterface $event) use ($beforeWrite, $aggregateRoot) : void {
                 $beforeWrite($aggregateRoot, $event);
             }
         );
@@ -207,10 +207,10 @@ 
                 $event->getAggregateId()
             ));
         }
-        if (! empty($event->getSequence())) {
+        if (!empty($event->getSequence())) {
             throw new NonWritableEvent('Sequence number should be empty. Found: ' . $event->getSequence());
         }
-        if (! empty($event->getStreamName())) {
+        if (!empty($event->getStreamName())) {
             throw new NonWritableEvent('Stream name should be empty. Found: ' . $event->getStreamName());
         }
     }

src/Aggregate/AggregateAccessor.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
         /** @var AggregateRoot $aggregateRoot */
         $events = $aggregateRoot->getRecordedEvents();
         $event  = array_shift($events);
-        if (! empty($event)) {
+        if (!empty($event)) {
             $this->writeProperty($aggregateRoot, 'recordedEvents', $events);
         }
         return $event;

src/Messaging/MessagingMiddleware.php

Spacing +3 added lines, -3 removed lines

@@ -27,7 +27,7 @@ 
     public function handle(MessageInterface $message) : void
     {
         $class = get_class($message);
-        if (! $this->supports($class)) {
+        if (!$this->supports($class)) {
             return;
         }
 
@@ -39,11 +39,11 @@ 
                 $locatedHandler($message);
                 continue;
             }
-            if (! is_array($locatedHandler)) {
+            if (!is_array($locatedHandler)) {
                 continue;
             }
             foreach ($locatedHandler as $handler) {
-                if (! is_callable($handler)) {
+                if (!is_callable($handler)) {
                     continue;
                 }
                 $handler($message);

src/Store/Matcher/Matcher.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
      */
     public function addSearchField(FilterObject $filterObject) : void
     {
-        if (! in_array($filterObject->getField(), $this->allowedFields)) {
+        if (!in_array($filterObject->getField(), $this->allowedFields)) {
             throw new MatcherException(
                 sprintf(
                     'Field "%s" is not allowed. Allowed: %s',

src/Store/InMemory/InMemoryEventPersister.php

Spacing +7 added lines, -7 removed lines

@@ -20,7 +20,7 @@ 
      */
     public function getByStream(StreamName $streamName, ?int $fromSequence = 0) : array
     {
-        return array_filter($this->events, static function (EventInterface $event) use (
+        return array_filter($this->events, static function(EventInterface $event) use (
             $streamName,
             $fromSequence
         ) {
@@ -40,7 +40,7 @@ 
      */
     public function find(EventMatcherInterface $eventMatcher) : array
     {
-        return array_filter($this->events, static function (EventInterface $event) use ($eventMatcher) {
+        return array_filter($this->events, static function(EventInterface $event) use ($eventMatcher) {
             $aggregateId    = $eventMatcher->getAggregateId();
             $aggregateClass = $eventMatcher->getAggregateClass();
             $fromSequence   = $eventMatcher->getSequence();
@@ -48,19 +48,19 @@ 
             $timestamp      = $eventMatcher->getTimestamp();
 
             $condition = true;
-            if (! empty($aggregateId)) {
+            if (!empty($aggregateId)) {
                 $condition = $condition && ($event->getAggregateId() === $aggregateId);
             }
-            if (! empty($aggregateClass)) {
+            if (!empty($aggregateClass)) {
                 $condition = $condition && ($event->getAggregateClass() === (string) $aggregateClass);
             }
-            if (! empty($fromSequence)) {
+            if (!empty($fromSequence)) {
                 $condition = $condition && ($event->getSequence() > $fromSequence);
             }
-            if (! empty($streamName)) {
+            if (!empty($streamName)) {
                 $condition = $condition && ($event->getStreamName() === (string) $streamName);
             }
-            if (! empty($timestamp)) {
+            if (!empty($timestamp)) {
                 $condition = $condition && ($event->getTimestamp() > $timestamp);
             }
             return $condition;

src/Stream/Stream.php

Spacing +2 added lines, -2 removed lines

@@ -46,7 +46,7 @@ 
         }
 
         if (empty($beforeEnqueue)) {
-            $beforeEnqueue = static function (EventInterface $event) : void {}; // phpcs:ignore
+            $beforeEnqueue = static function(EventInterface $event) : void {}; // phpcs:ignore
         }
 
         $this->queue         = new SplQueue();
@@ -81,7 +81,7 @@ 
         call_user_func($this->beforeEnqueue, $event);
         self::$eventAccessor->setStreamName($event, (string) $this->streamName);
 
-        if (! isset($this->lastEnqueuedSequenceNumber)) {
+        if (!isset($this->lastEnqueuedSequenceNumber)) {
             $this->lastEnqueuedSequenceNumber = $event->getSequence();
         }