LIN3S / SharedKernel

src/LIN3S/SharedKernel/Infrastructure/Persistence/Sql/Event/SqlEventStore.php

Spacing +4 added lines, -4 removed lines

@@ -9,7 +9,7 @@ 
  * file that was distributed with this source code.
  */
 
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace LIN3S\SharedKernel\Infrastructure\Persistence\Sql\Event;
 
@@ -68,7 +68,7 @@ 
         return new Stream($name, $domainEventsCollection);
     }
 
-    public function eventsSince(?\DateTimeInterface $since, int $offset = 0, int $limit = -1): array
+    public function eventsSince(?\DateTimeInterface $since, int $offset = 0, int $limit = -1) : array
     {
         $since = null === $since ? 0 : $since->getTimestamp();
         $tableName = self::TABLE_NAME;
@@ -94,7 +94,7 @@ 
             $storedEvent = new StoredEvent(
                 $this->buildDomainEvent($storedEventRow),
                 StreamName::fromName($storedEventRow['stream_name']),
-                new StreamVersion((int)$storedEventRow['stream_version'])
+                new StreamVersion((int) $storedEventRow['stream_version'])
             );
             $orderProperty = new \ReflectionProperty(StoredEvent::class, 'order');
             $orderProperty->setAccessible(true);
@@ -118,7 +118,7 @@ 
 
             if ('occurredOn' === $property->getName()) {
                 $occurredOn = new \DateTimeImmutable();
-                $occurredOn->setTimestamp((int)$storedEventRow['occurred_on']);
+                $occurredOn->setTimestamp((int) $storedEventRow['occurred_on']);
                 $property->setValue($domainEvent, $occurredOn);
                 continue;
             }

Upper-Lower-Casing +2 added lines, -2 removed lines

@@ -79,7 +79,7 @@ 
 ORDER BY `order` ASC
 LIMIT $limit
 OFFSET $offset
-SQL;
+sql;
 
         $storedEventRows = $this->pdo->query($sql, ['occurredOn' => $since]);
         $storedEvents = $this->buildStoredEvents($storedEventRows);
@@ -164,7 +164,7 @@ 
   `stream_version` INT NOT NULL,
   PRIMARY KEY (`order`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin;
-SQL;
+sql;
     }
 
     public static function removeSchema(): string